From a1801b5d6f85fdbea4cef037003466fd30e87b23 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Fri, 23 Nov 2018 23:51:07 +0100 Subject: [PATCH] update quic config --- transport/internet/quic/dialer.go | 3 +-- transport/internet/quic/hub.go | 9 ++++----- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/transport/internet/quic/dialer.go b/transport/internet/quic/dialer.go index a1290798..c8fe92c5 100644 --- a/transport/internet/quic/dialer.go +++ b/transport/internet/quic/dialer.go @@ -96,10 +96,9 @@ func (s *clientSessions) openConnection(destAddr net.Addr, config *Config, tlsCo quicConfig := &quic.Config{ ConnectionIDLength: 12, - KeepAlive: true, HandshakeTimeout: time.Second * 4, IdleTimeout: time.Second * 60, - MaxReceiveStreamFlowControlWindow: 256 * 1024, + MaxReceiveStreamFlowControlWindow: 512 * 1024, MaxReceiveConnectionFlowControlWindow: 2 * 1024 * 1024, MaxIncomingUniStreams: -1, } diff --git a/transport/internet/quic/hub.go b/transport/internet/quic/hub.go index 9da6d415..4cfbcef1 100644 --- a/transport/internet/quic/hub.go +++ b/transport/internet/quic/hub.go @@ -43,8 +43,8 @@ func (l *Listener) keepAccepting() { conn, err := l.listener.Accept() if err != nil { newError("failed to accept QUIC sessions").Base(err).WriteToLog() - l.listener.Close() - return + time.Sleep(time.Second) + continue } go l.acceptStreams(conn) } @@ -85,11 +85,10 @@ func Listen(ctx context.Context, address net.Address, port net.Port, streamSetti quicConfig := &quic.Config{ ConnectionIDLength: 12, - KeepAlive: true, HandshakeTimeout: time.Second * 4, IdleTimeout: time.Second * 60, - MaxReceiveStreamFlowControlWindow: 256 * 1024, - MaxReceiveConnectionFlowControlWindow: 2 * 1024 * 1024, + MaxReceiveStreamFlowControlWindow: 512 * 1024, + MaxReceiveConnectionFlowControlWindow: 4 * 1024 * 1024, MaxIncomingStreams: 64, MaxIncomingUniStreams: -1, }