A sync queue provides timestamp synchronization between multiple streams. More...

Data Fields
enum SyncQueueType	type

void *	logctx

int	finished

int	head_stream

int	head_finished_stream

int64_t	buf_size_us

SyncQueueStream *	streams

unsigned int	nb_streams

ObjPool *	pool

int	have_limiting

uintptr_t	align_mask

Detailed Description

A sync queue provides timestamp synchronization between multiple streams.

Some of these streams are marked as "limiting", then the queue ensures no stream gets ahead of any of the limiting streams.

Definition at line 88 of file sync_queue.c.

Field Documentation

◆ type

enum SyncQueueType SyncQueue::type

Definition at line 89 of file sync_queue.c.

Referenced by frame_end(), frame_move(), frame_null(), frame_samples(), sq_alloc(), sq_frame_samples(), and tb_update().

◆ logctx

void* SyncQueue::logctx

Definition at line 91 of file sync_queue.c.

Referenced by finish_stream(), overflow_heartbeat(), receive_for_stream(), sq_alloc(), and sq_send().

◆ finished

int SyncQueue::finished

Definition at line 94 of file sync_queue.c.

Referenced by finish_stream(), and receive_for_stream().

◆ head_stream

int SyncQueue::head_stream

Definition at line 97 of file sync_queue.c.

Referenced by queue_head_update(), receive_for_stream(), sq_alloc(), and stream_update_ts().

◆ head_finished_stream

int SyncQueue::head_finished_stream

Definition at line 99 of file sync_queue.c.

Referenced by finish_stream(), sq_alloc(), and stream_update_ts().

◆ buf_size_us

int64_t SyncQueue::buf_size_us

Definition at line 102 of file sync_queue.c.

Referenced by overflow_heartbeat(), and sq_alloc().

◆ streams

SyncQueueStream* SyncQueue::streams

Definition at line 104 of file sync_queue.c.

Referenced by finish_stream(), overflow_heartbeat(), queue_head_update(), receive_for_stream(), sq_add_stream(), sq_frame_samples(), sq_free(), sq_limit_frames(), sq_send(), and stream_update_ts().

◆ nb_streams

unsigned int SyncQueue::nb_streams

Definition at line 105 of file sync_queue.c.

Referenced by finish_stream(), overflow_heartbeat(), queue_head_update(), receive_internal(), sq_add_stream(), and sq_free().

◆ pool

ObjPool* SyncQueue::pool

Definition at line 108 of file sync_queue.c.

Referenced by receive_for_stream(), receive_samples(), sq_alloc(), sq_free(), and sq_send().

◆ have_limiting

int SyncQueue::have_limiting

Definition at line 110 of file sync_queue.c.

Referenced by queue_head_update(), and sq_add_stream().

◆ align_mask

uintptr_t SyncQueue::align_mask

Definition at line 112 of file sync_queue.c.

Referenced by frame_is_aligned(), and sq_frame_samples().

The documentation for this struct was generated from the following file:

fftools/sync_queue.c

Data Fields