dotcloud/docker

View on GitHub
internal/unix_noeintr/epoll_linux.go

Summary

Maintainability
A
0 mins
Test Coverage
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
    }
}