feat: epoll managered by runtime netpoller

go.mod

@@ -1,6 +1,6 @@
 module github.com/cloudwego/netpoll
 
-go 1.15
+go 1.18
 
 require (
 	github.com/bytedance/gopkg v0.0.0-20220413063733-65bf48ffb3a7

poll_default_bsd.go

@@ -25,13 +25,17 @@ import (
 	"unsafe"
 )
 
+func openPollFile() (int, error) {
+	return syscall.Kqueue()
+}
+
 func openPoll() (Poll, error) {
 	return openDefaultPoll()
 }
 
 func openDefaultPoll() (*defaultPoll, error) {
 	l := new(defaultPoll)
-	p, err := syscall.Kqueue()
+	p, err := openPollFile()
 	if err != nil {
 		return nil, err
 	}

poll_default_linux.go

@@ -23,6 +23,10 @@ import (
 	"unsafe"
 )
 
+func openPollFile() (int, error) {
+	return EpollCreate(0)
+}
+
 func openPoll() (Poll, error) {
 	return openDefaultPoll()
 }

runtime.go

@@ -0,0 +1,11 @@
+package netpoll
+
+import (
+	_ "unsafe"
+)
+
+//go:linkname pollOpen internal/poll.runtime_pollOpen
+func pollOpen(fd uintptr) (pd uintptr, errno int)
+
+//go:linkname pollWait internal/poll.runtime_pollWait
+func pollWait(pd uintptr, mode int) (errno int)

runtime_test.go

@@ -0,0 +1,18 @@
+package netpoll
+
+import (
+	"testing"
+)
+
+func TestRuntimeNetpoller(t *testing.T) {
+	pfd, err := openPollFile()
+	MustNil(t, err)
+
+	pd, errno := pollOpen(uintptr(pfd))
+	Assert(t, errno == 0, errno)
+
+	errno = pollWait(pd, 'r')
+	Assert(t, errno == 0, errno)
+
+	_ = pfd
+}