#include <stdatomic.h>
#include "libavutil/avassert.h"
#include "libavutil/opt.h"
#include "libavutil/time.h"
#include "libavutil/thread.h"
#include "libavutil/threadmessage.h"
#include "avformat.h"
#include "internal.h"
#include "mux.h"

Data Structures
struct	FifoContext

struct	FifoThreadContext

struct	FifoMessage

Macros
#define	FIFO_DEFAULT_QUEUE_SIZE 60

#define	FIFO_DEFAULT_MAX_RECOVERY_ATTEMPTS 0

#define	FIFO_DEFAULT_RECOVERY_WAIT_TIME_USEC 5000000

#define	OFFSET(x) offsetof(FifoContext, x)

Enumerations
enum	FifoMessageType { FIFO_NOOP, FIFO_WRITE_HEADER, FIFO_WRITE_PACKET, FIFO_FLUSH_OUTPUT }

Functions
static int	fifo_thread_write_header (FifoThreadContext *ctx)

static int	fifo_thread_flush_output (FifoThreadContext *ctx)

static int64_t	next_duration (AVFormatContext avf, AVPacket pkt, int64_t *last_dts)

static int	fifo_thread_write_packet (FifoThreadContext ctx, AVPacket pkt)

static int	fifo_thread_write_trailer (FifoThreadContext *ctx)

static int	fifo_thread_dispatch_message (FifoThreadContext ctx, FifoMessage msg)

static int	is_recoverable (const FifoContext *fifo, int err_no)

static void	free_message (void *msg)

static int	fifo_thread_process_recovery_failure (FifoThreadContext ctx, AVPacket pkt, int err_no)

static int	fifo_thread_attempt_recovery (FifoThreadContext ctx, FifoMessage msg, int err_no)

static int	fifo_thread_recover (FifoThreadContext ctx, FifoMessage msg, int err_no)

static void *	fifo_consumer_thread (void *data)

static int	fifo_mux_init (AVFormatContext avf, const AVOutputFormat oformat, const char *filename)

static int	fifo_init (AVFormatContext *avf)

static int	fifo_write_header (AVFormatContext *avf)

static int	fifo_write_packet (AVFormatContext avf, AVPacket pkt)

static int	fifo_write_trailer (AVFormatContext *avf)

static void	fifo_deinit (AVFormatContext *avf)

Variables
static const AVOption	options []

static const AVClass	fifo_muxer_class

const FFOutputFormat	ff_fifo_muxer

Macro Definition Documentation

◆ FIFO_DEFAULT_QUEUE_SIZE

#define FIFO_DEFAULT_QUEUE_SIZE 60

Definition at line 33 of file fifo.c.

◆ FIFO_DEFAULT_MAX_RECOVERY_ATTEMPTS

#define FIFO_DEFAULT_MAX_RECOVERY_ATTEMPTS 0

Definition at line 34 of file fifo.c.

◆ FIFO_DEFAULT_RECOVERY_WAIT_TIME_USEC

#define FIFO_DEFAULT_RECOVERY_WAIT_TIME_USEC 5000000

Definition at line 35 of file fifo.c.

◆ OFFSET

#define OFFSET ( x ) offsetof(FifoContext, x)

Definition at line 669 of file fifo.c.

Enumeration Type Documentation

◆ FifoMessageType

enum FifoMessageType

Enumerator
FIFO_NOOP
FIFO_WRITE_HEADER
FIFO_WRITE_PACKET
FIFO_FLUSH_OUTPUT

Definition at line 111 of file fifo.c.

Function Documentation

◆ fifo_thread_write_header()

static int fifo_thread_write_header ( FifoThreadContext * ctx )

static

Definition at line 123 of file fifo.c.

Referenced by fifo_thread_dispatch_message().

◆ fifo_thread_flush_output()

static int fifo_thread_flush_output ( FifoThreadContext * ctx )

static

Definition at line 162 of file fifo.c.

Referenced by fifo_thread_dispatch_message().

◆ next_duration()

static int64_t next_duration	(	AVFormatContext *	avf,
		AVPacket *	pkt,
		int64_t *	last_dts
	)

static

Definition at line 171 of file fifo.c.

Referenced by fifo_thread_write_packet(), and fifo_write_packet().

◆ fifo_thread_write_packet()

static int fifo_thread_write_packet	(	FifoThreadContext *	ctx,
		AVPacket *	pkt
	)

static

Definition at line 180 of file fifo.c.

Referenced by fifo_thread_dispatch_message().

◆ fifo_thread_write_trailer()

static int fifo_thread_write_trailer ( FifoThreadContext * ctx )

static

Definition at line 223 of file fifo.c.

Referenced by fifo_consumer_thread(), and fifo_thread_attempt_recovery().

◆ fifo_thread_dispatch_message()

static int fifo_thread_dispatch_message	(	FifoThreadContext *	ctx,
		FifoMessage *	msg
	)

static

Definition at line 239 of file fifo.c.

Referenced by fifo_consumer_thread(), and fifo_thread_attempt_recovery().

◆ is_recoverable()

static int is_recoverable	(	const FifoContext *	fifo,
		int	err_no
	)

static

Definition at line 266 of file fifo.c.

Referenced by fifo_thread_attempt_recovery().

◆ free_message()

static void free_message ( void * msg )

static

Definition at line 285 of file fifo.c.

Referenced by fifo_init(), and fifo_thread_attempt_recovery().

◆ fifo_thread_process_recovery_failure()

static int fifo_thread_process_recovery_failure	(	FifoThreadContext *	ctx,
		AVPacket *	pkt,
		int	err_no
	)

static

Definition at line 293 of file fifo.c.

Referenced by fifo_thread_attempt_recovery().

◆ fifo_thread_attempt_recovery()

static int fifo_thread_attempt_recovery	(	FifoThreadContext *	ctx,
		FifoMessage *	msg,
		int	err_no
	)

static

Definition at line 325 of file fifo.c.

Referenced by fifo_thread_recover().

◆ fifo_thread_recover()

static int fifo_thread_recover	(	FifoThreadContext *	ctx,
		FifoMessage *	msg,
		int	err_no
	)

static

Definition at line 396 of file fifo.c.

Referenced by fifo_consumer_thread().

◆ fifo_consumer_thread()

static void* fifo_consumer_thread ( void * data )

static

Definition at line 422 of file fifo.c.

Referenced by fifo_write_header().

◆ fifo_mux_init()

static int fifo_mux_init	(	AVFormatContext *	avf,
		const AVOutputFormat *	oformat,
		const char *	filename
	)

static

Definition at line 485 of file fifo.c.

Referenced by fifo_init().

◆ fifo_init()

static int fifo_init ( AVFormatContext * avf )

static

Definition at line 522 of file fifo.c.

◆ fifo_write_header()

static int fifo_write_header ( AVFormatContext * avf )

static

Definition at line 561 of file fifo.c.

◆ fifo_write_packet()

static int fifo_write_packet	(	AVFormatContext *	avf,
		AVPacket *	pkt
	)

static

Definition at line 576 of file fifo.c.

◆ fifo_write_trailer()

static int fifo_write_trailer ( AVFormatContext * avf )

static

Definition at line 620 of file fifo.c.

◆ fifo_deinit()

static void fifo_deinit ( AVFormatContext * avf )

static

Definition at line 659 of file fifo.c.

Variable Documentation

◆ options

const AVOption options[]

static

Definition at line 670 of file fifo.c.

◆ fifo_muxer_class

const AVClass fifo_muxer_class

static

Initial value:

= {
    .class_name = "Fifo muxer",
    .item_name  = av_default_item_name,
    .option     = options,
    .version    = LIBAVUTIL_VERSION_INT,
}

Definition at line 707 of file fifo.c.

◆ ff_fifo_muxer

const FFOutputFormat ff_fifo_muxer

Initial value:

= {
    .p.name         = "fifo",
    .p.long_name    = NULL_IF_CONFIG_SMALL("FIFO queue pseudo-muxer"),
    .p.priv_class   = &fifo_muxer_class,
    .p.flags        = AVFMT_NOFILE | AVFMT_ALLOW_FLUSH | AVFMT_TS_NEGATIVE,
    .priv_data_size = sizeof(FifoContext),
    .init           = fifo_init,
    .write_header   = fifo_write_header,
    .write_packet   = fifo_write_packet,
    .write_trailer  = fifo_write_trailer,
    .deinit         = fifo_deinit,
}

Definition at line 714 of file fifo.c.

Data Structures

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ FIFO_DEFAULT_QUEUE_SIZE

◆ FIFO_DEFAULT_MAX_RECOVERY_ATTEMPTS

◆ FIFO_DEFAULT_RECOVERY_WAIT_TIME_USEC

◆ OFFSET

Enumeration Type Documentation

◆ FifoMessageType

Function Documentation

◆ fifo_thread_write_header()

◆ fifo_thread_flush_output()

◆ next_duration()

◆ fifo_thread_write_packet()

◆ fifo_thread_write_trailer()

◆ fifo_thread_dispatch_message()

◆ is_recoverable()

◆ free_message()

◆ fifo_thread_process_recovery_failure()

◆ fifo_thread_attempt_recovery()

◆ fifo_thread_recover()

◆ fifo_consumer_thread()

◆ fifo_mux_init()

◆ fifo_init()

◆ fifo_write_header()

◆ fifo_write_packet()

◆ fifo_write_trailer()

◆ fifo_deinit()

Variable Documentation

◆ options

◆ fifo_muxer_class

◆ ff_fifo_muxer