From 6e43767fe483365b6c508a74db04f1344bdeb812 Mon Sep 17 00:00:00 2001 From: Aravind Velamur Srinivasan Date: Thu, 25 May 2017 11:50:04 -0700 Subject: [PATCH] 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 --- services/outputhost/messagecache.go | 2 +- services/outputhost/outputhost.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/services/outputhost/messagecache.go b/services/outputhost/messagecache.go index bb6916ec..f171833b 100644 --- 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 index d71d0c8b..87cc58e1 100644 --- 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