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
40
41
42
43
44
| // +build go1.11
| // +build aix darwin dragonfly freebsd linux netbsd openbsd
|
| package dns
|
| import (
| "context"
| "net"
| "syscall"
|
| "golang.org/x/sys/unix"
| )
|
| const supportsReusePort = true
|
| func reuseportControl(network, address string, c syscall.RawConn) error {
| var opErr error
| err := c.Control(func(fd uintptr) {
| opErr = unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_REUSEPORT, 1)
| })
| if err != nil {
| return err
| }
|
| return opErr
| }
|
| func listenTCP(network, addr string, reuseport bool) (net.Listener, error) {
| var lc net.ListenConfig
| if reuseport {
| lc.Control = reuseportControl
| }
|
| return lc.Listen(context.Background(), network, addr)
| }
|
| func listenUDP(network, addr string, reuseport bool) (net.PacketConn, error) {
| var lc net.ListenConfig
| if reuseport {
| lc.Control = reuseportControl
| }
|
| return lc.ListenPacket(context.Background(), network, addr)
| }
|
|
