Reset deferred queue length on change (#1868)

basho · Jul 25, 2023 · 960374a · 960374a
1 parent 44bfdc4
commit 960374a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/riak_kv_replrtq_snk.erl b/src/riak_kv_replrtq_snk.erl
@@ -349,6 +349,7 @@ handle_call({worker_count, QueueN, WorkerCount, PerPeerLimit}, _From, State) ->
  SinkWork0 =
  SinkWork#sink_work{work_queue = WorkQueue,
  minimum_queue_length = QueueLength,
+ deferred_queue_length = 0,
  max_worker_count = WorkerCount},
  W0 =
  lists:keyreplace(QueueN, 1, State#state.work,