提交 9a18fd63 作者: Brian Tiger Chow

chore(exch, bitswap) misc trivial cleanup

上级 e907b2e0
package bitswap package bitswap
import ( import (
"errors"
context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context" context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context"
ds "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/datastore.go" ds "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/datastore.go"
...@@ -20,7 +18,6 @@ import ( ...@@ -20,7 +18,6 @@ import (
// TODO rename -> Router? // TODO rename -> Router?
type Routing interface { type Routing interface {
// FindProvidersAsync returns a channel of providers for the given key // FindProvidersAsync returns a channel of providers for the given key
// TODO replace with timeout with context
FindProvidersAsync(context.Context, u.Key, int) <-chan *peer.Peer FindProvidersAsync(context.Context, u.Key, int) <-chan *peer.Peer
// Provide provides the key to the network // Provide provides the key to the network
...@@ -66,8 +63,7 @@ type bitswap struct { ...@@ -66,8 +63,7 @@ type bitswap struct {
// GetBlock attempts to retrieve a particular block from peers within the // GetBlock attempts to retrieve a particular block from peers within the
// deadline enforced by the context // deadline enforced by the context
func (bs *bitswap) Block(ctx context.Context, k u.Key) ( func (bs *bitswap) Block(ctx context.Context, k u.Key) (*blocks.Block, error) {
*blocks.Block, error) {
provs_ch := bs.routing.FindProvidersAsync(ctx, k, 20) provs_ch := bs.routing.FindProvidersAsync(ctx, k, 20)
...@@ -161,7 +157,7 @@ func (bs *bitswap) ReceiveMessage( ...@@ -161,7 +157,7 @@ func (bs *bitswap) ReceiveMessage(
} }
} }
} }
return nil, nil, errors.New("TODO implement") return nil, nil, nil
} }
// send strives to ensure that accounting is always performed when a message is // send strives to ensure that accounting is always performed when a message is
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论