log when dropping messages

2017-08-29 19:42:33 -07:00 · 2017-08-29 19:42:33 -07:00 · e7faa78d7c
parent 02b9c5724d
commit e7faa78d7c
1 changed files with 1 additions and 0 deletions
--- a/floodsub.go
+++ b/floodsub.go
@ -346,6 +346,7 @@ func (p *PubSub) publishMessage(from peer.ID, msg *pb.Message) error {
 		select {
 		case mch <- out:
 		default:
+			log.Infof("dropping message to peer %s: queue full", pid)
 			// Drop it. The peer is too slow.
 		}
 	}