Skip to content

Commit 329d6f5

Browse files
Merge pull request #14085 from rabbitmq/mergify/bp/v4.1.x/pr-14083
Return error if stream leader is undefined in stream manager (backport #14083)
2 parents 973e865 + 76461ea commit 329d6f5

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

deps/rabbitmq_stream/src/rabbit_stream_manager.erl

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ lookup_leader(VirtualHost, Stream) ->
203203
{ok, LeaderPid};
204204
false ->
205205
case leader_from_members(Q) of
206-
{ok, Pid} ->
206+
{ok, Pid} when is_pid(Pid) ->
207207
{ok, Pid};
208208
_ ->
209209
{error, not_available}
@@ -856,7 +856,7 @@ leader_from_members(Q) ->
856856
{error, not_found}
857857
end.
858858

859-
process_alive(Pid) ->
859+
process_alive(Pid) when is_pid(Pid) ->
860860
CurrentNode = node(),
861861
case node(Pid) of
862862
nonode@nohost ->
@@ -870,7 +870,9 @@ process_alive(Pid) ->
870870
_ ->
871871
false
872872
end
873-
end.
873+
end;
874+
process_alive(_) ->
875+
false.
874876

875877
is_stream_queue(Q) ->
876878
case amqqueue:get_type(Q) of

0 commit comments

Comments
 (0)