netpoll

Documentation

Index

• Constants
• func Dup(fd int) (int, string, error)
• type Poller
  • func OpenPoller() (poller *Poller, err error)
  • func (p *Poller) AddRead(fd int) error
  • func (p *Poller) AddReadWrite(fd int) error
  • func (p *Poller) AddWrite(fd int) error
  • func (p *Poller) Close() error
  • func (p *Poller) Delete(fd int) error
  • func (p *Poller) ModRead(fd int) error
  • func (p *Poller) ModReadWrite(fd int) error
  • func (p *Poller) Polling(callback func(fd int, ev uint32) error) error
  • func (p *Poller) Trigger(fn queue.TaskFunc, arg interface{}) (err error)
  • func (p *Poller) UrgentTrigger(fn queue.TaskFunc, arg interface{}) (err error)

Constants

const (
	// InitEvents represents the initial length of poller event-list.
	InitEvents = 128
	// MaxAsyncTasksAtOneTime is the maximum amount of asynchronous tasks that the event-loop will process at one time.
	MaxAsyncTasksAtOneTime = 256
	// ErrEvents represents exceptional events that are not read/write, like socket being closed,
	// reading/writing from/to a closed socket, etc.
	ErrEvents = unix.EPOLLERR | unix.EPOLLHUP | unix.EPOLLRDHUP
	// OutEvents combines EPOLLOUT event and some exceptional events.
	OutEvents = ErrEvents | unix.EPOLLOUT
	// InEvents combines EPOLLIN/EPOLLPRI events and some exceptional events.
	InEvents = ErrEvents | unix.EPOLLIN | unix.EPOLLPRI
)

Functions

func Dup

func Dup(fd int) (int, string, error)

Dup is the wrapper for dupCloseOnExec.

Types

type Poller

type Poller struct {
	// contains filtered or unexported fields
}

Poller represents a poller which is in charge of monitoring file-descriptors.

func OpenPoller

func OpenPoller() (poller *Poller, err error)

OpenPoller instantiates a poller.

func (*Poller) AddRead

func (p *Poller) AddRead(fd int) error

AddRead registers the given file-descriptor with readable event to the poller.

func (*Poller) AddReadWrite

func (p *Poller) AddReadWrite(fd int) error

AddReadWrite registers the given file-descriptor with readable and writable events to the poller.

func (*Poller) AddWrite

func (p *Poller) AddWrite(fd int) error

AddWrite registers the given file-descriptor with writable event to the poller.

func (*Poller) Close

func (p *Poller) Close() error

Close closes the poller.

func (*Poller) Delete

func (p *Poller) Delete(fd int) error

Delete removes the given file-descriptor from the poller.

func (*Poller) ModRead

func (p *Poller) ModRead(fd int) error

ModRead renews the given file-descriptor with readable event in the poller.

func (*Poller) ModReadWrite

func (p *Poller) ModReadWrite(fd int) error

ModReadWrite renews the given file-descriptor with readable and writable events in the poller.

func (*Poller) Polling

func (p *Poller) Polling(callback func(fd int, ev uint32) error) error

Polling blocks the current goroutine, waiting for network-events.

func (*Poller) Trigger

func (p *Poller) Trigger(fn queue.TaskFunc, arg interface{}) (err error)

Trigger is like UrgentTrigger but it puts task into asyncTaskQueue, call this method when the task is not so urgent, for instance writing data back to client.

Note that asyncTaskQueue is a queue with low-priority whose size may grow large and tasks in it may backlog.

func (*Poller) UrgentTrigger

func (p *Poller) UrgentTrigger(fn queue.TaskFunc, arg interface{}) (err error)

UrgentTrigger puts task into priorAsyncTaskQueue and wakes up the poller which is waiting for network-events, then the poller will get tasks from priorAsyncTaskQueue and run them.

Note that priorAsyncTaskQueue is a queue with high-priority and its size is expected to be small, so only those urgent tasks should be put into this queue.