From 36ce8a280b8077dc3a09c8f23393947ae068ea3b Mon Sep 17 00:00:00 2001
From: Brian Tiger Chow <brian.holderchow@gmail.com>
Date: Wed, 17 Sep 2014 18:28:51 -0700
Subject: [PATCH] chore(bitswap) rm halt chan since bitswap has no daemon
---
bitswap/bitswap.go | 10 ----------
1 file changed, 10 deletions(-)
diff --git a/bitswap/bitswap.go b/bitswap/bitswap.go
index 4fe95e21..e50d9f9e 100644
--- a/bitswap/bitswap.go
+++ b/bitswap/bitswap.go
@@ -49,11 +49,6 @@ type bitswap struct {
// interact with partners.
// TODO(brian): save the strategist's state to the datastore
strategist strategy.Strategist
-
- // haveList is the set of keys we have values for. a map for fast lookups.
- // haveList KeySet -- not needed. all values in datastore?
-
- haltChan chan struct{}
}
// NewSession initializes a bitswap session.
@@ -66,7 +61,6 @@ func NewSession(parent context.Context, s bsnet.NetworkService, p *peer.Peer, d
blockstore: blockstore.NewBlockstore(d),
routing: directory,
sender: bsnet.NewNetworkAdapter(s, &receiver),
- haltChan: make(chan struct{}),
notifications: notifications.New(),
}
receiver.Delegate(bs)
@@ -156,10 +150,6 @@ func (bs *bitswap) send(p *peer.Peer, b blocks.Block) {
bs.strategist.MessageSent(p, message)
}
-func (bs *bitswap) Halt() {
- bs.haltChan <- struct{}{}
-}
-
// TODO(brian): handle errors
func (bs *bitswap) ReceiveMessage(
ctx context.Context, sender *peer.Peer, incoming bsmsg.BitSwapMessage) (
--
GitLab