summaryrefslogtreecommitdiff
path: root/src/mem3/src/mem3_sync_event.erl
diff options
context:
space:
mode:
authorNick Vatamaniuc <vatamane@gmail.com>2021-11-20 01:00:08 -0500
committerNick Vatamaniuc <nickva@users.noreply.github.com>2021-11-22 17:31:31 -0500
commitb78ccf18cb4ed6e183ed0bf4e5cbe40d7a7dc493 (patch)
tree82158f0b6c7e97e6955bf0c558aac6eb0329b410 /src/mem3/src/mem3_sync_event.erl
parent6e87e43fae23647b281ede250ad9f1a68a8f1cde (diff)
downloadcouchdb-b78ccf18cb4ed6e183ed0bf4e5cbe40d7a7dc493.tar.gz
Apply erlfmt formatting to source tree
These exceptions from main were ported over to 3.x ``` --- a/src/chttpd/src/chttpd.erl +++ b/src/chttpd/src/chttpd.erl @@ -491,6 +491,7 @@ extract_cookie(#httpd{mochi_req = MochiReq}) -> end. %%% end hack +%% erlfmt-ignore set_auth_handlers() -> AuthenticationDefault = "{chttpd_auth, cookie_authentication_handler}, ``` ``` --- a/src/couch/src/couch_debug.erl +++ b/src/couch/src/couch_debug.erl @@ -49,6 +49,7 @@ help() -> ]. -spec help(Function :: atom()) -> ok. +%% erlfmt-ignore help(opened_files) -> ```
Diffstat (limited to 'src/mem3/src/mem3_sync_event.erl')
-rw-r--r--src/mem3/src/mem3_sync_event.erl21
1 files changed, 12 insertions, 9 deletions
diff --git a/src/mem3/src/mem3_sync_event.erl b/src/mem3/src/mem3_sync_event.erl
index 7bca23086..ec6debb45 100644
--- a/src/mem3/src/mem3_sync_event.erl
+++ b/src/mem3/src/mem3_sync_event.erl
@@ -14,8 +14,14 @@
-behaviour(gen_event).
-vsn(1).
--export([init/1, handle_event/2, handle_call/2, handle_info/2, terminate/2,
- code_change/3]).
+-export([
+ init/1,
+ handle_event/2,
+ handle_call/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3
+]).
init(_) ->
net_kernel:monitor_nodes(true),
@@ -25,11 +31,9 @@ handle_event({add_node, Node}, State) when Node =/= node() ->
net_kernel:connect_node(Node),
mem3_sync_nodes:add([Node]),
{ok, State};
-
-handle_event({remove_node, Node}, State) ->
+handle_event({remove_node, Node}, State) ->
mem3_sync:remove_node(Node),
{ok, State};
-
handle_event(_Event, State) ->
{ok, State}.
@@ -41,11 +45,9 @@ handle_info({nodeup, Node}, State) ->
Nodes = lists:filter(fun(N) -> lists:member(N, mem3:nodes()) end, Nodes0),
wait_for_rexi(Nodes, 5),
{ok, State};
-
handle_info({nodedown, Node}, State) ->
mem3_sync:remove_node(Node),
{ok, State};
-
handle_info(_Info, State) ->
{ok, State}.
@@ -75,12 +77,13 @@ wait_for_rexi(Waiting, Retries) ->
case length(Up) > 0 of
true ->
mem3_sync_nodes:add(Up);
- false -> ok
+ false ->
+ ok
end,
case length(NotUp) > 0 andalso Retries > 0 of
true ->
timer:sleep(1000),
- wait_for_rexi(NotUp, Retries-1);
+ wait_for_rexi(NotUp, Retries - 1);
false ->
ok
end.