We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e42c588 commit dffaae0Copy full SHA for dffaae0
internal/transport/http2_client.go
@@ -524,7 +524,9 @@ func (t *http2Client) getPeer() *peer.Peer {
524
// OutgoingGoAwayHandler writes a GOAWAY to the connection. Always returns (false, err) as we want the GoAway
525
// to be the last frame loopy writes to the transport.
526
func (t *http2Client) outgoingGoAwayHandler(g *goAway) (bool, error) {
527
- if err := t.framer.fr.WriteGoAway(math.MaxInt32*3/4, http2.ErrCodeNo, g.debugData); err != nil {
+ t.mu.Lock()
528
+ defer t.mu.Unlock()
529
+ if err := t.framer.fr.WriteGoAway(t.nextID-2, http2.ErrCodeNo, g.debugData); err != nil {
530
return false, err
531
}
532
return false, g.closeConn
0 commit comments