aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAnders Svensson <[email protected]>2013-02-08 01:38:25 +0100
committerAnders Svensson <[email protected]>2013-02-08 19:28:47 +0100
commit63d57f401e9e9a8ed376934581f42793d00e32cc (patch)
tree30274122019f27230fa01fb3483f0bde210d032f
parente49e7acc2af99bbd06fa028168f9e1549cc5c658 (diff)
downloadotp-63d57f401e9e9a8ed376934581f42793d00e32cc.tar.gz
otp-63d57f401e9e9a8ed376934581f42793d00e32cc.tar.bz2
otp-63d57f401e9e9a8ed376934581f42793d00e32cc.zip
Tweak service interface towards diameter_peer
-rw-r--r--lib/diameter/src/base/diameter_peer.erl9
-rw-r--r--lib/diameter/src/base/diameter_service.erl11
2 files changed, 11 insertions, 9 deletions
diff --git a/lib/diameter/src/base/diameter_peer.erl b/lib/diameter/src/base/diameter_peer.erl
index 25c9eab4cb..20b22c7949 100644
--- a/lib/diameter/src/base/diameter_peer.erl
+++ b/lib/diameter/src/base/diameter_peer.erl
@@ -272,7 +272,7 @@ handle_cast(Msg, State) ->
%% Remote service is distributing a message.
handle_info({notify, SvcName, T}, S) ->
- bang(diameter_service:whois(SvcName), T),
+ diameter_service:notify(SvcName, T),
{noreply, S};
handle_info(Info, State) ->
@@ -304,13 +304,6 @@ code_change(_OldVsn, State, _Extra) ->
ifc_send(Pid, T) ->
Pid ! {diameter, T}.
-%% bang/2
-
-bang(undefined = No, _) ->
- No;
-bang(Pid, T) ->
- Pid ! T.
-
%% call/1
call(Request) ->
diff --git a/lib/diameter/src/base/diameter_service.erl b/lib/diameter/src/base/diameter_service.erl
index a4b788af4e..f1342df16c 100644
--- a/lib/diameter/src/base/diameter_service.erl
+++ b/lib/diameter/src/base/diameter_service.erl
@@ -40,7 +40,7 @@
stop_transport/2]).
%% towards diameter_peer
--export([whois/1]).
+-export([notify/2]).
%% towards diameter_traffic
-export([find_incoming_app/4,
@@ -51,6 +51,7 @@
subscriptions/1,
subscriptions/0,
call_module/3,
+ whois/1,
state/1,
uptime/1]).
@@ -324,6 +325,14 @@ find_incoming_app(PeerT, TPid, Id, Apps) ->
false
end.
+%% ---------------------------------------------------------------------------
+%% # notify/2
+%% ---------------------------------------------------------------------------
+
+notify(SvcName, Msg) ->
+ Pid = whois(SvcName),
+ is_pid(Pid) andalso (Pid ! Msg).
+
%% ===========================================================================
%% ===========================================================================