better bitswap logging
Jeromy committed
May 17, 2015 at 17:09 UTC
c273a3bd4f616cb95cebb1cf0b4b665bac8a6d39
2 files changed
+5
-2
exchange/bitswap/bitswap.go
+1
-1
@@ -288,7 +288,7 @@ func (bs *Bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg
288
bs.dupBlocksRecvd++
289
}
290
bs.counterLk.Unlock()
291
- log.Debugf("got block %s from %s (%d,%d)", block, p, bs.blocksRecvd, bs.dupBlocksRecvd)
291
+ log.Infof("got block %s from %s (%d,%d)", block, p, bs.blocksRecvd, bs.dupBlocksRecvd)
292
293
hasBlockCtx, cancel := context.WithTimeout(ctx, hasBlockTimeout)
294
if err := bs.HasBlock(hasBlockCtx, block); err != nil {
exchange/bitswap/wantmanager.go
+4
-1
@@ -66,6 +66,7 @@ type msgQueue struct {
66
}
67
68
func (pm *WantManager) WantBlocks(ks []u.Key) {
69
+ log.Infof("want blocks: %s", ks)
70
pm.addEntries(ks, false)
71
}
72
@@ -97,6 +98,7 @@ func (pm *WantManager) SendBlock(ctx context.Context, env *engine.Envelope) {
98
99
msg := bsmsg.New(false)
100
msg.AddBlock(env.Block)
101
+ log.Infof("Sending block %s to %s", env.Peer, env.Block)
102
err := pm.network.SendMessage(ctx, env.Peer, msg)
103
if err != nil {
104
log.Error(err)
@@ -143,8 +145,9 @@ func (pm *WantManager) runQueue(mq *msgQueue) {
145
146
err := pm.network.ConnectTo(pm.ctx, mq.p)
147
if err != nil {
146
- log.Error(err)
148
+ log.Errorf("cant connect to peer %s: %s", mq.p, err)
149
// TODO: cant connect, what now?
150
+ continue
151
}
152
153
// grab outgoing message