mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-19 23:06:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtpmux: More Refactoring

Browse source 
20070322113228-65035-bae34a79599e7de5293ed77b022361ccff822bb9.gz
This commit is contained in:
zeeshan.ali@nokia.com 2007-03-22 11:32:28 +00:00 committed by Tim-Philipp Müller
parent 0f755657ce
commit 0de7fb6f37
1 changed files with 72 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

124
gst/rtpmanager/gstrtpdtmfmux.c
View file

@ -187,8 +187,42 @@ gst_rtp_dtmf_mux_chain (GstPad * pad, GstBuffer * buffer)
return ret; return ret;
} }
static void
gst_rtp_dtmf_mux_lock_stream (GstRTPDTMFMux *mux, GstPad * pad)
{
if (mux->special_pad != NULL) {
GST_WARNING_OBJECT (mux,
"Stream lock already acquired by pad %s",
GST_ELEMENT_NAME (mux->special_pad));
}
else
mux->special_pad = gst_object_ref (pad);
}
static void
gst_rtp_dtmf_mux_unlock_stream (GstRTPDTMFMux *mux, GstPad * pad)
{
if (mux->special_pad == NULL) {
GST_WARNING_OBJECT (mux,
"Stream lock not acquired, can't release it");
}
else if (pad != mux->special_pad) {
GST_WARNING_OBJECT (mux,
"pad %s attempted to release Stream lock"
" which was acquired by pad %s", GST_ELEMENT_NAME (pad),
GST_ELEMENT_NAME (mux->special_pad));
}
else {
gst_object_unref (mux->special_pad);
mux->special_pad = NULL;
}
}
static gboolean static gboolean
gst_rtp_dtmf_mux_stream_lock_event_handler (GstRTPDTMFMux *mux, GstPad * pad, gst_rtp_dtmf_mux_handle_stream_lock_event (GstRTPDTMFMux *mux, GstPad * pad,
const GstStructure * event_structure) const GstStructure * event_structure)
{ {
gboolean lock; gboolean lock;
@ -197,41 +231,46 @@ gst_rtp_dtmf_mux_stream_lock_event_handler (GstRTPDTMFMux *mux, GstPad * pad,
return FALSE; return FALSE;
GST_OBJECT_LOCK (mux); GST_OBJECT_LOCK (mux);
if (lock) { if (lock)
if (mux->special_pad != NULL) { gst_rtp_dtmf_mux_lock_stream (mux, pad);
GST_WARNING_OBJECT (mux, else
"Stream lock already acquired by pad %s", gst_rtp_dtmf_mux_unlock_stream (mux, pad);
GST_ELEMENT_NAME (mux->special_pad));
}
else
mux->special_pad = gst_object_ref (pad);
}
else {
if (mux->special_pad == NULL) {
GST_WARNING_OBJECT (mux,
"Stream lock not acquired, can't release it");
}
else if (pad != mux->special_pad) {
GST_WARNING_OBJECT (mux,
"pad %s attempted to release Stream lock"
" which was acquired by pad %s", GST_ELEMENT_NAME (pad),
GST_ELEMENT_NAME (mux->special_pad));
}
else {
gst_object_unref (mux->special_pad);
mux->special_pad = NULL;
}
}
GST_OBJECT_UNLOCK (mux); GST_OBJECT_UNLOCK (mux);
return TRUE; return TRUE;
} }
static gboolean
gst_rtp_dtmf_mux_handle_downstream_event (GstRTPDTMFMux *mux, GstPad * pad, GstEvent * event)
{
const GstStructure *structure;
gboolean ret = FALSE;
structure = gst_event_get_structure (event);
/* FIXME: is this event generic enough to be given a generic name? */
if (structure && gst_structure_has_name (structure, "stream-lock")) {
ret = gst_rtp_dtmf_mux_handle_stream_lock_event (mux, pad, structure);
}
return ret;
}
static gboolean
gst_rtp_dtmf_mux_ignore_event (GstPad * pad, GstEvent * event)
{
gboolean ret;
if (parent_class->sink_event_func) {
/* Give the parent a chance to handle the event first */
ret = parent_class->sink_event_func (pad, event);
}
else
ret = gst_pad_event_default (pad, event);
return ret;
}
static gboolean static gboolean
gst_rtp_dtmf_mux_sink_event (GstPad * pad, GstEvent * event) gst_rtp_dtmf_mux_sink_event (GstPad * pad, GstEvent * event)
{ {
@ -245,33 +284,14 @@ gst_rtp_dtmf_mux_sink_event (GstPad * pad, GstEvent * event)
switch (type) { switch (type) {
case GST_EVENT_CUSTOM_DOWNSTREAM_OOB: case GST_EVENT_CUSTOM_DOWNSTREAM_OOB:
{ ret = gst_rtp_dtmf_mux_handle_downstream_event (mux, pad, event);
const GstStructure *structure;
structure = gst_event_get_structure (event);
/* FIXME: is this event generic enough to be given a generic name? */
if (structure && gst_structure_has_name (structure, "stream-lock")) {
ret = gst_rtp_dtmf_mux_stream_lock_event_handler (mux, pad, structure);
}
ret = TRUE;
break; break;
}
default: default:
{ ret = gst_rtp_dtmf_mux_ignore_event (pad, event);
if (parent_class->sink_event_func) {
/* Give the parent a chance to handle the event first */
ret = parent_class->sink_event_func (pad, event);
}
else
ret = gst_pad_event_default (pad, event);
break; break;
}
} }
gst_object_unref (mux); gst_object_unref (mux);
return ret; return ret;
} }