Reduce the channel sizes (#206)

* Reduce the channel sizes * Increase the channel size to 2000 * Increase ack channel size to 2000 as well * Reduce the channel size to 1000
uber-archive · May 25, 2017 · 6e43767 · 6e43767
1 parent d85ebe7
commit 6e43767
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/services/outputhost/messagecache.go b/services/outputhost/messagecache.go
@@ -155,7 +155,7 @@ const (
 	stateProgressing
 )
 
-const ackChannelSize = 10000
+const ackChannelSize = 1000
 
 // AckID is an acknowledgement ID; not the same as common.AckID, which decomposes this string
 // Capitalized because otherwise the type name conflicts horribly with local variables

diff --git a/services/outputhost/outputhost.go b/services/outputhost/outputhost.go
@@ -53,7 +53,7 @@ import (
 const (
 	// defaultIdleTimeout is the time to wait before we close all streams
 	defaultIdleTimeout        = 10 * time.Minute
-	defaultPrefetchBufferSize = 10000 // XXX: find the optimal prefetch buffer size
+	defaultPrefetchBufferSize = 1000 // XXX: find the optimal prefetch buffer size
 	defaultUnloadChSize       = 50
 	defaultAckMgrMapChSize    = 500
 	defaultAckMgrIDStartFrom  = 0                // the default ack mgr id for this host to start from