kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-09-02 11:06:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

pjsip_transport_events: handle multiple addresses for a domain

Browse Source 
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 2ee258b0fc)
This commit is contained in:
Thomas Guebels
2024-10-29 15:32:33 +01:00
committed by Asterisk Development Team
parent 2b9409debf
commit 56e48b05b5
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
include/asterisk/res_pjsip.h
View File

@@ -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;

15
res/res_pjsip/pjsip_transport_events.c
View File

@@ -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)) {