mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-12 03:16:33 +00:00
Code Issues 1 Projects Releases Wiki Activity

added first_buffer signal, and default to caps_proxy true

Browse source 
Original commit message from CVS:
added first_buffer signal, and default to caps_proxy true
This commit is contained in:
Erik Walthinsen 2001-05-16 21:19:59 +00:00
parent 65a6e752bf
commit 07aeaa83d5
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
gst/autoplug/gstautoplugcache.c
View file

@ -56,6 +56,7 @@ struct _GstAutoplugCache {
gint buffer_count; gint buffer_count;
GList *current_playout; GList *current_playout;
gboolean fire_empty; gboolean fire_empty;
gboolean fire_first;
}; };
struct _GstAutoplugCacheClass { struct _GstAutoplugCacheClass {
@ -165,7 +166,9 @@ gst_autoplugcache_init (GstAutoplugCache *cache)
// gst_pad_set_negotiate_function (cache->srcpad, gst_autoplugcache_nego_src); // gst_pad_set_negotiate_function (cache->srcpad, gst_autoplugcache_nego_src);
gst_element_add_pad (GST_ELEMENT(cache), cache->srcpad); gst_element_add_pad (GST_ELEMENT(cache), cache->srcpad);
cache->caps_proxy = FALSE; cache->caps_proxy = TRUE; // TESTING!
gst_pad_set_negotiate_function (cache->sinkpad, GST_DEBUG_FUNCPTR(gst_autoplugcache_nego_sink));
gst_pad_set_negotiate_function (cache->srcpad, GST_DEBUG_FUNCPTR(gst_autoplugcache_nego_src));
// provide a zero basis for the cache // provide a zero basis for the cache
cache->cache = g_list_prepend(NULL, NULL); cache->cache = g_list_prepend(NULL, NULL);
@ -173,13 +176,14 @@ gst_autoplugcache_init (GstAutoplugCache *cache)
cache->buffer_count = 0; cache->buffer_count = 0;
cache->current_playout = 0; cache->current_playout = 0;
cache->fire_empty = FALSE; cache->fire_empty = FALSE;
cache->fire_first = FALSE;
} }
static void static void
gst_autoplugcache_loop (GstElement *element) gst_autoplugcache_loop (GstElement *element)
{ {
GstAutoplugCache *cache; GstAutoplugCache *cache;
GstBuffer *buf; GstBuffer *buf = NULL;
cache = GST_AUTOPLUGCACHE (element); cache = GST_AUTOPLUGCACHE (element);
@ -253,6 +257,11 @@ gst_autoplugcache_loop (GstElement *element)
// move the current_playout pointer // move the current_playout pointer
cache->current_playout = g_list_previous (cache->current_playout); cache->current_playout = g_list_previous (cache->current_playout);
if (cache->fire_first) {
gtk_signal_emit (GTK_OBJECT(cache), gst_autoplugcache_signals[FIRST_BUFFER], buf);
cache->fire_first = FALSE;
}
// push that buffer // push that buffer
gst_pad_push (cache->srcpad, GST_BUFFER(cache->current_playout->data)); gst_pad_push (cache->srcpad, GST_BUFFER(cache->current_playout->data));
} }
@ -313,6 +322,8 @@ GST_DEBUG(0,"caps_proxy is %d\n",cache->caps_proxy);
cache->current_playout = cache->cache_start; cache->current_playout = cache->cache_start;
// now we can fire a signal when the cache runs dry // now we can fire a signal when the cache runs dry
cache->fire_empty = TRUE; cache->fire_empty = TRUE;
// also set it up to fire the first_buffer signal again
cache->fire_first = TRUE;
} }
break; break;
default: default: