diff --git a/p2p/test/transport/transport_test.go b/p2p/test/transport/transport_test.go index bfbd2c0bce..bd7de05d7a 100644 --- a/p2p/test/transport/transport_test.go +++ b/p2p/test/transport/transport_test.go @@ -9,7 +9,6 @@ import ( "io" "net" "runtime" - "strings" "sync" "sync/atomic" "testing" @@ -379,9 +378,6 @@ func TestMoreStreamsThanOurLimits(t *testing.T) { const streamCount = 1024 for _, tc := range transportsToTest { t.Run(tc.Name, func(t *testing.T) { - if strings.Contains(tc.Name, "WebRTC") { - t.Skip("This test potentially exhausts the uint16 WebRTC stream ID space.") - } listenerLimits := rcmgr.PartialLimitConfig{ PeerDefault: rcmgr.ResourceLimits{ Streams: 32, diff --git a/p2p/transport/webrtc/connection.go b/p2p/transport/webrtc/connection.go index e23975f4da..38d391c579 100644 --- a/p2p/transport/webrtc/connection.go +++ b/p2p/transport/webrtc/connection.go @@ -8,6 +8,7 @@ import ( "net" "sync" "sync/atomic" + "time" ic "github.com/libp2p/go-libp2p/core/crypto" "github.com/libp2p/go-libp2p/core/network" @@ -176,6 +177,7 @@ func (c *connection) OpenStream(ctx context.Context) (network.MuxedStream, error str.Reset() return nil, fmt.Errorf("failed to add stream(%d) to connection: %w", streamID, err) } + fmt.Println(time.Now(), "stream opened", str.id) return str, nil } @@ -189,6 +191,7 @@ func (c *connection) AcceptStream() (network.MuxedStream, error) { str.Reset() return nil, err } + fmt.Println(time.Now(), "stream accepted", str.id) return str, nil } }