1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
% Osmocom adaptor to interface the IPA core with osmo_sccp
% (C) 2011 by Harald Welte <laforge@gnumonks.org>
%
% All Rights Reserved
%
% This program is free software; you can redistribute it and/or modify
% it under the terms of the GNU Affero General Public License as
% published by the Free Software Foundation; either version 3 of the
% License, or (at your option) any later version.
%
% This program is distributed in the hope that it will be useful,
% but WITHOUT ANY WARRANTY; without even the implied warranty of
% MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
% GNU General Public License for more details.
%
% You should have received a copy of the GNU Affero General Public License
% along with this program. If not, see <http://www.gnu.org/licenses/>.
-module(sccp_link_ipa_client).
-author('Harald Welte <laforge@gnumonks.org>').
-behavior(gen_server).
-include_lib("osmo_ss7/include/osmo_util.hrl").
%-include_lib("osmo_ss7/include/ipa.hrl").
-include_lib("osmo_ss7/include/sccp.hrl").
-include("osmo_sccp.hrl").
-export([start_link/1, init/1]).
-export([handle_cast/2]).
-record(loop_dat, {
ipa_pid,
link
}).
start_link(Args) ->
gen_server:start_link(?MODULE, Args, []).
init(L = #sigtran_link{type = ipa_client, name = Name, linkset_name = LinksetName,
sls = Sls, local = Local, remote = Remote}) ->
#sigtran_peer{ip = LocalIp, port = LocalPort} = Local,
#sigtran_peer{ip = RemoteIp, port = RemotePort} = Remote,
% start the IPA link to the SG
Opts = [{user_pid, self()}, {sctp_remote_ip, RemoteIp},
{sctp_remote_port, RemotePort}, {sctp_local_port, LocalPort},
{user_fun, fun ipa_tx_to_user/2}, {user_args, self()}],
{ok, IpaPid} = ipa_core:start_link(Opts),
% FIXME: register this link with SCCP_SCRC
ok = sccp_link:register_link(LinksetName, Sls, Name),
{ok, #loop_dat{ipa_pid = IpaPid, link = L}}.
% % instantiate SCCP routing instance
% {ok, ScrcPid} = sccp_scrc:start_link([{mtp_tx_action, {callback_fn, fun scrc_tx_to_mtp/2, M3uaPid}}]),
% loop(#loop_dat{ipa_pid = M3uaPid, scrc_pid = ScrcPid}).
set_link_state(#sigtran_link{linkset_name = LinksetName, sls = Sls}, State) ->
ok = sccp_links:set_link_state(LinksetName, Sls, State).
scrc_tx_to_mtp(Prim, Args) ->
M3uaPid = Args,
gen_fsm:send_event(M3uaPid, Prim).
% Callback that we pass to the ipa_core, which it will call when it wants to
% send a primitive up the stack to SCCP
ipa_tx_to_user(Prim, Args) ->
UserPid = Args,
gen_server:cast(UserPid, Prim).
% This is what we receive from ipa_tx_to_user/2
handle_cast(#primitive{subsystem = 'M', gen_name = 'SCTP_ESTABLISH', spec_name = confirm}, L) ->
io:format("~p: SCTP_ESTABLISH.ind -> ASP_UP.req~n", [?MODULE]),
gen_fsm:send_event(L#loop_dat.ipa_pid, osmo_util:make_prim('M','ASP_UP',request)),
{noreply, L};
handle_cast(#primitive{subsystem = 'M', gen_name = 'ASP_UP', spec_name = confirm}, L) ->
io:format("~p: ASP_UP.ind -> ASP_ACTIVE.req~n", [?MODULE]),
set_link_state(L, up),
gen_fsm:send_event(L#loop_dat.ipa_pid, osmo_util:make_prim('M','ASP_ACTIVE',request)),
{noreply, L};
handle_cast(#primitive{subsystem = 'M', gen_name = 'ASP_ACTIVE', spec_name = confirm}, L) ->
io:format("~p: ASP_ACTIVE.ind - M3UA now active and ready~n", [?MODULE]),
set_link_state(L, active),
%tx_sccp_udt(L#loop_dat.scrc_pid),
{noreply, L};
handle_cast(#primitive{subsystem = 'M', gen_name = 'ASP_DOWN'}, L) ->
io:format("~p: ASP_DOWN.ind~n", [?MODULE]),
set_link_state(L, down),
{noreply, L};
handle_cast(#primitive{subsystem = 'M', gen_name = 'ASP_INACTIVE'}, L) ->
io:format("~p: ASP_DOWN.ind~n", [?MODULE]),
set_link_state(L, inactive),
{noreply, L};
handle_cast(P, L) ->
io:format("~p: Ignoring M3UA prim ~p~n", [?MODULE, P]),
{noreply, L}.
tx_sccp_udt(ScrcPid) ->
CallingP = #sccp_addr{ssn = ?SCCP_SSN_MSC, point_code = osmo_util:pointcode2int(itu, {1,2,2})},
CalledP = #sccp_addr{ssn = ?SCCP_SSN_HLR, point_code = osmo_util:pointcode2int(itu, {1,1,1})},
Data = <<1,2,3,4>>,
Opts = [{protocol_class, 0}, {called_party_addr, CalledP},
{calling_party_addr, CallingP}, {user_data, Data}],
io:format("~p: Sending N-UNITDATA.req to SCRC~n", [?MODULE]),
gen_fsm:send_event(ScrcPid, osmo_util:make_prim('N','UNITDATA',request,Opts)).
|
