diff --git a/pkg/kv/kvserver/kvflowcontrol/rac2/range_controller.go b/pkg/kv/kvserver/kvflowcontrol/rac2/range_controller.go index 20cc42f4116e..b21d1d9175e1 100644 --- a/pkg/kv/kvserver/kvflowcontrol/rac2/range_controller.go +++ b/pkg/kv/kvserver/kvflowcontrol/rac2/range_controller.go @@ -855,6 +855,8 @@ func (rss *replicaSendStream) closeLocked(ctx context.Context) { } func (rss *replicaSendStream) changeToProbeLocked(ctx context.Context, now time.Time) { + log.VEventf(ctx, 1, "r%v:%v stream %v changing to probe", + rss.parent.parent.opts.RangeID, rss.parent.desc, rss.parent.stream) // This is the first time we've seen the replica change to StateProbe, // update the connected state and start time. If the state doesn't // change within probeRecentlyReplicateDuration, we will close the diff --git a/pkg/kv/kvserver/kvflowcontrol/replica_rac2/processor.go b/pkg/kv/kvserver/kvflowcontrol/replica_rac2/processor.go index ed42c9f5b628..9e7718ea8ec4 100644 --- a/pkg/kv/kvserver/kvflowcontrol/replica_rac2/processor.go +++ b/pkg/kv/kvserver/kvflowcontrol/replica_rac2/processor.go @@ -557,6 +557,7 @@ func (p *processorImpl) SetEnabledWhenLeaderRaftMuLocked( if level != EnabledWhenLeaderV1Encoding || p.desc.replicas == nil { return } + log.VEventf(ctx, 1, "enabled v2 protocol using v1 priority encoding") // May need to create RangeController. var leaderID roachpb.ReplicaID var term uint64