opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-29 17:36:38 +08:00
Code Issues Projects Releases Wiki Activity

style(bitswap) rename Adapter -> BitSwapNetwork for clarity

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-10-27 07:02:38 -07:00
committed by Juan Batiz-Benet
parent 919fb31a16
commit 2bc82adfae
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
exchange/bitswap/bitswap.go
View File

@ -57,7 +57,7 @@ func NetMessageSession(ctx context.Context, p peer.Peer,
type bitswap struct { type bitswap struct {
// sender delivers messages on behalf of the session // sender delivers messages on behalf of the session
sender bsnet.Adapter sender bsnet.BitSwapNetwork
// blockstore is the local database // blockstore is the local database
// NB: ensure threadsafety // NB: ensure threadsafety

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

@ -8,8 +8,8 @@ import (
u "github.com/jbenet/go-ipfs/util" u "github.com/jbenet/go-ipfs/util"
) )
// Adapter provides network connectivity for BitSwap sessions // BitSwapNetwork provides network connectivity for BitSwap sessions
type Adapter interface { type BitSwapNetwork interface {
// DialPeer ensures there is a connection to peer. // DialPeer ensures there is a connection to peer.
DialPeer(context.Context, peer.Peer) error DialPeer(context.Context, peer.Peer) error
@ -31,6 +31,7 @@ type Adapter interface {
SetDelegate(Receiver) SetDelegate(Receiver)
} }
// Implement Receiver to receive messages from the BitSwapNetwork
type Receiver interface { type Receiver interface {
ReceiveMessage( ReceiveMessage(
ctx context.Context, sender peer.Peer, incoming bsmsg.BitSwapMessage) ( ctx context.Context, sender peer.Peer, incoming bsmsg.BitSwapMessage) (
@ -39,7 +40,6 @@ type Receiver interface {
ReceiveError(error) ReceiveError(error)
} }
// 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
FindProvidersAsync(context.Context, u.Key, int) <-chan peer.Peer FindProvidersAsync(context.Context, u.Key, int) <-chan peer.Peer

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

@ -15,7 +15,7 @@ import (
var log = util.Logger("net_message_adapter") var log = util.Logger("net_message_adapter")
// NetMessageAdapter wraps a NetMessage network service // NetMessageAdapter wraps a NetMessage network service
func NetMessageAdapter(s inet.Service, n inet.Network, r Receiver) Adapter { func NetMessageAdapter(s inet.Service, n inet.Network, r Receiver) BitSwapNetwork {
adapter := impl{ adapter := impl{
nms: s, nms: s,
net: n, net: n,

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

@ -13,7 +13,7 @@ import (
) )
type Network interface { type Network interface {
Adapter(peer.Peer) bsnet.Adapter Adapter(peer.Peer) bsnet.BitSwapNetwork
HasPeer(peer.Peer) bool HasPeer(peer.Peer) bool
@ -43,7 +43,7 @@ type network struct {
clients map[util.Key]bsnet.Receiver clients map[util.Key]bsnet.Receiver
} }
func (n *network) Adapter(p peer.Peer) bsnet.Adapter { func (n *network) Adapter(p peer.Peer) bsnet.BitSwapNetwork {
client := &networkClient{ client := &networkClient{
local: p, local: p,
network: n, network: n,