res_pjsip_session: Check for removed stream state.

When a sip session is refreshed, the stream topology is looped
through, checking each stream for compatible formats. This would
cause a crash if the stream state was AST_STREAM_STATE_REMOVED,
since the formats would never be set for this stream, causing
a NULL value to be returned from ast_stream_get_formats. This
commit adds a check for streams with removed states.

Also removed a stray semicolon.

Change-Id: Ic86f8b65a4a26a60885b28b8b1a0b22e1b471d42

diff --git a/main/bridge.c b/main/bridge.c
index ab12ecf64666ee844e796fd61d5c8c8f568cf0c9..5d9c0c1f756a381605905c9a01e3f6ce8091f74c 100644 (file)
--- a/main/bridge.c
+++ b/main/bridge.c
@@ -1741,7 +1741,7 @@ int ast_bridge_join(struct ast_bridge *bridge,
 
        ao2_ref(bridge_channel, -1);
 
-join_exit:;
+join_exit:
        ast_bridge_run_after_callback(chan);
        bridge_channel_impart_signal(chan);
        if (!(ast_channel_softhangup_internal_flag(chan) & AST_SOFTHANGUP_ASYNCGOTO)

diff --git a/res/res_pjsip_sdp_rtp.c b/res/res_pjsip_sdp_rtp.c
index e095f06604c2f7432c1c8ee2ea4e51c931eabf29..8ec57aa8e1ea5552a0a5520666b751a885e6b01b 100644 (file)
--- a/res/res_pjsip_sdp_rtp.c
+++ b/res/res_pjsip_sdp_rtp.c
@@ -1338,7 +1338,7 @@ static int create_outgoing_sdp_stream(struct ast_sip_session *session, struct as
                media->desc.port = 0;
                media->desc.port_count = 1;
 
-               if (remote) {
+               if (remote && remote->media[ast_stream_get_position(stream)]) {
                        pjmedia_sdp_media *remote_media = remote->media[ast_stream_get_position(stream)];
                        int index;
 

diff --git a/res/res_pjsip_session.c b/res/res_pjsip_session.c
index 64416a0636fc91f0753e2014f4ddf14138a2d6cb..77ddfbc146b3d8dbb563cc63f261468168ebd8ef 100644 (file)
--- a/res/res_pjsip_session.c
+++ b/res/res_pjsip_session.c
@@ -1455,6 +1455,10 @@ int ast_sip_session_refresh(struct ast_sip_session *session,
                                        continue;
                                }
 
+                               /* No need to do anything with stream if it's media state is removed */
+                               if (ast_stream_get_state(stream) == AST_STREAM_STATE_REMOVED) {
+                                       continue;
+                               }
 
                                /* Enforce the configured allowed codecs on audio and video streams */
                                if (ast_stream_get_type(stream) == AST_MEDIA_TYPE_AUDIO || ast_stream_get_type(stream) == AST_MEDIA_TYPE_VIDEO) {
@@ -1465,14 +1469,12 @@ int ast_sip_session_refresh(struct ast_sip_session *session,
                                                ast_sip_session_media_state_free(media_state);
                                                return 0;
                                        }
-
                                        ast_format_cap_get_compatible(ast_stream_get_formats(stream), session->endpoint->media.codecs, joint_cap);
                                        if (!ast_format_cap_count(joint_cap)) {
                                                ao2_ref(joint_cap, -1);
-                                               ast_sip_session_media_state_free(media_state);
-                                               return 0;
+                                               ast_stream_set_state(stream, AST_STREAM_STATE_REMOVED);
+                                               continue;
                                        }
-
                                        ast_stream_set_formats(stream, joint_cap);
                                }