rtpsession: notify when SSRC changes

Emit a g_object_notify when the SSRc changes because of a collision.
Fixes #580144

diff --git a/gst/rtpmanager/rtpsession.c b/gst/rtpmanager/rtpsession.c
index bd72ed9..219aacf 100644 (file)
--- a/gst/rtpmanager/rtpsession.c
+++ b/gst/rtpmanager/rtpsession.c
@@ -1221,6 +1221,8 @@ rtp_session_set_internal_ssrc (RTPSession * sess, guint32 ssrc)
         GINT_TO_POINTER (sess->source->ssrc), sess->source);
   }
   RTP_SESSION_UNLOCK (sess);
         GINT_TO_POINTER (sess->source->ssrc), sess->source);
   }
   RTP_SESSION_UNLOCK (sess);

+
+  g_object_notify (G_OBJECT (sess), "internal-ssrc");

 }
 
 /**
 }
 
 /**


@@ -2435,6 +2437,7 @@ rtp_session_on_timeout (RTPSession * sess, GstClockTime current_time,
   GList *item;
   ReportData data;
   RTPSource *own;
   GList *item;
   ReportData data;
   RTPSource *own;

+  gboolean notify = FALSE;

 
   g_return_val_if_fail (RTP_IS_SESSION (sess), GST_FLOW_ERROR);
 
 
   g_return_val_if_fail (RTP_IS_SESSION (sess), GST_FLOW_ERROR);
 


@@ -2521,10 +2524,14 @@ rtp_session_on_timeout (RTPSession * sess, GstClockTime current_time,
     sess->bye_reason = NULL;
     sess->sent_bye = FALSE;
     sess->change_ssrc = FALSE;
     sess->bye_reason = NULL;
     sess->sent_bye = FALSE;
     sess->change_ssrc = FALSE;

+    notify = TRUE;

     GST_DEBUG ("changed our SSRC to %08x", own->ssrc);
   }
   RTP_SESSION_UNLOCK (sess);
 
     GST_DEBUG ("changed our SSRC to %08x", own->ssrc);
   }
   RTP_SESSION_UNLOCK (sess);
 

+  if (notify)
+    g_object_notify (G_OBJECT (sess), "internal-ssrc");
+

   /* push out the RTCP packet */
   if (data.rtcp) {
     /* close the RTCP packet */
   /* push out the RTCP packet */
   if (data.rtcp) {
     /* close the RTCP packet */