diff options
| author | Alexander Couzens <lynxis@fe80.eu> | 2023-11-11 18:57:03 +0100 |
|---|---|---|
| committer | Alexander Couzens <lynxis@fe80.eu> | 2023-11-11 19:18:52 +0100 |
| commit | e9c2b1ddaa2cc9eba23e8b2285a6691ba795bdf6 (patch) | |
| tree | 60578e0d366d21a1d491592bc233d4a66d1f8ffc | |
| parent | 96eb0938db167ed06b31b83c9e4c017371cdea96 (diff) | |
osmo_dia2gsup: add config option diameter_connect_timer
The diameter_connect_timer can be set to reduce the ttcn3 timing.
Otherwise every test case would need to wait for at least one connect timer period to
succeed.
Related: OS#5657
Change-Id: I669a76022d866824e7b4e9f30dd7e51aa714ae7d
| -rw-r--r-- | src/osmo_dia2gsup.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/osmo_dia2gsup.erl b/src/osmo_dia2gsup.erl index 90f5ddc..5a817fd 100644 --- a/src/osmo_dia2gsup.erl +++ b/src/osmo_dia2gsup.erl @@ -70,10 +70,12 @@ init(State) -> % DIAMETER side SvcName = ?MODULE, diameter:start_service(SvcName, ?SERVICE(SvcName)), + Ip = application:get_env(osmo_dia2gsup, diameter_ip, "127.0.0.8"), Port = application:get_env(osmo_dia2gsup, diameter_port, 3868), Proto = application:get_env(osmo_dia2gsup, diameter_proto, sctp), - listen({address, Proto, element(2,inet:parse_address(Ip)), Port}), + ConnectTimer = application:get_env(osmo_dia2gsup, diameter_connect_timer, 30000), + listen(?SVC_NAME, {address, Proto, element(2,inet:parse_address(Ip)), Port}, {timer, ConnectTimer}), lager:info("Diameter HSS Application started on IP ~s, ~p port ~p~n", [Ip, Proto, Port]), {ok, State}. @@ -114,14 +116,12 @@ terminate(_Reason, _State) -> %% Internal Function Definitions %% ------------------------------------------------------------------ -listen(Name, {address, Protocol, IPAddr, Port}) -> +listen(Name, {address, Protocol, IPAddr, Port}, {timer, ConnectTimer}) -> TransOpts = [{transport_module, tmod(Protocol)}, {transport_config, [{reuseaddr, true}, - {ip, IPAddr}, {port, Port}]}], + {ip, IPAddr}, {port, Port}]}, + {connect_timer, ConnectTimer}], {ok, _} = diameter:add_transport(Name, {listen, TransOpts}). -listen(Address) -> - listen(?SVC_NAME, Address). - tmod(tcp) -> diameter_tcp; tmod(sctp) -> diameter_sctp. |