Add PCAP utility routine for testing
diff --git a/ebin/osmo_ss7.app b/ebin/osmo_ss7.app
index 8206b5b..5d1a2b1 100644
--- a/ebin/osmo_ss7.app
+++ b/ebin/osmo_ss7.app
@@ -7,7 +7,8 @@
isup_codec,
m2ua_codec,
mtp3_codec,
- sccp_codec, sccp_scoc, sccp_scrc
+ sccp_codec, sccp_scoc, sccp_scrc,
+ osmo_ss7_pcap
]},
{registered, []},
{applications, []},
diff --git a/rebar.config b/rebar.config
index 10d55cf..e6f23ee 100644
--- a/rebar.config
+++ b/rebar.config
@@ -1 +1,4 @@
{sub_dirs, ["rel"]}.
+{deps, [
+ {epcap, "0.03", {git, "git://git.osmocom.org/erlang/epcap", "master"}}
+ ]}.
diff --git a/src/osmo_ss7_pcap.erl b/src/osmo_ss7_pcap.erl
new file mode 100644
index 0000000..0b23464
--- /dev/null
+++ b/src/osmo_ss7_pcap.erl
@@ -0,0 +1,81 @@
+% MGW Nat testing code
+
+% (C) 2011 by Harald Welte <laforge@gnumonks.org>
+% (C) 2011 OnWaves
+%
+% 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(osmo_ss7_pcap).
+-author("Harald Welte <laforge@gnumonks.org>").
+-export([pcap_apply/3]).
+
+-define(NODEBUG, 1).
+
+-include_lib("eunit/include/eunit.hrl").
+-include_lib("epcap/include/epcap_net.hrl").
+
+pcap_apply(File, Filter, Args) ->
+ epcap:start([{file, File}, {filter, Filter}]),
+ loop(Args).
+
+loop(Args) ->
+ receive
+ [{pkthdr, {_,_,_,{datalink,Datalink}}}, {packet, Packet}] ->
+ Decaps = epcap_net:decapsulate_dlt(Datalink, Packet),
+ handle_pkt_cb(Decaps, Args),
+ loop(Args);
+ {epcap, eof} ->
+ ?debugFmt("EOF from PCAP~n", []),
+ epcap:stop();
+ Default ->
+ ?debugFmt("Unknown ~p from PCAP~n", [Default])
+ end.
+
+
+handle_pkt_cb([Ether, IP, Hdr, Payload], Args) ->
+ ?debugFmt("~p:~n ~p/~p~n", [IP, Hdr, Payload]),
+ case Hdr of
+ #sctp{chunks = Chunks} ->
+ handle_sctp_chunks(Chunks, [Ether, IP, Hdr], Args);
+ _ ->
+ ok
+ end.
+
+handle_sctp_chunks([], _Path, _Args) ->
+ ok;
+handle_sctp_chunks([Head|Tail], Path, Args) ->
+ RewriteFn = proplists:get_value(rewrite_fn, Args),
+ case Head of
+ #sctp_chunk{type = 0, payload=#sctp_chunk_data{ppi=2, data=Data}} ->
+ %mgw_nat:mangle_rx_data(l, from_stp, Data, fun handle_rewrite_cb/5);
+ put(rewrite_cb, RewriteFn),
+ shim_rw_actor(sctp, from_msc, Path, 2, Data);
+ _ ->
+ ok
+ end,
+ handle_sctp_chunks(Tail, Path, Args).
+
+shim_rw_actor(Proto, From, Path, MsgType, Msg) ->
+ ?debugFmt(" IN:~p:~p:~p~n", [Proto, From, Msg]),
+ Fn = get(rewrite_cb),
+ MsgOut = Fn(Proto, From, Path, MsgType, Msg),
+ case MsgOut of
+ Msg ->
+ MsgOut;
+ _ ->
+ %io:format("OUT:~p:~p:~p~n", [Proto, From, MsgOut]),
+ MsgOut
+ end.