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

fix tests halting

Browse Source
This commit is contained in:
Jeromy
2014-11-19 23:34:40 +00:00
parent 0abc72c062
commit e4b2ae3bb2
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
exchange/bitswap/bitswap.go
View File

@ -117,6 +117,9 @@ func (bs *bitswap) GetBlocks(parent context.Context, ks []u.Key) (*blocks.Block,
} }
func (bs *bitswap) sendWantListTo(ctx context.Context, peers <-chan peer.Peer) error { func (bs *bitswap) sendWantListTo(ctx context.Context, peers <-chan peer.Peer) error {
if peers == nil {
panic("Cant send wantlist to nil peerchan")
}
message := bsmsg.New() message := bsmsg.New()
for _, wanted := range bs.wantlist.Keys() { for _, wanted := range bs.wantlist.Keys() {
message.AddWanted(wanted) message.AddWanted(wanted)
@ -164,6 +167,7 @@ func (bs *bitswap) run(ctx context.Context) {
for { for {
select { select {
case <-broadcastSignal: case <-broadcastSignal:
unsentKeys = 0
wantlist := bs.wantlist.Keys() wantlist := bs.wantlist.Keys()
if len(wantlist) == 0 { if len(wantlist) == 0 {
continue continue

2
routing/mock/routing.go
View File

@ -59,7 +59,7 @@ func (mr *MockRouter) FindProviders(ctx context.Context, key u.Key) ([]peer.Peer
} }
func (mr *MockRouter) FindPeer(ctx context.Context, pid peer.ID) (peer.Peer, error) { func (mr *MockRouter) FindPeer(ctx context.Context, pid peer.ID) (peer.Peer, error) {
log.Debug("FindPeer: %s", pid) log.Debugf("FindPeer: %s", pid)
return nil, nil return nil, nil
} }