bitswap

Jul 27, 2018

Changes in this version

+ var ErrAlreadyHaveBlock = errors.New("already have block")

+ var HasBlockBufferSize = 256

+ var TaskWorkerCount = 8

+ func New(parent context.Context, network bsnet.BitSwapNetwork, ...) exchange.Interface

+ type Bitswap struct

+ func (bs *Bitswap) CancelWants(cids []*cid.Cid, ses uint64)

+ func (bs *Bitswap) Close() error

+ func (bs *Bitswap) GetBlock(parent context.Context, k *cid.Cid) (blocks.Block, error)

+ func (bs *Bitswap) GetBlocks(ctx context.Context, keys []*cid.Cid) (<-chan blocks.Block, error)

+ func (bs *Bitswap) GetWantlist() []*cid.Cid

+ func (bs *Bitswap) HasBlock(blk blocks.Block) error

+ func (bs *Bitswap) IsOnline() bool

+ func (bs *Bitswap) LedgerForPeer(p peer.ID) *decision.Receipt

+ func (bs *Bitswap) NewSession(ctx context.Context) *Session

+ func (bs *Bitswap) PeerConnected(p peer.ID)

+ func (bs *Bitswap) PeerDisconnected(p peer.ID)

+ func (bs *Bitswap) ReceiveError(err error)

+ func (bs *Bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg.BitSwapMessage)

+ func (bs *Bitswap) SessionsForBlock(c *cid.Cid) []*Session

+ func (bs *Bitswap) Stat() (*Stat, error)

+ func (bs *Bitswap) WantlistForPeer(p peer.ID) []*cid.Cid

+ type Instance struct

+ Exchange *Bitswap

+ Peer peer.ID

+ func MkSession(ctx context.Context, net tn.Network, p testutil.Identity) Instance

+ func (i *Instance) Blockstore() blockstore.Blockstore

+ func (i *Instance) SetBlockstoreLatency(t time.Duration) time.Duration

+ type Session struct

+ func (s *Session) GetBlock(parent context.Context, k *cid.Cid) (blocks.Block, error)

+ func (s *Session) GetBlocks(ctx context.Context, keys []*cid.Cid) (<-chan blocks.Block, error)

+ type SessionGenerator struct

+ func NewTestSessionGenerator(net tn.Network) SessionGenerator

+ func (g *SessionGenerator) Close() error

+ func (g *SessionGenerator) Instances(n int) []Instance

+ func (g *SessionGenerator) Next() Instance

+ type Stat struct

+ BlocksReceived uint64

+ BlocksSent uint64

+ DataReceived uint64

+ DataSent uint64

+ DupBlksReceived uint64

+ DupDataReceived uint64

+ Peers []string

+ ProvideBufLen int

+ Wantlist []*cid.Cid

+ type WantManager struct

+ func NewWantManager(ctx context.Context, network bsnet.BitSwapNetwork) *WantManager

+ func (pm *WantManager) CancelWants(ctx context.Context, ks []*cid.Cid, peers []peer.ID, ses uint64)

+ func (pm *WantManager) Connected(p peer.ID)

+ func (pm *WantManager) ConnectedPeers() []peer.ID

+ func (pm *WantManager) Disconnected(p peer.ID)

+ func (pm *WantManager) Run()

+ func (pm *WantManager) SendBlock(ctx context.Context, env *engine.Envelope)

+ func (pm *WantManager) WantBlocks(ctx context.Context, ks []*cid.Cid, peers []peer.ID, ses uint64)