1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
package unix_noeintr
import (
"errors"
"golang.org/x/sys/unix"
)
func EpollCreate() (int, error) {
for {
fd, err := unix.EpollCreate1(unix.EPOLL_CLOEXEC)
if errors.Is(err, unix.EINTR) {
continue
}
return fd, err
}
}
func EpollCtl(epFd int, op int, fd int, event *unix.EpollEvent) error {
for {
err := unix.EpollCtl(epFd, op, fd, event)
if errors.Is(err, unix.EINTR) {
continue
}
return err
}
}
func EpollWait(epFd int, events []unix.EpollEvent, msec int) (int, error) {
for {
n, err := unix.EpollWait(epFd, events, msec)
if errors.Is(err, unix.EINTR) {
continue
}
return n, err
}
}
|
