chore: increase limits

rosen-bridge · Jun 29, 2024 · c3d1e55 · c3d1e55
1 parent d231c54
commit c3d1e55
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 3 deletions.
diff --git a/packages/rosenet-node/lib/createRoseNetNode.ts b/packages/rosenet-node/lib/createRoseNetNode.ts
@@ -95,7 +95,12 @@ const createRoseNetNode = async ({
         denyDialPeer: isPeerUnauthorized,
       }),
     },
-    streamMuxers: [mplex()],
+    streamMuxers: [
+      mplex({
+        maxStreamBufferSize: 100_000_000,
+        maxUnprocessedMessageQueueSize: 200_000_000,
+      }),
+    ],
     peerDiscovery: [
       bootstrap({
         list: config.relayMultiaddrs,
@@ -160,7 +165,11 @@ const createRoseNetNode = async ({
             }
           });
         },
-        { runOnTransientConnection: true },
+        {
+          runOnTransientConnection: true,
+          maxInboundStreams: 2000,
+          maxOutboundStreams: 2000,
+        },
       );
       RoseNetNodeContext.logger.debug(
         `handler for ${ROSENET_DIRECT_PROTOCOL_V1} protocol set`,

diff --git a/packages/rosenet-relay/lib/createRoseNetRelay.ts b/packages/rosenet-relay/lib/createRoseNetRelay.ts
@@ -63,7 +63,12 @@ const createRoseNetRelay = async ({
       denyInboundRelayedConnection: () => true,
       denyDialPeer: isPeerUnauthorized,
     },
-    streamMuxers: [mplex()],
+    streamMuxers: [
+      mplex({
+        maxStreamBufferSize: 100_000_000,
+        maxUnprocessedMessageQueueSize: 200_000_000,
+      }),
+    ],
     services: {
       circuitRelay: circuitRelayServer({
         reservations: {
@@ -72,6 +77,9 @@ const createRoseNetRelay = async ({
           defaultDataLimit: 0n,
           applyDefaultLimit: false,
         },
+        maxInboundHopStreams: 2000,
+        maxOutboundHopStreams: 2000,
+        maxOutboundStopStreams: 2000,
       }),
       pubsub: gossipsub({
         allowPublishToZeroPeers: true,