net: implement network polling using epoll and kqueue

This is the first implementation of (almost) generic polling.
The Poll currently only support the Read events from now, because the
most common use case is for handling multiple socket without using
goroutines.

1 files changed, 39 insertions, 0 deletions

diff --git a/lib/net/poll.go b/lib/net/poll.go
new file mode 100644
index 00000000..ec5369b2
--- /dev/null
+++ b/lib/net/poll.go
@@ -0,0 +1,39 @@
+package net
+
+const (
+	maxQueue = 128
+)
+
+//
+// Poll represent an interface to network polling.
+//
+type Poll interface {
+	//
+	// Close the poll.
+	//
+	Close()
+
+	//
+	// RegisterRead add the file descriptor to read poll.
+	//
+	RegisterRead(fd int) (err error)
+
+	//
+	// ReregisterRead register the file descriptor back to events.
+	// This method must be used on Linux after calling WaitRead.
+	//
+	// See https://idea.popcount.org/2017-02-20-epoll-is-fundamentally-broken-12/
+	//
+	ReregisterRead(idx, fd int)
+
+	//
+	// UnregisterRead remove file descriptor from the poll.
+	//
+	UnregisterRead(fd int) (err error)
+
+	//
+	// WaitRead wait for read event received and return list of file
+	// descriptor that are ready for reading.
+	//
+	WaitRead() (fds []int, err error)
+}