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

fix(bitswap:strategy) move key set

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-09-17 18:47:40 -07:00
parent b8133a4853
commit 22539cf6d0
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
bitswap/bitswap.go
View File

@ -24,10 +24,6 @@ import (
// advertisements. WantLists are sorted in terms of priority. // advertisements. WantLists are sorted in terms of priority.
const PartnerWantListMax = 10 const PartnerWantListMax = 10
// KeySet is just a convenient alias for maps of keys, where we only care
// access/lookups.
type KeySet map[u.Key]struct{}
// bitswap instances implement the bitswap protocol. // bitswap instances implement the bitswap protocol.
type bitswap struct { type bitswap struct {
// peer is the identity of this (local) node. // peer is the identity of this (local) node.
@ -59,6 +55,7 @@ func NewSession(parent context.Context, s bsnet.NetworkService, p *peer.Peer, d
bs := &bitswap{ bs := &bitswap{
blockstore: blockstore.NewBlockstore(d), blockstore: blockstore.NewBlockstore(d),
notifications: notifications.New(), notifications: notifications.New(),
strategist: strategy.New(d),
peer: p, peer: p,
routing: directory, routing: directory,
sender: bsnet.NewNetworkAdapter(s, &receiver), sender: bsnet.NewNetworkAdapter(s, &receiver),

6
bitswap/strategy/ledger.go
View File

@ -8,6 +8,10 @@ import (
u "github.com/jbenet/go-ipfs/util" u "github.com/jbenet/go-ipfs/util"
) )
// keySet is just a convenient alias for maps of keys, where we only care
// access/lookups.
type keySet map[u.Key]struct{}
// ledger stores the data exchange relationship between two peers. // ledger stores the data exchange relationship between two peers.
type ledger struct { type ledger struct {
lock sync.RWMutex lock sync.RWMutex
@ -28,7 +32,7 @@ type ledger struct {
exchangeCount uint64 exchangeCount uint64
// wantList is a (bounded, small) set of keys that Partner desires. // wantList is a (bounded, small) set of keys that Partner desires.
wantList KeySet wantList keySet
Strategy strategyFunc Strategy strategyFunc
} }