Skip to content

Commit 9c2797b

Browse files
committed
Add snap ID and peer ID to relevant log lines in sendLatestSnapshot; fix - use peer.ID instead of peer as a value in log line
1 parent fea3dad commit 9c2797b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

replication.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -337,12 +337,12 @@ func (r *Raft) sendLatestSnapshot(s *followerReplication) (bool, error) {
337337
peer := s.peer
338338
s.peerLock.RUnlock()
339339

340-
r.logger.Info("installing snapshot on", "peer", peer, "id", snapID, "size", req.Size)
340+
r.logger.Info("installing snapshot on", "peer", peer.ID, "id", snapID, "size", req.Size)
341341
// Make the call
342342
start := time.Now()
343343
var resp InstallSnapshotResponse
344344
if err := r.trans.InstallSnapshot(peer.ID, peer.Address, &req, &resp, snapshot); err != nil {
345-
r.logger.Error("failed to install snapshot", "id", snapID, "error", err)
345+
r.logger.Error("failed to install snapshot", "peer", peer.ID, "id", snapID, "error", err)
346346
s.failures++
347347
return false, err
348348
}
@@ -376,7 +376,7 @@ func (r *Raft) sendLatestSnapshot(s *followerReplication) (bool, error) {
376376
s.notifyAll(true)
377377
} else {
378378
s.failures++
379-
r.logger.Warn("installSnapshot rejected to", "peer", peer)
379+
r.logger.Warn("installSnapshot rejected to", "peer", peer.ID, "id", snapID)
380380
}
381381
return false, nil
382382
}

0 commit comments

Comments
 (0)