Pipeline

A #GstPipeline is a special #GstBin used as the toplevel container for the filter graph. The #GstPipeline will manage the selection and distribution of a global #GstClock as well as provide a #GstBus to the application.

gst_pipeline_new() is used to create a pipeline. when you are done with the pipeline, use gst_object_unref() to free its resources including all added #GstElement objects (if not otherwise referenced).

Elements are added and removed from the pipeline using the #GstBin methods like gst_bin_add() and gst_bin_remove() (see #GstBin).

Before changing the state of the #GstPipeline (see #GstElement) a #GstBus can be retrieved with gst_pipeline_get_bus(). This bus can then be used to receive #GstMessage from the elements in the pipeline.

By default, a #GstPipeline will automatically flush the pending #GstBus messages when going to the NULL state to ensure that no circular references exist when no messages are read from the #GstBus. This behaviour can be changed with gst_pipeline_set_auto_flush_bus().

When the #GstPipeline performs the PAUSED to PLAYING state change it will select a clock for the elements. The clock selection algorithm will by default select a clock provided by an element that is most upstream (closest to the source). For live pipelines (ones that return #GST_STATE_CHANGE_NO_PREROLL from the gst_element_set_state() call) this will select the clock provided by the live source. For normal pipelines this will select a clock provided by the sinks (most likely the audio sink). If no element provides a clock, a default #GstSystemClock is used.

The clock selection can be controlled with the gst_pipeline_use_clock() method, which will enforce a given clock on the pipeline. With gst_pipeline_auto_clock() the default clock selection algorithm can be restored.

A #GstPipeline maintains a running time for the elements. The running time is defined as the difference between the current clock time and the base time. When the pipeline goes to READY or a flushing seek is performed on it, the running time is reset to 0. When the pipeline is set from PLAYING to PAUSED, the current clock time is sampled and used to configure the base time for the elements when the pipeline is set to PLAYING again. The effect is that the running time (as the difference between the clock time and the base time) will count how much time was spent in the PLAYING state. This default behaviour can be changed with the gst_element_set_start_time() method.

Constructors

this
this(GstPipeline* gstPipeline, bool ownedRef)

Sets our main struct and passes it to the parent class.

this
this(string name)

Create a new pipeline with the given name.

Members

Functions

autoClock
void autoClock()

Let @pipeline select a clock automatically. This is the default behaviour.

getAutoFlushBus
bool getAutoFlushBus()

Check if @pipeline will automatically flush messages when going to the NULL state.

getBus
Bus getBus()

Gets the #GstBus of @pipeline. The bus allows applications to receive #GstMessage packets.

getClock
Clock getClock()

Gets the current clock used by @pipeline. Users of object oriented languages should use gst_pipeline_get_pipeline_clock() to avoid confusion with gst_element_get_clock() which has a different behavior.

getDelay
GstClockTime getDelay()

Get the configured delay (see gst_pipeline_set_delay()).

getLatency
GstClockTime getLatency()

Gets the latency that should be configured on the pipeline. See gst_pipeline_set_latency().

getPipelineClock
Clock getPipelineClock()

Gets the current clock used by @pipeline.

getPipelineStruct
GstPipeline* getPipelineStruct(bool transferOwnership)

Get the main Gtk struct

getStruct
void* getStruct()

the main Gtk struct as a void*

setAutoFlushBus
void setAutoFlushBus(bool autoFlush)

Usually, when a pipeline goes from READY to NULL state, it automatically flushes all pending messages on the bus, which is done for refcounting purposes, to break circular references.

setClock
bool setClock(Clock clock)

Set the clock for @pipeline. The clock will be distributed to all the elements managed by the pipeline.

setDelay
void setDelay(GstClockTime delay)

Set the expected delay needed for all elements to perform the PAUSED to PLAYING state change. @delay will be added to the base time of the elements so that they wait an additional @delay amount of time before starting to process buffers and cannot be #GST_CLOCK_TIME_NONE.

setLatency
void setLatency(GstClockTime latency)

Sets the latency that should be configured on the pipeline. Setting GST_CLOCK_TIME_NONE will restore the default behaviour of using the minimum latency from the LATENCY query. Setting this is usually not required and the pipeline will figure out an appropriate latency automatically.

setStruct
void setStruct(GObject* obj)
Undocumented in source. Be warned that the author may not have intended to support it.
useClock
void useClock(Clock clock)

Force @pipeline to use the given @clock. The pipeline will always use the given clock even if new clock providers are added to this pipeline.

Static functions

getType
GType getType()

Variables

gstPipeline
GstPipeline* gstPipeline;

the main Gtk struct

Inherited Members

From Bin

gstBin
GstBin* gstBin;

the main Gtk struct

getBinStruct
GstBin* getBinStruct(bool transferOwnership)

Get the main Gtk struct

getStruct
void* getStruct()

the main Gtk struct as a void*

setStruct
void setStruct(GObject* obj)
Undocumented in source. Be warned that the author may not have intended to support it.
__anonymous
mixin ChildProxyT!(GstBin)
Undocumented in source.
addMany
void addMany(Element[] elems)

Adds a list of elements to a bin. This function is equivalent to calling add() for each member of the list. The return value of each add() is ignored.

removeMany
void removeMany(Element[] elems)

Remove a list of elements from a bin. This function is equivalent to calling remove() with each member of the list.

getType
GType getType()
add
bool add(Element element)

Adds the given element to the bin. Sets the element's parent, and thus takes ownership of the element. An element can only be added to one bin.

findUnlinkedPad
Pad findUnlinkedPad(GstPadDirection direction)

Recursively looks for elements with an unlinked pad of the given direction within the specified bin and returns an unlinked pad if one is found, or %NULL otherwise. If a pad is found, the caller owns a reference to it and should use gst_object_unref() on the pad when it is not needed any longer.

getByInterface
Element getByInterface(GType iface)

Looks for an element inside the bin that implements the given interface. If such an element is found, it returns the element. You can cast this element to the given interface afterwards. If you want all elements that implement the interface, use gst_bin_iterate_all_by_interface(). This function recurses into child bins.

getByName
Element getByName(string name)

Gets the element with the given name from a bin. This function recurses into child bins.

getByNameRecurseUp
Element getByNameRecurseUp(string name)

Gets the element with the given name from this bin. If the element is not found, a recursion is performed on the parent bin.

getSuppressedFlags
GstElementFlags getSuppressedFlags()

Return the suppressed flags of the bin.

iterateAllByInterface
Iterator iterateAllByInterface(GType iface)

Looks for all elements inside the bin that implements the given interface. You can safely cast all returned elements to the given interface. The function recurses inside child bins. The iterator will yield a series of #GstElement that should be unreffed after use.

iterateElements
Iterator iterateElements()

Gets an iterator for the elements in this bin.

iterateRecurse
Iterator iterateRecurse()

Gets an iterator for the elements in this bin. This iterator recurses into GstBin children.

iterateSinks
Iterator iterateSinks()

Gets an iterator for all elements in the bin that have the #GST_ELEMENT_FLAG_SINK flag set.

iterateSorted
Iterator iterateSorted()

Gets an iterator for the elements in this bin in topologically sorted order. This means that the elements are returned from the most downstream elements (sinks) to the sources.

iterateSources
Iterator iterateSources()

Gets an iterator for all elements in the bin that have the #GST_ELEMENT_FLAG_SOURCE flag set.

recalculateLatency
bool recalculateLatency()

Query @bin for the current latency using and reconfigures this latency to all the elements with a LATENCY event.

remove
bool remove(Element element)

Removes the element from the bin, unparenting it as well. Unparenting the element means that the element will be dereferenced, so if the bin holds the only reference to the element, the element will be freed in the process of removing it from the bin. If you want the element to still exist after removing, you need to call gst_object_ref() before removing it from the bin.

setSuppressedFlags
void setSuppressedFlags(GstElementFlags flags)

Suppress the given flags on the bin. #GstElementFlags of a child element are propagated when it is added to the bin. When suppressed flags are set, those specified flags will not be propagated to the bin.

syncChildrenStates
bool syncChildrenStates()

Synchronizes the state of every child of @bin with the state of @bin. See also gst_element_sync_state_with_parent().

OnDeepElementAddedDelegateWrapper
class OnDeepElementAddedDelegateWrapper
Undocumented in source.
onDeepElementAddedListeners
OnDeepElementAddedDelegateWrapper[] onDeepElementAddedListeners;
Undocumented in source.
addOnDeepElementAdded
gulong addOnDeepElementAdded(void delegate(Bin, Element, Bin) dlg, ConnectFlags connectFlags)

Will be emitted after the element was added to sub_bin.

callBackDeepElementAdded
void callBackDeepElementAdded(GstBin* binStruct, GstBin* subBin, GstElement* element, OnDeepElementAddedDelegateWrapper wrapper)
Undocumented in source. Be warned that the author may not have intended to support it.
callBackDeepElementAddedDestroy
void callBackDeepElementAddedDestroy(OnDeepElementAddedDelegateWrapper wrapper, GClosure* closure)
Undocumented in source. Be warned that the author may not have intended to support it.
OnDeepElementRemovedDelegateWrapper
class OnDeepElementRemovedDelegateWrapper
Undocumented in source.
onDeepElementRemovedListeners
OnDeepElementRemovedDelegateWrapper[] onDeepElementRemovedListeners;
Undocumented in source.
addOnDeepElementRemoved
gulong addOnDeepElementRemoved(void delegate(Bin, Element, Bin) dlg, ConnectFlags connectFlags)

Will be emitted after the element was removed from sub_bin.

callBackDeepElementRemoved
void callBackDeepElementRemoved(GstBin* binStruct, GstBin* subBin, GstElement* element, OnDeepElementRemovedDelegateWrapper wrapper)
Undocumented in source. Be warned that the author may not have intended to support it.
callBackDeepElementRemovedDestroy
void callBackDeepElementRemovedDestroy(OnDeepElementRemovedDelegateWrapper wrapper, GClosure* closure)
Undocumented in source. Be warned that the author may not have intended to support it.
OnDoLatencyDelegateWrapper
class OnDoLatencyDelegateWrapper
Undocumented in source.
onDoLatencyListeners
OnDoLatencyDelegateWrapper[] onDoLatencyListeners;
Undocumented in source.
addOnDoLatency
gulong addOnDoLatency(bool delegate(Bin) dlg, ConnectFlags connectFlags)

Will be emitted when the bin needs to perform latency calculations. This signal is only emitted for toplevel bins or when async-handling is enabled.

callBackDoLatency
int callBackDoLatency(GstBin* binStruct, OnDoLatencyDelegateWrapper wrapper)
Undocumented in source. Be warned that the author may not have intended to support it.
callBackDoLatencyDestroy
void callBackDoLatencyDestroy(OnDoLatencyDelegateWrapper wrapper, GClosure* closure)
Undocumented in source. Be warned that the author may not have intended to support it.
OnElementAddedDelegateWrapper
class OnElementAddedDelegateWrapper
Undocumented in source.
onElementAddedListeners
OnElementAddedDelegateWrapper[] onElementAddedListeners;
Undocumented in source.
addOnElementAdded
gulong addOnElementAdded(void delegate(Element, Bin) dlg, ConnectFlags connectFlags)

Will be emitted after the element was added to the bin.

callBackElementAdded
void callBackElementAdded(GstBin* binStruct, GstElement* element, OnElementAddedDelegateWrapper wrapper)
Undocumented in source. Be warned that the author may not have intended to support it.
callBackElementAddedDestroy
void callBackElementAddedDestroy(OnElementAddedDelegateWrapper wrapper, GClosure* closure)
Undocumented in source. Be warned that the author may not have intended to support it.
OnElementRemovedDelegateWrapper
class OnElementRemovedDelegateWrapper
Undocumented in source.
onElementRemovedListeners
OnElementRemovedDelegateWrapper[] onElementRemovedListeners;
Undocumented in source.
addOnElementRemoved
gulong addOnElementRemoved(void delegate(Element, Bin) dlg, ConnectFlags connectFlags)

Will be emitted after the element was removed from the bin.

callBackElementRemoved
void callBackElementRemoved(GstBin* binStruct, GstElement* element, OnElementRemovedDelegateWrapper wrapper)
Undocumented in source. Be warned that the author may not have intended to support it.
callBackElementRemovedDestroy
void callBackElementRemovedDestroy(OnElementRemovedDelegateWrapper wrapper, GClosure* closure)
Undocumented in source. Be warned that the author may not have intended to support it.

Meta