webrtc: add TestManyStreams to transport integration tests

libp2p · Oct 10, 2023 · 3148787 · 3148787
1 parent 675d6d7
commit 3148787
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/p2p/test/transport/transport_test.go b/p2p/test/transport/transport_test.go
@@ -366,9 +366,6 @@ func TestManyStreams(t *testing.T) {
 	const streamCount = 128
 	for _, tc := range transportsToTest {
 		t.Run(tc.Name, func(t *testing.T) {
-			if strings.Contains(tc.Name, "WebRTC") {
-				t.Skip("Pion doesn't correctly handle large queues of streams.")
-			}
 			h1 := tc.HostGenerator(t, TransportTestCaseOpts{NoRcmgr: true})
 			h2 := tc.HostGenerator(t, TransportTestCaseOpts{NoListen: true, NoRcmgr: true})
 			defer h1.Close()

diff --git a/p2p/transport/webrtc/connection.go b/p2p/transport/webrtc/connection.go
@@ -25,7 +25,8 @@ import (
 
 var _ tpt.CapableConn = &connection{}
 
-const maxAcceptQueueLen = 10
+// maxAcceptQueueLen is the number of waiting streams.
+const maxAcceptQueueLen = 256
 
 const maxDataChannelID = 1 << 10