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

http3: fix race in concurrent Transport.RoundTrip calls (#5323)

Browse Source 
* http3: fix data race in Transport

* reset init Once
This commit is contained in:
Glonee
2025-09-07 11:25:00 +08:00
committed by GitHub
parent 357f679072
commit 483d257336
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
http3/transport.go
View File

@@ -153,6 +153,13 @@ func (t *Transport) init() error {
if t.QUICConfig.MaxIncomingStreams == 0 {
t.QUICConfig.MaxIncomingStreams = -1 // don't allow any bidirectional streams
}
if t.Dial == nil {
udpConn, err := net.ListenUDP("udp", nil)
if err != nil {
return err
}
t.transport = &quic.Transport{Conn: udpConn}
}
return nil
}
@@ -350,13 +357,6 @@ func (t *Transport) dial(ctx context.Context, hostname string) (*quic.Conn, clie
dial := t.Dial
if dial == nil {
if t.transport == nil {
udpConn, err := net.ListenUDP("udp", nil)
if err != nil {
return nil, nil, err
}
t.transport = &quic.Transport{Conn: udpConn}
}
dial = func(ctx context.Context, addr string, tlsCfg *tls.Config, cfg *quic.Config) (*quic.Conn, error) {
network := "udp"
udpAddr, err := t.resolveUDPAddr(ctx, network, addr)
@@ -448,6 +448,7 @@ func (t *Transport) Close() error {
return err
}
t.transport = nil
t.initOnce = sync.Once{}
}
return nil
}