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

Added code to attempt the scheduling of chained cases. Very simply right now. Also added code to allow the use_coth...

Browse source 
Original commit message from CVS:
Added code to attempt the scheduling of chained cases.  Very simply right
now.  Also added code to allow the use_cothread flag of a bin to force all
the chains to use cothreads as well.
This commit is contained in:
Erik Walthinsen 2000-12-27 00:46:26 +00:00
parent 1d0694ade4
commit 8139aeca9e
3 changed files with 52 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
gst/gstbin.c
View file

@ -710,7 +710,7 @@ gst_bin_iterate_func (GstBin *bin)
chain = (_GstBinChain *)(chains->data);
chains = g_list_next (chains);
if (chain->use_cothreads) {
if (chain->need_cothreads) {
// all we really have to do is switch to the first child
// FIXME this should be lots more intelligent about where to start
DEBUG("starting iteration via cothreads\n");

2
gst/gstbin.h
View file

@ -101,7 +101,7 @@ struct __GstBinChain {
GList *entries;
gboolean use_cothreads;
gboolean need_cothreads;
GstElement *entry;
};

54
gst/gstscheduler.c
View file

@ -261,6 +261,37 @@ gst_schedule_cothreaded_chain (GstBin *bin, _GstBinChain *chain) {
}
}
static void
gst_schedule_chained_chain (GstBin *bin, _GstBinChain *chain) {
GList *elements;
GstElement *element;
GList *pads;
GstPad *pad;
// walk through all the elements
elements = chain->elements;
while (elements) {
element = GST_ELEMENT (elements->data);
elements = g_list_next (elements);
// walk through all the pads
pads = gst_element_get_pad_list (element);
while (pads) {
pad = GST_PAD (pads->data);
pads = g_list_next (pads);
if (gst_pad_get_direction (pad) == GST_PAD_SINK) {
DEBUG("copying chain function into push proxy for %s:%s\n",GST_DEBUG_PAD_NAME(pad));
pad->pushfunc = pad->chainfunc;
} else {
DEBUG("copying get function into pull proxy for %s:%s\n",GST_DEBUG_PAD_NAME(pad));
pad->pullfunc = pad->getfunc;
pad->pullregionfunc = pad->getregionfunc;
}
}
}
}
void gst_bin_schedule_func(GstBin *bin) {
// GstElement *manager;
GList *elements;
@ -315,16 +346,24 @@ void gst_bin_schedule_func(GstBin *bin) {
chain->num_elements++;
// set the cothreads flag as appropriate
if (GST_FLAG_IS_SET (element, GST_ELEMENT_USE_COTHREAD))
chain->use_cothreads = TRUE;
chain->need_cothreads = TRUE;
if (bin->use_cothreads == TRUE)
chain->need_cothreads = TRUE;
// if we're managed by the current bin, and we're not decoupled,
// go find all the peers and add them to the list of elements to check
if ((element->manager == GST_ELEMENT(bin)) &&
!GST_FLAG_IS_SET (element, GST_ELEMENT_DECOUPLED)) {
// remove ourselves from the outer list of all managed elements
DEBUG("removing '%s' from list of possible elements\n",gst_element_get_name(element));
// DEBUG("removing '%s' from list of possible elements\n",gst_element_get_name(element));
elements = g_list_remove (elements, element);
// if this element is a source, add it as an entry
if (element->numsinkpads == 0) {
chain->entries = g_list_prepend (chain->entries, element);
DEBUG("added '%s' as SRC entry into the chain\n",gst_element_get_name(element));
}
// now we have to walk the pads to find peers
pads = gst_element_get_pad_list (element);
while (pads) {
@ -339,6 +378,13 @@ void gst_bin_schedule_func(GstBin *bin) {
// add the peer element to the pending list
DEBUG("adding '%s' to list of pending elements\n",gst_element_get_name(GST_ELEMENT(pad->peer->parent)));
pending = g_slist_prepend (pending, GST_ELEMENT(pad->peer->parent));
// if this is a sink pad, then the element on the other side is an entry
if ((gst_pad_get_direction (pad) == GST_PAD_SINK) &&
(GST_FLAG_IS_SET (pad->peer->parent, GST_ELEMENT_DECOUPLED))) {
chain->entries = g_list_prepend (chain->entries, pad->peer->parent);
DEBUG("added '%s' as DECOUPLED entry into the chain\n",gst_element_get_name(GST_ELEMENT(pad->peer->parent)));
}
} else
DEBUG("element '%s' has already been dealt with\n",gst_element_get_name(GST_ELEMENT(pad->peer->parent)));
}
@ -370,10 +416,10 @@ void gst_bin_schedule_func(GstBin *bin) {
chains = g_list_next (chains);
// schedule as appropriate
if (chain->use_cothreads) {
if (chain->need_cothreads) {
gst_schedule_cothreaded_chain (bin,chain);
} else {
DEBUG("non-cothreaded case not coded yet\n");
gst_schedule_chained_chain (bin,chain);
}
}