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

dtls: drop upstream segment and stream-start events

Browse Source 
Fixes tests with GstHarness

We will push our own from the srcpad task.
This commit is contained in:
Matthew Waters 2018-02-05 16:57:52 +11:00
parent dc452aa799
commit eaef193d08
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
ext/dtls/gstdtlsenc.c
View File

@ -96,6 +96,7 @@ static gboolean src_activate_mode (GstPad *, GstObject *, GstPadMode,
static void src_task_loop (GstPad *); static void src_task_loop (GstPad *);
static GstFlowReturn sink_chain (GstPad *, GstObject *, GstBuffer *); static GstFlowReturn sink_chain (GstPad *, GstObject *, GstBuffer *);
static gboolean sink_event (GstPad * pad, GstObject * parent, GstEvent * event);
static void on_key_received (GstDtlsConnection *, gpointer key, guint cipher, static void on_key_received (GstDtlsConnection *, gpointer key, guint cipher,
guint auth, GstDtlsEnc *); guint auth, GstDtlsEnc *);
@ -355,6 +356,7 @@ gst_dtls_enc_request_new_pad (GstElement * element,
} }
gst_pad_set_chain_function (sink, GST_DEBUG_FUNCPTR (sink_chain)); gst_pad_set_chain_function (sink, GST_DEBUG_FUNCPTR (sink_chain));
gst_pad_set_event_function (sink, GST_DEBUG_FUNCPTR (sink_event));
ret = gst_pad_set_active (sink, TRUE); ret = gst_pad_set_active (sink, TRUE);
g_warn_if_fail (ret); g_warn_if_fail (ret);
@ -493,6 +495,29 @@ sink_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
return GST_FLOW_OK; return GST_FLOW_OK;
} }
static gboolean
sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
{
gboolean ret = FALSE;
switch (GST_EVENT_TYPE (event)) {
/* Drop segment, stream-start as we will push our own from the src pad
* task.
* FIXME: do we need any information from upstream for pushing our own? */
case GST_EVENT_SEGMENT:
case GST_EVENT_STREAM_START:
gst_event_unref (event);
ret = TRUE;
break;
default:
ret = gst_pad_event_default (pad, parent, event);
break;
}
return ret;
}
static void static void
on_key_received (GstDtlsConnection * connection, gpointer key, guint cipher, on_key_received (GstDtlsConnection * connection, gpointer key, guint cipher,
guint auth, GstDtlsEnc * self) guint auth, GstDtlsEnc * self)