mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-24 02:31:03 +00:00
Code Issues 1 Projects Releases Wiki Activity

srtpenc: Add support for buffer list

Browse source 
https://bugzilla.gnome.org/show_bug.cgi?id=746387
This commit is contained in:
Jose Antonio Santos Cadenas 2015-03-18 10:16:41 +01:00 committed by Sebastian Dröge
parent ef4a904700
commit f295beda07
1 changed files with 104 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

105
ext/srtp/gstsrtpenc.c
View file

@ -219,6 +219,10 @@ static GstFlowReturn gst_srtp_enc_chain_rtp (GstPad * pad, GstObject * parent,
GstBuffer * buf); GstBuffer * buf);
static GstFlowReturn gst_srtp_enc_chain_rtcp (GstPad * pad, GstObject * parent, static GstFlowReturn gst_srtp_enc_chain_rtcp (GstPad * pad, GstObject * parent,
GstBuffer * buf); GstBuffer * buf);
static GstFlowReturn gst_srtp_enc_chain_list_rtp (GstPad * pad,
GstObject * parent, GstBufferList * buf);
static GstFlowReturn gst_srtp_enc_chain_list_rtcp (GstPad * pad,
GstObject * parent, GstBufferList * buf);
static gboolean gst_srtp_enc_sink_event_rtp (GstPad * pad, GstObject * parent, static gboolean gst_srtp_enc_sink_event_rtp (GstPad * pad, GstObject * parent,
GstEvent * event); GstEvent * event);
@ -511,6 +515,8 @@ create_rtp_sink (GstSrtpEnc * filter, const gchar * name)
GST_DEBUG_FUNCPTR (gst_srtp_enc_iterate_internal_links_rtp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_iterate_internal_links_rtp));
gst_pad_set_chain_function (sinkpad, gst_pad_set_chain_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_rtp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_rtp));
gst_pad_set_chain_list_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_list_rtp));
gst_pad_set_event_function (sinkpad, gst_pad_set_event_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_sink_event_rtp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_sink_event_rtp));
gst_pad_set_active (sinkpad, TRUE); gst_pad_set_active (sinkpad, TRUE);
@ -555,6 +561,8 @@ create_rtcp_sink (GstSrtpEnc * filter, const gchar * name)
GST_DEBUG_FUNCPTR (gst_srtp_enc_iterate_internal_links_rtcp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_iterate_internal_links_rtcp));
gst_pad_set_chain_function (sinkpad, gst_pad_set_chain_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_rtcp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_rtcp));
gst_pad_set_chain_list_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_chain_list_rtcp));
gst_pad_set_event_function (sinkpad, gst_pad_set_event_function (sinkpad,
GST_DEBUG_FUNCPTR (gst_srtp_enc_sink_event_rtcp)); GST_DEBUG_FUNCPTR (gst_srtp_enc_sink_event_rtcp));
gst_pad_set_active (sinkpad, TRUE); gst_pad_set_active (sinkpad, TRUE);
@ -1087,7 +1095,7 @@ gst_srtp_enc_chain (GstPad * pad, GstObject * parent, GstBuffer * buf,
GstSrtpEnc *filter = GST_SRTP_ENC (parent); GstSrtpEnc *filter = GST_SRTP_ENC (parent);
GstFlowReturn ret = GST_FLOW_OK; GstFlowReturn ret = GST_FLOW_OK;
GstPad *otherpad; GstPad *otherpad;
GstBuffer *bufout; GstBuffer *bufout = NULL;
if (!gst_srtp_enc_check_buffer (filter, buf, is_rtcp)) { if (!gst_srtp_enc_check_buffer (filter, buf, is_rtcp)) {
goto fail; goto fail;
@ -1142,6 +1150,87 @@ fail:
goto out; goto out;
} }
static GstFlowReturn
gst_srtp_enc_chain_list (GstPad * pad, GstObject * parent,
GstBufferList * buf_list, gboolean is_rtcp)
{
GstSrtpEnc *filter = GST_SRTP_ENC (parent);
GstFlowReturn ret = GST_FLOW_OK;
GstPad *otherpad;
GstBufferList *out_list = NULL;
guint i, num_buffers;
num_buffers = gst_buffer_list_length (buf_list);
GST_LOG_OBJECT (pad, "Buffer chain with list of %d", num_buffers);
for (i = 0; i < num_buffers; i++) {
GstBuffer *buf = gst_buffer_list_get (buf_list, i);
if (!gst_srtp_enc_check_buffer (filter, buf, is_rtcp)) {
goto fail;
}
}
if ((ret = gst_srtp_enc_check_set_caps (filter, pad, is_rtcp)) != GST_FLOW_OK) {
goto out;
}
GST_OBJECT_LOCK (filter);
if (!HAS_CRYPTO (filter)) {
GST_OBJECT_UNLOCK (filter);
otherpad = get_rtp_other_pad (pad);
return gst_pad_push_list (otherpad, buf_list);
}
GST_OBJECT_UNLOCK (filter);
out_list = gst_buffer_list_new ();
for (i = 0; i < num_buffers; i++) {
GstBuffer *bufout;
GstBuffer *buf = gst_buffer_list_get (buf_list, i);
if ((bufout = gst_srtp_enc_process_buffer (filter, pad, buf, is_rtcp))) {
gst_buffer_list_add (out_list, bufout);
} else {
gst_buffer_list_unref (out_list);
goto fail;
}
}
/* Push buffer to source pad */
otherpad = get_rtp_other_pad (pad);
ret = gst_pad_push_list (otherpad, out_list);
if (ret != GST_FLOW_OK) {
goto out;
}
GST_OBJECT_LOCK (filter);
if (gst_srtp_get_soft_limit_reached ()) {
GST_OBJECT_UNLOCK (filter);
g_signal_emit (filter, gst_srtp_enc_signals[SIGNAL_SOFT_LIMIT], 0);
GST_OBJECT_LOCK (filter);
if (filter->random_key && !filter->key_changed)
gst_srtp_enc_replace_random_key (filter);
}
GST_OBJECT_UNLOCK (filter);
out:
gst_buffer_list_unref (buf_list);
return ret;
fail:
ret = GST_FLOW_ERROR;
goto out;
}
static GstFlowReturn static GstFlowReturn
gst_srtp_enc_chain_rtp (GstPad * pad, GstObject * parent, GstBuffer * buf) gst_srtp_enc_chain_rtp (GstPad * pad, GstObject * parent, GstBuffer * buf)
{ {
@ -1154,6 +1243,20 @@ gst_srtp_enc_chain_rtcp (GstPad * pad, GstObject * parent, GstBuffer * buf)
return gst_srtp_enc_chain (pad, parent, buf, TRUE); return gst_srtp_enc_chain (pad, parent, buf, TRUE);
} }
static GstFlowReturn
gst_srtp_enc_chain_list_rtp (GstPad * pad, GstObject * parent,
GstBufferList * buf_list)
{
return gst_srtp_enc_chain_list (pad, parent, buf_list, FALSE);
}
static GstFlowReturn
gst_srtp_enc_chain_list_rtcp (GstPad * pad, GstObject * parent,
GstBufferList * buf_list)
{
return gst_srtp_enc_chain_list (pad, parent, buf_list, TRUE);
}
/* Change state /* Change state
*/ */