diff --git a/docks/crane_init.go b/docks/crane_init.go index 331beb3..6943c8b 100644 --- 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 index 4ce707a..a4bc673 100644 --- 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 index 374d10f..771e68c 100644 --- 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 index a33b669..64f2550 100644 --- 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 )