comments

beacon-chain/sync/initial-sync/sync_blocks.go

@@ -96,7 +96,7 @@ func (s *InitialSync) processBatchedBlocks(msg p2p.Message) {
 	if msg.Peer != s.bestPeer {
 		// Only process batch block responses that come from the best peer
 		// we originally synced with.
-		log.Debugf("Received batch blocks from a different peer: %s", msg.Peer.Pretty())
+		log.WithField("peerID", msg.Peer.Pretty()).Debug("Received batch blocks from a different peer")
 		return
 	}
 

beacon-chain/sync/querier.go

@@ -162,7 +162,7 @@ func (q *Querier) run() {
 		case <-ticker.C:
 			q.RequestLatestHead()
 		case <-timeout:
-			queryLog.Infof("Peer with highest canonical head: %v", q.bestPeer.Pretty())
+			queryLog.WithField("peerID", q.bestPeer.Pretty()).Info("Peer with highest canonical head")
 			queryLog.Infof(
 				"Latest chain head is at slot: %d and state root: %#x",
 				q.currentHeadSlot-params.BeaconConfig().GenesisSlot, q.currentStateRoot,
@@ -187,7 +187,7 @@ func (q *Querier) run() {
 	}
 }
 
-// RequestLatestHead sends a request for all
+// RequestLatestHead broadcasts a request for
 // the latest chain head slot and state root to a peer.
 func (q *Querier) RequestLatestHead() {
 	request := &pb.ChainHeadRequest{}