@@ -159,7 +159,7 @@ func (rq *replicateQueue) Tick(ctx context.Context, tick time.Time, s state.Stat
159
159
}
160
160
161
161
rq .next , rq .lastSyncChangeID = pushReplicateChange (
162
- ctx , change , repl , tick , rq .settings .ReplicaChangeDelayFn (), rq .baseQueue .stateChanger , rq .as )
162
+ ctx , change , repl , tick , rq .settings .ReplicaChangeDelayFn (), rq .baseQueue .stateChanger , rq .as , "replicate queue" )
163
163
}
164
164
165
165
rq .lastTick = tick
@@ -173,6 +173,7 @@ func pushReplicateChange(
173
173
delayFn func (int64 , bool ) time.Duration ,
174
174
stateChanger state.Changer ,
175
175
as * mmaprototypehelpers.AllocatorSync ,
176
+ queueName string ,
176
177
) (time.Time , mmaprototypehelpers.SyncChangeID ) {
177
178
var stateChange state.Change
178
179
var changeID mmaprototypehelpers.SyncChangeID
@@ -212,6 +213,7 @@ func pushReplicateChange(
212
213
repl .StoreID (), /* leaseholder */
213
214
)
214
215
}
216
+ log .VEventf (ctx , 1 , "pushing state change for range=%s, details=%s changeIDs=%v coming from %s" , repl .rng , op .Details , changeID , queueName )
215
217
stateChange = & state.ReplicaChange {
216
218
RangeID : state .RangeID (change .Replica .GetRangeID ()),
217
219
Changes : op .Chgs ,
0 commit comments