Skip to content

Commit 2494f66

Browse files
author
Alex Valiushko
committed
better external API
1 parent 6619ddf commit 2494f66

File tree

2 files changed

+7
-12
lines changed

2 files changed

+7
-12
lines changed

src/ra.erl

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,6 @@
5959
%% membership changes
6060
add_member/2,
6161
add_member/3,
62-
maybe_add_member/2,
63-
maybe_add_member/3,
6462
remove_member/2,
6563
remove_member/3,
6664
leave_and_terminate/3,
@@ -572,23 +570,20 @@ add_member(ServerLoc, ServerId) ->
572570
%% @see add_member/2
573571
%% @end
574572
-spec add_member(ra_server_id() | [ra_server_id()],
575-
ra_server_id(), timeout()) ->
573+
ra_server_id() | {maybe, ra_server_id()},
574+
timeout()) ->
576575
ra_cmd_ret() |
577576
{error, already_member} |
578577
{error, cluster_change_not_permitted}.
578+
add_member(ServerLoc, {maybe, ServerId}, Timeout) ->
579+
ra_server_proc:command(ServerLoc,
580+
{'$ra_maybe_join', ServerId, after_log_append},
581+
Timeout);
579582
add_member(ServerLoc, ServerId, Timeout) ->
580583
ra_server_proc:command(ServerLoc,
581584
{'$ra_join', ServerId, after_log_append},
582585
Timeout).
583586

584-
maybe_add_member(ServerLoc, ServerId) ->
585-
maybe_add_member(ServerLoc, ServerId, ?DEFAULT_TIMEOUT).
586-
maybe_add_member(ServerLoc, ServerId, Timeout) ->
587-
ra_server_proc:command(ServerLoc,
588-
{'$ra_maybe_join', ServerId, after_log_append},
589-
Timeout).
590-
591-
592587
%% @doc Removes a server from the cluster's membership configuration.
593588
%% This function returns after appending a cluster membership change
594589
%% command to the log.

test/ra_voter_SUITE.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ start_and_join({ClusterName, _} = ServerRef, {_, _} = New) ->
102102
ok.
103103

104104
start_and_maybe_join({ClusterName, _} = ServerRef, {_, _} = New) ->
105-
{ok, _, _} = ra:maybe_add_member(ServerRef, New),
105+
{ok, _, _} = ra:add_member(ServerRef, {maybe, New}),
106106
ok = ra:start_server(default, ClusterName, New, add_machine(), [ServerRef]),
107107
ok.
108108

0 commit comments

Comments
 (0)