Prevent data race in allowWindowIncrease (#259)

libp2p · Feb 7, 2022 · 9df78c4 · 9df78c4
1 parent 1ad4d0f
commit 9df78c4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/transport.go b/transport.go
@@ -381,7 +381,9 @@ func (t *transport) allowWindowIncrease(sess quic.Session, size uint64) bool {
 	// into our connections map (which we do right after dialing / accepting it),
 	// we have no way to account for that memory. This should be very rare.
 	// Block this attempt. The session can request more memory later.
+	t.connMx.Lock()
 	c, ok := t.conns[sess]
+	t.connMx.Unlock()
 	if !ok {
 		return false
 	}