diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/mod_sip_registrar.erl | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/mod_sip_registrar.erl b/src/mod_sip_registrar.erl index 7233d053b..8662ed74c 100644 --- a/src/mod_sip_registrar.erl +++ b/src/mod_sip_registrar.erl @@ -25,7 +25,7 @@ -define(CALL_TIMEOUT, timer:seconds(30)). -define(DEFAULT_EXPIRES, 3600). -define(FLOW_TIMEOUT_DATAGRAM, 29). --define(FLOW_TIMEOUT_STREAM, 180). +-define(FLOW_TIMEOUT_STREAM, 120). -record(sip_session, {us = {<<"">>, <<"">>} :: {binary(), binary()}, socket = #sip_socket{} :: #sip_socket{}, @@ -321,6 +321,11 @@ delete_expired_session(US, TRef) -> fun(#sip_session{reg_tref = T1, flow_tref = T2} = Session) when T1 == TRef; T2 == TRef -> + if T2 /= undefined -> + close_socket(Session); + true -> + ok + end, delete_session(Session); (_) -> ok @@ -518,6 +523,13 @@ set_monitor_and_timer(#sip_session{socket = #sip_socket{type = Type, set_timer(#sip_session{us = US}, Timeout) -> erlang:start_timer(Timeout * 1000, self(), US). +close_socket(#sip_session{socket = SIPSocket}) -> + if SIPSocket#sip_socket.type /= udp -> + esip_socket:close(SIPSocket); + true -> + ok + end. + delete_session(#sip_session{reg_tref = RegTRef, flow_tref = FlowTRef, conn_mref = MRef} = Session) -> |