opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-29 01:12:24 +08:00
Code Issues Projects Releases Wiki Activity

bitswap: log superfluous messages

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-04 14:06:33 -08:00
parent aeb2e07198
commit 10072c149d
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -149,9 +149,13 @@ func (e *Engine) Peers() []peer.ID {
// arguments. // arguments.
func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error { func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error {
log := log.Prefix("bitswap.Engine.MessageReceived(%s)", p) 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") defer log.Debugf("exit")
if len(m.Wantlist()) == 0 && len(m.Blocks()) == 0 {
log.Info("superfluous message")
}
newWorkExists := false newWorkExists := false
defer func() { defer func() {
if newWorkExists { if newWorkExists {
@ -166,6 +170,7 @@ func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error {
if m.Full() { if m.Full() {
l.wantList = wl.New() l.wantList = wl.New()
} }
for _, entry := range m.Wantlist() { for _, entry := range m.Wantlist() {
if entry.Cancel { if entry.Cancel {
log.Debug("cancel", entry.Key) log.Debug("cancel", entry.Key)