@@ -375,7 +375,8 @@ remove_reachable_member(NodeToRemove) ->
375375remove_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