[asterisk-commits] mmichelson: branch certified-13.1 r431326 - in /certified/branches/13.1: ./ res/
SVN commits to the Asterisk project
asterisk-commits at lists.digium.com
Wed Jan 28 15:30:43 CST 2015
Author: mmichelson
Date: Wed Jan 28 15:30:40 2015
New Revision: 431326
URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=431326
Log:
Fix file descriptor leak in RTP code.
SIP requests that offered codecs incompatible with configured values
could result in the allocation of RTP and RTCP ports that would not get
reclaimed later.
ASTERISK-24666 #close
Reported by Y Ateya
Review: https://reviewboard.asterisk.org/r/4323
AST-2015-001
........
Merged revisions 431300 from http://svn.asterisk.org/svn/asterisk/branches/12
........
Merged revisions 431303 from http://svn.asterisk.org/svn/asterisk/branches/13
Modified:
certified/branches/13.1/ (props changed)
certified/branches/13.1/res/res_pjsip_sdp_rtp.c
certified/branches/13.1/res/res_pjsip_session.c
certified/branches/13.1/res/res_pjsip_t38.c
Propchange: certified/branches/13.1/
------------------------------------------------------------------------------
Binary property 'branch-13-merged' - no diff available.
Modified: certified/branches/13.1/res/res_pjsip_sdp_rtp.c
URL: http://svnview.digium.com/svn/asterisk/certified/branches/13.1/res/res_pjsip_sdp_rtp.c?view=diff&rev=431326&r1=431325&r2=431326
==============================================================================
--- certified/branches/13.1/res/res_pjsip_sdp_rtp.c (original)
+++ certified/branches/13.1/res/res_pjsip_sdp_rtp.c Wed Jan 28 15:30:40 2015
@@ -1245,6 +1245,7 @@
ast_rtp_instance_stop(session_media->rtp);
ast_rtp_instance_destroy(session_media->rtp);
}
+ session_media->rtp = NULL;
}
/*! \brief SDP handler for 'audio' media stream */
Modified: certified/branches/13.1/res/res_pjsip_session.c
URL: http://svnview.digium.com/svn/asterisk/certified/branches/13.1/res/res_pjsip_session.c?view=diff&rev=431326&r1=431325&r2=431326
==============================================================================
--- certified/branches/13.1/res/res_pjsip_session.c (original)
+++ certified/branches/13.1/res/res_pjsip_session.c Wed Jan 28 15:30:40 2015
@@ -184,6 +184,26 @@
void ast_sip_session_unregister_sdp_handler(struct ast_sip_session_sdp_handler *handler, const char *stream_type)
{
ao2_callback_data(sdp_handlers, OBJ_KEY | OBJ_UNLINK | OBJ_NODATA, remove_handler, (void *)stream_type, handler);
+}
+
+/*!
+ * \brief Set an SDP stream handler for a corresponding session media.
+ *
+ * \note Always use this function to set the SDP handler for a session media.
+ *
+ * This function will properly free resources on the SDP handler currently being
+ * used by the session media, then set the session media to use the new SDP
+ * handler.
+ */
+static void session_media_set_handler(struct ast_sip_session_media *session_media,
+ struct ast_sip_session_sdp_handler *handler)
+{
+ ast_assert(session_media->handler != handler);
+
+ if (session_media->handler) {
+ session_media->handler->stream_destroy(session_media);
+ }
+ session_media->handler = handler;
}
static int handle_incoming_sdp(struct ast_sip_session *session, const pjmedia_sdp_session *sdp)
@@ -235,6 +255,9 @@
continue;
}
AST_LIST_TRAVERSE(&handler_list->list, handler, next) {
+ if (handler == session_media->handler) {
+ continue;
+ }
ast_debug(1, "Negotiating incoming SDP media stream '%s' using %s SDP handler\n",
session_media->stream_type,
handler->id);
@@ -249,7 +272,7 @@
session_media->stream_type,
handler->id);
/* Handled by this handler. Move to the next stream */
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
handled = 1;
break;
}
@@ -317,6 +340,9 @@
continue;
}
AST_LIST_TRAVERSE(&handler_list->list, handler, next) {
+ if (handler == session_media->handler) {
+ continue;
+ }
ast_debug(1, "Applying negotiated SDP media stream '%s' using %s SDP handler\n",
session_media->stream_type,
handler->id);
@@ -331,7 +357,7 @@
session_media->stream_type,
handler->id);
/* Handled by this handler. Move to the next stream */
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
return CMP_MATCH;
}
}
@@ -744,6 +770,9 @@
continue;
}
AST_LIST_TRAVERSE(&handler_list->list, handler, next) {
+ if (handler == session_media->handler) {
+ continue;
+ }
if (!handler->defer_incoming_sdp_stream) {
continue;
}
@@ -753,15 +782,15 @@
case AST_SIP_SESSION_SDP_DEFER_NOT_HANDLED:
continue;
case AST_SIP_SESSION_SDP_DEFER_ERROR:
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
return 0;
case AST_SIP_SESSION_SDP_DEFER_NOT_NEEDED:
/* Handled by this handler. */
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
break;
case AST_SIP_SESSION_SDP_DEFER_NEEDED:
/* Handled by this handler. */
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
return 1;
}
/* Move to the next stream */
@@ -922,9 +951,21 @@
static void session_media_dtor(void *obj)
{
struct ast_sip_session_media *session_media = obj;
- if (session_media->handler) {
- session_media->handler->stream_destroy(session_media);
- }
+ struct sdp_handler_list *handler_list;
+ /* It is possible for SDP handlers to allocate memory on a session_media but
+ * not end up getting set as the handler for this session_media. This traversal
+ * ensures that all memory allocated by SDP handlers on the session_media is
+ * cleared (as well as file descriptors, etc.).
+ */
+ handler_list = ao2_find(sdp_handlers, session_media->stream_type, OBJ_KEY);
+ if (handler_list) {
+ struct ast_sip_session_sdp_handler *handler;
+
+ AST_LIST_TRAVERSE(&handler_list->list, handler, next) {
+ handler->stream_destroy(session_media);
+ }
+ }
+ ao2_cleanup(handler_list);
if (session_media->srtp) {
ast_sdp_srtp_destroy(session_media->srtp);
}
@@ -2088,6 +2129,9 @@
/* no handler for this stream type and we have a list to search */
AST_LIST_TRAVERSE(&handler_list->list, handler, next) {
+ if (handler == session_media->handler) {
+ continue;
+ }
res = handler->create_outgoing_sdp_stream(session, session_media, answer);
if (res < 0) {
/* catastrophic error */
@@ -2095,7 +2139,7 @@
}
if (res > 0) {
/* Handled by this handler. Move to the next stream */
- session_media->handler = handler;
+ session_media_set_handler(session_media, handler);
return CMP_MATCH;
}
}
Modified: certified/branches/13.1/res/res_pjsip_t38.c
URL: http://svnview.digium.com/svn/asterisk/certified/branches/13.1/res/res_pjsip_t38.c?view=diff&rev=431326&r1=431325&r2=431326
==============================================================================
--- certified/branches/13.1/res/res_pjsip_t38.c (original)
+++ certified/branches/13.1/res/res_pjsip_t38.c Wed Jan 28 15:30:40 2015
@@ -816,6 +816,7 @@
if (session_media->udptl) {
ast_udptl_destroy(session_media->udptl);
}
+ session_media->udptl = NULL;
}
/*! \brief SDP handler for 'image' media stream */
More information about the asterisk-commits
mailing list