Skip to content

Commit

Permalink
Merge pull request #2961 from ipfs/kevina/AllKeysChan-buf-size
Browse files Browse the repository at this point in the history
Increase channel buffer size in blockstore.AllKeysChan().
  • Loading branch information
whyrusleeping committed Jul 10, 2016
2 parents fd971ed + 9e6cc1f commit 94e35db
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion blocks/blockstore/blockstore.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 94e35db

Please sign in to comment.