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

[MOVED FROM GST-P-FARSIGHT] added debugs

Browse source 
20070913204614-4f0f6-68c2a69ae7a1efca6e13c116dbad7f9b686f0242.gz
This commit is contained in:
Youness Alaoui 2007-09-13 20:46:14 +00:00 committed by Edward Hervey
parent 4a11ad9df0
commit a88f8d3310
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
gst/dtmf/gstdtmfsrc.c
View file

@ -655,8 +655,11 @@ gst_dtmf_src_create (GstBaseSrc * basesrc, guint64 offset,
start: start:
if (dtmfsrc->last_event == NULL) { if (dtmfsrc->last_event == NULL) {
GST_DEBUG_OBJECT (dtmfsrc, "popping");
event = g_async_queue_pop (dtmfsrc->event_queue); event = g_async_queue_pop (dtmfsrc->event_queue);
GST_DEBUG_OBJECT (dtmfsrc, "popped %d", event->event_type);
if (event->event_type == DTMF_EVENT_TYPE_STOP) { if (event->event_type == DTMF_EVENT_TYPE_STOP) {
GST_WARNING_OBJECT (dtmfsrc, GST_WARNING_OBJECT (dtmfsrc,
"Received a DTMF stop event when already stopped"); "Received a DTMF stop event when already stopped");
@ -673,6 +676,7 @@ gst_dtmf_src_create (GstBaseSrc * basesrc, guint64 offset,
* We're pushing it back because it has to stay in there until * We're pushing it back because it has to stay in there until
* the task is really paused (and the queue will then be flushed) * the task is really paused (and the queue will then be flushed)
*/ */
GST_DEBUG_OBJECT (dtmfsrc, "pushing pause_task...");
g_async_queue_push (dtmfsrc->event_queue, event); g_async_queue_push (dtmfsrc->event_queue, event);
g_async_queue_unref (dtmfsrc->event_queue); g_async_queue_unref (dtmfsrc->event_queue);
} }
@ -689,11 +693,21 @@ gst_dtmf_src_create (GstBaseSrc * basesrc, guint64 offset,
g_free (dtmfsrc->last_event); g_free (dtmfsrc->last_event);
dtmfsrc->last_event = NULL; dtmfsrc->last_event = NULL;
goto start; goto start;
} else if (event->event_type == DTMF_EVENT_TYPE_PAUSE_TASK) {
/*
* We're pushing it back because it has to stay in there until
* the task is really paused (and the queue will then be flushed)
*/
GST_DEBUG_OBJECT (dtmfsrc, "pushing pause_task...");
g_async_queue_push (dtmfsrc->event_queue, event);
g_async_queue_unref (dtmfsrc->event_queue);
} }
} }
} }
g_async_queue_unref (dtmfsrc->event_queue); g_async_queue_unref (dtmfsrc->event_queue);
GST_DEBUG_OBJECT (dtmfsrc, "end event check");
if (dtmfsrc->last_event) { if (dtmfsrc->last_event) {
buf = gst_dtmf_src_create_next_tone_packet (dtmfsrc, dtmfsrc->last_event); buf = gst_dtmf_src_create_next_tone_packet (dtmfsrc, dtmfsrc->last_event);
@ -705,6 +719,7 @@ gst_dtmf_src_create (GstBaseSrc * basesrc, guint64 offset,
ret = GST_FLOW_WRONG_STATE; ret = GST_FLOW_WRONG_STATE;
} }
GST_DEBUG_OBJECT (dtmfsrc, "returning");
return ret; return ret;
} }