Skip to content

Commit efb2ade

Browse files
patelarjavmeta-codesync[bot]
authored andcommitted
Add telemetry for priority commits
Summary: As title. Reviewed By: jaher Differential Revision: D85261297 fbshipit-source-id: 3de10296c3ca3ca8340234b983ebd6baee6a91cf
1 parent cd7fe39 commit efb2ade

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/wa_raft_queue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -229,6 +229,7 @@ registered_name(Table, Partition) ->
229229
commit_started(#queues{counters = Counters} = Queues, Priority) ->
230230
case commit_queue_full(Queues, Priority) of
231231
true ->
232+
?RAFT_COUNT({'raft.acceptor.commit.queue.full', Priority}),
232233
commit_queue_full;
233234
false ->
234235
case apply_queue_full(Queues) of

src/wa_raft_server.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1218,7 +1218,7 @@ leader(
12181218
) ->
12191219
% No size limit is imposed here as the pending queue cannot grow larger
12201220
% than the limit on the number of pending commits.
1221-
?RAFT_COUNT('raft.commit'),
1221+
?RAFT_COUNT({'raft.commit', Priority}),
12221222
State1 = case Priority of
12231223
high ->
12241224
State0#raft_state{pending_high = [{From, Op} | PendingHigh]};

0 commit comments

Comments
 (0)