coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-02-27 13:27:50 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

chore(bitswap) remove Peerstore() methods from bitswap.Network interface

Browse Source
This commit is contained in:
Brian Tiger Chow 2014-12-23 08:44:25 -05:00 committed by Juan Batiz-Benet
parent c34132e080
commit bd45adfb89
3 changed files with 5 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
exchange/bitswap/network/interface.go
View File

@ -26,8 +26,6 @@ type BitSwapNetwork interface {
peer.ID,
bsmsg.BitSwapMessage) (incoming bsmsg.BitSwapMessage, err error)
Peerstore() peer.Peerstore
// SetDelegate registers the Reciver to handle messages received from the
// network.
SetDelegate(Receiver)

4
exchange/bitswap/network/ipfs_impl.go
View File

@ -72,10 +72,6 @@ func (bsnet *impl) SetDelegate(r Receiver) {
bsnet.receiver = r
}
func (bsnet *impl) Peerstore() peer.Peerstore {
return bsnet.Peerstore()
}
// FindProvidersAsync returns a channel of providers for the given key
func (bsnet *impl) FindProvidersAsync(ctx context.Context, k util.Key, max int) <-chan peer.ID {
out := make(chan peer.ID)

17
exchange/bitswap/testnet/network.go
View File

@ -52,10 +52,9 @@ type network struct {
func (n *network) Adapter(p peer.ID) bsnet.BitSwapNetwork {
client := &networkClient{
local: p,
network: n,
peerstore: peer.NewPeerstore(),
routing: n.routingserver.Client(peer.PeerInfo{ID: p}),
local: p,
network: n,
routing: n.routingserver.Client(peer.PeerInfo{ID: p}),
}
n.clients[p] = client
return client
@ -155,9 +154,8 @@ func (n *network) SendRequest(
type networkClient struct {
local peer.ID
bsnet.Receiver
network Network
peerstore peer.Peerstore
routing routing.IpfsRouting
network Network
routing routing.IpfsRouting
}
func (nc *networkClient) SendMessage(
@ -187,7 +185,6 @@ func (nc *networkClient) FindProvidersAsync(ctx context.Context, k util.Key, max
defer close(out)
providers := nc.routing.FindProvidersAsync(ctx, k, max)
for info := range providers {
nc.peerstore.AddAddresses(info.ID, info.Addrs)
select {
case <-ctx.Done():
case out <- info.ID:
@ -213,7 +210,3 @@ func (nc *networkClient) DialPeer(ctx context.Context, p peer.ID) error {
func (nc *networkClient) SetDelegate(r bsnet.Receiver) {
nc.Receiver = r
}
func (nc *networkClient) Peerstore() peer.Peerstore {
return nc.peerstore
}