eventloop

Feb 28, 2022

Changes in this version

type Poller — darwin/amd64, linux/amd64

+ func (p *Poller) ClearByConn(conn iface.IConnect)

Feb 16, 2022

Changes in this version

type Poller — darwin/amd64, linux/amd64

+ func (p *Poller) ProceedWrite(conn iface.IConnect) error

Feb 16, 2022

Changes in this version

type Poller — darwin/amd64, linux/amd64

+ func (p *Poller) GetConnectMgr() iface.IConnectManager

Jan 26, 2022

Changes in this version

type Poller — darwin/amd64, linux/amd64

+ func (p *Poller) DoWrite(conn iface.IConnect) error

+ func (p *Poller) ModRead(fd, connID int) error

+ func (p *Poller) ModWrite(fd, connID int) error

Jan 25, 2022

Changes in this version

+ type EventLoop struct

+ Num int

+ func NewEventLoop(num int) *EventLoop

+ func (e *EventLoop) AddRead(conn iface.IConnect) error

+ func (e *EventLoop) Init(connectMgr iface.IConnectManager) error

+ func (e *EventLoop) Remove(conn iface.IConnect) error

+ func (e *EventLoop) Start(emitCh chan<- iface.IRequest)

+ func (e *EventLoop) Stop()

+ type Poller struct — darwin/amd64, linux/amd64

+ ConnectMgr iface.IConnectManager

+ Epfd int

+ Events []unix.EpollEvent

+ Events []unix.Kevent_t

+ func NewPoller(connectMgr iface.IConnectManager) (*Poller, error)

+ func (p *Poller) AddRead(fd int, connID int) error

+ func (p *Poller) AddRead(fd, connID int) error

+ func (p *Poller) AddWrite(fd, connID int) error

+ func (p *Poller) Close() error

+ func (p *Poller) Remove(fd int) error

+ func (p *Poller) Wait(emitCh chan<- iface.IRequest)