Skip to content

GitLab

Commit 44f32138 authored by Jeromy's avatar Jeromy
Browse files
Options

fix tests halting

parent c6af3fe4
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
bitswap.go
View file @ 44f32138
...@@ -117,6 +117,9 @@ func (bs *bitswap) GetBlocks(parent context.Context, ks []u.Key) (*blocks.Block, ...@@ -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) { ...@@ -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
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment