From ccdf227e0c0d481cb23f174c3e02038c3dec0eae Mon Sep 17 00:00:00 2001 From: Marco Munizaga Date: Mon, 19 Jan 2026 16:51:03 -0500 Subject: [PATCH] Set new parameters for new WebTransport version --- p2p/transport/quicreuse/config.go | 2 ++ p2p/transport/webtransport/listener.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/p2p/transport/quicreuse/config.go b/p2p/transport/quicreuse/config.go index 62f8919c8..62722082d 100644 --- a/p2p/transport/quicreuse/config.go +++ b/p2p/transport/quicreuse/config.go @@ -15,4 +15,6 @@ var quicConfig = &quic.Config{ Versions: []quic.Version{quic.Version1}, // We don't use datagrams (yet), but this is necessary for WebTransport EnableDatagrams: true, + // Required for WebTransport + EnableStreamResetPartialDelivery: true, } diff --git a/p2p/transport/webtransport/listener.go b/p2p/transport/webtransport/listener.go index 1b244bb65..605586295 100644 --- a/p2p/transport/webtransport/listener.go +++ b/p2p/transport/webtransport/listener.go @@ -68,6 +68,7 @@ func newListener(reuseListener quicreuse.Listener, t *transport, isStaticTLSConf ConnContext: func(ctx context.Context, c *quic.Conn) context.Context { return context.WithValue(ctx, connKey{}, c) }, + EnableDatagrams: true, }, CheckOrigin: func(_ *http.Request) bool { return true }, }, @@ -77,6 +78,7 @@ func newListener(reuseListener quicreuse.Listener, t *transport, isStaticTLSConf mux := http.NewServeMux() mux.HandleFunc(webtransportHTTPEndpoint, ln.httpHandler) ln.server.H3.Handler = mux + webtransport.ConfigureHTTP3Server(ln.server.H3) go func() { defer close(ln.serverClosed) for {