Skip to content

Commit 3246bcb

Browse files
committed
mirrored_supervisor: Catch timeout from Khepri in hanlde_info/2
1 parent 4f412d8 commit 3246bcb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

deps/rabbit/src/mirrored_supervisor.erl

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -345,7 +345,10 @@ handle_info({'DOWN', _Ref, process, Pid, _Reason},
345345
child_order = ChildOrder}) ->
346346
%% No guarantee pg will have received the DOWN before us.
347347
R = case lists:sort(pg:get_members(Group)) -- [Pid] of
348-
[O | _] -> ChildSpecs = update_all(O, Pid),
348+
[O | _] -> ChildSpecs = case update_all(O, Pid) of
349+
List when is_list(List) -> List;
350+
{error, timeout} -> []
351+
end,
349352
[start(Delegate, ChildSpec)
350353
|| ChildSpec <- restore_child_order(ChildSpecs,
351354
ChildOrder)];

0 commit comments

Comments
 (0)