mirror of
https://github.com/slackhq/nebula.git
synced 2026-05-16 04:47:38 +02:00
81 lines
1.4 KiB
Go
81 lines
1.4 KiB
Go
package tio
|
|
|
|
import (
|
|
"encoding/binary"
|
|
"errors"
|
|
"fmt"
|
|
|
|
"golang.org/x/sys/unix"
|
|
)
|
|
|
|
type pollQueueSet struct {
|
|
pq []*Poll
|
|
// pqi is exactly the same as pq, but stored as the interface type
|
|
pqi []Queue
|
|
shutdownFd int
|
|
}
|
|
|
|
func NewPollQueueSet() (QueueSet, error) {
|
|
shutdownFd, err := unix.Eventfd(0, unix.EFD_NONBLOCK|unix.EFD_CLOEXEC)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to create eventfd: %w", err)
|
|
}
|
|
|
|
out := &pollQueueSet{
|
|
pq: []*Poll{},
|
|
pqi: []Queue{},
|
|
shutdownFd: shutdownFd,
|
|
}
|
|
|
|
return out, nil
|
|
}
|
|
|
|
func (c *pollQueueSet) Queues() []Queue {
|
|
return c.pqi
|
|
}
|
|
|
|
func (c *pollQueueSet) Add(fd int) error {
|
|
x, err := newPoll(fd, c.shutdownFd)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
c.pq = append(c.pq, x)
|
|
c.pqi = append(c.pqi, x)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *pollQueueSet) wakeForShutdown() error {
|
|
var buf [8]byte
|
|
binary.NativeEndian.PutUint64(buf[:], 1)
|
|
_, err := unix.Write(c.shutdownFd, buf[:])
|
|
return err
|
|
}
|
|
|
|
func (c *pollQueueSet) Close() error {
|
|
if c.shutdownFd < 0 {
|
|
return nil
|
|
}
|
|
|
|
errs := []error{}
|
|
|
|
if err := c.wakeForShutdown(); err != nil {
|
|
errs = append(errs, err)
|
|
}
|
|
|
|
for _, x := range c.pq {
|
|
if err := x.Close(); err != nil {
|
|
errs = append(errs, err)
|
|
}
|
|
}
|
|
|
|
// All Polls reference shutdownFd in their pollfd arrays, so close it
|
|
// only after every Poll.Close has returned.
|
|
if err := unix.Close(c.shutdownFd); err != nil {
|
|
errs = append(errs, err)
|
|
}
|
|
c.shutdownFd = -1
|
|
|
|
return errors.Join(errs...)
|
|
}
|