From 9e6cc1f112ef42f50c1b11b720bb127e060f18ff Mon Sep 17 00:00:00 2001 From: Kevin Atkinson Date: Sun, 10 Jul 2016 15:35:27 -0400 Subject: [PATCH] Increase channel buffer size in blockstore.AllKeysChan(). License: MIT Signed-off-by: Kevin Atkinson --- blocks/blockstore/blockstore.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blocks/blockstore/blockstore.go b/blocks/blockstore/blockstore.go index 477141cd62c..605be2bd867 100644 --- a/blocks/blockstore/blockstore.go +++ b/blocks/blockstore/blockstore.go @@ -196,7 +196,7 @@ func (bs *blockstore) AllKeysChan(ctx context.Context) (<-chan key.Key, error) { } } - output := make(chan key.Key) + output := make(chan key.Key, dsq.KeysOnlyBufSize) go func() { defer func() { res.Process().Close() // ensure exit (signals early exit, too)