117 lines
4.5 KiB
Erlang
117 lines
4.5 KiB
Erlang
% Osmocom adaptor to interface the M2UA core with osmo_sccp
|
|
|
|
% (C) 2013 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/>.
|
|
%
|
|
% Additional Permission under GNU AGPL version 3 section 7:
|
|
%
|
|
% If you modify this Program, or any covered work, by linking or
|
|
% combining it with runtime libraries of Erlang/OTP as released by
|
|
% Ericsson on http://www.erlang.org (or a modified version of these
|
|
% libraries), containing parts covered by the terms of the Erlang Public
|
|
% License (http://www.erlang.org/EPLICENSE), the licensors of this
|
|
% Program grant you additional permission to convey the resulting work
|
|
% without the need to license the runtime libraries of Erlang/OTP under
|
|
% the GNU Affero General Public License. Corresponding Source for a
|
|
% non-source form of such a combination shall include the source code
|
|
% for the parts of the runtime libraries of Erlang/OTP used as well as
|
|
% that of the covered work.
|
|
|
|
-module(ss7_link_m2ua).
|
|
-author('Harald Welte <laforge@gnumonks.org>').
|
|
-behavior(gen_server).
|
|
|
|
-include_lib("osmo_ss7/include/osmo_util.hrl").
|
|
-include_lib("osmo_ss7/include/m2ua.hrl").
|
|
-include_lib("osmo_ss7/include/sccp.hrl").
|
|
-include_lib("osmo_ss7/include/osmo_ss7.hrl").
|
|
|
|
-export([start_link/1, init/1]).
|
|
|
|
-export([handle_info/2, terminate/2]).
|
|
|
|
-record(loop_dat, {
|
|
m2ua_pid,
|
|
link
|
|
}).
|
|
|
|
start_link(Args = #sigtran_link{name=LinkName}) ->
|
|
Name = list_to_atom("ss7_link_m2ua_" ++ LinkName),
|
|
gen_server:start_link({local, Name}, ?MODULE, Args, [{debug, [trace]}]).
|
|
|
|
init(L = #sigtran_link{type = m2ua, name = Name, linkset_name = LinksetName,
|
|
sls = Sls, local = Local, remote = Remote, role = Role}) ->
|
|
#sigtran_peer{ip = LocalIp, port = LocalPort} = Local,
|
|
#sigtran_peer{ip = RemoteIp, port = RemotePort} = Remote,
|
|
% start the M2UA link to the SG
|
|
Opts = [{module, sctp_m2ua}, {module_args, [Role]},
|
|
{sctp_role, ss7_links:role2sctp_role(Role)},
|
|
{user_pid, self()}, {sctp_remote_ip, RemoteIp},
|
|
{sctp_remote_port, RemotePort}, {sctp_local_port, LocalPort},
|
|
{sctp_local_ip, LocalIp}],
|
|
{ok, M2uaPid} = sctp_core:start_link(Opts),
|
|
% FIXME: register this link with SCCP_SCRC
|
|
ok = ss7_links:register_link(LinksetName, Sls, Name),
|
|
{ok, #loop_dat{m2ua_pid = M2uaPid, 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{m2ua_pid = M3uaPid, scrc_pid = ScrcPid}).
|
|
|
|
|
|
set_link_state(#sigtran_link{linkset_name = LinksetName, sls = Sls}, State) ->
|
|
ok = ss7_links:set_link_state(LinksetName, Sls, State).
|
|
|
|
scrc_tx_to_mtp(Prim, Args) ->
|
|
M2uaPid = Args,
|
|
gen_fsm:send_event(M2uaPid, Prim).
|
|
|
|
handle_info(P = #primitive{subsystem = 'MTP', gen_name = 'TRANSFER', spec_name = request}, L) ->
|
|
scrc_tx_to_mtp(P, L#loop_dat.m2ua_pid),
|
|
{noreply, L};
|
|
|
|
handle_info(#primitive{subsystem = 'M', gen_name = 'ASP_UP'}, L) ->
|
|
set_link_state(L#loop_dat.link, up),
|
|
{noreply, L};
|
|
handle_info(#primitive{subsystem = 'M', gen_name = 'ASP_ACTIVE'}, L) ->
|
|
set_link_state(L#loop_dat.link, active),
|
|
{noreply, L};
|
|
handle_info(#primitive{subsystem = 'M', gen_name = 'ASP_DOWN'}, L) ->
|
|
set_link_state(L#loop_dat.link, down),
|
|
{noreply, L};
|
|
handle_info(#primitive{subsystem = 'M', gen_name = 'ASP_INACTIVE'}, L) ->
|
|
set_link_state(L#loop_dat.link, up),
|
|
{noreply, L};
|
|
|
|
handle_info(P, L) ->
|
|
io:format("~p: Ignoring M2UA cast ~p~n", [?MODULE, P]),
|
|
{noreply, L}.
|
|
|
|
terminate(Reason, _S) ->
|
|
io:format("terminating ~p with reason ~p", [?MODULE, Reason]),
|
|
ok.
|
|
|
|
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)).
|
|
|