Skip to content

Commit 0d2537a

Browse files
committed
Fix my previous patch
1 parent 7205f29 commit 0d2537a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,7 @@ 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-
Timeout = khepri:get_default_timeout(),
378+
Timeout = khepri_app:get_default_timeout(),
379379
Ret = ra:remove_member(ServerRef, ServerId, Timeout),
380380
case Ret of
381381
{ok, _, _} ->
@@ -461,8 +461,8 @@ transfer_leadership0([Destination | TransferCandidates]) ->
461461
rabbit_log:info("Khepri clustering: transferring leadership to node ~p", [Destination]),
462462
case ra_leaderboard:lookup_leader(?STORE_ID) of
463463
{Name, Node} = Id when Node == node() ->
464-
Timeout = khepri:get_default_timeout(),
465-
case ra:transfer_leadership(Id, {Name, Destination}, Timeout) of
464+
Timeout = khepri_app:get_default_timeout(),
465+
case ra:transfer_leadership(Id, {Name, Destination}) of
466466
ok ->
467467
case ra:members(Id, Timeout) of
468468
{_, _, {_, NewNode}} ->

0 commit comments

Comments
 (0)