From 0eae1583ea5719bfc314f402e6b509a7c9018744 Mon Sep 17 00:00:00 2001 From: gammazero Date: Thu, 29 Oct 2020 23:10:10 -0400 Subject: [PATCH] Increase default outbound message size --- router/websocketserver.go | 2 +- transport/localpeer.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/router/websocketserver.go b/router/websocketserver.go index 764a15b8..c393dc3c 100644 --- a/router/websocketserver.go +++ b/router/websocketserver.go @@ -25,7 +25,7 @@ const ( msgpackWebsocketProtocol = "wamp.2.msgpack" cborWebsocketProtocol = "wamp.2.cbor" - defaultOutQueueSize = 16 + defaultOutQueueSize = 64 ) type protocol struct { diff --git a/transport/localpeer.go b/transport/localpeer.go index 13ba3587..d4d95515 100644 --- a/transport/localpeer.go +++ b/transport/localpeer.go @@ -6,7 +6,7 @@ import ( "github.com/gammazero/nexus/v3/wamp" ) -const linkedPeersOutQueueSize = 16 +const linkedPeersOutQueueSize = 64 // LinkedPeers creates two connected peers. Messages sent to one peer appear // in the Recv of the other. This is used for connecting client sessions to