提交 d59cbe74 作者: Łukasz Magiera

providers: Cleanup after rebase

License: MIT
Signed-off-by: 's avatarŁukasz Magiera <magik6k@gmail.com>
上级 61d2e946
...@@ -31,6 +31,7 @@ const ( ...@@ -31,6 +31,7 @@ const (
var ( var (
provideKeysBufferSize = 2048 provideKeysBufferSize = 2048
// HasBlockBufferSize is the maximum numbers of CIDs that will get buffered // HasBlockBufferSize is the maximum numbers of CIDs that will get buffered
// for providing // for providing
HasBlockBufferSize = 256 HasBlockBufferSize = 256
...@@ -45,7 +46,7 @@ type blockRequest struct { ...@@ -45,7 +46,7 @@ type blockRequest struct {
Ctx context.Context 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 { type Interface interface {
Provide(k *cid.Cid) error Provide(k *cid.Cid) error
ProvideRecursive(ctx context.Context, n ipld.Node, serv ipld.NodeGetter) error ProvideRecursive(ctx context.Context, n ipld.Node, serv ipld.NodeGetter) error
...@@ -65,6 +66,7 @@ type providers struct { ...@@ -65,6 +66,7 @@ type providers struct {
// network. blocks pushed down this channel get buffered and fed to the // network. blocks pushed down this channel get buffered and fed to the
// provideKeys channel later on to avoid too much network activity // provideKeys channel later on to avoid too much network activity
newBlocks chan *cid.Cid newBlocks chan *cid.Cid
// provideKeys directly feeds provide workers // provideKeys directly feeds provide workers
provideKeys chan *cid.Cid provideKeys chan *cid.Cid
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论