Skip to content

Commit 93245c2

Browse files
committed
Use same timeout in Ra than in Khepri
1 parent c0e5eff commit 93245c2

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,8 @@ remove_reachable_member(NodeToRemove) ->
375375
remove_down_member(NodeToRemove) ->
376376
ServerRef = khepri_cluster:node_to_member(?STORE_ID, node()),
377377
ServerId = khepri_cluster:node_to_member(?STORE_ID, NodeToRemove),
378-
Ret = ra:remove_member(ServerRef, ServerId),
378+
Timeout = khepri:get_default_timeout(),
379+
Ret = ra:remove_member(ServerRef, ServerId, Timeout),
379380
case Ret of
380381
{ok, _, _} ->
381382
?LOG_DEBUG(
@@ -460,9 +461,10 @@ transfer_leadership0([Destination | TransferCandidates]) ->
460461
rabbit_log:info("Khepri clustering: transferring leadership to node ~p", [Destination]),
461462
case ra_leaderboard:lookup_leader(?STORE_ID) of
462463
{Name, Node} = Id when Node == node() ->
463-
case ra:transfer_leadership(Id, {Name, Destination}) of
464+
Timeout = khepri:get_default_timeout(),
465+
case ra:transfer_leadership(Id, {Name, Destination}, Timeout) of
464466
ok ->
465-
case ra:members(Id) of
467+
case ra:members(Id, Timeout) of
466468
{_, _, {_, NewNode}} ->
467469
rabbit_log:info("Khepri clustering: successfully transferred leadership to node ~p", [Destination]),
468470
{ok, NewNode};

0 commit comments

Comments
 (0)