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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
//go:build linux
package quic
import (
"errors"
"net"
"os"
"testing"
"golang.org/x/sys/unix"
"github.com/stretchr/testify/require"
)
var (
errGSO = &os.SyscallError{Err: unix.EIO}
errNotPermitted = &os.SyscallError{Syscall: "sendmsg", Err: unix.EPERM}
)
func TestForcingReceiveBufferSize(t *testing.T) {
if os.Getuid() != 0 {
t.Skip("Must be root to force change the receive buffer size")
}
c, err := net.ListenPacket("udp", "127.0.0.1:0")
require.NoError(t, err)
defer c.Close()
syscallConn, err := c.(*net.UDPConn).SyscallConn()
require.NoError(t, err)
const small = 256 << 10 // 256 KB
require.NoError(t, forceSetReceiveBuffer(syscallConn, small))
size, err := inspectReadBuffer(syscallConn)
require.NoError(t, err)
// the kernel doubles this value (to allow space for bookkeeping overhead)
require.Equal(t, 2*small, size)
const large = 32 << 20 // 32 MB
require.NoError(t, forceSetReceiveBuffer(syscallConn, large))
size, err = inspectReadBuffer(syscallConn)
require.NoError(t, err)
// the kernel doubles this value (to allow space for bookkeeping overhead)
require.Equal(t, 2*large, size)
}
func TestForcingSendBufferSize(t *testing.T) {
if os.Getuid() != 0 {
t.Skip("Must be root to force change the send buffer size")
}
c, err := net.ListenPacket("udp", "127.0.0.1:0")
require.NoError(t, err)
defer c.Close()
syscallConn, err := c.(*net.UDPConn).SyscallConn()
require.NoError(t, err)
const small = 256 << 10 // 256 KB
require.NoError(t, forceSetSendBuffer(syscallConn, small))
size, err := inspectWriteBuffer(syscallConn)
require.NoError(t, err)
// the kernel doubles this value (to allow space for bookkeeping overhead)
require.Equal(t, 2*small, size)
const large = 32 << 20 // 32 MB
require.NoError(t, forceSetSendBuffer(syscallConn, large))
size, err = inspectWriteBuffer(syscallConn)
require.NoError(t, err)
// the kernel doubles this value (to allow space for bookkeeping overhead)
require.Equal(t, 2*large, size)
}
func TestGSOError(t *testing.T) {
require.True(t, isGSOError(errGSO))
require.False(t, isGSOError(nil))
require.False(t, isGSOError(errors.New("test")))
}
|
