tweak quic parameters

transport/internet/quic/dialer.go

@@ -3,6 +3,7 @@ package quic
 import (
 	"context"
 	"sync"
+	"time"
 
 	"v2ray.com/core/transport/internet/tls"
 
@@ -29,7 +30,12 @@ func (s *clientSessions) getSession(destAddr net.Addr, config *Config, tlsConfig
 	dest := net.DestinationFromAddr(destAddr)
 
 	if session, found := s.sessions[dest]; found {
-		return session, nil
+		select {
+		case <-session.Context().Done():
+			// Session has been closed. Creating a new one.
+		default:
+			return session, nil
+		}
 	}
 
 	rawConn, err := internet.ListenSystemPacket(context.Background(), &net.UDPAddr{
@@ -41,9 +47,14 @@ func (s *clientSessions) getSession(destAddr net.Addr, config *Config, tlsConfig
 	}
 
 	quicConfig := &quic.Config{
-		Versions:           []quic.VersionNumber{quic.VersionMilestone0_10_0},
-		ConnectionIDLength: 12,
-		KeepAlive:          true,
+		Versions:                              []quic.VersionNumber{quic.VersionMilestone0_10_0},
+		ConnectionIDLength:                    12,
+		KeepAlive:                             true,
+		HandshakeTimeout:                      time.Second * 4,
+		IdleTimeout:                           time.Second * 300,
+		MaxReceiveStreamFlowControlWindow:     128 * 1024,
+		MaxReceiveConnectionFlowControlWindow: 512 * 1024,
+		MaxIncomingUniStreams:                 -1,
 	}
 
 	conn, err := wrapSysConn(rawConn, config)

transport/internet/quic/hub.go

@@ -2,6 +2,7 @@ package quic
 
 import (
 	"context"
+	"time"
 
 	quic "github.com/lucas-clemente/quic-go"
 	"v2ray.com/core/common"
@@ -50,13 +51,13 @@ func (l *Listener) keepAccepting() {
 }
 
 // Addr implements internet.Listener.Addr.
-func (v *Listener) Addr() net.Addr {
-	return v.listener.Addr()
+func (l *Listener) Addr() net.Addr {
+	return l.listener.Addr()
 }
 
 // Close implements internet.Listener.Close.
-func (v *Listener) Close() error {
-	return v.listener.Close()
+func (l *Listener) Close() error {
+	return l.listener.Close()
 }
 
 // Listen creates a new Listener based on configurations.
@@ -83,10 +84,15 @@ func Listen(ctx context.Context, address net.Address, port net.Port, streamSetti
 	}
 
 	quicConfig := &quic.Config{
-		Versions:           []quic.VersionNumber{quic.VersionMilestone0_10_0},
-		ConnectionIDLength: 12,
-		KeepAlive:          true,
-		AcceptCookie:       func(net.Addr, *quic.Cookie) bool { return true },
+		Versions:                              []quic.VersionNumber{quic.VersionMilestone0_10_0},
+		ConnectionIDLength:                    12,
+		KeepAlive:                             true,
+		HandshakeTimeout:                      time.Second * 4,
+		IdleTimeout:                           time.Second * 300,
+		MaxReceiveStreamFlowControlWindow:     128 * 1024,
+		MaxReceiveConnectionFlowControlWindow: 512 * 1024,
+		MaxIncomingStreams:                    256,
+		MaxIncomingUniStreams:                 -1,
 	}
 
 	conn, err := wrapSysConn(rawConn, config)