FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

rtpmux: Send stream-start before caps

Browse Source
This commit is contained in:
Nicolas Dufresne 2013-05-11 23:24:36 -04:00 committed by Sebastian Dröge
parent 7719b19aec
commit 04c9f43567
3 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
gst/rtpmanager/gstrtpmux.c
View File

@ -554,6 +554,16 @@ gst_rtp_mux_setcaps (GstPad * pad, GstRTPMux * rtp_mux, GstCaps * caps)
"clock-base", G_TYPE_UINT, rtp_mux->ts_base, "clock-base", G_TYPE_UINT, rtp_mux->ts_base,
"seqnum-base", G_TYPE_UINT, rtp_mux->seqnum_base, NULL); "seqnum-base", G_TYPE_UINT, rtp_mux->seqnum_base, NULL);
if (rtp_mux->send_stream_start) {
gchar s_id[32];
/* stream-start (FIXME: create id based on input ids) */
g_snprintf (s_id, sizeof (s_id), "interleave-%08x", g_random_int ());
gst_pad_push_event (rtp_mux->srcpad, gst_event_new_stream_start (s_id));
rtp_mux->send_stream_start = FALSE;
}
GST_DEBUG_OBJECT (rtp_mux, GST_DEBUG_OBJECT (rtp_mux,
"setting caps %" GST_PTR_FORMAT " on src pad..", caps); "setting caps %" GST_PTR_FORMAT " on src pad..", caps);
ret = gst_pad_set_caps (rtp_mux->srcpad, caps); ret = gst_pad_set_caps (rtp_mux->srcpad, caps);
@ -815,6 +825,7 @@ gst_rtp_mux_ready_to_paused (GstRTPMux * rtp_mux)
GST_OBJECT_LOCK (rtp_mux); GST_OBJECT_LOCK (rtp_mux);
g_clear_object (&rtp_mux->last_pad); g_clear_object (&rtp_mux->last_pad);
rtp_mux->send_stream_start = TRUE;
if (rtp_mux->ssrc == -1) if (rtp_mux->ssrc == -1)
rtp_mux->current_ssrc = g_random_int (); rtp_mux->current_ssrc = g_random_int ();

1
gst/rtpmanager/gstrtpmux.h
View File

@ -75,6 +75,7 @@ struct _GstRTPMux
GstPad *last_pad; /* protected by object lock */ GstPad *last_pad; /* protected by object lock */
GstClockTime last_stop; GstClockTime last_stop;
gboolean send_stream_start;
}; };
struct _GstRTPMuxClass struct _GstRTPMuxClass

5
tests/check/elements/rtpmux.c
View File

@ -148,6 +148,11 @@ test_basic (const gchar * elem_name, const gchar * sink2, int count,
gst_pad_set_active (src1, TRUE); gst_pad_set_active (src1, TRUE);
gst_pad_set_active (src2, TRUE); gst_pad_set_active (src2, TRUE);
fail_unless (gst_pad_push_event (src1,
gst_event_new_stream_start ("stream1")));
fail_unless (gst_pad_push_event (src2,
gst_event_new_stream_start ("stream2")));
gst_caps_set_simple (sinkcaps, gst_caps_set_simple (sinkcaps,
"payload", G_TYPE_INT, 98, "seqnum-base", G_TYPE_UINT, 100, "payload", G_TYPE_INT, 98, "seqnum-base", G_TYPE_UINT, 100,
"clock-base", G_TYPE_UINT, 1000, "ssrc", G_TYPE_UINT, 66, NULL); "clock-base", G_TYPE_UINT, 1000, "ssrc", G_TYPE_UINT, 66, NULL);