From 50c1db3fbfccc3528a5335ad2b64e2471d7f7314 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 18 Aug 2015 15:43:49 -0700 Subject: [PATCH] raft: downgrade the logging around snapshot to debugf Snapshot related logging is spamming when leader trying to sync a failed peer. --- raft/raft.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/raft/raft.go b/raft/raft.go index e7f535feb..1108604b9 100644 --- a/raft/raft.go +++ b/raft/raft.go @@ -270,10 +270,10 @@ func (r *raft) sendAppend(to uint64) { } m.Snapshot = snapshot sindex, sterm := snapshot.Metadata.Index, snapshot.Metadata.Term - r.logger.Infof("%x [firstindex: %d, commit: %d] sent snapshot[index: %d, term: %d] to %x [%s]", + r.logger.Debugf("%x [firstindex: %d, commit: %d] sent snapshot[index: %d, term: %d] to %x [%s]", r.id, r.raftLog.firstIndex(), r.Commit, sindex, sterm, to, pr) pr.becomeSnapshot(sindex) - r.logger.Infof("%x paused sending replication messages to %x [%s]", r.id, to, pr) + r.logger.Debugf("%x paused sending replication messages to %x [%s]", r.id, to, pr) } else { m.Type = pb.MsgApp m.Index = pr.Next - 1 @@ -550,7 +550,7 @@ func stepLeader(r *raft, m pb.Message) { case pr.State == ProgressStateProbe: pr.becomeReplicate() case pr.State == ProgressStateSnapshot && pr.maybeSnapshotAbort(): - r.logger.Infof("%x snapshot aborted, resumed sending replication messages to %x [%s]", r.id, m.From, pr) + r.logger.Debugf("%x snapshot aborted, resumed sending replication messages to %x [%s]", r.id, m.From, pr) pr.becomeProbe() case pr.State == ProgressStateReplicate: pr.ins.freeTo(m.Index) @@ -583,11 +583,11 @@ func stepLeader(r *raft, m pb.Message) { } if !m.Reject { pr.becomeProbe() - r.logger.Infof("%x snapshot succeeded, resumed sending replication messages to %x [%s]", r.id, m.From, pr) + r.logger.Debugf("%x snapshot succeeded, resumed sending replication messages to %x [%s]", r.id, m.From, pr) } else { pr.snapshotFailure() pr.becomeProbe() - r.logger.Infof("%x snapshot failed, resumed sending replication messages to %x [%s]", r.id, m.From, pr) + r.logger.Debugf("%x snapshot failed, resumed sending replication messages to %x [%s]", r.id, m.From, pr) } // If snapshot finish, wait for the msgAppResp from the remote node before sending // out the next msgApp.