Merge pull request #51 from safing/fix/increase-queue-sizes

Increase queue sizes
safing · Jan 31, 2022 · faba5ae · faba5ae
2 parents 616f25b + e854212
commit faba5ae
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/docks/crane_init.go b/docks/crane_init.go
@@ -139,7 +139,7 @@ func (crane *Crane) startLocal() *terminal.Error {
 
 	// Create crane controller.
 	_, initData, tErr := NewLocalCraneControllerTerminal(crane, &terminal.TerminalOpts{
-		QueueSize: 10000,
+		QueueSize: terminal.DefaultQueueSize,
 		Padding:   8,
 	})
 	if tErr != nil {

diff --git a/docks/op_capacity.go b/docks/op_capacity.go
@@ -24,7 +24,7 @@ const (
 	capacityTestTimeout        = 30 * time.Second
 
 	capacityTestMsgSize     = 1000
-	capacityTestSendTimeout = 100 * time.Millisecond
+	capacityTestSendTimeout = 1000 * time.Millisecond
 )
 
 var (

diff --git a/docks/terminal_expansion.go b/docks/terminal_expansion.go
@@ -28,7 +28,7 @@ func ExpandTo(t terminal.OpTerminal, routeTo string, encryptFor *hub.Hub) (*Expa
 	// Create expansion terminal.
 	opts := &terminal.TerminalOpts{
 		Version:   1,
-		QueueSize: 100,
+		QueueSize: terminal.DefaultQueueSize,
 	}
 	tBase, initData, tErr := terminal.NewLocalBaseTerminal(context.Background(), 0, t.FmtID(), encryptFor, opts)
 	if tErr != nil {

diff --git a/terminal/flow_queue.go b/terminal/flow_queue.go
@@ -12,8 +12,8 @@ import (
 )
 
 const (
-	DefaultQueueSize        = 1000
-	MaxQueueSize            = 60000
+	DefaultQueueSize        = 50000
+	MaxQueueSize            = 1000000
 	forceReportBelowPercent = 0.75
 )