aboutsummaryrefslogtreecommitdiffstats
path: root/lib/megaco/test/megaco_call_flow_test.erl
diff options
context:
space:
mode:
Diffstat (limited to 'lib/megaco/test/megaco_call_flow_test.erl')
-rw-r--r--lib/megaco/test/megaco_call_flow_test.erl1767
1 files changed, 1767 insertions, 0 deletions
diff --git a/lib/megaco/test/megaco_call_flow_test.erl b/lib/megaco/test/megaco_call_flow_test.erl
new file mode 100644
index 0000000000..a25a7924e8
--- /dev/null
+++ b/lib/megaco/test/megaco_call_flow_test.erl
@@ -0,0 +1,1767 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 2000-2009. All Rights Reserved.
+%%
+%% The contents of this file are subject to the Erlang Public License,
+%% Version 1.1, (the "License"); you may not use this file except in
+%% compliance with the License. You should have received a copy of the
+%% Erlang Public License along with this software. If not, it can be
+%% retrieved online at http://www.erlang.org/.
+%%
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+%% the License for the specific language governing rights and limitations
+%% under the License.
+%%
+%% %CopyrightEnd%
+%%
+
+%%
+%%----------------------------------------------------------------------
+%% Purpose: Test encoding/decoding of the sample call flows Megaco/H.248
+%%----------------------------------------------------------------------
+%% megaco_call_flow_test:pretty_text().
+%% megaco_call_flow_test:compact_text().
+%% megaco_call_flow_test:bin().
+%% megaco_call_flow_test:asn1_ber().
+%% megaco_call_flow_test:asn1_ber_bin().
+%% megaco_call_flow_test:asn1_per().
+%% megaco_call_flow_test:erl_dist().
+%% megaco_call_flow_test:compressed_erl_dist().
+%% megaco_call_flow_test:gnuplot_gif().
+%% megaco_call_flow_test:gnuplot_size_gif().
+%% megaco_call_flow_test:gnuplot_enc_time_gif().
+%% megaco_call_flow_test:gnuplot_dec_time_gif().
+%% megaco_call_flow_test:gnuplot_code_time_gif().
+%%----------------------------------------------------------------------
+
+-module(megaco_call_flow_test).
+
+-compile(export_all).
+-include_lib("megaco/include/megaco.hrl").
+-include_lib("megaco/include/megaco_message_v1.hrl").
+-include("megaco_test_lib.hrl").
+
+t() -> megaco_test_lib:t(?MODULE).
+t(Case) -> megaco_test_lib:t({?MODULE, Case}).
+
+%% Test server callbacks
+init_per_testcase(Case, Config) ->
+ megaco_test_lib:init_per_testcase(Case, Config).
+
+fin_per_testcase(Case, Config) ->
+ megaco_test_lib:fin_per_testcase(Case, Config).
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% Top test case
+
+all(suite) ->
+ [
+ text,
+ binary
+ ].
+
+text(suite) ->
+ [
+ pretty,
+ compact
+ ].
+
+flex(suite) ->
+ [
+ pretty_flex,
+ compact_flex
+ ].
+
+binary(suite) ->
+ [
+ bin,
+ ber,
+ ber_bin,
+ per
+ ].
+
+pretty(suite) ->
+ [];
+pretty(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ pretty_text().
+
+compact(suite) ->
+ [];
+compact(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ compact_text().
+
+pretty_flex(suite) ->
+ [];
+pretty_flex(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ pretty_flex().
+
+compact_flex(suite) ->
+ [];
+compact_flex(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ compact_flex().
+
+bin(suite) ->
+ [];
+bin(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ bin().
+
+ber(suite) ->
+ [];
+ber(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ asn1_ber().
+
+ber_bin(suite) ->
+ [];
+ber_bin(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ asn1_ber_bin().
+
+per(suite) ->
+ [];
+per(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ asn1_per().
+
+standard_erl(suite) ->
+ [];
+standard_erl(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ standard_erl().
+
+compressed_erl(suite) ->
+ [];
+compressed_erl(Config) when is_list(Config) ->
+ ?ACQUIRE_NODES(1, Config),
+ compressed_erl().
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+-define(PP(Name, Val), #'PropertyParm'{name = Name, value = [Val]}).
+-define(SP(Name, Val), #'StatisticsParameter'{statName = Name, statValue = [Val]}) .
+
+names() ->
+ [
+ msg1, msg2, msg3, msg4, msg5a, msg5b, msg6, msg7, msg9, msg10,
+ msg11, msg12, msg13, msg14, msg15, msg16, msg17a, msg17b,
+ msg18a, msg18b, msg18c, msg18d, msg19a, msg19b, msg20, msg21,
+ msg22a, msg22b, msg23a, msg23b
+ ].
+
+%% In this example, MG1 has the IP address 124.124.124.222, MG2 is
+%% 125.125.125.111, and the MGC is 123.123.123.4. The default Megaco port
+%% is 55555 for all three.
+
+-define(DEFAULT_PORT, 55555).
+-define(MG1_MID_NO_PORT, {ip4Address,
+ #'IP4Address'{address = [124, 124, 124, 222]}}).
+-define(MG1_MID, {ip4Address, #'IP4Address'{address = [124, 124, 124, 222],
+ portNumber = ?DEFAULT_PORT}}).
+-define(MG2_MID, {ip4Address, #'IP4Address'{address = [125, 125, 125, 111],
+ portNumber = ?DEFAULT_PORT}}).
+-define(MGC_MID, {ip4Address, #'IP4Address'{address = [123, 123, 123, 4],
+ portNumber = ?DEFAULT_PORT}}).
+
+-define(A4444, ["11111111", "00000000", "00000000"]).
+-define(A4445, ["11111111", "00000000", "11111111"]).
+-define(A5555, ["11111111", "11111111", "00000000"]).
+-define(A5556, ["11111111", "11111111", "11111111"]).
+
+%% -define(A4444, ["00000000"]).
+%% -define(A4445, ["00001111"]).
+%% -define(A5555, ["11110000"]).
+%% -define(A5556, ["11111111"]).
+
+request(Mid, TransId, ContextId, CmdReq) when is_list(CmdReq) ->
+ Actions = [#'ActionRequest'{contextId = ContextId,
+ commandRequests = CmdReq}],
+ Req = {transactions,
+ [{transactionRequest,
+ #'TransactionRequest'{transactionId = TransId,
+ actions = Actions}}]},
+ #'MegacoMessage'{mess = #'Message'{version = 1,
+ mId = Mid,
+ messageBody = Req}}.
+
+reply(Mid, TransId, ContextId, CmdReply) when is_list(CmdReply) ->
+ Actions = [#'ActionReply'{contextId = ContextId,
+ commandReply = CmdReply}],
+ Req = {transactions,
+ [{transactionReply,
+ #'TransactionReply'{transactionId = TransId,
+ transactionResult = {actionReplies, Actions}}}]},
+ #'MegacoMessage'{mess = #'Message'{version = 1,
+ mId = Mid,
+ messageBody = Req}}.
+
+%%----------------------------------------------------------------------
+%% 1. An MG registers with an MGC using the ServiceChange command:
+%%
+%% MG1 to MGC:
+%% "MEGACO/1 [124.124.124.222]
+%% Transaction = 9998 {
+%% Context = - {
+%% ServiceChange = ROOT {Services {
+%% Method=Restart,
+%% ServiceChangeAddress=55555, Profile=ResGW/1}
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg1() ->
+ msg1(?MG1_MID_NO_PORT).
+msg1(Mid) ->
+ Address = {portNumber, ?DEFAULT_PORT},
+ Profile = #'ServiceChangeProfile'{profileName = "resgw",
+ version = 1},
+ Parm = #'ServiceChangeParm'{serviceChangeMethod = restart,
+ serviceChangeAddress = Address,
+ serviceChangeReason = ["901 mg cold boot"],
+ %% BUGBUG: Mandatory reason missing in spec
+ serviceChangeProfile = Profile},
+ Req = #'ServiceChangeRequest'{terminationID = [?megaco_root_termination_id],
+ serviceChangeParms = Parm},
+ CmdReq = #'CommandRequest'{command = {serviceChangeReq, Req}},
+ request(Mid, 9998, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%%
+%% 2. The MGC sends a reply:
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Reply = 9998 {
+%% Context = - {ServiceChange = ROOT {
+%% Services {ServiceChangeAddress=55555, Profile=ResGW/1} } }
+%% }
+%%----------------------------------------------------------------------
+
+msg2() ->
+ msg2(?MGC_MID).
+msg2(Mid) ->
+ Address = {portNumber, ?DEFAULT_PORT},
+ Profile = #'ServiceChangeProfile'{profileName = "resgw",
+ version = 1},
+ Parm = #'ServiceChangeResParm'{serviceChangeAddress = Address,
+ serviceChangeProfile = Profile},
+ Reply = #'ServiceChangeReply'{terminationID = [?megaco_root_termination_id],
+ serviceChangeResult = {serviceChangeResParms,
+ Parm}},
+ reply(Mid, 9998, ?megaco_null_context_id, [{serviceChangeReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 3. The MGC programs a Termination in the NULL context. The
+%% terminationId is A4444, the streamId is 1, the requestId in the
+%% Events descriptor is 2222. The mId is the identifier of the sender
+%% of this message, in this case, it is the IP address and port
+%% [123.123.123.4]:55555. Mode for this stream is set to
+%% SendReceive. "al" is the analog line supervision package.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 9999 {
+%% Context = - {
+%% Modify = A4444 {
+%% Media { Stream = 1 {
+%% LocalControl {
+%% Mode = SendReceive,
+%% tdmc/gain=2, ; in dB,
+%% tdmc/ec=G165
+%% },
+%% Local {
+%% v=0
+%% c=IN IP4 $
+%% m=audio $ RTP/AVP 0
+%% a=fmtp:PCMU VAD=X-NNVAD ; special voice activity
+%% ; detection algorithm
+%% }
+%% }
+%% },
+%% Events = 2222 {al/of}
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg3() ->
+ msg3(?MGC_MID).
+msg3(Mid) ->
+ msg3(Mid, ?A4444).
+msg3(Mid, Tid) ->
+ Gain = ?PP("tdmc/gain", "2"),
+ %% Ec = ?PP("tdmc/ec", "G165"),
+ Ec = ?PP("tdmc/ec", "g165"), %% BUGBUG: should be case insensitive
+ LCD = #'LocalControlDescriptor'{streamMode = sendRecv,
+ propertyParms = [Gain, Ec]},
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 $ "),
+ M = ?PP("m", "audio $ RTP/AVP 0"),
+ A = ?PP("a", "fmtp:PCMU VAD=X-NNVAD"),
+ LD = #'LocalRemoteDescriptor'{propGrps = [[V, C, M, A]]},
+ Parms = #'StreamParms'{localControlDescriptor = LCD,
+ localDescriptor = LD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ ReqEvent = #'RequestedEvent'{pkgdName = "al/of",
+ evParList = []},
+ EventsDesc = #'EventsDescriptor'{requestID = 2222,
+ eventList = [ReqEvent]},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = Tid}],
+ descriptors = [{mediaDescriptor, MediaDesc},
+ {eventsDescriptor, EventsDesc}]},
+ CmdReq = #'CommandRequest'{command = {modReq, AmmReq}},
+ request(Mid, 9999, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% The dialplan script could have been loaded into the MG previously.
+%% Its function would be to wait for the OffHook, turn on dialtone and
+%% start collecting DTMF digits. However in this example, we use the
+%% digit map, which is put into place after the offhook is detected (step
+%% 5 below).
+%%
+%%
+%% Note that the embedded EventsDescriptor could have been used to
+%% combine steps 3 and 4 with steps 8 and 9, eliminating steps 6 and 7.
+%%
+%%
+%% 4. The MG1 accepts the Modify with this reply:
+%%
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 9999 {
+%% Context = - {Modify = A4444}
+%% }
+%%----------------------------------------------------------------------
+
+msg4() ->
+ msg4(?MG1_MID).
+msg4(Mid) ->
+ msg4(Mid, ?A4444).
+msg4(Mid, Tid) ->
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = Tid}]},
+ reply(Mid, 9999, ?megaco_null_context_id, [{modReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 5. A similar exchange happens between MG2 and the MGC, resulting in an
+%% idle Termination called A5555.
+%%----------------------------------------------------------------------
+
+msg5a() ->
+ msg5a(?MGC_MID).
+msg5a(Mid) ->
+ msg3(Mid, ?A4444).
+
+msg5b() ->
+ msg5b(?MG2_MID).
+msg5b(Mid) ->
+ msg4(Mid, ?A5555).
+
+%%----------------------------------------------------------------------
+%% A.1.2 Collecting Originator Digits and Initiating Termination
+%%
+%% The following builds upon the previously shown conditions. It
+%% illustrates the transactions from the Media Gateway Controller and
+%% originating Media Gateway (MG1) to get the originating Termination
+%% (A4444) through the stages of digit collection required to initiate a
+%% connection to the terminating Media Gateway (MG2).
+%%
+%% 6. MG1 detects an offhook event from User 1 and reports it to the
+%% Media Gateway Controller via the Notify Command.
+%%
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Transaction = 10000 {
+%% Context = - {
+%% Notify = A4444 {ObservedEvents =2222 {
+%% 19990729T22000000:al/of}}
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg6() ->
+ msg6(?MG1_MID).
+msg6(Mid) ->
+ TimeStamp = #'TimeNotation'{date = "19990729",
+ time = "22000000"},
+ Event = #'ObservedEvent'{eventName = "al/of",
+ timeNotation = TimeStamp,
+ eventParList = []},
+ Desc = #'ObservedEventsDescriptor'{requestId = 2222,
+ observedEventLst = [Event]},
+ NotifyReq = #'NotifyRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ observedEventsDescriptor = Desc},
+ CmdReq = #'CommandRequest'{command = {notifyReq, NotifyReq}},
+ request(Mid, 10000, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% 7. And the Notify is acknowledged.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Reply = 10000 {
+%% Context = - {Notify = A4444}
+%% }
+%%----------------------------------------------------------------------
+
+msg7() ->
+ msg7(?MGC_MID).
+msg7(Mid) ->
+ Reply = #'NotifyReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ reply(Mid, 10000, ?megaco_null_context_id, [{notifyReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 8. The MGC Modifies the termination to play dial tone, and to look for
+%% digits now. There is also an embedded event to stop dialtone upon
+%% detection of the first digit. dd is the DTMF Detection package, and
+%% ce is the completion event.
+%%----------------------------------------------------------------------
+
+%% BUGBUG: Example missing in spec
+
+%%----------------------------------------------------------------------
+%% 9.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 10001 {
+%% Context = - {
+%% Modify = A4444 {
+%% Events = 2223 {
+%% al/on, dd/ce {DigitMap=Dialplan0}
+%% },
+%% Signals {cg/dt},
+%% DigitMap= Dialplan0{
+%% (0S| 00S|[1-7]xLxx|8Lxxxxxxx|#xxxxxxx|*xx|9L1xxxxxxxxxx|9L011x.S)}
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg9() ->
+ msg9(?MGC_MID).
+msg9(Mid) ->
+ Name = "dialplan00",
+ Body = "(0s| 00s|[1-7]xlxx|8lxxxxxxx|#xxxxxxx|*xx|9l1xxxxxxxxxx|9l011x.s)",
+ Value = #'DigitMapValue'{digitMapBody = Body},
+ On = #'RequestedEvent'{pkgdName = "al/on", evParList = []},
+ Action = #'RequestedActions'{eventDM = {digitMapName, Name}},
+ Ce = #'RequestedEvent'{pkgdName = "dd/ce",
+ eventAction = Action,
+ evParList = []},
+ EventsDesc = #'EventsDescriptor'{requestID = 2223,
+ eventList = [On, Ce]},
+ Signal = #'Signal'{signalName = "cg/rt", sigParList = []},
+ DigMapDesc = #'DigitMapDescriptor'{digitMapName = Name,
+ digitMapValue = Value},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ descriptors = [{eventsDescriptor, EventsDesc},
+ {signalsDescriptor, [{signal, Signal}]},
+ {digitMapDescriptor, DigMapDesc}]},
+ CmdReq = #'CommandRequest'{command = {modReq, AmmReq}},
+ request(Mid, 10001, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% 10. And the Modify is acknowledged.
+%%
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 10001 {
+%% Context = - {Modify = A4444}
+%% }
+%%----------------------------------------------------------------------
+
+msg10() ->
+ msg10(?MG1_MID).
+msg10(Mid) ->
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ reply(Mid, 10001, ?megaco_null_context_id, [{modReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 11. Next, digits are accumulated by MG1 as they are dialed by User 1.
+%% Dialtone is stopped upon detection of the first digit, using the
+%% embedded event in step 8. When an appropriate match is made of
+%% collected digits against the currently programmed Dialplan for
+%% A4444, another Notify is sent to the Media Gateway Controller.
+%%
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Transaction = 10002 {
+%% Context = - {
+%% Notify = A4444 {ObservedEvents =2223 {
+%% 19990729T22010001:dd/ce{ds="916135551212"}}}
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg11() ->
+ msg11(?MG1_MID).
+msg11(Mid) ->
+ TimeStamp = #'TimeNotation'{date = "19990729",
+ time = "22010001"},
+ Parm = #'EventParameter'{eventParameterName = "ds",
+ value = ["916135551212"]},
+ %% BUGBUG: Quoted string or safe char?
+ Event = #'ObservedEvent'{eventName = "dd/ce",
+ timeNotation = TimeStamp,
+ eventParList = [Parm]},
+ Desc = #'ObservedEventsDescriptor'{requestId = 2223,
+ observedEventLst = [Event]},
+ NotifyReq = #'NotifyRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ observedEventsDescriptor = Desc},
+ CmdReq = #'CommandRequest'{command = {notifyReq, NotifyReq}},
+ request(Mid, 10002, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% 12. And the Notify is acknowledged.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Reply = 10002 {
+%% Context = - {Notify = A4444}
+%% }
+%%----------------------------------------------------------------------
+
+msg12() ->
+ msg12(?MGC_MID).
+msg12(Mid) ->
+ Reply = #'NotifyReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ reply(Mid, 10002, ?megaco_null_context_id, [{notifyReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 13. The controller then analyses the digits and determines that a
+%% connection needs to be made from MG1 to MG2. Both the TDM
+%% termination A4444, and an RTP termination are added to a new
+%% context in MG1. Mode is ReceiveOnly since Remote descriptor values
+%% are not yet specified. Preferred codecs are in the MGC's preferred
+%% order of choice.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 10003 {
+%% Context = $ {
+%% Add = A4444,
+%% Add = $ {
+%% Media {
+%% Stream = 1 {
+%% LocalControl {
+%% Mode = ReceiveOnly,
+%%
+%% nt/jit=40, ; in ms
+%% },
+%% Local {
+%% v=0
+%% c=IN IP4 $
+%% m=audio $ RTP/AVP 4
+%% a=ptime:30
+%% v=0
+%% c=IN IP4 $
+%% m=audio $ RTP/AVP 0
+%% }
+%% }
+%% }
+%% }
+%% }
+%% }
+%%
+%% NOTE - The MGC states its prefrred parameter values as a series of
+%% sdp blocks in Local. The MG fills in the Local Descriptor in the
+%% Reply.
+%%----------------------------------------------------------------------
+
+msg13() ->
+ msg13(?MGC_MID).
+msg13(Mid) ->
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ descriptors = []},
+ CmdReq = #'CommandRequest'{command = {addReq, AmmReq}},
+ Jit = ?PP("nt/jit", "40"),
+ LCD = #'LocalControlDescriptor'{streamMode = recvOnly,
+ propertyParms = [Jit]},
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 $ "),
+ M = ?PP("m", "audio $ RTP/AVP 4"),
+ A = ?PP("a", "ptime:30"),
+ V2 = ?PP("v", "0"),
+ C2 = ?PP("c", "IN IP4 $ "),
+ M2 = ?PP("m", "audio $ RTP/AVP 0"),
+ LD = #'LocalRemoteDescriptor'{propGrps = [[V, C, M, A], [V2, C2, M2]]},
+ Parms = #'StreamParms'{localControlDescriptor = LCD,
+ localDescriptor = LD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ ChooseTid = #megaco_term_id{contains_wildcards = true,
+ id = [[?megaco_choose]]},
+ AmmReq2 = #'AmmRequest'{terminationID = [ChooseTid],
+ descriptors = [{mediaDescriptor, MediaDesc}]},
+ CmdReq2 = #'CommandRequest'{command = {addReq, AmmReq2}},
+ request(Mid, 10003, ?megaco_choose_context_id, [CmdReq, CmdReq2]).
+
+%%----------------------------------------------------------------------
+%% 14. MG1 acknowledges the new Termination and fills in the Local IP
+%% address and UDP port. It also makes a choice for the codec based
+%% on the MGC preferences in Local. MG1 sets the RTP port to 2222.
+%%
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 10003 {
+%% Context = 2000 {
+%% Add = A4444,
+%% Add=A4445{
+%% Media {
+%% Stream = 1 {
+%% Local {
+%% v=0
+%% c=IN IP4 124.124.124.222
+%% m=audio 2222 RTP/AVP 4
+%% a=ptime:30
+%% a=recvonly
+%% } ; RTP profile for G.723 is 4
+%% }
+%% }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg14() ->
+ msg14(?MG1_MID).
+msg14(Mid) ->
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 124.124.124.222"),
+ M = ?PP("m", "audio 2222 RTP/AVP 4"),
+ A = ?PP("a", "a=ptime:30"),
+ A2= ?PP("a", "recvonly"),
+ LD = #'LocalRemoteDescriptor'{propGrps = [[V, C, M, A, A2]]},
+ Parms = #'StreamParms'{localDescriptor = LD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ Reply2 = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4445}],
+ terminationAudit = [{mediaDescriptor, MediaDesc}]},
+ reply(Mid, 10003, 2000, [{addReply, Reply}, {addReply, Reply2}]).
+
+%%----------------------------------------------------------------------
+%% 15. The MGC will now associate A5555 with a new Context on MG2, and
+%% establish an RTP Stream (i.e, A5556 will be assigned), SendReceive
+%% connection through to the originating user, User 1. The MGC also
+%% sets ring on A5555.
+%%
+%% MGC to MG2:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 50003 {
+%% Context = $ {
+%% Add = A5555 { Media {
+%% Stream = 1 {
+%% LocalControl {Mode = SendReceive} }},
+%% Signals {al/ri}
+%% },
+%% Add = $ {Media {
+%% Stream = 1 {
+%% LocalControl {
+%% Mode = SendReceive,
+%% nt/jit=40 ; in ms
+%% },
+%% Local {
+%% v=0
+%% c=IN IP4 $
+%% m=audio $ RTP/AVP 4
+%% a=ptime:30
+%% },
+%% Remote {
+%% v=0
+%% c=IN IP4 124.124.124.222
+%% m=audio 2222 RTP/AVP 4
+%% a=ptime:30
+%% } ; RTP profile for G.723 is 4
+%% }
+%% }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg15() ->
+ msg15(?MGC_MID).
+msg15(Mid) ->
+ LCD = #'LocalControlDescriptor'{streamMode = sendRecv,
+ propertyParms = []},
+ Parms = #'StreamParms'{localControlDescriptor = LCD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ Signal = #'Signal'{signalName = "al/ri",
+ sigParList = []},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A5555}],
+ descriptors = [{mediaDescriptor, MediaDesc},
+ {signalsDescriptor, [{signal, Signal}]}]},
+ CmdReq = #'CommandRequest'{command = {addReq, AmmReq}},
+ Jit = ?PP("nt/jit", "40"),
+ LCD2 = #'LocalControlDescriptor'{streamMode = sendRecv,
+ propertyParms = [Jit]},
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 $ "),
+ M = ?PP("m", "audio $ RTP/AVP 4"),
+ A = ?PP("a", "ptime:30"),
+ LD2 = #'LocalRemoteDescriptor'{propGrps = [[V, C, M, A]]},
+ V2 = ?PP("v", "0"),
+ C2 = ?PP("c", "IN IP4 124.124.124.222"),
+ M2 = ?PP("m", "audio 2222 RTP/AVP 4"),
+ RD2 = #'LocalRemoteDescriptor'{propGrps = [[V2, C2, M2]]},
+ Parms2 = #'StreamParms'{localControlDescriptor = LCD2,
+ localDescriptor = LD2,
+ remoteDescriptor = RD2},
+ StreamDesc2 = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms2},
+ MediaDesc2 = #'MediaDescriptor'{streams = {multiStream, [StreamDesc2]}},
+ ChooseTid = #megaco_term_id{contains_wildcards = true,
+ id = [[?megaco_choose]]},
+ AmmReq2 = #'AmmRequest'{terminationID = [ChooseTid],
+ descriptors = [{mediaDescriptor, MediaDesc2}]},
+ CmdReq2 = #'CommandRequest'{command = {addReq, AmmReq2}},
+ request(Mid, 50003, ?megaco_choose_context_id, [CmdReq, CmdReq2]).
+
+%%----------------------------------------------------------------------
+%% 16. This is acknowledged. The stream port number is different from the
+%% control port number. In this case it is 1111 (in the SDP).
+%%
+%% MG2 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 50003 {
+%% Context = 5000 {
+%% Add = A5556{
+%% Media {
+%% Stream = 1 {
+%% Local {
+%% v=0
+%% c=IN IP4 125.125.125.111
+%% m=audio 1111 RTP/AVP 4
+%% }
+%% } ; RTP profile for G723 is 4
+%% }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg16() ->
+ msg16(?MG2_MID).
+msg16(Mid) ->
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 125.125.125.111"),
+ M = ?PP("m", "audio 1111 RTP/AVP 4"),
+ LD = #'LocalRemoteDescriptor'{propGrps = [[V, C, M]]},
+ Parms = #'StreamParms'{localDescriptor = LD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A5556}],
+ terminationAudit = [{mediaDescriptor, MediaDesc}]},
+ reply(Mid, 50003, 5000, [{addReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 17. The above IPAddr and UDPport need to be given to MG1 now.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 10005 {
+%% Context = 2000 {
+%% Modify = A4444 {
+%% Signals {cg/rt}
+%% },
+%% Modify = A4445 {
+%% Media {
+%% Stream = 1 {
+%% Remote {
+%% v=0
+%% c=IN IP4 125.125.125.111
+%% m=audio 1111 RTP/AVP 4
+%% }
+%% } ; RTP profile for G723 is 4
+%% }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg17a() ->
+ msg17a(?MGC_MID).
+msg17a(Mid) ->
+ Signal = #'Signal'{signalName = "cg/rt", sigParList = []},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ descriptors = [{signalsDescriptor, [{signal, Signal}]}]},
+ CmdReq = #'CommandRequest'{command = {modReq, AmmReq}},
+
+ V = ?PP("v", "0"),
+ C = ?PP("c", "IN IP4 125.125.125.111"),
+ M = ?PP("m", "audio 1111 RTP/AVP 4"),
+ RD2 = #'LocalRemoteDescriptor'{propGrps = [[V, C, M]]},
+ Parms2 = #'StreamParms'{remoteDescriptor = RD2},
+ StreamDesc2 = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms2},
+ MediaDesc2 = #'MediaDescriptor'{streams = {multiStream, [StreamDesc2]}},
+ AmmReq2 = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4445}],
+ descriptors = [{mediaDescriptor, MediaDesc2}]},
+ CmdReq2 = #'CommandRequest'{command = {modReq, AmmReq2}},
+ request(Mid, 10005, 2000, [CmdReq, CmdReq2]).
+
+%%----------------------------------------------------------------------
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 10005 {
+%% Context = 2000 {Modify = A4444, Modify = A4445}
+%% }
+%%----------------------------------------------------------------------
+
+msg17b() ->
+ msg17b(?MG1_MID).
+msg17b(Mid) ->
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ Reply2 = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4445}]},
+ reply(Mid, 10005, 2000, [{modReply, Reply}, {modReply, Reply2}]).
+
+%%----------------------------------------------------------------------
+%% 18. The two gateways are now connected and User 1 hears the
+%% RingBack. The MG2 now waits until User2 picks up the receiver and
+%% then the two-way call is established.
+%%
+%% MG2 to MGC:
+%% MEGACO/1 [125.125.125.111]:55555
+%% Transaction = 50005 {
+%% Context = 5000 {
+%% Notify = A5555 {ObservedEvents =1234 {
+%% 19990729T22020002:al/of}}
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg18a() ->
+ msg18a(?MG2_MID).
+msg18a(Mid) ->
+ TimeStamp = #'TimeNotation'{date = "19990729",
+ time = "22020002"},
+ Event = #'ObservedEvent'{eventName = "al/of",
+ timeNotation = TimeStamp,
+ eventParList = []},
+ Desc = #'ObservedEventsDescriptor'{requestId = 1234,
+ observedEventLst = [Event]},
+ NotifyReq = #'NotifyRequest'{terminationID = [#megaco_term_id{id = ?A5555}],
+ observedEventsDescriptor = Desc},
+ CmdReq = #'CommandRequest'{command = {notifyReq, NotifyReq}},
+ request(Mid, 50005, 5000, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% MGC to MG2:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Reply = 50005 {
+%% Context = - {Notify = A5555}
+%% }
+%%----------------------------------------------------------------------
+
+msg18b() ->
+ msg18b(?MGC_MID).
+msg18b(Mid) ->
+ Reply = #'NotifyReply'{terminationID = [#megaco_term_id{id = ?A5555}]},
+ reply(Mid, 50005, ?megaco_null_context_id, [{notifyReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% MGC to MG2:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 50006 {
+%% Context = 5000 {
+%% Modify = A5555 {
+%% Events = 1235 {al/on},
+%% Signals { } ; to turn off ringing
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg18c() ->
+ msg18c(?MGC_MID).
+msg18c(Mid) ->
+ On = #'RequestedEvent'{pkgdName = "al/on", evParList = []},
+ EventsDesc = #'EventsDescriptor'{requestID = 1235,
+ eventList = [On]},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A5555}],
+ descriptors = [{eventsDescriptor, EventsDesc},
+ {signalsDescriptor, []}]},
+ CmdReq = #'CommandRequest'{command = {modReq, AmmReq}},
+ request(Mid, 50006, 5000, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% MG2 to MGC:
+%% MEGACO/1 [125.125.125.111]:55555
+%% Reply = 50006 {
+%% Context = 5000 {Modify = A4445}
+%% }
+%%----------------------------------------------------------------------
+
+msg18d() ->
+ msg18d(?MG2_MID).
+msg18d(Mid) ->
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4445}]},
+ reply(Mid, 50006, 5000, [{modReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 19. Change mode on MG1 to SendReceive, and stop the ringback.
+%%
+%% MGC to MG1:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 10006 {
+%% Context = 2000 {
+%% Modify = A4445 {
+%% Media {
+%% Stream = 1 {
+%% LocalControl {
+%% Mode=SendReceive
+%% }
+%% }
+%% }
+%% },
+%% Modify = A4444 {
+%% Signals { }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg19a() ->
+ msg19a(?MGC_MID).
+msg19a(Mid) ->
+ LCD = #'LocalControlDescriptor'{streamMode = sendRecv,
+ propertyParms = []},
+ Parms = #'StreamParms'{localControlDescriptor = LCD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = Parms},
+ MediaDesc = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ AmmReq = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4445}],
+ descriptors = [{mediaDescriptor, MediaDesc}]},
+ CmdReq = #'CommandRequest'{command = {modReq, AmmReq}},
+ AmmReq2 = #'AmmRequest'{terminationID = [#megaco_term_id{id = ?A4444}],
+ descriptors = [{signalsDescriptor, []}]},
+ CmdReq2 = #'CommandRequest'{command = {modReq, AmmReq2}},
+ request(Mid, 10006, 2000, [CmdReq, CmdReq2]).
+
+%%----------------------------------------------------------------------
+%% MG1 to MGC:
+%% MEGACO/1 [124.124.124.222]:55555
+%% Reply = 10006 {
+%% Context = 2000 {Modify = A4445, Modify = A4444}}
+%%----------------------------------------------------------------------
+
+msg19b() ->
+ msg19b(?MG1_MID).
+msg19b(Mid) ->
+ Reply = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4445}]},
+ Reply2= #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A4444}]},
+ reply(Mid, 10006, 2000, [{modReply, Reply}, {modReply, Reply2}]).
+
+%%----------------------------------------------------------------------
+%% 20. The MGC decides to Audit the RTP termination on MG2.
+%%
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 50007 {
+%% Context = - {AuditValue = A5556{
+%% Audit{Media, DigitMap, Events, Signals, Packages, Statistics }}
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg20() ->
+ msg20(?MGC_MID).
+msg20(Mid) ->
+ Tokens = [mediaToken, eventsToken, signalsToken,
+ digitMapToken, statsToken, packagesToken],
+ AuditDesc = #'AuditDescriptor'{auditToken = Tokens},
+ Req = #'AuditRequest'{terminationID = #megaco_term_id{id = ?A5556},
+ auditDescriptor = AuditDesc},
+ CmdReq = #'CommandRequest'{command = {auditValueRequest, Req}},
+ request(Mid, 50007, ?megaco_null_context_id, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% 21. The MG2 replies. An RTP termination has no events nor signals, so
+%% these are left out in the reply .
+%%
+%% MEGACO/1 [125.125.125.111]:55555
+%% Reply = 50007 {
+%% Context = - {
+%% AuditValue = A5556 {
+%% Media {
+%% Stream = 1 {
+%% LocalControl { Mode = SendReceive,
+%% nt/jit=40 },
+%% Local {
+%% v=0
+%% c=IN IP4 125.125.125.111
+%% m=audio 1111 RTP/AVP 4
+%% a=ptime:30
+%% },
+%% Remote {
+%% v=0
+%% c=IN IP4 124.124.124.222
+%% m=audio 2222 RTP/AVP 4
+%% a=ptime:30
+%% } } },
+%% Packages {nt-1, rtp-1},
+%% Statistics { rtp/ps=1200, ; packets sent
+%% nt/os=62300, ; octets sent
+%% rtp/pr=700, ; packets received
+%% nt/or=45100, ; octets received
+%% rtp/pl=0.2, ; % packet loss
+%% rtp/jit=20,
+%% rtp/delay=40 } ; avg latency
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg21() ->
+ msg21(?MG2_MID).
+msg21(Mid) ->
+ Jit = ?PP("nt/jit", "40"),
+ LCD = #'LocalControlDescriptor'{streamMode = sendRecv,
+ propertyParms = [Jit]},
+ LDV = ?PP("v", "0"),
+ LDC = ?PP("c", "IN IP4 125.125.125.111"),
+ LDM = ?PP("m", "audio 1111 RTP/AVP 4"),
+ LDA = ?PP("a", "ptime:30"),
+ LD = #'LocalRemoteDescriptor'{propGrps = [[LDV, LDC, LDM, LDA]]},
+ RDV = ?PP("v", "0"),
+ RDC = ?PP("c", "IN IP4 124.124.124.222"),
+ RDM = ?PP("m", "audio 2222 RTP/AVP 4"),
+ RDA = ?PP("a", "ptime:30"),
+ RD = #'LocalRemoteDescriptor'{propGrps = [[RDV, RDC, RDM, RDA]]},
+ StreamParms = #'StreamParms'{localControlDescriptor = LCD,
+ localDescriptor = LD,
+ remoteDescriptor = RD},
+ StreamDesc = #'StreamDescriptor'{streamID = 1,
+ streamParms = StreamParms},
+ Media = #'MediaDescriptor'{streams = {multiStream, [StreamDesc]}},
+ PackagesItem = #'PackagesItem'{packageName = "nt",
+ packageVersion = 1},
+ PackagesItem2 = #'PackagesItem'{packageName = "rtp",
+ packageVersion = 1},
+ Stat = ?SP("rtp/ps","1200"),
+ Stat2 = ?SP("nt/os","62300"),
+ Stat3 = ?SP("rtp/pr","700"),
+ Stat4 = ?SP("nt/or","45100"),
+ Stat5 = ?SP("rtp/pl","0.2"),
+ Stat6 = ?SP("rtp/jit","20"),
+ Stat7 = ?SP("rtp/delay","40"),
+ Statistics = [Stat, Stat2, Stat3, Stat4, Stat5, Stat6, Stat7],
+ Audits = [{mediaDescriptor, Media},
+ {packagesDescriptor, [PackagesItem, PackagesItem2]},
+ {statisticsDescriptor, Statistics}],
+ Reply = {auditResult, #'AuditResult'{terminationID = #megaco_term_id{id = ?A5556},
+ terminationAuditResult = Audits}},
+ reply(Mid, 50007, ?megaco_null_context_id, [{auditValueReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 22. When the MGC receives an onhook signal from one of the MGs, it
+%% brings down the call. In this example, the user at MG2 hangs up first.
+%%
+%% MG2 to MGC:
+%% MEGACO/1 [125.125.125.111]:55555
+%% Transaction = 50008 {
+%% Context = 5000 {
+%% Notify = A5555 {ObservedEvents =1235 {
+%% 19990729T24020002:al/on}
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg22a() ->
+ msg22a(?MG2_MID).
+msg22a(Mid) ->
+ TimeStamp = #'TimeNotation'{date = "19990729",
+ time = "24020002"},
+ Event = #'ObservedEvent'{eventName = "al/on",
+ timeNotation = TimeStamp,
+ eventParList = []},
+ Desc = #'ObservedEventsDescriptor'{requestId = 1235,
+ observedEventLst = [Event]},
+ NotifyReq = #'NotifyRequest'{terminationID = [#megaco_term_id{id = ?A5555}],
+ observedEventsDescriptor = Desc},
+ CmdReq = #'CommandRequest'{command = {notifyReq, NotifyReq}},
+ request(Mid, 50008, 5000, [CmdReq]).
+
+%%----------------------------------------------------------------------
+%% MGC to MG2:
+%% MEGACO/1 [123.123.123.4]:55555
+%% Reply = 50008 {
+%% Context = - {Notify = A5555}
+%% }
+%%----------------------------------------------------------------------
+
+msg22b() ->
+ msg22b(?MGC_MID).
+msg22b(Mid) ->
+ Reply = #'NotifyReply'{terminationID = [#megaco_term_id{id = ?A5555}]},
+ reply(Mid, 50008, ?megaco_null_context_id, [{notifyReply, Reply}]).
+
+%%----------------------------------------------------------------------
+%% 23. The MGC now sends both MGs a Subtract to take down the call. Only
+%% the subtracts to MG2 are shown here. Each termination has its own
+%% set of statistics that it gathers. An MGC may not need to request
+%% both to be returned. A5555 is a physical termination, and A5556 is
+%% an RTP termination.
+%%
+%% MGC to MG2:
+%%
+%% MEGACO/1 [123.123.123.4]:55555
+%% Transaction = 50009 {
+%% Context = 5000 {
+%% Subtract = A5555 {Audit{Statistics}},
+%% Subtract = A5556 {Audit{Statistics}}
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg23a() ->
+ msg23a(?MGC_MID).
+msg23a(Mid) ->
+ CommonAuditDesc = #'AuditDescriptor'{auditToken = [statsToken]},
+ SubReq = #'SubtractRequest'{terminationID = [#megaco_term_id{id = ?A5555}],
+ auditDescriptor = CommonAuditDesc},
+ SubReq2 = #'SubtractRequest'{terminationID = [#megaco_term_id{id = ?A5556}],
+ auditDescriptor = CommonAuditDesc},
+ CmdReq = #'CommandRequest'{command = {subtractReq, SubReq}},
+ CmdReq2 = #'CommandRequest'{command = {subtractReq, SubReq2}},
+ request(Mid, 50009, 5000, [CmdReq, CmdReq2]).
+%%
+%%----------------------------------------------------------------------
+%% MG2 to MGC:
+%%
+%% MEGACO/1 [125.125.125.111]:55555
+%% Reply = 50009 {
+%% Context = 5000 {
+%% Subtract = A5555 {
+%% Statistics {
+%% nt/os=45123, ; Octets Sent
+%% nt/dur=40 ; in seconds
+%% }
+%% },
+%% Subtract = A5556 {
+%% Statistics {
+%% rtp/ps=1245, ; packets sent
+%% nt/os=62345, ; octets sent
+%% rtp/pr=780, ; packets received
+%% nt/or=45123, ; octets received
+%% rtp/pl=10, ; % packets lost
+%% rtp/jit=27,
+%% rtp/delay=48 ; average latency
+%% }
+%% }
+%% }
+%% }
+%%----------------------------------------------------------------------
+
+msg23b() ->
+ msg23b(?MG2_MID).
+msg23b(Mid) ->
+ Stat11 = ?SP("nt/os","45123"),
+ Stat12 = ?SP("nt/dur", "40"),
+ Stats1 = [Stat11, Stat12],
+ Reply1 = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A5555}],
+ terminationAudit = [{statisticsDescriptor, Stats1}]},
+ Stat21 = ?SP("rtp/ps","1245"),
+ Stat22 = ?SP("nt/os", "62345"),
+ Stat23 = ?SP("rtp/pr", "780"),
+ Stat24 = ?SP("nt/or", "45123"),
+ Stat25 = ?SP("rtp/pl", "10"),
+ Stat26 = ?SP("rtp/jit", "27"),
+ Stat27 = ?SP("rtp/delay","48"),
+ Stats2 = [Stat21, Stat22, Stat23, Stat24, Stat25, Stat26, Stat27],
+ Reply2 = #'AmmsReply'{terminationID = [#megaco_term_id{id = ?A5556}],
+ terminationAudit = [{statisticsDescriptor, Stats2}]},
+ reply(Mid, 50009, 5000, [{subtractReply, Reply1}, {subtractReply, Reply2}]).
+
+%%----------------------------------------------------------------------
+%% 24. The MGC now sets up both MG1 and MG2 to be ready to detect the
+%% next off-hook event. See step 1. Note that this could be the
+%% default state of a termination in the null context, and if this
+%% were the case, no message need be sent from the MGC to the
+%% MG. Once a termination returns to the null context, it goes back
+%% to the default termination values for that termination.
+%%----------------------------------------------------------------------
+
+%% BUGBUG: Example missing in spec
+
+%%----------------------------------------------------------------------
+%% Testing
+%%----------------------------------------------------------------------
+
+messages() ->
+ [{Slogan, catch ?MODULE:Slogan()} || Slogan <- names()].
+
+encoders() ->
+ [
+ {megaco_pretty_text_encoder, [], []},
+ {megaco_compact_text_encoder, [], []},
+ {megaco_binary_encoder, [], [native]},
+ %% {megaco_ber_encoder, [], [native]},
+ %% {megaco_ber_bin_encoder, [], [native]},
+ {megaco_per_encoder, [], [native]},
+ {megaco_erl_dist_encoder, [], []},
+ {megaco_erl_dist_encoder, [compressed], [compressed]}
+ ].
+
+
+pretty_mod({Mod, Opt, _Opt2}) ->
+ case Mod of
+ megaco_pretty_text_encoder when Opt == [flex] -> pretty_flex;
+ megaco_compact_text_encoder when Opt == [flex] -> compact_flex;
+ megaco_pretty_text_encoder -> pretty_text;
+ megaco_compact_text_encoder -> compact_text;
+ megaco_binary_encoder -> asn1_ber;
+ megaco_ber_encoder -> asn1_ber_old;
+ megaco_ber_bin_encoder -> asn1_ber_bin;
+ megaco_per_encoder -> asn1_per;
+ megaco_erl_dist_encoder when Opt == [] -> standard_erl;
+ megaco_erl_dist_encoder when Opt == [compressed] -> compressed_erl;
+ Ugly -> Ugly
+ end.
+
+%%----------------------------------------------------------------------
+%% Run specific encoder for all test cases
+%%----------------------------------------------------------------------
+
+pretty_text() ->
+ Default = [],
+ Encoder = {megaco_pretty_text_encoder, Default, Default},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+compact_text() ->
+ Default = [],
+ Encoder = {megaco_compact_text_encoder, Default, Default},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+pretty_flex() ->
+ Default = [flex],
+ Encoder = {megaco_pretty_text_encoder, Default, Default},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+compact_flex() ->
+ Default = [flex],
+ Encoder = {megaco_compact_text_encoder, Default, Default},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+bin() ->
+ Default = [],
+ Native = [native],
+ Encoder = {megaco_binary_encoder, Default, Native},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+asn1_ber() ->
+ Default = [],
+ Native = [native],
+ Encoder = {megaco_ber_encoder, Default, Native},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+asn1_ber_bin() ->
+ Default = [],
+ Native = [native],
+ Encoder = {megaco_ber_bin_encoder, Default, Native},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+asn1_per() ->
+ Default = [],
+ Native = [native],
+ Encoder = {megaco_per_encoder, Default, Native},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+standard_erl() ->
+ Config = [],
+ Encoder = {megaco_erl_dist_encoder, Config, Config},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+compressed_erl() ->
+ Config = [compressed],
+ Encoder = {megaco_erl_dist_encoder, Config, Config},
+ All = [encode(Slogan, Msg, Encoder) || {Slogan, Msg} <- messages()],
+ compute_res(All).
+
+encode(Slogan, DecodedMsg, {Mod, Opt, _Opt2} = _Encoder) ->
+ Main = "==================================================",
+ Sub = "--------------------------------------------------",
+ case catch Mod:encode_message(Opt, DecodedMsg) of
+ {ok, EncodedMsg} when is_binary(EncodedMsg) ->
+ Sz = size(EncodedMsg),
+ ok = io:format("~w ~s ~w bytes~n",
+ [Slogan, Main, Sz]),
+ catch io:format("~n~s~n", [(catch binary_to_list(EncodedMsg))]),
+ case catch Mod:decode_message(Opt, EncodedMsg) of
+ {ok, ReDecodedMsg} ->
+ fmt(Slogan, DecodedMsg, ReDecodedMsg);
+ {error, {Line, _, Reason}} when is_integer(Line)->
+ ?ERROR([{Slogan, Line, decode_failed}, {error, Reason}, {encoded, EncodedMsg}, DecodedMsg]),
+ io:format("~n~w <ERROR> #~w: ~w~n",
+ [Slogan, Line, Reason]);
+ Other ->
+ ?ERROR([{Slogan, 0, decode_failed}, Other, {encoded, EncodedMsg}, DecodedMsg]),
+ io:format("~n~w <ERROR> ~w~n", [Slogan, Other])
+ end,
+ Sz;
+ Other ->
+ ?ERROR([{Slogan, encode_failed}, Other, DecodedMsg]),
+ ok = io:format("~w ~s~n~p~n<ERROR> ~s~n~p~n",
+ [Slogan, Main, DecodedMsg, Sub, Other]),
+ {Slogan, {encode_message, Other}}
+ end.
+
+fmt(_Slogan, Msg, Msg) ->
+ ok;
+fmt(Slogan, {'MegacoMessage', A, {'Message', V, MID, {transactions, [{T, Old}]}}},
+ {'MegacoMessage', A, {'Message', V, MID, {transactions, [{T, New}]}}}) ->
+ fmt(Slogan, Old, New);
+fmt(Slogan, Old, New) ->
+ PrettyOld = lists:flatten(io_lib:format("~p", [Old])),
+ PrettyNew = lists:flatten(io_lib:format("~p", [New])),
+ fmt_diff(Slogan, Old, New, PrettyOld, PrettyNew, []).
+
+fmt_diff(Slogan, Old, New, [H | OldRest], [H | NewRest], Common) ->
+ fmt_diff(Slogan, Old, New, OldRest, NewRest, [H | Common]);
+fmt_diff(Slogan, Old, New, OldRest, NewRest, Common) ->
+ RevCommon = lists:reverse(Common),
+ ?ERROR([{Slogan, decode_mismatch}, {old, Old}, {new, New}]),
+ Sub = "--------------------------------------------------",
+ io:format("~n~w COMMON ~s~n~s~n", [Slogan, Sub, RevCommon]),
+ io:format("~n~w OLD ~s~n~s~n", [Slogan, Sub, OldRest]),
+ io:format("~n~w NEW ~s~n~s~n", [Slogan, Sub, NewRest]).
+
+compute_res(All) ->
+ compute_res(All, [], 0).
+
+compute_res([H | T], Bad, Sum) when is_integer(H) ->
+ compute_res(T, Bad, Sum + H);
+compute_res([H | T], Bad, Sum) ->
+ compute_res(T, [H | Bad], Sum);
+compute_res([], Bad, Sum) ->
+ ok = io:format("#bytes: ~w; errors: ~p~n", [Sum, Bad]).
+
+%%----------------------------------------------------------------------
+%% Compute sizes of encoded messages
+%%----------------------------------------------------------------------
+
+msg_sizes() ->
+ Encoders = encoders(),
+ msg_sizes(Encoders).
+
+%% Returns a list of {MessageSlogan, MessageSizes} where
+%% MessageSizes is the result from msg_sizes/2
+msg_sizes(Encoders) ->
+ [{S, msg_sizes(Msg, Encoders)} || {S, Msg} <- messages()].
+
+%% Returns a list of {Encoder, Res} tuples
+%% where Res either is the message size (integer)
+%% or an error atom
+msg_sizes(DecodedMsg, Encoders) ->
+ [abs_msg_size(DecodedMsg, E) || E <- Encoders].
+
+abs_msg_size(DecodedMsg, {Mod, Opt, _Opt2} = Encoder) ->
+ case catch Mod:encode_message(Opt, DecodedMsg) of
+ {ok, EncodedMsg} when is_binary(EncodedMsg) ->
+ {Encoder, size(EncodedMsg)};
+ Error ->
+ {Encoder, {bad_encoder, Error}}
+ end.
+
+%%----------------------------------------------------------------------
+%% Compute time for encoding messages
+%%----------------------------------------------------------------------
+
+encoding_times() ->
+ Encoders = encoders(),
+ encoding_times(Encoders).
+
+%% Returns a list of {MessageSlogan, EncodingTimes} where
+%% EncodingTimes is the result from encoding_times/2
+encoding_times(Encoders) ->
+ [{Slogan, encoding_times(Msg, Encoders)} || {Slogan, Msg} <- messages()].
+
+%% Returns a list of {Encoder, Res} tuples
+%% where Res either is the encoding time (integer)
+%% or an error atom
+encoding_times(DecodedMsg, Encoders) ->
+ [{E, encoding_time(encoding_msg(DecodedMsg, E))} || E <- Encoders].
+
+encoding_msg(DecodedMsg, {Mod, Opt, Opt2} = Encoder) ->
+ {ok, EncodedMsg} = Mod:encode_message(Opt, DecodedMsg),
+ {ok, DecodedMsg2} = Mod:decode_message(Opt2, EncodedMsg),
+ {Encoder, DecodedMsg2}.
+
+encoding_time({{Mod, _Opt, Opt2} = Encoder, DecodedMsg}) ->
+ meter(fun() -> {ok, _} = Mod:encode_message(Opt2, DecodedMsg) end, Encoder).
+
+%%----------------------------------------------------------------------
+%% Compute time for decoding messages
+%%----------------------------------------------------------------------
+
+decoding_times() ->
+ Decoders = encoders(),
+ decoding_times(Decoders).
+
+%% Returns a list of {MessageSlogan, DecodingTimes} where
+%% DecodingTimes is the result from decoding_times/2
+decoding_times(Decoders) ->
+ [{Slogan, decoding_times(Msg, Decoders)} || {Slogan, Msg} <- messages()].
+
+%% Returns a list of {Decoder, Res} tuples
+%% where Res either is the decoding time (integer)
+%% or an error atom
+decoding_times(DecodedMsg, Encoders) ->
+ [{E, decoding_time(decoding_msg(DecodedMsg, E))} || E <- Encoders].
+
+decoding_msg(DecodedMsg, {Mod, Opt, _Opt2} = Encoder) ->
+ {ok, EncodedMsg} = Mod:encode_message(Opt, DecodedMsg),
+ {Encoder, EncodedMsg}.
+
+decoding_time({{Mod, _Opt, Opt2} = Encoder, EncodedMsg}) ->
+ meter(fun() -> {ok, _} = Mod:decode_message(Opt2, EncodedMsg) end, Encoder).
+
+%%----------------------------------------------------------------------
+%%----------------------------------------------------------------------
+
+coding_times() ->
+ Coders = encoders(),
+ coding_times(Coders).
+
+%% Returns a list of {MessageSlogan, DecodingTimes} where
+%% DecodingTimes is the result from decoding_times/2
+coding_times(Coders) ->
+ [{Slogan, coding_times(Msg, Coders)} || {Slogan, Msg} <- messages()].
+
+%% Returns a list of {Decoder, Res} tuples
+%% where Res either is the decoding time (integer)
+%% or an error atom
+coding_times(DecodedMsg, Coders) ->
+ [{E, coding_time(coding_msg(DecodedMsg, E))} || E <- Coders].
+
+coding_msg(DecodedMsg, {Mod, Opt, _Opt2} = Encoder) ->
+ {ok, EncodedMsg} = Mod:encode_message(Opt, DecodedMsg),
+ {Encoder, EncodedMsg}.
+
+coding_time({{Mod, _Opt, Opt2} = Encoder, EncodedMsg}) ->
+ Fun = fun() ->
+ {ok, DecodedMsg} = Mod:decode_message(Opt2, EncodedMsg),
+ {ok, _} = Mod:encode_message(Opt2, DecodedMsg)
+ end,
+ meter(Fun, Encoder).
+
+%%----------------------------------------------------------------------
+%% Return size statistics as term
+%%----------------------------------------------------------------------
+
+size_stat() ->
+ Encoders = encoders(),
+ MsgSizes = msg_sizes(Encoders),
+ stat(Encoders, MsgSizes).
+
+%%----------------------------------------------------------------------
+%%----------------------------------------------------------------------
+
+gnuplot_gif() ->
+ [
+ {size, gnuplot_size_gif()},
+ {encoding, gnuplot_enc_time_gif()},
+ {decoding, gnuplot_dec_time_gif()},
+ {coding, gnuplot_code_time_gif()}
+ ].
+
+%%----------------------------------------------------------------------
+%% Generate GIF picture from size statistics with gnuplot
+%%----------------------------------------------------------------------
+
+gnuplot_size_gif() ->
+ {ok, _Cwd} = file:get_cwd(),
+ TmpDir = "megaco_encoded_size.tmp",
+ GifFile = "megaco_encoded_size.gif",
+ Header =
+ ["set title \"Size comparison of Megaco/H.248 encoding formats\"\n",
+ "set timestamp top\n",
+ "set terminal gif\n",
+ "set xlabel \"Test cases from Appendix A\"\n",
+ "set ylabel \"Message size in bytes\"\n",
+ "set rmargin 10\n",
+ "set key left top Left\n",
+ "set output \"", GifFile, "\"\n\n"],
+ Encoders = encoders(),
+ Stat = msg_sizes(Encoders),
+ BatchFile = gnuplot_dir(TmpDir, Header, Encoders, Stat),
+ Cmd = "cd " ++ TmpDir ++ "; gnuplot " ++ BatchFile,
+ os:cmd(Cmd),
+ ok = io:format("~n~s~nxv ~s~n", [Cmd, filename:join([TmpDir, GifFile])]),
+ stat(Encoders, Stat).
+
+%%----------------------------------------------------------------------
+%% Return encoding time statistics as term
+%%----------------------------------------------------------------------
+
+encoding_times_stat() ->
+ Encoders = encoders(),
+ EncodingTimes = encoding_times(Encoders),
+ stat(Encoders, EncodingTimes).
+
+%%----------------------------------------------------------------------
+%% Return encoding time statistics as term
+%%----------------------------------------------------------------------
+
+decoding_times_stat() ->
+ Encoders = encoders(),
+ DecodingTimes = decoding_times(Encoders),
+ stat(Encoders, DecodingTimes).
+
+%%----------------------------------------------------------------------
+%% Return encoding time statistics as term
+%%----------------------------------------------------------------------
+
+coding_times_stat() ->
+ Encoders = encoders(),
+ CodingTimes = coding_times(Encoders),
+ stat(Encoders, CodingTimes).
+
+%%----------------------------------------------------------------------
+%% Generate GIF picture from encoding time statistics with gnuplot
+%%----------------------------------------------------------------------
+
+gnuplot_enc_time_gif() ->
+ {ok, _Cwd} = file:get_cwd(),
+ TmpDir = "megaco_encoding_time.tmp",
+ GifFile = "megaco_encoding_time.gif",
+ Header =
+ ["set title \"Encoding time comparison of Megaco/H.248 encoding formats\"\n",
+ "set timestamp top\n",
+ "set terminal gif\n",
+ "set xlabel \"Test cases from Appendix A\"\n",
+ "set ylabel \"Time for encoding in micro seconds\"\n",
+ "set rmargin 10\n",
+ "set key left top Left\n",
+ "set output \"", GifFile, "\"\n\n"],
+ Encoders = encoders(),
+ Stat = encoding_times(Encoders),
+ BatchFile = gnuplot_dir(TmpDir, Header, Encoders, Stat),
+ Cmd = "cd " ++ TmpDir ++ "; gnuplot " ++ BatchFile,
+ os:cmd(Cmd),
+ ok = io:format("~n~s~nxv ~s~n", [Cmd, filename:join([TmpDir, GifFile])]),
+ stat(Encoders, Stat).
+
+%%----------------------------------------------------------------------
+%% Generate GIF picture from decoding time statistics with gnuplot
+%%----------------------------------------------------------------------
+
+gnuplot_dec_time_gif() ->
+ {ok, _Cwd} = file:get_cwd(),
+ TmpDir = "megaco_decoding_time.tmp",
+ GifFile = "megaco_decoding_time.gif",
+ Header =
+ ["set title \"Decoding time comparison of Megaco/H.248 encoding formats\"\n",
+ "set timestamp top\n",
+ "set terminal gif\n",
+ "set xlabel \"Test cases from Appendix A\"\n",
+ "set ylabel \"Time for decoding in micro seconds\"\n",
+ "set rmargin 10\n",
+ "set key left top Left\n",
+ "set output \"", GifFile, "\"\n\n"],
+ Encoders = encoders(),
+ Stat = decoding_times(Encoders),
+ BatchFile = gnuplot_dir(TmpDir, Header, Encoders, Stat),
+ Cmd = "cd " ++ TmpDir ++ "; gnuplot " ++ BatchFile,
+ os:cmd(Cmd),
+ ok = io:format("~n~s~nxv ~s~n", [Cmd, filename:join([TmpDir, GifFile])]),
+ stat(Encoders, Stat).
+
+%%----------------------------------------------------------------------
+%% Generate GIF picture from decoding time statistics with gnuplot
+%%----------------------------------------------------------------------
+
+gnuplot_code_time_gif() ->
+ {ok, _Cwd} = file:get_cwd(),
+ TmpDir = "megaco_coding_time.tmp",
+ GifFile = "megaco_coding_time.gif",
+ Header =
+ ["set title \"Encoding + decoding time comparison of Megaco/H.248 encoding formats\"\n",
+ "set timestamp top\n",
+ "set terminal gif\n",
+ "set xlabel \"Test cases from Appendix A\"\n",
+ "set ylabel \"Time for encoding+decoding in micro seconds\"\n",
+ "set rmargin 10\n",
+ "set key left top Left\n",
+ "set output \"", GifFile, "\"\n\n"],
+ Encoders = encoders(),
+ Stat = coding_times(Encoders),
+ BatchFile = gnuplot_dir(TmpDir, Header, Encoders, Stat),
+ Cmd = "cd " ++ TmpDir ++ "; gnuplot " ++ BatchFile,
+ os:cmd(Cmd),
+ ok = io:format("~n~s~nxv ~s~n", [Cmd, filename:join([TmpDir, GifFile])]),
+ stat(Encoders, Stat).
+
+%%----------------------------------------------------------------------
+%% Encode asn.1 messages
+%%----------------------------------------------------------------------
+
+gen_byte_msg(Msg, {Mod, Opt, _Opt2} = _Encoder) ->
+ {ok, EncodedMsg} = Mod:encode_message(Opt, Msg),
+ EncodedMsg.
+
+%%----------------------------------------------------------------------
+%% Gen the C header file content as a binary
+%%----------------------------------------------------------------------
+
+gen_header_file_binary([]) ->
+ ok;
+gen_header_file_binary([{S, B}| Rest]) ->
+ file:write_file(atom_to_list(S), B),
+ gen_header_file_binary(Rest).
+
+%%----------------------------------------------------------------------
+%% Generate headerfile for asn.1 BER test in C
+%%----------------------------------------------------------------------
+
+gen_ber_header() ->
+ Encoder = {megaco_ber_encoder, [], []},
+ L = [{S, gen_byte_msg(Msg, Encoder)} || {S, Msg} <- messages()],
+ gen_header_file_binary(L).
+
+%%----------------------------------------------------------------------
+%% Generate headerfile for asn.1 BER test in C
+%%----------------------------------------------------------------------
+gen_ber_bin_header() ->
+ Encoder = {megaco_ber_bin_encoder, [], []},
+ L = [{S, gen_byte_msg(Msg, Encoder)} || {S, Msg} <- messages()],
+ gen_header_file_binary(L).
+
+%%----------------------------------------------------------------------
+%% Generate headerfile for asn.1 PER test in C
+%%----------------------------------------------------------------------
+gen_per_header() ->
+ Encoder = {megaco_per_encoder, [], []},
+ L = [{S, gen_byte_msg(Msg, Encoder)} || {S, Msg} <- messages()],
+ gen_header_file_binary(L).
+
+%%----------------------------------------------------------------------
+%% Execute a fun a number of times and return avg in millis
+%%----------------------------------------------------------------------
+
+meter(Fun, Encoder) ->
+ MaxTime = timer:seconds(5),
+ Rep = 2,
+ M = pretty_mod(Encoder),
+ io:format("~p:\t", [M]),
+ Times = [single_meter(Fun, MaxTime, {M, N}) || N <- lists:seq(1, Rep)],
+ Min = lists:min(Times),
+ Max = lists:max(Times),
+ Median = lists:nth((Rep + 1) div 2, lists:sort(Times)),
+ io:format("(median=~p, diff=~p)~n", [Median, Max - Min]),
+ Median.
+
+single_meter(Fun, MaxTime, Tag) ->
+ Pid = spawn_link(?MODULE, single_meter, [self(), Fun, MaxTime, Tag]),
+ receive
+ {meter, Pid, Time} ->
+ io:format("~p \t", [Time]),
+ Time;
+ {'EXIT', Pid, Reason} ->
+ {bad_result, Reason}
+ end.
+
+single_meter(Parent, Fun, Expected, _Tag) ->
+ erlang:statistics(runtime),
+ erlang:send_after(Expected, self(), return_count),
+ Count = count(Fun, 1),
+ {_, Actual} = erlang:statistics(runtime),
+ %% Diff = Actual - Expected,
+ Micros = trunc((Actual / Count) * 1000),
+ Parent ! {meter, self(), Micros},
+ unlink(Parent),
+ exit(normal).
+
+count(Fun, N) ->
+ Fun(),
+ receive
+ return_count ->
+ N
+ after 0 ->
+ count(Fun, N + 1)
+ end.
+
+stat(Encoders, Stat) ->
+ Fun =
+ fun({_Mod, _Opt, _Opt2} = E) ->
+ List = lists:flatten([[Val || {E2, Val} <- Info, E2 == E] ||
+ {_Slogan, Info} <- Stat]),
+ Max = lists:max(List),
+ Min = lists:min(List),
+ case catch lists:sum(List) of
+ {'EXIT', _} ->
+ {E, bad, List};
+ Sum when is_integer(Sum) ->
+ N = length(List),
+ {E, [{min, Min}, {avg, Sum div N}, {max, Max}]}
+ end
+ end,
+ lists:map(Fun, Encoders).
+
+gnuplot_dir(Dir, Header, Encoders, Stat) ->
+ file:make_dir(Dir),
+ {Names, Arrows} = gnuplot_data(Encoders, Dir, Stat, 1, [], []),
+ [H | T] = [lists:concat(["\"", N, "\" with linespoints"]) || N <- Names],
+ Plots = [[", ", Plot] || Plot <- T],
+ IoList = [Header, Arrows, "\nplot ", H, Plots, "\n\nshow output\n"],
+ Bin = list_to_binary(IoList),
+ BatchFile = "gnuplot.batch",
+ file:write_file(filename:join(Dir, BatchFile), Bin),
+ BatchFile.
+
+gnuplot_data([], _Dir, _Stat, _Pos, Names, Arrows) ->
+ {lists:reverse(Names), lists:reverse(Arrows)};
+gnuplot_data([{Mod, _Opt, _Opt2} = E | Encoders], Dir, Stat, Pos, Names, Arrows) ->
+ Plot = fun({Msg, List}, {N, AccSz}) ->
+ {value, {_, Sz}} = lists:keysearch(E, 1, List),
+ ActualSz =
+ if
+ is_integer(Sz) ->
+ Sz;
+ true ->
+ ok = io:format("<ERROR> ~p(~p) -> ~p~n",
+ [Mod, Msg, Sz]),
+ 0
+ end,
+ Acc = {N + 1, [ActualSz | AccSz]},
+ {lists:concat([N + 1, " ", ActualSz, "\n"]), Acc}
+ end,
+ {Data, {N, Sizes}} = lists:mapfoldl(Plot, {0, []}, Stat),
+ Min = lists:min(Sizes),
+ Max = lists:max(Sizes),
+ Sum = lists:sum(Sizes),
+ Avg = Sum div N,
+ Len = length(Stat),
+ Pretty = pretty_mod(E),
+ Name = lists:concat([Pretty, " (", Min, ",", Avg, ",", Max, ")"]),
+ file:write_file(filename:join(Dir, Name), list_to_binary(Data)),
+ %%"plot \"-\" title \"", E, "\" with linespoints\n", Data, "e\n",
+ Arrow =
+ lists:concat(["set arrow from 1,", Avg,
+ " to ", Len, ", ", Avg,
+ " nohead lt ", Pos, "\n",
+ "set label \" ", Avg, " (avg)\" at ", Len, ",", Avg + 10, "\n"]),
+ gnuplot_data(Encoders, Dir, Stat, Pos + 1, [Name | Names], [Arrow | Arrows]).