conn

Documentation

Overview

conn defines the Conn object which packs system file descriptor and performs reading or writing operations.

Index

• type AsyncWriteConn
  • func (that *AsyncWriteConn) Write(data []byte) (n int, err error)
• type AsyncWritevConn
  • func (that *AsyncWritevConn) Write(data []byte) (n int, err error)
• type Conn
  • func NewTCPConn(fd int) (c *Conn)
  • func (that *Conn) Adapt(adapter iface.ConnAdapter, callback ...iface.AsyncCallback) net.Conn
  • func (that *Conn) AsyncClose()
  • func (that *Conn) AsyncReadFromFd()
  • func (that *Conn) AsyncReadFromFdAndWait(wg *sync.WaitGroup)
  • func (that *Conn) AsyncWrite(data []byte, cb ...iface.AsyncCallback) error
  • func (that *Conn) AsyncWriteToFd()
  • func (that *Conn) AsyncWriteToFdAndWait(wg *sync.WaitGroup)
  • func (that *Conn) AsyncWritev(bs [][]byte, cb ...iface.AsyncCallback) error
  • func (that *Conn) Close() (rerr error)
  • func (that *Conn) GetBufferFromPool() []byte
  • func (that *Conn) GetFd() int
  • func (that *Conn) InitContext(tconf *tls.Config, adapter iface.ConnAdapter, callback ...iface.AsyncCallback) (err error)
  • func (that *Conn) LocalAddr() net.Addr
  • func (that *Conn) Open() error
  • func (that *Conn) PutBufferToPool(buf []byte)
  • func (that *Conn) Read(p []byte) (n int, err error)
  • func (that *Conn) ReadFromFd() error
  • func (that *Conn) RemoteAddr() net.Addr
  • func (that *Conn) SetConn(co *ConnOpts)
  • func (that *Conn) SetDeadline(t time.Time) error
  • func (that *Conn) SetReadDeadline(t time.Time) error
  • func (that *Conn) SetWriteDeadline(t time.Time) error
  • func (that *Conn) Write(p []byte) (int, error)
  • func (that *Conn) WriteToFd() error
  • func (that *Conn) Writev(bs [][]byte) (int, error)
• type ConnOpts
• type WritevConn
  • func (that *WritevConn) Write(data []byte) (n int, err error)

Types

type AsyncWriteConn

type AsyncWriteConn struct {
	*Conn
	CallBack iface.AsyncCallback
}

func (*AsyncWriteConn) Write

func (that *AsyncWriteConn) Write(data []byte) (n int, err error)

type AsyncWritevConn

type AsyncWritevConn struct {
	*Conn
	CallBack iface.AsyncCallback
}

func (*AsyncWritevConn) Write

func (that *AsyncWritevConn) Write(data []byte) (n int, err error)

type Conn

type Conn struct {
	Fd              int
	Poller          *poll.Poller
	Sock            syscall.Sockaddr
	AddrLocal       net.Addr
	AddrRemote      net.Addr
	OutBuffer       *elastic.Buffer
	InBuffer        elastic.RingBuffer
	Buffer          []byte
	IsUDP           bool
	Ctx             *iface.Context
	Opened          bool
	Handler         iface.IEventHandler
	WritevChunkSize int
	ErrChan         chan error
	// contains filtered or unexported fields
}

func NewTCPConn

func NewTCPConn(fd int) (c *Conn)

new Conn

func (*Conn) Adapt

func (that *Conn) Adapt(adapter iface.ConnAdapter, callback ...iface.AsyncCallback) net.Conn

Adapt adapts asyncwrite or writev to net.Conn interface.

func (*Conn) AsyncClose

func (that *Conn) AsyncClose()

func (*Conn) AsyncReadFromFd

func (that *Conn) AsyncReadFromFd()

func (*Conn) AsyncReadFromFdAndWait

func (that *Conn) AsyncReadFromFdAndWait(wg *sync.WaitGroup)

func (*Conn) AsyncWrite

func (that *Conn) AsyncWrite(data []byte, cb ...iface.AsyncCallback) error

func (*Conn) AsyncWriteToFd

func (that *Conn) AsyncWriteToFd()

func (*Conn) AsyncWriteToFdAndWait

func (that *Conn) AsyncWriteToFdAndWait(wg *sync.WaitGroup)

func (*Conn) AsyncWritev

func (that *Conn) AsyncWritev(bs [][]byte, cb ...iface.AsyncCallback) error

func (*Conn) Close

func (that *Conn) Close() (rerr error)

func (*Conn) GetBufferFromPool

func (that *Conn) GetBufferFromPool() []byte

func (*Conn) GetFd

func (that *Conn) GetFd() int

public methods

func (*Conn) InitContext

func (that *Conn) InitContext(tconf *tls.Config, adapter iface.ConnAdapter, callback ...iface.AsyncCallback) (err error)

func (*Conn) LocalAddr

func (that *Conn) LocalAddr() net.Addr

methods for net.Conn interface

func (*Conn) Open

func (that *Conn) Open() error

func (*Conn) PutBufferToPool

func (that *Conn) PutBufferToPool(buf []byte)

func (*Conn) Read

func (that *Conn) Read(p []byte) (n int, err error)

func (*Conn) ReadFromFd

func (that *Conn) ReadFromFd() error

func (*Conn) RemoteAddr

func (that *Conn) RemoteAddr() net.Addr

func (*Conn) SetConn

func (that *Conn) SetConn(co *ConnOpts)

func (*Conn) SetDeadline

func (that *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (that *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetWriteDeadline

func (that *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) Write

func (that *Conn) Write(p []byte) (int, error)

func (*Conn) WriteToFd

func (that *Conn) WriteToFd() error

func (*Conn) Writev

func (that *Conn) Writev(bs [][]byte) (int, error)

type ConnOpts

type ConnOpts struct {
	Poller            *poll.Poller
	SockAddr          syscall.Sockaddr
	LocalAddr         net.Addr
	RemoteAddr        net.Addr
	Handler           iface.IEventHandler
	WriteBufferCap    int
	WritevChunkSize   int
	SocketWriteBuffer int
	SocketReadBuffer  int
}

type WritevConn

type WritevConn struct {
	*Conn
}

func (*WritevConn) Write

func (that *WritevConn) Write(data []byte) (n int, err error)