Packages
otpbp
4.67.2
7.18.0
7.16.1
7.15.0
7.14.0
7.13.0
7.12.0
7.11.0
7.10.2
7.9.3
7.9.2
7.9.1
7.8.7
7.8.6
7.8.5
7.8.4
7.7.1
7.7.0
7.6.3
7.6.2
7.6.1
7.6.0
7.5.1
7.5.0
7.4.0
7.3.4
7.3.3
7.3.2
7.3.1
7.3.0
7.2.0
7.1.1
7.1.0
7.0.4
7.0.3
7.0.2
7.0.1
6.26.0
6.25.0
6.24.0
6.23.0
6.22.2
6.21.3
6.21.2
6.21.1
6.20.2
6.19.1
6.19.0
6.18.3
6.18.2
6.18.1
6.18.0
6.17.1
6.17.0
6.16.0
6.15.4
6.15.3
6.15.2
6.15.1
6.15.0
6.14.0
6.13.5
6.13.4
6.13.3
6.13.2
6.13.1
6.13.0
6.12.0
6.11.2
6.11.1
6.10.0
6.9.2
6.9.1
6.9.0
6.8.0
6.7.1
6.7.0
6.6.4
6.6.3
6.6.2
6.6.1
6.6.0
6.5.0
6.4.0
6.3.3
6.3.2
6.3.1
6.3.0
6.2.1
6.2.0
6.1.0
6.0.0
5.39.0
5.38.0
5.37.0
5.36.0
5.35.2
5.34.3
5.34.2
5.34.1
5.33.1
5.32.1
5.32.0
5.31.3
5.31.2
5.31.1
5.31.0
5.30.1
5.30.0
5.29.0
5.28.4
5.28.3
5.28.2
5.28.1
5.28.0
5.27.0
5.26.5
5.26.4
5.26.3
5.26.2
5.26.1
5.26.0
5.25.0
5.24.2
5.24.1
5.23.0
5.22.2
5.22.1
5.22.0
5.21.0
5.20.1
5.20.0
5.19.4
5.19.3
5.19.2
5.19.1
5.19.0
5.18.0
5.17.0
5.16.3
5.16.1
5.16.0
5.15.1
5.15.0
5.14.0
5.13.1
5.13.0
5.12.1
5.12.0
5.11.2
5.11.1
5.10.1
5.10.0
5.9.0
5.8.0
5.7.0
5.6.1
5.6.0
5.5.0
5.4.2
5.4.1
5.4.0
5.3.0
5.2.2
5.2.1
5.2.0
5.1.2
5.1.1
4.79.0
4.78.0
4.77.0
4.76.2
4.75.3
4.75.2
4.75.1
4.74.0
4.73.1
4.73.0
4.72.3
4.72.2
4.72.1
4.72.0
4.71.1
4.71.0
4.70.0
4.69.4
4.69.3
4.69.2
4.69.1
4.69.0
4.68.0
4.67.5
4.67.4
4.67.3
4.67.2
4.67.0
4.66.0
4.65.2
4.65.1
4.64.0
4.63.2
4.63.1
4.63.0
4.62.0
4.61.1
4.61.0
4.60.4
4.60.3
4.60.2
4.60.1
4.60.0
4.59.0
4.58.0
4.57.2
4.57.1
4.57.0
4.56.2
4.56.1
4.56.0
4.55.0
4.54.0
4.53.0
4.52.1
4.52.0
4.51.3
4.51.2
4.51.0
4.50.0
4.49.3
4.49.2
OTP backports
Current section
Files
Jump to
Current section
Files
src/otpbp_diameter_service.erl
-module(otpbp_diameter_service).
-ifndef(HAVE_diameter_service__which_connections_0).
% OTP 27.0
-export([which_connections/0]).
-endif.
-ifndef(HAVE_diameter_service__which_connections_1).
% OTP 27.0
-export([which_connections/1]).
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_0).
% OTP 27.0
-export([which_watchdogs/0]).
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_1).
% OTP 27.0
-export([which_watchdogs/1]).
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_0).
-ifdef(HAVE_diameter_service__which_watchdogs_1).
-import(diameter_service, [which_watchdogs/1]).
-endif.
-endif.
-ifndef(HAVE_diameter_service__which_connections_0).
-ifdef(HAVE_diameter_service__which_connections_1).
-import(diameter_service, [which_connections/1]).
-endif.
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_1).
-ifndef(NEED_record_watchdog).
-define(NEED_record_watchdog, true).
-endif.
-endif.
-ifndef(HAVE_diameter_service__which_connections_1).
-ifndef(NEED_record_watchdog).
-define(NEED_record_watchdog, true).
-endif.
-endif.
-ifndef(HAVE_diameter_service__which_connections_0).
which_connections() -> which_connections([SvcName || {SvcName, _} <- diameter_service:services()], []).
which_connections([], Acc) -> lists:reverse(Acc);
which_connections([SvcName|Services], Acc) ->
which_connections(Services,
case which_connections(SvcName) of
[] -> Acc;
Conns -> [{SvcName, Conns}|Acc]
end).
-endif.
-ifdef(NEED_record_watchdog).
-include_lib("diameter/include/diameter.hrl").
-define(WD_INITIAL, initial).
-define(WD_OKAY, okay).
-define(WD_SUSPECT, suspect).
-define(WD_DOWN, down).
-define(WD_REOPEN, reopen).
-type wd_state() :: ?WD_INITIAL | ?WD_OKAY | ?WD_SUSPECT | ?WD_DOWN | ?WD_REOPEN.
-type match(T) :: T | '_' | '$1' | '$2'.
-record(watchdog, {pid :: match(pid()) | undefined,
type :: match(connect | accept),
ref :: match(reference()),
options :: match([diameter:transport_opt()]),
state = ?WD_INITIAL :: match(wd_state()),
started = diameter_lib:now(),
peer = false :: match(boolean() | pid())}).
-endif.
-ifndef(HAVE_diameter_service__which_connections_1).
which_connections(SvcName) ->
case ets:lookup(diameter_service, SvcName) of
[S] when element(1, S) =:= state ->
case element(case element(8, S) of
M when not M; is_pid(M) -> 6;
_ -> 9 % OTP < 20.0
end,
S) of
{PT, _, _} -> connections_info(element(5, S), PT);
_ -> []
end;
[S] ->
case tuple_to_list(S) of
[state, _, _, WDT, {PT, _, _}|_] -> connections_info(WDT, PT);
_ -> []
end;
[] -> []
end.
-record(peer, {pid :: pid(),
apps :: match([{0..16#FFFFFFFF, diameter:app_alias()}] | [diameter:app_alias()]),
caps :: match(#diameter_caps{}),
started = diameter_lib:now(),
watchdog :: match(pid()|undefined)}).
connections_info(WDT, PT) ->
try ets:tab2list(WDT) of
L -> connections_info(PT, L, [])
catch
error: badarg -> []
end.
connections_info(_PT, [], Acc) -> lists:reverse(Acc);
connections_info(PT, [WD|WDs], Acc) -> connections_info(PT, WDs, [connection_info(PT, WD)|Acc]).
-compile({inline, connection_info/2}).
connection_info(PT, #watchdog{pid = Pid, type = Type, ref = Ref, state = State, started = Started, peer = TPid}) ->
connection_info(PT, TPid, State,
#{wd => #{ref => Ref, pid => Pid, type => Type, state => State,
uptime => diameter_lib:now_diff(Started)}}).
-compile({inline, connection_info/4}).
connection_info(PT, TPid, State, Info) when is_pid(TPid), State =/= ?WD_DOWN ->
try ets:lookup(PT, TPid) of
[#peer{pid = PPid, started = Started}] -> connection_info(PPid, Started, Info);
[] -> Info
catch
error: badarg -> []
end;
connection_info(_PT, _PPid, _State, Info) -> Info.
-compile({inline, connection_info/3}).
connection_info(PPid, Started, Info) ->
Uptime = diameter_lib:now_diff(Started),
{_, PD} = process_info(PPid, dictionary),
{_, {TPid, {_Type, TMod, _Cfg}}} = lists:keyfind({diameter_peer_fsm, start}, 1, PD),
{_, TD} = process_info(TPid, dictionary),
{_, Data} = lists:keyfind({TMod, info}, 1, TD),
try TMod:info(Data) of
TInfo ->
Info#{peer => #{pid => PPid, uptime => Uptime},
sockname => proplists:get_value(socket, TInfo),
peername => proplists:get_value(peer, TInfo)}
catch
_:_ -> Info#{peer => #{pid => PPid, uptime => Uptime}}
end.
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_0).
which_watchdogs() -> which_watchdogs(diameter_service:services(), []).
which_watchdogs([], Acc) -> lists:flatten(lists:reverse(Acc));
which_watchdogs([{SvcName, _}|Services], Acc) ->
which_watchdogs(Services,
case which_watchdogs(SvcName) of
WDs when is_list(WDs) -> [[WD#{service => SvcName} || WD <- WDs]|Acc];
undefined -> Acc
end).
-endif.
-ifndef(HAVE_diameter_service__which_watchdogs_1).
which_watchdogs(SvcName) ->
case ets:lookup(diameter_service, SvcName) of
[S] when element(1, S) =:= state ->
lists:map(fun(#watchdog{pid = Pid, type = Type, ref = Ref, state = State, started = Started, peer = Peer}) ->
#{pid => Pid, ref => Ref, type => Type, state => State,
uptime => diameter_lib:now_diff(Started), peer => Peer}
end,
ets:tab2list(element(5, S)));
[] -> undefined
end.
-endif.