Skip to content

Commit 2a27132

Browse files
Merge pull request #9794 from rabbitmq/qq-open-files-fix
Fix quorum queue open files info
2 parents be450bd + 0693d64 commit 2a27132

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1615,8 +1615,13 @@ open_files(Name) ->
16151615
case whereis(Name) of
16161616
undefined ->
16171617
{node(), 0};
1618-
Pid ->
1619-
{node(), ets_lookup_element(ra_open_file_metrics, Pid, 2, 0)}
1618+
_ ->
1619+
case ra_counters:counters({Name, node()}, [open_segments]) of
1620+
#{open_segments := Num} ->
1621+
{node(), Num};
1622+
_ ->
1623+
{node(), 0}
1624+
end
16201625
end.
16211626

16221627
leader(Q) when ?is_amqqueue(Q) ->

0 commit comments

Comments
 (0)