From 6795ded3f4ecfa2d34babd5d713913d3396e6a16 Mon Sep 17 00:00:00 2001 From: Thomas Guebels Date: Tue, 29 Oct 2024 15:32:33 +0100 Subject: [PATCH] pjsip_transport_events: handle multiple addresses for a domain The key used for transport monitors was the remote host name for the transport and not the remote address resolved for this domain. This was problematic for domains returning multiple addresses as several transport monitors were created with the same key. Whenever a subsystem wanted to register a callback it would always end up attached to the first transport monitor with a matching key. The key used for transport monitors is now the remote address and port the transport actually connected to. Fixes: #932 (cherry picked from commit 184a30efac73d763781784b8632749d1d5be41b7) --- include/asterisk/res_pjsip.h | 5 +---- res/res_pjsip/pjsip_transport_events.c | 15 +++++++++------ 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/include/asterisk/res_pjsip.h b/include/asterisk/res_pjsip.h index dc66a40184..421acf4ee3 100644 --- a/include/asterisk/res_pjsip.h +++ b/include/asterisk/res_pjsip.h @@ -88,10 +88,7 @@ * \param _dest The destination buffer of at least IP6ADDR_COLON_PORT_BUFLEN bytes */ #define AST_SIP_MAKE_REMOTE_IPADDR_PORT_STR(_transport, _dest) \ - snprintf(_dest, IP6ADDR_COLON_PORT_BUFLEN, \ - PJSTR_PRINTF_SPEC ":%d", \ - PJSTR_PRINTF_VAR(_transport->remote_name.host), \ - _transport->remote_name.port); + pj_sockaddr_print(&_transport->key.rem_addr, _dest, sizeof(_dest), 1); /* Forward declarations of PJSIP stuff */ struct pjsip_rx_data; diff --git a/res/res_pjsip/pjsip_transport_events.c b/res/res_pjsip/pjsip_transport_events.c index aa575b7d58..65a740cb2c 100644 --- a/res/res_pjsip/pjsip_transport_events.c +++ b/res/res_pjsip/pjsip_transport_events.c @@ -173,6 +173,7 @@ static void transport_state_do_reg_callbacks(struct ao2_container *transports, p static void verify_log_result(int log_level, const pjsip_transport *transport, pj_uint32_t verify_status) { + char transport_remote_ipaddr_port[IP6ADDR_COLON_PORT_BUFLEN]; const char *status[32]; unsigned int count; unsigned int i; @@ -184,9 +185,11 @@ static void verify_log_result(int log_level, const pjsip_transport *transport, return; } + AST_SIP_MAKE_REMOTE_IPADDR_PORT_STR(transport, transport_remote_ipaddr_port); for (i = 0; i < count; ++i) { - ast_log(log_level, _A_, "Transport '%s' to remote '%.*s' - %s\n", transport->factory->info, + ast_log(log_level, _A_, "Transport '%s' to remote '%.*s' - %s - %s\n", transport->factory->info, (int)pj_strlen(&transport->remote_name.host), pj_strbuf(&transport->remote_name.host), + transport_remote_ipaddr_port, status[i]); } } @@ -291,16 +294,16 @@ static void transport_state_callback(pjsip_transport *transport, pjsip_transport_state state, const pjsip_transport_state_info *info) { struct ao2_container *transports; + char transport_remote_ipaddr_port[IP6ADDR_COLON_PORT_BUFLEN]; /* We only care about monitoring reliable transports */ if (PJSIP_TRANSPORT_IS_RELIABLE(transport) && (transports = ao2_global_obj_ref(active_transports))) { struct transport_monitor *monitored; + AST_SIP_MAKE_REMOTE_IPADDR_PORT_STR(transport, transport_remote_ipaddr_port); - ast_debug(3, "Transport " PJSTR_PRINTF_SPEC ":%d(%s,%s): RefCnt: %ld state:%s\n", - PJSTR_PRINTF_VAR(transport->remote_name.host), - transport->remote_name.port, transport->obj_name, - transport->type_name, + ast_debug(3, "Transport %s(%s,%s): RefCnt: %ld state:%s\n", + transport_remote_ipaddr_port, transport->obj_name, transport->type_name, pj_atomic_get(transport->ref_cnt), transport_state2str(state)); switch (state) { case PJSIP_TP_STATE_CONNECTED: @@ -316,7 +319,7 @@ static void transport_state_callback(pjsip_transport *transport, break; } monitored->transport = transport; - AST_SIP_MAKE_REMOTE_IPADDR_PORT_STR(transport, monitored->key); + ast_copy_string(monitored->key, transport_remote_ipaddr_port, sizeof(monitored->key)); monitored->transport_obj_name = ast_strdup(transport->obj_name); if (AST_VECTOR_INIT(&monitored->monitors, 5)) {