aboutsummaryrefslogtreecommitdiffstats
path: root/lib/diameter/src/base
diff options
context:
space:
mode:
authorAnders Svensson <[email protected]>2017-09-09 20:37:56 +0200
committerAnders Svensson <[email protected]>2017-09-09 20:37:56 +0200
commit254185ebde7aff22a168aa6d4e32e5f943da3f09 (patch)
treeb354ca79afea9342139c0f25c165b4ad639c20a1 /lib/diameter/src/base
parent085e80ea7d5b56a8603f19ece0fe8e0c506b63da (diff)
parent97d9651c856960cf1ff62bded434efcc384a1f77 (diff)
downloadotp-254185ebde7aff22a168aa6d4e32e5f943da3f09.tar.gz
otp-254185ebde7aff22a168aa6d4e32e5f943da3f09.tar.bz2
otp-254185ebde7aff22a168aa6d4e32e5f943da3f09.zip
Merge branch 'anders/diameter/performance/OTP-14521' into maint
* anders/diameter/performance/OTP-14521: Simplify implementation in diameter_reg (take 2)
Diffstat (limited to 'lib/diameter/src/base')
-rw-r--r--lib/diameter/src/base/diameter_reg.erl14
1 files changed, 6 insertions, 8 deletions
diff --git a/lib/diameter/src/base/diameter_reg.erl b/lib/diameter/src/base/diameter_reg.erl
index 9ada36acc5..bd5db54a5c 100644
--- a/lib/diameter/src/base/diameter_reg.erl
+++ b/lib/diameter/src/base/diameter_reg.erl
@@ -340,24 +340,22 @@ notify(Op, {_,_} = Rec, #state{notify = Dict} = S) ->
notify(Op, {_, Pid} = Rec, Pat, Rcvrs, Dict) ->
case lists:member(Rec, match(Pat, Pid)) of
true ->
- reset(Pat, Dict, lists:foldr(fun(P,A) -> send(P, Op, Rec, A) end,
- [],
- Rcvrs));
+ reset(Pat, Dict, [P || P <- Rcvrs, send(P, Op, Rec)]);
false ->
Dict
end.
-%% send/4
+%% send/3
-send([Pid | T] = Rcvr, Op, Rec, Acc) ->
+send([Pid | T], Op, Rec) ->
Pid ! {T, Op, Rec},
- [Rcvr | Acc];
+ true;
%% No processes wait on remove: they receive notification immediately
%% or at add, by construction.
-send({_,_} = From, add, Rec, Acc) ->
+send({_,_} = From, add, Rec) ->
gen_server:reply(From, [Rec]),
- Acc.
+ false.
%% down/2