We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 034a0b8 commit b30d6beCopy full SHA for b30d6be
src/riak_core_connection_mgr.erl
@@ -588,12 +588,13 @@ locate_endpoints({Type, Name}, Strategy, Locators) ->
588
-spec fail_endpoint(ip_addr(), term(), proto_id(), #state{}) -> #state{}.
589
fail_endpoint(Addr, Reason, ProtocolId, State) ->
590
%% update the stats module
591
- Stat = {conn_error, reason_to_atom(Reason)},
+ Err = reason_to_atom(Reason),
592
+ Stat = {conn_error, Err},
593
riak_core_connection_mgr_stats:update(Stat, Addr, ProtocolId),
594
%% update the endpoint
595
Fun = fun(EP=#ep{backoff_delay = Backoff, failures = Failures}) ->
596
erlang:send_after(Backoff, self(), {backoff_timer, Addr}),
- EP#ep{failures = orddict:update_counter(Reason, 1, Failures),
597
+ EP#ep{failures = orddict:update_counter(Err, 1, Failures),
598
nb_failures = EP#ep.nb_failures + 1,
599
backoff_delay = increase_backoff(Backoff),
600
last_fail_time = os:timestamp(),
0 commit comments