diff --git a/routing/dht/dht_net.go b/routing/dht/dht_net.go index 2b857ce2b..c8b6b66eb 100644 --- a/routing/dht/dht_net.go +++ b/routing/dht/dht_net.go @@ -38,8 +38,6 @@ func (dht *IpfsDHT) handleNewMessage(s inet.Stream) { // update the peer (on valid msgs only) dht.updateFromMessage(ctx, mPeer, pmes) - log.Event(ctx, "foo", dht.self, mPeer, pmes) - // get handler for this msg type. handler := dht.handlerForMsgType(pmes.GetType()) if handler == nil { diff --git a/routing/dht/routing.go b/routing/dht/routing.go index 35d804650..07d9ddc43 100644 --- a/routing/dht/routing.go +++ b/routing/dht/routing.go @@ -215,7 +215,7 @@ func (dht *IpfsDHT) getClosestPeers(ctx context.Context, key u.Key) (<-chan peer // run it! _, err := query.Run(ctx, tablepeers) if err != nil { - log.Errorf("closestPeers query run error: %s", err) + log.Debugf("closestPeers query run error: %s", err) } }()