From 1b1260b658a969baece8de9380bfff473b2938ec Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Tue, 16 Dec 2014 23:39:39 -0800 Subject: [PATCH] rm unused method License: MIT Signed-off-by: Brian Tiger Chow --- exchange/bitswap/decision/engine.go | 10 ---------- exchange/bitswap/decision/engine_test.go | 17 ----------------- 2 files changed, 27 deletions(-) diff --git a/exchange/bitswap/decision/engine.go b/exchange/bitswap/decision/engine.go index b8018eef0..e34b6a225 100644 --- a/exchange/bitswap/decision/engine.go +++ b/exchange/bitswap/decision/engine.go @@ -96,16 +96,6 @@ func (e *Engine) Peers() []peer.Peer { return response } -// BlockIsWantedByPeer returns true if peer wants the block given by this -// key -func (e *Engine) BlockIsWantedByPeer(k u.Key, p peer.Peer) bool { - e.lock.RLock() - defer e.lock.RUnlock() - - ledger := e.findOrCreate(p) - return ledger.WantListContains(k) -} - // MessageReceived performs book-keeping. Returns error if passed invalid // arguments. func (e *Engine) MessageReceived(p peer.Peer, m bsmsg.BitSwapMessage) error { diff --git a/exchange/bitswap/decision/engine_test.go b/exchange/bitswap/decision/engine_test.go index 592236c3e..5b1740754 100644 --- a/exchange/bitswap/decision/engine_test.go +++ b/exchange/bitswap/decision/engine_test.go @@ -60,23 +60,6 @@ func TestConsistentAccounting(t *testing.T) { } } -func TestBlockRecordedAsWantedAfterMessageReceived(t *testing.T) { - beggar := newPeerAndLedgermanager("can't be chooser") - chooser := newPeerAndLedgermanager("chooses JIF") - - block := blocks.NewBlock([]byte("data wanted by beggar")) - - messageFromBeggarToChooser := message.New() - messageFromBeggarToChooser.AddEntry(block.Key(), 1) - - chooser.Engine.MessageReceived(beggar.Peer, messageFromBeggarToChooser) - // for this test, doesn't matter if you record that beggar sent - - if !chooser.Engine.BlockIsWantedByPeer(block.Key(), beggar.Peer) { - t.Fatal("chooser failed to record that beggar wants block") - } -} - func TestPeerIsAddedToPeersWhenMessageReceivedOrSent(t *testing.T) { sanfrancisco := newPeerAndLedgermanager("sf")