diff --git a/pkg/kv/kvserver/replica_proposal_buf.go b/pkg/kv/kvserver/replica_proposal_buf.go index e32428da2028..ee232f57ac93 100644 --- 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 index d7dd421e8db7..4d04b6f2ad19 100644 --- a/pkg/kv/kvserver/replica_raft.go +++ b/pkg/kv/kvserver/replica_raft.go @@ -270,6 +270,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, quotaSize) if err != nil { @@ -504,6 +505,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)