mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-02 12:32:29 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtpsession: send stream-start and segment events

Browse source 
Also send stream-start and segment event on the RTCP pad.
We don't need to send anything on the sync_src pad because we
already forwarded all incomming events.
This commit is contained in:
Wim Taymans 2013-05-28 12:23:37 +02:00
parent 779bcc093c
commit 63f0ecbbe7
1 changed files with 27 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
gst/rtpmanager/gstrtpsession.c
View file

@ -1101,6 +1101,31 @@ gst_rtp_session_send_rtp (RTPSession * sess, RTPSource * src,
return result; return result;
} }
static void
do_rtcp_events (GstRtpSession * rtpsession, GstPad * srcpad)
{
GstCaps *caps;
GstSegment seg;
GstEvent *event;
gchar *stream_id;
stream_id =
g_strdup_printf ("%08x%08x%08x%08x", g_random_int (), g_random_int (),
g_random_int (), g_random_int ());
event = gst_event_new_stream_start (stream_id);
gst_pad_push_event (srcpad, event);
g_free (stream_id);
caps = gst_caps_new_empty_simple ("application/x-rtcp");
gst_pad_set_caps (srcpad, caps);
gst_caps_unref (caps);
gst_segment_init (&seg, GST_FORMAT_TIME);
event = gst_event_new_segment (&seg);
gst_pad_push_event (srcpad, event);
}
/* called when the session manager has an RTCP packet ready for further /* called when the session manager has an RTCP packet ready for further
* sending. The eos flag is set when an EOS event should be sent downstream as * sending. The eos flag is set when an EOS event should be sent downstream as
* well. */ * well. */
@ -1119,17 +1144,12 @@ gst_rtp_session_send_rtcp (RTPSession * sess, RTPSource * src,
goto stopping; goto stopping;
if ((rtcp_src = rtpsession->send_rtcp_src)) { if ((rtcp_src = rtpsession->send_rtcp_src)) {
GstCaps *caps;
gst_object_ref (rtcp_src); gst_object_ref (rtcp_src);
GST_RTP_SESSION_UNLOCK (rtpsession); GST_RTP_SESSION_UNLOCK (rtpsession);
/* set rtcp caps on output pad */ /* set rtcp caps on output pad */
if (!(caps = gst_pad_get_current_caps (rtcp_src))) { if (!gst_pad_has_current_caps (rtcp_src))
caps = gst_caps_new_empty_simple ("application/x-rtcp"); do_rtcp_events (rtpsession, rtcp_src);
gst_pad_set_caps (rtcp_src, caps);
}
gst_caps_unref (caps);
GST_LOG_OBJECT (rtpsession, "sending RTCP"); GST_LOG_OBJECT (rtpsession, "sending RTCP");
result = gst_pad_push (rtcp_src, buffer); result = gst_pad_push (rtcp_src, buffer);
@ -1176,18 +1196,9 @@ gst_rtp_session_sync_rtcp (RTPSession * sess, RTPSource * src,
goto stopping; goto stopping;
if ((sync_src = rtpsession->sync_src)) { if ((sync_src = rtpsession->sync_src)) {
GstCaps *caps;
gst_object_ref (sync_src); gst_object_ref (sync_src);
GST_RTP_SESSION_UNLOCK (rtpsession); GST_RTP_SESSION_UNLOCK (rtpsession);
/* set rtcp caps on output pad */
if (!(caps = gst_pad_get_current_caps (sync_src))) {
caps = gst_caps_new_empty_simple ("application/x-rtcp");
gst_pad_set_caps (sync_src, caps);
}
gst_caps_unref (caps);
GST_LOG_OBJECT (rtpsession, "sending Sync RTCP"); GST_LOG_OBJECT (rtpsession, "sending Sync RTCP");
result = gst_pad_push (sync_src, buffer); result = gst_pad_push (sync_src, buffer);
gst_object_unref (sync_src); gst_object_unref (sync_src);