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

rm unused method

Browse Source 
License: MIT
Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
This commit is contained in:
Brian Tiger Chow
2014-12-16 23:39:39 -08:00
committed by Juan Batiz-Benet
parent 8d4d5b86ef
commit 1b1260b658
2 changed files with 0 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
exchange/bitswap/decision/engine.go
View File

@ -96,16 +96,6 @@ func (e *Engine) Peers() []peer.Peer {
return response 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 // MessageReceived performs book-keeping. Returns error if passed invalid
// arguments. // arguments.
func (e *Engine) MessageReceived(p peer.Peer, m bsmsg.BitSwapMessage) error { func (e *Engine) MessageReceived(p peer.Peer, m bsmsg.BitSwapMessage) error {

17
exchange/bitswap/decision/engine_test.go
View File

@ -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) { func TestPeerIsAddedToPeersWhenMessageReceivedOrSent(t *testing.T) {
sanfrancisco := newPeerAndLedgermanager("sf") sanfrancisco := newPeerAndLedgermanager("sf")