add sccp_ssn dumper module, dump messages of specified subsystem

ebin/osmo_sccp.app

@@ -7,7 +7,8 @@
 			sccp_routing,
 			sccp_scrc,
 			sccp_scoc,
-			sccp_user
+			sccp_user,
+			sccp_ssn_dump
 		]},
 	 {registered, [osmo_sccp_app]},
 	 {mod, {osmo_sccp_app, []}},

src/sccp_ssn_dump.erl

@@ -0,0 +1,51 @@
+% SCCP subsystem for dumping SCCP messages (testing)
+
+% (C) 2010-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_ssn_dump).
+-behaviour(gen_server).
+-export([start_link/1, init/1, handle_info/2]).
+
+-include_lib("osmo_ss7/include/osmo_util.hrl").
+-include_lib("osmo_ss7/include/sccp.hrl").
+
+-record(loop_dat, {
+	ssns
+}).
+
+start_link(Ssns) ->
+	gen_server:start_link(sccp_ssn_dump, [Ssns], []).
+
+init(Ssn) when is_tuple(Ssn) ->
+	init([Ssn]);
+init(Ssns) when is_list(Ssns) ->
+	bind_ssns(Ssns),
+	{ok, idle, #loop_dat{ssns = Ssns}}.
+
+bind_ssns([]) ->
+	ok;
+bind_ssns([{Ssn, Pc}|Tail]) ->
+	io:format("binding ~p ~p~n", [Ssn, Pc]),
+	ok = sccp_user:bind_ssn(Ssn, Pc),
+	bind_ssns(Tail).
+
+
+handle_info({sccp, Prim}, LoopDat) ->
+	io:format("sccp_ssn_dump in: ~p~n", [Prim]),
+	{noreply, LoopDat}.

src/sccp_user.erl

@@ -32,7 +32,8 @@
 -export([start_link/0]).
 
 % client functions, may internally talk to our sccp_user server
--export([bind_ssn/2, unbind_ssn/2, pid_for_ssn/2, local_ssn_avail/2]).
+-export([bind_ssn/2, unbind_ssn/2, pid_for_ssn/2, local_ssn_avail/2,
+	 dump/0]).
 
 -record(scu_state, {
 	user_table
@@ -80,6 +81,18 @@ local_ssn_avail(Ssn, Pc) ->
 		false
 	end.
 
+dump() ->
+	List = ets:tab2list(sccp_user_tbl),
+	io:format("Registered SCCP subsystems:~n"),
+	dump(List).
+
+dump([]) ->
+	ok;
+dump([Head|Tail]) when is_record(Head, scu_record) ->
+	#scu_record{ssn_pc = {Ssn, Pc}, user_pid = Pid} = Head,
+	io:format("  Pointcode ~p, SSN ~p, Pid ~p~n", [Pc,Ssn,Pid]),
+	dump(Tail).
+
 % server side code 
 
 % bind a {SSN, PC} tuple to the pid of the caller