Merge pull request #104071 from cockroachdb/blathers/backport-release…

…-23.1-104025 release-23.1: kvserver: add a few Raft proposal trace events
cockroachdb · Jun 6, 2023 · 28529f2 · 28529f2
2 parents 19db4ce + 2cbd96d
commit 28529f2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/pkg/kv/kvserver/replica_proposal_buf.go b/pkg/kv/kvserver/replica_proposal_buf.go
@@ -535,6 +535,7 @@ func (b *propBuf) FlushLockedWithRaftGroup(
 			ents = append(ents, raftpb.Entry{
 				Data: p.encodedCommand,
 			})
+			log.VEvent(p.ctx, 2, "flushing proposal to Raft")
 		}
 	}
 	if firstErr != nil {

diff --git a/pkg/kv/kvserver/replica_raft.go b/pkg/kv/kvserver/replica_raft.go
@@ -269,6 +269,7 @@ func (r *Replica) evalAndPropose(
 			"command is too large: %d bytes (max: %d)", quotaSize, maxSize,
 		))
 	}
+	log.VEventf(proposal.ctx, 2, "acquiring proposal quota (%d bytes)", quotaSize)
 	var err error
 	proposal.quotaAlloc, err = r.maybeAcquireProposalQuota(ctx, ba, quotaSize)
 	if err != nil {
@@ -501,6 +502,7 @@ func (r *Replica) propose(
 	//
 	// NB: we must not hold r.mu while using the proposal buffer, see comment
 	// on the field.
+	log.VEvent(p.ctx, 2, "submitting proposal to proposal buffer")
 	err := r.mu.proposalBuf.Insert(ctx, p, tok.Move(ctx))
 	if err != nil {
 		return kvpb.NewError(err)