Reproducing bug

vacp2p · Nov 6, 2023 · 4f6ed3b · 4f6ed3b
1 parent 1ea3f3a
commit 4f6ed3b
Show file tree

Hide file tree

Showing 3 changed files with 404 additions and 395 deletions.
diff --git a/libp2p/builders.nim b/libp2p/builders.nim
@@ -312,6 +312,7 @@ proc newStandardSwitch*(
     .withMaxConnsPerPeer(maxConnsPerPeer)
     .withPeerStore(capacity=peerStoreCapacity)
     .withMplex(inTimeout, outTimeout)
+    .withYamux()
     .withTcpTransport(transportFlags)
     .withNameResolver(nameResolver)
     .withNoise()

diff --git a/libp2p/muxers/yamux/yamux.nim b/libp2p/muxers/yamux/yamux.nim
@@ -454,6 +454,7 @@ method handle*(m: Yamux) {.async, gcsafe.} =
             if header.streamId in m.flushed:
               m.flushed.del(header.streamId)
             if header.streamId mod 2 == m.currentId mod 2:
+              debug "Peer used our reserved stream id, skipping", id=header.streamId, currentId=m.currentId, peerId=m.connection.peerId
               raise newException(YamuxError, "Peer used our reserved stream id")
             let newStream = m.createStream(header.streamId, false)
             if m.channels.len >= m.maxChannCount: