fix wantlist removal accounting, add tests

License: MIT
Signed-off-by: Jeromy <jeromyj@gmail.com>

exchange/bitswap/bitswap.go

@@ -285,6 +285,9 @@ func (bs *Bitswap) getNextSessionID() uint64 {
 
 // CancelWant removes a given key from the wantlist
 func (bs *Bitswap) CancelWants(cids []*cid.Cid, ses uint64) {
+	if len(cids) == 0 {
+		return
+	}
 	bs.wm.CancelWants(context.Background(), cids, nil, ses)
 }
 

exchange/bitswap/bitswap_test.go

@@ -328,7 +328,7 @@ func TestBasicBitswap(t *testing.T) {
 
 	t.Log("Test a one node trying to get one block from another")
 
-	instances := sg.Instances(2)
+	instances := sg.Instances(3)
 	blocks := bg.Blocks(1)
 	err := instances[0].Exchange.HasBlock(blocks[0])
 	if err != nil {
@@ -343,6 +343,10 @@ func TestBasicBitswap(t *testing.T) {
 	}
 
 	time.Sleep(time.Millisecond * 20)
+	wl := instances[2].Exchange.WantlistForPeer(instances[1].Peer)
+	if len(wl) != 0 {
+		t.Fatal("should have no items in other peers wantlist")
+	}
 	if len(instances[1].Exchange.GetWantlist()) != 0 {
 		t.Fatal("shouldnt have anything in wantlist")
 	}

exchange/bitswap/decision/engine.go

@@ -105,13 +105,10 @@ func NewEngine(ctx context.Context, bs bstore.Blockstore) *Engine {
 }
 
 func (e *Engine) WantlistForPeer(p peer.ID) (out []*wl.Entry) {
-	e.lock.Lock()
-	partner, ok := e.ledgerMap[p]
-	if ok {
-		out = partner.wantList.SortedEntries()
-	}
-	e.lock.Unlock()
-	return out
+	partner := e.findOrCreate(p)
+	partner.lk.Lock()
+	defer partner.lk.Unlock()
+	return partner.wantList.SortedEntries()
 }
 
 func (e *Engine) LedgerForPeer(p peer.ID) *Receipt {

exchange/bitswap/wantlist/wantlist.go

@@ -170,7 +170,7 @@ func (w *Wantlist) Remove(c *cid.Cid) bool {
 	}
 
 	delete(w.set, k)
-	return false
+	return true
 }
 
 func (w *Wantlist) Contains(k *cid.Cid) (*Entry, bool) {

exchange/bitswap/wantlist/wantlist_test.go

@@ -48,25 +48,34 @@ func assertNotHasCid(t *testing.T, w wli, c *cid.Cid) {
 func TestBasicWantlist(t *testing.T) {
 	wl := New()
 
-	wl.Add(testcids[0], 5)
+	if !wl.Add(testcids[0], 5) {
+		t.Fatal("expected true")
+	}
 	assertHasCid(t, wl, testcids[0])
-	wl.Add(testcids[1], 4)
+	if !wl.Add(testcids[1], 4) {
+		t.Fatal("expected true")
+	}
 	assertHasCid(t, wl, testcids[0])
 	assertHasCid(t, wl, testcids[1])
 
 	if wl.Len() != 2 {
 		t.Fatal("should have had two items")
 	}
 
-	wl.Add(testcids[1], 4)
+	if wl.Add(testcids[1], 4) {
+		t.Fatal("add shouldnt report success on second add")
+	}
 	assertHasCid(t, wl, testcids[0])
 	assertHasCid(t, wl, testcids[1])
 
 	if wl.Len() != 2 {
 		t.Fatal("should have had two items")
 	}
 
-	wl.Remove(testcids[0])
+	if !wl.Remove(testcids[0]) {
+		t.Fatal("should have gotten true")
+	}
+
 	assertHasCid(t, wl, testcids[1])
 	if _, has := wl.Contains(testcids[0]); has {
 		t.Fatal("shouldnt have this cid")
@@ -76,12 +85,20 @@ func TestBasicWantlist(t *testing.T) {
 func TestSesRefWantlist(t *testing.T) {
 	wl := NewThreadSafe()
 
-	wl.Add(testcids[0], 5, 1)
+	if !wl.Add(testcids[0], 5, 1) {
+		t.Fatal("should have added")
+	}
 	assertHasCid(t, wl, testcids[0])
-	wl.Remove(testcids[0], 2)
+	if wl.Remove(testcids[0], 2) {
+		t.Fatal("shouldnt have removed")
+	}
 	assertHasCid(t, wl, testcids[0])
-	wl.Add(testcids[0], 5, 1)
+	if wl.Add(testcids[0], 5, 1) {
+		t.Fatal("shouldnt have added")
+	}
 	assertHasCid(t, wl, testcids[0])
-	wl.Remove(testcids[0], 1)
+	if !wl.Remove(testcids[0], 1) {
+		t.Fatal("should have removed")
+	}
 	assertNotHasCid(t, wl, testcids[0])
 }