#include <stdint.h>
#include <string.h>
#include "libavutil/avassert.h"
#include "libavutil/error.h"
#include "libavutil/fifo.h"
#include "libavutil/mathematics.h"
#include "libavutil/mem.h"
#include "objpool.h"
#include "sync_queue.h"

Data Structures
struct	SyncQueueStream

struct	SyncQueue

Functions
static void	frame_move (const SyncQueue *sq, SyncQueueFrame dst, SyncQueueFrame src)

static int64_t	frame_ts (const SyncQueue *sq, SyncQueueFrame frame)

static int	frame_null (const SyncQueue *sq, SyncQueueFrame frame)

static void	finish_stream (SyncQueue *sq, unsigned int stream_idx)

static void	queue_head_update (SyncQueue *sq)

static void	stream_update_ts (SyncQueue *sq, unsigned int stream_idx, int64_t ts)

static int	overflow_heartbeat (SyncQueue *sq, int stream_idx)

int	sq_send (SyncQueue *sq, unsigned int stream_idx, SyncQueueFrame frame)
	Submit a frame for the stream with index stream_idx. More...

static int	receive_for_stream (SyncQueue *sq, unsigned int stream_idx, SyncQueueFrame frame)

static int	receive_internal (SyncQueue *sq, int stream_idx, SyncQueueFrame frame)

int	sq_receive (SyncQueue *sq, int stream_idx, SyncQueueFrame frame)
	Read a frame from the queue. More...

int	sq_add_stream (SyncQueue *sq, int limiting)
	Add a new stream to the sync queue. More...

void	sq_set_tb (SyncQueue *sq, unsigned int stream_idx, AVRational tb)
	Set the timebase for the stream with index stream_idx. More...

void	sq_limit_frames (SyncQueue *sq, unsigned int stream_idx, uint64_t frames)
	Limit the number of output frames for stream with index stream_idx to max_frames. More...

SyncQueue *	sq_alloc (enum SyncQueueType type, int64_t buf_size_us)
	Allocate a sync queue of the given type. More...

void	sq_free (SyncQueue **psq)

Function Documentation

◆ frame_move()

static void frame_move	(	const SyncQueue *	sq,
		SyncQueueFrame	dst,
		SyncQueueFrame	src
	)

static

Definition at line 66 of file sync_queue.c.

Referenced by receive_for_stream(), and sq_send().

◆ frame_ts()

static int64_t frame_ts	(	const SyncQueue *	sq,
		SyncQueueFrame	frame
	)

static

Definition at line 75 of file sync_queue.c.

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

◆ frame_null()

static int frame_null	(	const SyncQueue *	sq,
		SyncQueueFrame	frame
	)

static

Definition at line 82 of file sync_queue.c.

Referenced by sq_send().

◆ finish_stream()

static void finish_stream	(	SyncQueue *	sq,
		unsigned int	stream_idx
	)

static

Definition at line 87 of file sync_queue.c.

Referenced by sq_limit_frames(), sq_send(), and stream_update_ts().

◆ queue_head_update()

static void queue_head_update ( SyncQueue * sq )

static

Definition at line 121 of file sync_queue.c.

Referenced by stream_update_ts().

◆ stream_update_ts()

static void stream_update_ts	(	SyncQueue *	sq,
		unsigned int	stream_idx,
		int64_t	ts
	)

static

Definition at line 147 of file sync_queue.c.

Referenced by overflow_heartbeat(), and sq_send().

◆ overflow_heartbeat()

static int overflow_heartbeat	(	SyncQueue *	sq,
		int	stream_idx
	)

static

Definition at line 176 of file sync_queue.c.

Referenced by sq_receive().

◆ sq_send()

int sq_send	(	SyncQueue *	sq,
		unsigned int	stream_idx,
		SyncQueueFrame	frame
	)

Submit a frame for the stream with index stream_idx.

On success, the sync queue takes ownership of the frame and will reset the contents of the supplied frame. On failure, the frame remains owned by the caller.

Sending a frame with NULL contents marks the stream as finished.

Returns

0 on success
AVERROR_EOF when no more frames should be submitted for this stream
another a negative error code on failure

Definition at line 234 of file sync_queue.c.

Referenced by close_output_stream(), flush_encoders(), submit_encode_frame(), and sync_queue_process().

◆ receive_for_stream()

static int receive_for_stream	(	SyncQueue *	sq,
		unsigned int	stream_idx,
		SyncQueueFrame	frame
	)

static

Definition at line 277 of file sync_queue.c.

Referenced by receive_internal().

◆ receive_internal()

static int receive_internal	(	SyncQueue *	sq,
		int	stream_idx,
		SyncQueueFrame	frame
	)

static

Definition at line 315 of file sync_queue.c.

Referenced by sq_receive().

◆ sq_receive()

int sq_receive	(	SyncQueue *	sq,
		int	stream_idx,
		SyncQueueFrame	frame
	)

Read a frame from the queue.

Parameters

stream_idx	index of the stream to read a frame for. May be -1, then try to read a frame from any stream that is ready for output.
frame	output frame will be written here on success. The frame is owned by the caller.

Returns

a non-negative index of the stream to which the returned frame belongs
AVERROR(EAGAIN) when more frames need to be submitted to the queue
AVERROR_EOF when no more frames will be available for this stream (for any stream if stream_idx is -1)
another negative error code on failure

Definition at line 339 of file sync_queue.c.

Referenced by submit_encode_frame(), and sync_queue_process().

◆ sq_add_stream()

int sq_add_stream	(	SyncQueue *	sq,
		int	limiting
	)

Add a new stream to the sync queue.

Parameters

limiting whether the stream is limiting, i.e. no other stream can be longer than this one

Returns

a non-negative stream index on success
a negative error code on error

Definition at line 351 of file sync_queue.c.

Referenced by setup_sync_queues().

◆ sq_set_tb()

void sq_set_tb	(	SyncQueue *	sq,
		unsigned int	stream_idx,
		AVRational	tb
	)

Set the timebase for the stream with index stream_idx.

Should be called before sending any frames for this stream.

Definition at line 378 of file sync_queue.c.

Referenced by init_output_stream_encode(), and of_stream_init().

◆ sq_limit_frames()

void sq_limit_frames	(	SyncQueue *	sq,
		unsigned int	stream_idx,
		uint64_t	frames
	)

Limit the number of output frames for stream with index stream_idx to max_frames.

Definition at line 393 of file sync_queue.c.

Referenced by setup_sync_queues().

◆ sq_alloc()

SyncQueue* sq_alloc	(	enum SyncQueueType	type,
		int64_t	buf_size_us
	)

Allocate a sync queue of the given type.

Parameters

buf_size_us maximum duration that will be buffered in microseconds

Definition at line 405 of file sync_queue.c.

Referenced by setup_sync_queues().

◆ sq_free()

void sq_free ( SyncQueue ** psq )

Definition at line 428 of file sync_queue.c.

Referenced by of_close().

Data Structures

Functions

Function Documentation

◆ frame_move()

◆ frame_ts()

◆ frame_null()

◆ finish_stream()

◆ queue_head_update()

◆ stream_update_ts()

◆ overflow_heartbeat()

◆ sq_send()

◆ receive_for_stream()

◆ receive_internal()

◆ sq_receive()

◆ sq_add_stream()

◆ sq_set_tb()

◆ sq_limit_frames()

◆ sq_alloc()

◆ sq_free()