GstLALCollectData

typedef struct {
	GstCollectData as_gstcollectdata;

	guint unit_size;
	gint rate;
} GstLALCollectData;

gstlal_collect_pads_add_pad ()

GstLALCollectData * gstlal_collect_pads_add_pad         (GstCollectPads *pads,
                                                         GstPad *pad,
                                                         guint size);

Equivalent to #gst_collect_pads_add_pad().

gstlal_collect_pads_add_pad_full ()

GstLALCollectData * gstlal_collect_pads_add_pad_full    (GstCollectPads *pads,
                                                         GstPad *pad,
                                                         guint size,
                                                         GstCollectDataDestroyNotify destroy_notify);

Wraps #gst_collect_pads_add_pad_full(), initializing the additional fields in the custom GstLALCollectData object.

gstlal_collect_pads_get_earliest_times ()

gboolean            gstlal_collect_pads_get_earliest_times
                                                        (GstCollectPads *pads,
                                                         GstClockTime *t_start,
                                                         GstClockTime *t_end);

Computes the earliest of the start and of the end times of the GstCollectPads' input buffers.

Upon the successful completion of this function, both time parameters will be set to GST_CLOCK_TIME_NONE if all input streams are at EOS. Otherwise, if at least one stream is not at EOS, the times are set to the earliest interval spanned by all the buffers that are available.

Note that if no input pads have data available, this condition is interpreted as EOS. EOS is, therefore, indistinguishable from the initial state, wherein no data has yet arrived. It is assumed this function will only be invoked from within the collected() method, and therefore only after at least one pad has received a buffer, and therefore the "no data available" condition is only seen at EOS.

Should be called with the GstCollectPads' lock held (i.e., from the collected() method).

gstlal_collect_pads_get_rate ()

gint                gstlal_collect_pads_get_rate        (GstPad *pad);

Get the unit rate (e.g., sample rate, frame rate, etc.) on the given input stream.

Should be called with the GstCollectPads' lock held (i.e., from the collected() method).

gstlal_collect_pads_get_segment ()

GstSegment *        gstlal_collect_pads_get_segment     (GstCollectPads *pads);

Compute the smallest segment that contains the segments (from the most recent newsegment events) of all pads. The segments must be in the same format on all pads. The return value is a newly allocated GstSegment owned by the calling code.

Should be called with the GstCollectPads' lock held (i.e., from the collected() method).

gstlal_collect_pads_get_unit_size ()

guint               gstlal_collect_pads_get_unit_size   (GstPad *pad);

Get the number of bytes per unit (e.g., sample, frame, etc.) on the given input stream.

Should be called with the GstCollectPads' lock held (i.e., from the collected() method).

gstlal_collect_pads_remove_pad ()

gboolean            gstlal_collect_pads_remove_pad      (GstCollectPads *pads,
                                                         GstPad *pad);

Equivalent to #gst_collect_pads_remove_pad().

gstlal_collect_pads_set_rate ()

void                gstlal_collect_pads_set_rate        (GstPad *pad,
                                                         gint rate);

Set the unit rate (e.g., sample rate, frame rate, etc.) on the given input stream.

Should be called with the GstCollectPads' lock held (e.g., from the collected() method).

gstlal_collect_pads_set_unit_size ()

void                gstlal_collect_pads_set_unit_size   (GstPad *pad,
                                                         guint unit_size);

Set the number of bytes per unit (e.g., sample, frame, etc.) on the given input stream.

Should be called with the GstCollectPads' lock held (e.g., from the collected() method).

gstlal_collect_pads_take_buffer_sync ()

GstBuffer *         gstlal_collect_pads_take_buffer_sync
                                                        (GstCollectPads *pads,
                                                         GstLALCollectData *data,
                                                         GstClockTime t_end);

Wrapper for #gst_collect_pads_take_buffer(). Returns a GstBuffer containing the samples taken from the start of the current buffer upto (not including) the offset corresponding to t_end. The buffer returned might be shorter if the pad does not have data upto the requested time. The buffer returned by this function has its offset and offset_end set to indicate its location in the input stream. Calling this function has the effect of flushing the pad upto the offset corresponding to t_end or the upper bound of the available data, whichever comes first.

If the pad has no data available then NULL is returned, this indicates EOS. If the pad has data available but it is subsequent to the requested interval then a zero-length buffer is returned.

Should be called with the GstCollectPads' lock held (i.e., from the collected() method).