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
38
39
|
//go:build unix
package eunix
import (
"os"
"time"
"golang.org/x/sys/unix"
)
// WaitForRead blocks until any of the given files is ready to be read or
// timeout. A negative timeout means no timeout. It returns a boolean array
// indicating which files are ready to be read and any possible error.
func WaitForRead(timeout time.Duration, files ...*os.File) (ready []bool, err error) {
maxfd := 0
fdset := &unix.FdSet{}
for _, file := range files {
fd := int(file.Fd())
if maxfd < fd {
maxfd = fd
}
fdset.Set(fd)
}
_, err = unix.Select(maxfd+1, fdset, nil, nil, optionalTimeval(timeout))
ready = make([]bool, len(files))
for i, file := range files {
ready[i] = fdset.IsSet(int(file.Fd()))
}
return ready, err
}
func optionalTimeval(d time.Duration) *unix.Timeval {
if d < 0 {
return nil
}
timeval := unix.NsecToTimeval(int64(d))
return &timeval
}
|
