From f5516715ebb47d51d617d83a70612a9900079502 Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sun, 28 May 2023 17:08:17 +0300 Subject: [PATCH] quicproxy: increase UDP send and receive buffer sizes (#3813) --- integrationtests/tools/proxy/proxy.go | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) diff --git a/integrationtests/tools/proxy/proxy.go b/integrationtests/tools/proxy/proxy.go index 01e6a4a99..4ed2d89de 100644 --- a/integrationtests/tools/proxy/proxy.go +++ b/integrationtests/tools/proxy/proxy.go @@ -169,6 +169,12 @@ func NewQuicProxy(local string, opts *Opts) (*QuicProxy, error) { if err != nil { return nil, err } + if err := conn.SetReadBuffer(protocol.DesiredReceiveBufferSize); err != nil { + return nil, err + } + if err := conn.SetWriteBuffer(protocol.DesiredSendBufferSize); err != nil { + return nil, err + } raddr, err := net.ResolveUDPAddr("udp", opts.RemoteAddr) if err != nil { return nil, err @@ -225,13 +231,19 @@ func (p *QuicProxy) LocalPort() int { } func (p *QuicProxy) newConnection(cliAddr *net.UDPAddr) (*connection, error) { - srvudp, err := net.DialUDP("udp", nil, p.serverAddr) + conn, err := net.DialUDP("udp", nil, p.serverAddr) if err != nil { return nil, err } + if err := conn.SetReadBuffer(protocol.DesiredReceiveBufferSize); err != nil { + return nil, err + } + if err := conn.SetWriteBuffer(protocol.DesiredSendBufferSize); err != nil { + return nil, err + } return &connection{ ClientAddr: cliAddr, - ServerConn: srvudp, + ServerConn: conn, incomingPackets: make(chan packetEntry, 10), Incoming: newQueue(), Outgoing: newQueue(),