From 10072c149dbdf6aafc345b9232e67da457074aab Mon Sep 17 00:00:00 2001 From: Juan Batiz-Benet Date: Sun, 4 Jan 2015 14:06:33 -0800 Subject: [PATCH] bitswap: log superfluous messages --- exchange/bitswap/decision/engine.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/exchange/bitswap/decision/engine.go b/exchange/bitswap/decision/engine.go index b2e20bf8e..e4b2ab832 100644 --- a/exchange/bitswap/decision/engine.go +++ b/exchange/bitswap/decision/engine.go @@ -149,9 +149,13 @@ func (e *Engine) Peers() []peer.ID { // arguments. func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error { log := log.Prefix("bitswap.Engine.MessageReceived(%s)", p) - log.Debugf("enter") + log.Debugf("enter. %d entries %d blocks", len(m.Wantlist()), len(m.Blocks())) defer log.Debugf("exit") + if len(m.Wantlist()) == 0 && len(m.Blocks()) == 0 { + log.Info("superfluous message") + } + newWorkExists := false defer func() { if newWorkExists { @@ -166,6 +170,7 @@ func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error { if m.Full() { l.wantList = wl.New() } + for _, entry := range m.Wantlist() { if entry.Cancel { log.Debug("cancel", entry.Key)