diff options
author | Nick Vatamaniuc <vatamane@gmail.com> | 2021-11-20 01:00:08 -0500 |
---|---|---|
committer | Nick Vatamaniuc <nickva@users.noreply.github.com> | 2021-11-22 17:31:31 -0500 |
commit | b78ccf18cb4ed6e183ed0bf4e5cbe40d7a7dc493 (patch) | |
tree | 82158f0b6c7e97e6955bf0c558aac6eb0329b410 /src/mem3/src/mem3_sync_event.erl | |
parent | 6e87e43fae23647b281ede250ad9f1a68a8f1cde (diff) | |
download | couchdb-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.erl | 21 |
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. |