gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

transport: increase the UDP send buffer size as well

Browse Source
This commit is contained in:
Marten Seemann
2023-05-08 14:22:47 +03:00
parent 74be4d2755
commit 2ab17e20af
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
transport.go
View File

@@ -270,7 +270,7 @@ func (t *Transport) close(e error) {
} }
// only print warnings about the UDP receive buffer size once // only print warnings about the UDP receive buffer size once
var receiveBufferWarningOnce sync.Once var setBufferWarningOnce sync.Once
func (t *Transport) listen(conn rawConn) { func (t *Transport) listen(conn rawConn) {
defer close(t.listening) defer close(t.listening)
@@ -278,7 +278,17 @@ func (t *Transport) listen(conn rawConn) {
if err := setReceiveBuffer(t.Conn, t.logger); err != nil { if err := setReceiveBuffer(t.Conn, t.logger); err != nil {
if !strings.Contains(err.Error(), "use of closed network connection") { if !strings.Contains(err.Error(), "use of closed network connection") {
receiveBufferWarningOnce.Do(func() { setBufferWarningOnce.Do(func() {
if disable, _ := strconv.ParseBool(os.Getenv("QUIC_GO_DISABLE_RECEIVE_BUFFER_WARNING")); disable {
return
}
log.Printf("%s. See https://github.com/quic-go/quic-go/wiki/UDP-Receive-Buffer-Size for details.", err)
})
}
}
if err := setSendBuffer(t.Conn, t.logger); err != nil {
if !strings.Contains(err.Error(), "use of closed network connection") {
setBufferWarningOnce.Do(func() {
if disable, _ := strconv.ParseBool(os.Getenv("QUIC_GO_DISABLE_RECEIVE_BUFFER_WARNING")); disable { if disable, _ := strconv.ParseBool(os.Getenv("QUIC_GO_DISABLE_RECEIVE_BUFFER_WARNING")); disable {
return return
} }