diff --git a/channels/chan_sip.c b/channels/chan_sip.c index bcf05060b2..9c1b1ecca8 100644 --- a/channels/chan_sip.c +++ b/channels/chan_sip.c @@ -19456,22 +19456,28 @@ static int sip_standard_port(enum sip_transport type, int port) return port == STANDARD_SIP_PORT; } -/*! \todo document this function. */ +/*! + * \brief Find thread for TCP/TLS session (based on IP/Port + * + * \note This function returns an astobj2 reference + */ static struct ast_tcptls_session_instance *sip_tcp_locate(struct sockaddr_in *s) { struct sip_threadinfo *th; + struct ast_tcptls_session_instance *tcptls_instance = NULL; AST_LIST_LOCK(&threadl); AST_LIST_TRAVERSE(&threadl, th, list) { if ((s->sin_family == th->ser->remote_address.sin_family) && (s->sin_addr.s_addr == th->ser->remote_address.sin_addr.s_addr) && (s->sin_port == th->ser->remote_address.sin_port)) { - AST_LIST_UNLOCK(&threadl); - return th->ser; + tcptls_instance = (ao2_ref(th->ser, +1), th->ser); + break; } } AST_LIST_UNLOCK(&threadl); - return NULL; + + return tcptls_instance; } /*! \todo document this function. */ @@ -19505,7 +19511,6 @@ static int sip_prepare_socket(struct sip_pvt *p) ao2_ref(s->ser, -1); s->ser = NULL; } - ao2_ref(ser, +1); s->ser = ser; return s->fd; }