Memory-managed wrapper type.

Type class for types which can be safely cast to Aggregator, for instance with toAggregator.

Cast to Aggregator, for types for which this is known to be safe. For general casts, use castTo.

This method will push the provided output buffer downstream. If needed, mandatory events such as stream-start, caps, and segment events will be sent before pushing the buffer.

This method will push the provided output buffer list downstream. If needed, mandatory events such as stream-start, caps, and segment events will be sent before pushing the buffer.

Since: 1.18

Lets Aggregator sub-classes get the memory allocator acquired by the base class and its params.

Unref the allocator after use it.

No description available in the introspection data.

Subclasses may use the return value to inform whether they should return FlowReturnEos from their aggregate implementation.

Since: 1.22

No description available in the introspection data.

Since: 1.20

Retrieves the latency values reported by self in response to the latency query, or CLOCK_TIME_NONE if there is not live source connected and the element will not wait for the clock.

Typically only called by subclasses.

Negotiates src pad caps with downstream elements. Unmarks GST_PAD_FLAG_NEED_RECONFIGURE in any case. But marks it again if AggregatorClass::negotiate fails.

Since: 1.18

Use this function to determine what input buffers will be aggregated to produce the next output buffer. This should only be called from a Aggregator::samplesSelected handler, and can be used to precisely control aggregating parameters for a given set of input samples.

Since: 1.18

Subclasses should call this when they have prepared the buffers they will aggregate for each of their sink pads, but before using any of the properties of the pads that govern *how* aggregation should be performed, for example z-index for video aggregators.

If aggregatorUpdateSegment is used by the subclass, it MUST be called before aggregatorSelectedSamples.

This function MUST only be called from the AggregatorClass::aggregate() function.

Since: 1.18

Subclasses should call this at construction time in order for self to aggregate on a timeout even when no live source is connected.

Since: 1.22

Subclasses should call this when they don't want to time out waiting for a pad that hasn't yet received any buffers in live mode.

Aggregator will still wait once on each newly-added pad, making sure upstream has had a fair chance to start up.

Since: 1.20

Lets Aggregator sub-classes tell the baseclass what their internal latency is. Will also post a LATENCY message on the bus so the pipeline can reconfigure its global latency if the values changed.

Sets the caps to be used on the src pad.

This is a simple AggregatorClass::get_next_time implementation that just looks at the Segment on the srcpad of the aggregator and bases the next time on the running time there.

This is the desired behaviour in most cases where you have a live source and you have a dead line based aggregator subclass.

Since: 1.16

Subclasses should use this to update the segment on their source pad, instead of directly pushing new segment events downstream.

Subclasses MUST call this before aggregatorSelectedSamples, if it is used at all.

Since: 1.18

Construct a GValueConstruct with valid value for the “emit-signals” property. This is rarely needed directly, but it is used by new.

Get the value of the “emit-signals” property. When overloading is enabled, this is equivalent to

get aggregator #emitSignals

Set the value of the “emit-signals” property. When overloading is enabled, this is equivalent to

set aggregator [ #emitSignals := value ]

Construct a GValueConstruct with valid value for the “latency” property. This is rarely needed directly, but it is used by new.

Get the value of the “latency” property. When overloading is enabled, this is equivalent to

get aggregator #latency

Set the value of the “latency” property. When overloading is enabled, this is equivalent to

set aggregator [ #latency := value ]

Construct a GValueConstruct with valid value for the “min-upstream-latency” property. This is rarely needed directly, but it is used by new.

Get the value of the “min-upstream-latency” property. When overloading is enabled, this is equivalent to

get aggregator #minUpstreamLatency

Set the value of the “min-upstream-latency” property. When overloading is enabled, this is equivalent to

set aggregator [ #minUpstreamLatency := value ]

Construct a GValueConstruct with valid value for the “start-time” property. This is rarely needed directly, but it is used by new.

Get the value of the “start-time” property. When overloading is enabled, this is equivalent to

get aggregator #startTime

Set the value of the “start-time” property. When overloading is enabled, this is equivalent to

set aggregator [ #startTime := value ]

Construct a GValueConstruct with valid value for the “start-time-selection” property. This is rarely needed directly, but it is used by new.

Get the value of the “start-time-selection” property. When overloading is enabled, this is equivalent to

get aggregator #startTimeSelection

Set the value of the “start-time-selection” property. When overloading is enabled, this is equivalent to

set aggregator [ #startTimeSelection := value ]

Signals that the Aggregator subclass has selected the next set of input samples it will aggregate. Handlers may call aggregatorPeekNextSample at that point.

Since: 1.18

Connect a signal handler for the samplesSelected signal, to be run after the default handler. When overloading is enabled, this is equivalent to

after aggregator #samplesSelected callback

By default the object invoking the signal is not passed to the callback. If you need to access it, you can use the implit ?self parameter. Note that this requires activating the ImplicitParams GHC extension.

Connect a signal handler for the samplesSelected signal, to be run before the default handler. When overloading is enabled, this is equivalent to

on aggregator #samplesSelected callback