opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-30 18:13:54 +08:00
Code Issues Projects Releases Wiki Activity

style(bitswap) rename to network

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-12-23 07:08:53 -05:00
committed by Juan Batiz-Benet
parent 60f3a874c2
commit 070b633df8
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
exchange/bitswap/bitswap.go
View File

@ -64,7 +64,7 @@ func New(parent context.Context, p peer.ID, network bsnet.BitSwapNetwork, routin
notifications: notif, notifications: notif,
engine: decision.NewEngine(ctx, bstore), engine: decision.NewEngine(ctx, bstore),
routing: routing, routing: routing,
sender: network, network: network,
wantlist: wantlist.NewThreadSafe(), wantlist: wantlist.NewThreadSafe(),
batchRequests: make(chan []u.Key, sizeBatchRequestChan), batchRequests: make(chan []u.Key, sizeBatchRequestChan),
} }
@ -78,8 +78,8 @@ func New(parent context.Context, p peer.ID, network bsnet.BitSwapNetwork, routin
// bitswap instances implement the bitswap protocol. // bitswap instances implement the bitswap protocol.
type bitswap struct { type bitswap struct {
// sender delivers messages on behalf of the session // network delivers messages on behalf of the session
sender bsnet.BitSwapNetwork network bsnet.BitSwapNetwork
// blockstore is the local database // blockstore is the local database
// NB: ensure threadsafety // NB: ensure threadsafety
@ -341,11 +341,11 @@ func (bs *bitswap) ReceiveError(err error) {
// sent // sent
func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error { func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error {
log.Event(ctx, "DialPeer", p) log.Event(ctx, "DialPeer", p)
err := bs.sender.DialPeer(ctx, p) err := bs.network.DialPeer(ctx, p)
if err != nil { if err != nil {
return errors.Wrap(err) return errors.Wrap(err)
} }
if err := bs.sender.SendMessage(ctx, p, m); err != nil { if err := bs.network.SendMessage(ctx, p, m); err != nil {
return errors.Wrap(err) return errors.Wrap(err)
} }
return bs.engine.MessageSent(p, m) return bs.engine.MessageSent(p, m)