mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-10 17:35:59 +00:00
Code Issues 1 Projects Releases Wiki Activity

dtlsenc: Handle pad activity states properly

Browse source
This commit is contained in:
Sebastian Dröge 2015-03-18 17:38:35 +01:00
parent ff01df1093
commit 4fed95c534
2 changed files with 30 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
ext/dtls/gstdtlsenc.c
View file

@ -368,6 +368,7 @@ src_activate_mode (GstPad * pad, GstObject * parent, GstPadMode mode,
if (active) { if (active) {
GST_DEBUG_OBJECT (self, "src pad activating in push mode"); GST_DEBUG_OBJECT (self, "src pad activating in push mode");
self->flushing = FALSE;
self->send_initial_events = TRUE; self->send_initial_events = TRUE;
success = success =
gst_pad_start_task (pad, (GstTaskFunction) src_task_loop, self->src, gst_pad_start_task (pad, (GstTaskFunction) src_task_loop, self->src,
@ -379,7 +380,7 @@ src_activate_mode (GstPad * pad, GstObject * parent, GstPadMode mode,
GST_DEBUG_OBJECT (self, "deactivating src pad"); GST_DEBUG_OBJECT (self, "deactivating src pad");
g_mutex_lock (&self->queue_lock); g_mutex_lock (&self->queue_lock);
GST_PAD_MODE (pad) = GST_PAD_MODE_NONE; self->flushing = TRUE;
g_cond_signal (&self->queue_cond_add); g_cond_signal (&self->queue_cond_add);
g_mutex_unlock (&self->queue_lock); g_mutex_unlock (&self->queue_lock);
success = gst_pad_stop_task (pad); success = gst_pad_stop_task (pad);
@ -396,14 +397,14 @@ src_task_loop (GstPad * pad)
{ {
GstDtlsEnc *self = GST_DTLS_ENC (GST_PAD_PARENT (pad)); GstDtlsEnc *self = GST_DTLS_ENC (GST_PAD_PARENT (pad));
GstFlowReturn ret; GstFlowReturn ret;
GstPad *peer; GstBuffer *buffer;
gboolean peer_is_active; gboolean start_connection_timeout = FALSE;
GST_TRACE_OBJECT (self, "src loop: acquiring lock"); GST_TRACE_OBJECT (self, "src loop: acquiring lock");
g_mutex_lock (&self->queue_lock); g_mutex_lock (&self->queue_lock);
GST_TRACE_OBJECT (self, "src loop: acquired lock"); GST_TRACE_OBJECT (self, "src loop: acquired lock");
if (!gst_pad_is_active (pad)) { if (self->flushing) {
GST_LOG_OBJECT (self, "src task loop entered on inactive pad"); GST_LOG_OBJECT (self, "src task loop entered on inactive pad");
GST_TRACE_OBJECT (self, "src loop: releasing lock"); GST_TRACE_OBJECT (self, "src loop: releasing lock");
g_mutex_unlock (&self->queue_lock); g_mutex_unlock (&self->queue_lock);
@ -415,7 +416,7 @@ src_task_loop (GstPad * pad)
g_cond_wait (&self->queue_cond_add, &self->queue_lock); g_cond_wait (&self->queue_cond_add, &self->queue_lock);
GST_TRACE_OBJECT (self, "src loop: add signaled"); GST_TRACE_OBJECT (self, "src loop: add signaled");
if (!gst_pad_is_active (pad)) { if (self->flushing) {
GST_LOG_OBJECT (self, "pad inactive, task returning"); GST_LOG_OBJECT (self, "pad inactive, task returning");
GST_TRACE_OBJECT (self, "src loop: releasing lock"); GST_TRACE_OBJECT (self, "src loop: releasing lock");
g_mutex_unlock (&self->queue_lock); g_mutex_unlock (&self->queue_lock);
@ -424,48 +425,35 @@ src_task_loop (GstPad * pad)
} }
GST_TRACE_OBJECT (self, "src loop: queue has element"); GST_TRACE_OBJECT (self, "src loop: queue has element");
peer = gst_pad_get_peer (pad); buffer = g_queue_pop_head (&self->queue);
peer_is_active = gst_pad_is_active (peer); g_mutex_unlock (&self->queue_lock);
gst_object_unref (peer);
if (peer_is_active) { if (self->send_initial_events) {
GstBuffer *buffer; GstSegment segment;
gboolean start_connection_timeout = FALSE; gchar s_id[32];
GstCaps *caps;
buffer = g_queue_pop_head (&self->queue); self->send_initial_events = FALSE;
g_mutex_unlock (&self->queue_lock);
if (self->send_initial_events) { g_snprintf (s_id, sizeof (s_id), "dtlsenc-%08x", g_random_int ());
GstSegment segment; gst_pad_push_event (self->src, gst_event_new_stream_start (s_id));
gchar s_id[32]; caps = gst_caps_new_empty_simple ("application/x-dtls");
GstCaps *caps; gst_pad_push_event (self->src, gst_event_new_caps (caps));
gst_caps_unref (caps);
gst_segment_init (&segment, GST_FORMAT_BYTES);
gst_pad_push_event (self->src, gst_event_new_segment (&segment));
start_connection_timeout = TRUE;
}
self->send_initial_events = FALSE; GST_TRACE_OBJECT (self, "src loop: releasing lock");
g_snprintf (s_id, sizeof (s_id), "dtlsenc-%08x", g_random_int ()); ret = gst_pad_push (self->src, buffer);
gst_pad_push_event (self->src, gst_event_new_stream_start (s_id)); if (start_connection_timeout)
caps = gst_caps_new_empty_simple ("application/x-dtls"); gst_dtls_connection_start_timeout (self->connection);
gst_pad_push_event (self->src, gst_event_new_caps (caps));
gst_caps_unref (caps);
gst_segment_init (&segment, GST_FORMAT_BYTES);
gst_pad_push_event (self->src, gst_event_new_segment (&segment));
start_connection_timeout = TRUE;
}
GST_TRACE_OBJECT (self, "src loop: releasing lock"); if (G_UNLIKELY (ret != GST_FLOW_OK)) {
GST_WARNING_OBJECT (self, "failed to push buffer on src pad: %s",
ret = gst_pad_push (self->src, buffer); gst_flow_get_name (ret));
if (start_connection_timeout)
gst_dtls_connection_start_timeout (self->connection);
if (G_UNLIKELY (ret != GST_FLOW_OK)) {
GST_WARNING_OBJECT (self, "failed to push buffer on src pad: %s",
gst_flow_get_name (ret));
}
} else {
g_mutex_unlock (&self->queue_lock);
g_warn_if_reached ();
GST_TRACE_OBJECT (self, "src loop: releasing lock");
} }
} }

1
ext/dtls/gstdtlsenc.h
View file

@ -50,6 +50,7 @@ struct _GstDtlsEnc {
GQueue queue; GQueue queue;
GMutex queue_lock; GMutex queue_lock;
GCond queue_cond_add; GCond queue_cond_add;
gboolean flushing;
GstDtlsConnection *connection; GstDtlsConnection *connection;
gchar *connection_id; gchar *connection_id;