From 30831b33b5cc656df3352ffa2348f84ee5ef9b74 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Mon, 18 Dec 2017 17:13:06 +0100 Subject: [PATCH] providers: Cleanup after rebase MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit License: MIT Signed-off-by: Łukasz Magiera --- providers/providers.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/providers/providers.go b/providers/providers.go index 1bdedcea56b..f52ee7bdae9 100644 --- a/providers/providers.go +++ b/providers/providers.go @@ -31,6 +31,7 @@ const ( var ( provideKeysBufferSize = 2048 + // HasBlockBufferSize is the maximum numbers of CIDs that will get buffered // for providing HasBlockBufferSize = 256 @@ -45,7 +46,7 @@ type blockRequest struct { Ctx context.Context } -// Interface is an definition of providers interface to libp2p routing system +// Interface defines providers interface to libp2p routing system type Interface interface { Provide(k *cid.Cid) error ProvideRecursive(ctx context.Context, n ipld.Node, serv ipld.NodeGetter) error @@ -65,6 +66,7 @@ type providers struct { // network. blocks pushed down this channel get buffered and fed to the // provideKeys channel later on to avoid too much network activity newBlocks chan *cid.Cid + // provideKeys directly feeds provide workers provideKeys chan *cid.Cid