Skip to content

Commit 0158cbb

Browse files
committed
Warn on undefined remote uid while recovering
1 parent 43cebed commit 0158cbb

File tree

1 file changed

+16
-4
lines changed

1 file changed

+16
-4
lines changed

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -737,10 +737,22 @@ repair_amqqueue_nodes(Q0) ->
737737
false ->
738738
TS0#{nodes => RaNodes};
739739
true ->
740-
RaUids = maps:from_list([{N, erpc:call(N, ra_directory, uid_of,
741-
[?RA_SYSTEM, Name],
742-
?RPC_TIMEOUT)}
743-
|| N <- RaNodes]),
740+
RaUidsList = [begin
741+
Uid = erpc:call(N, ra_directory, uid_of,
742+
[?RA_SYSTEM, Name],
743+
?RPC_TIMEOUT),
744+
case Uid of
745+
undefined ->
746+
?LOG_WARNING("Unexpected undefined uuid from node ~p for quorum queue ~ts during repair_amqqueue_nodes",
747+
[N, rabbit_misc:rs(QName)]);
748+
_ ->
749+
ok
750+
end,
751+
{N, Uid}
752+
end
753+
|| N <- RaNodes],
754+
755+
RaUids = maps:from_list(RaUidsList),
744756
TS0#{nodes => RaUids}
745757
end,
746758
amqqueue:set_type_state(Q, TS)

0 commit comments

Comments
 (0)