GstAggregatorClass

The aggregator base class will handle in a thread-safe way all manners of concurrent flushes, seeks, pad additions and removals, leaving to the subclass the responsibility of clipping buffers, and aggregating buffers in the way the implementor sees fit.

It will also take care of event ordering (stream-start, segment, eos).

Basically, a simple implementation will override aggregate, and call _finish_buffer from inside that function.

struct GstAggregatorClass {

GstElementClass parentClass;

GstFlowReturn function(GstAggregator* aggregator) flush;

GstBuffer* function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstBuffer* buf) clip;

GstFlowReturn function(GstAggregator* aggregator, GstBuffer* buffer) finishBuffer;

int function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstEvent* event) sinkEvent;

int function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstQuery* query) sinkQuery;

int function(GstAggregator* aggregator, GstEvent* event) srcEvent;

int function(GstAggregator* aggregator, GstQuery* query) srcQuery;

int function(GstAggregator* aggregator, GstPadMode mode, int active) srcActivate;

GstFlowReturn function(GstAggregator* aggregator, int timeout) aggregate;

int function(GstAggregator* aggregator) stop;

int function(GstAggregator* aggregator) start;

GstClockTime function(GstAggregator* aggregator) getNextTime;

GstAggregatorPad* function(GstAggregator* self, GstPadTemplate* templ, const(char)* reqName, GstCaps* caps) createNewPad;

GstFlowReturn function(GstAggregator* self, GstCaps* caps, GstCaps** ret) updateSrcCaps;

GstCaps* function(GstAggregator* self, GstCaps* caps) fixateSrcCaps;

int function(GstAggregator* self, GstCaps* caps) negotiatedSrcCaps;

int function(GstAggregator* self, GstQuery* query) decideAllocation;

int function(GstAggregator* self, GstAggregatorPad* pad, GstQuery* decideQuery, GstQuery* query) proposeAllocation;

void*[20] GstReserved;

}

Members

Variables

aggregate GstFlowReturn function(GstAggregator* aggregator, int timeout) aggregate;
clip GstBuffer* function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstBuffer* buf) clip;
createNewPad GstAggregatorPad* function(GstAggregator* self, GstPadTemplate* templ, const(char)* reqName, GstCaps* caps) createNewPad;
decideAllocation int function(GstAggregator* self, GstQuery* query) decideAllocation;
finishBuffer GstFlowReturn function(GstAggregator* aggregator, GstBuffer* buffer) finishBuffer;
fixateSrcCaps GstCaps* function(GstAggregator* self, GstCaps* caps) fixateSrcCaps;
flush GstFlowReturn function(GstAggregator* aggregator) flush;
getNextTime GstClockTime function(GstAggregator* aggregator) getNextTime;
negotiatedSrcCaps int function(GstAggregator* self, GstCaps* caps) negotiatedSrcCaps;
proposeAllocation int function(GstAggregator* self, GstAggregatorPad* pad, GstQuery* decideQuery, GstQuery* query) proposeAllocation;
sinkEvent int function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstEvent* event) sinkEvent;
sinkQuery int function(GstAggregator* aggregator, GstAggregatorPad* aggregatorPad, GstQuery* query) sinkQuery;
srcActivate int function(GstAggregator* aggregator, GstPadMode mode, int active) srcActivate;
srcEvent int function(GstAggregator* aggregator, GstEvent* event) srcEvent;
srcQuery int function(GstAggregator* aggregator, GstQuery* query) srcQuery;
start int function(GstAggregator* aggregator) start;
stop int function(GstAggregator* aggregator) stop;
updateSrcCaps
GstFlowReturn function(GstAggregator* self, GstCaps* caps, GstCaps** ret) updateSrcCaps;