FFmpeg
Files | Macros | Typedefs | Functions

Files

file  fifo.h
 

Macros

#define AV_FIFO_FLAG_AUTO_GROW   (1 << 0)
 Automatically resize the FIFO on writes, so that the data fits. More...
 

Typedefs

typedef int AVFifoCB(void *opaque, void *buf, size_t *nb_elems)
 Callback for writing or reading from a FIFO, passed to (and invoked from) the av_fifo_*_cb() functions. More...
 

Functions

AVFifoav_fifo_alloc2 (size_t elems, size_t elem_size, unsigned int flags)
 Allocate and initialize an AVFifo with a given element size. More...
 
size_t av_fifo_elem_size (const AVFifo *f)
 
void av_fifo_auto_grow_limit (AVFifo *f, size_t max_elems)
 Set the maximum size (in elements) to which the FIFO can be resized automatically. More...
 
size_t av_fifo_can_read (const AVFifo *f)
 
size_t av_fifo_can_write (const AVFifo *f)
 
int av_fifo_grow2 (AVFifo *f, size_t inc)
 Enlarge an AVFifo. More...
 
int av_fifo_write (AVFifo *f, const void *buf, size_t nb_elems)
 Write data into a FIFO. More...
 
int av_fifo_write_from_cb (AVFifo *f, AVFifoCB read_cb, void *opaque, size_t *nb_elems)
 Write data from a user-provided callback into a FIFO. More...
 
int av_fifo_read (AVFifo *f, void *buf, size_t nb_elems)
 Read data from a FIFO. More...
 
int av_fifo_read_to_cb (AVFifo *f, AVFifoCB write_cb, void *opaque, size_t *nb_elems)
 Feed data from a FIFO into a user-provided callback. More...
 
int av_fifo_peek (const AVFifo *f, void *buf, size_t nb_elems, size_t offset)
 Read data from a FIFO without modifying FIFO state. More...
 
int av_fifo_peek_to_cb (const AVFifo *f, AVFifoCB write_cb, void *opaque, size_t *nb_elems, size_t offset)
 Feed data from a FIFO into a user-provided callback. More...
 
void av_fifo_drain2 (AVFifo *f, size_t size)
 Discard the specified amount of data from an AVFifo. More...
 
void av_fifo_reset2 (AVFifo *f)
 
void av_fifo_freep2 (AVFifo **f)
 Free an AVFifo and reset pointer to NULL. More...
 

Detailed Description

A generic FIFO API

Macro Definition Documentation

◆ AV_FIFO_FLAG_AUTO_GROW

#define AV_FIFO_FLAG_AUTO_GROW   (1 << 0)

Automatically resize the FIFO on writes, so that the data fits.

This automatic resizing happens up to a limit that can be modified with av_fifo_auto_grow_limit().

Definition at line 67 of file fifo.h.

Typedef Documentation

◆ AVFifoCB

typedef int AVFifoCB(void *opaque, void *buf, size_t *nb_elems)

Callback for writing or reading from a FIFO, passed to (and invoked from) the av_fifo_*_cb() functions.

It may be invoked multiple times from a single av_fifo_*_cb() call and may process less data than the maximum size indicated by nb_elems.

Parameters
opaquethe opaque pointer provided to the av_fifo_*_cb() function
bufthe buffer for reading or writing the data, depending on which av_fifo_*_cb function is called
nb_elemsOn entry contains the maximum number of elements that can be read from / written into buf. On success, the callback should update it to contain the number of elements actually written.
Returns
0 on success, a negative error code on failure (will be returned from the invoking av_fifo_*_cb() function)

Definition at line 60 of file fifo.h.

Function Documentation

◆ av_fifo_alloc2()

AVFifo* av_fifo_alloc2 ( size_t  elems,
size_t  elem_size,
unsigned int  flags 
)

Allocate and initialize an AVFifo with a given element size.

Parameters
elemsinitial number of elements that can be stored in the FIFO
elem_sizeSize in bytes of a single element. Further operations on the returned FIFO will implicitly use this element size.
flagsa combination of AV_FIFO_FLAG_*
Returns
newly-allocated AVFifo on success, a negative error code on failure

Definition at line 47 of file fifo.c.

Referenced by amf_load_library(), av1_decode_init(), av_audio_fifo_alloc(), av_thread_message_queue_alloc(), config_input(), cuvid_decode_init(), deshake_opencl_init(), dnn_detect_init(), dts2pts_init(), dv_init_mux(), ff_ccfifo_init(), ff_d3d12va_decode_init(), ff_qsv_enc_init(), ff_qsvvpp_init(), ff_vaapi_encode_init(), fg_thread_init(), ifilter_alloc(), init(), input_init(), libvorbis_encode_init(), main(), mpeg_mux_init(), nvenc_setup_surfaces(), packet_queue_init(), qsv_decode_init(), qsv_decode_preinit(), ring_init(), sch_add_mux_stream(), sq_add_stream(), start_jack(), swf_write_header(), tq_alloc(), udp_open(), and vpx_init().

◆ av_fifo_elem_size()

size_t av_fifo_elem_size ( const AVFifo f)
Returns
Element size for FIFO operations. This element size is set at FIFO allocation and remains constant during its lifetime

Definition at line 82 of file fifo.c.

Referenced by main().

◆ av_fifo_auto_grow_limit()

void av_fifo_auto_grow_limit ( AVFifo f,
size_t  max_elems 
)

Set the maximum size (in elements) to which the FIFO can be resized automatically.

Has no effect unless AV_FIFO_FLAG_AUTO_GROW is used.

Definition at line 77 of file fifo.c.

◆ av_fifo_can_read()

size_t av_fifo_can_read ( const AVFifo f)

◆ av_fifo_can_write()

size_t av_fifo_can_write ( const AVFifo f)
Returns
Number of elements that can be written into the given FIFO without growing it.

In other words, this number of elements or less is guaranteed to fit into the FIFO. More data may be written when the AV_FIFO_FLAG_AUTO_GROW flag was specified at FIFO creation, but this may involve memory allocation, which can fail.

Definition at line 94 of file fifo.c.

Referenced by activate(), av_audio_fifo_realloc(), dts2pts_filter(), dv_assemble_frame(), ff_vaapi_encode_receive_packet(), fifo_check_space(), libvorbis_encode_frame(), main(), mpeg_mux_write_packet(), mux_queue_packet(), process_callback(), ring_space(), ringbuf_float_at(), supply_new_packets(), swf_write_audio(), tq_send(), and udp_write().

◆ av_fifo_grow2()

int av_fifo_grow2 ( AVFifo f,
size_t  inc 
)

Enlarge an AVFifo.

On success, the FIFO will be large enough to hold exactly inc + av_fifo_can_read() + av_fifo_can_write() elements. In case of failure, the old FIFO is kept unchanged.

Parameters
fAVFifo to resize
incnumber of elements to allocate for, in addition to the current allocated size
Returns
a non-negative number on success, a negative error code on failure

Definition at line 99 of file fifo.c.

Referenced by av_audio_fifo_realloc(), fifo_check_space(), main(), mpeg_mux_write_packet(), and mux_queue_packet().

◆ av_fifo_write()

int av_fifo_write ( AVFifo f,
const void *  buf,
size_t  nb_elems 
)

Write data into a FIFO.

In case nb_elems > av_fifo_can_write(f) and the AV_FIFO_FLAG_AUTO_GROW flag was not specified at FIFO creation, nothing is written and an error is returned.

Calling function is guaranteed to succeed if nb_elems <= av_fifo_can_write(f).

Parameters
fthe FIFO buffer
bufData to be written. nb_elems * av_fifo_elem_size(f) bytes will be read from buf on success.
nb_elemsnumber of elements to write into FIFO
Returns
a non-negative number on success, a negative error code on failure

Definition at line 188 of file fifo.c.

Referenced by activate(), av1_receive_frame_internal(), av_audio_fifo_write(), cuvid_handle_picture_display(), d3d12va_discard_helper_objects(), dnn_detect_parse_yolo_output(), dv_assemble_frame(), encode_frame(), ff_amf_receive_packet(), ff_ccfifo_extractbytes(), ff_nvenc_receive_packet(), ff_qsvvpp_filter_frame(), ff_vaapi_encode_receive_packet(), filter_frame(), frame_data_submit(), h264_queue_frame(), handle_input(), libvorbis_encode_frame(), main(), mpeg_mux_write_packet(), mux_queue_packet(), nvenc_alloc_surface(), nvenc_send_frame(), packet_queue_put_private(), process_callback(), qsv_decode(), qsv_decode_frame(), send_frame(), sq_send(), sub2video_frame(), supply_new_packets(), swf_write_audio(), timestamp_queue_enqueue(), tq_send(), and udp_write().

◆ av_fifo_write_from_cb()

int av_fifo_write_from_cb ( AVFifo f,
AVFifoCB  read_cb,
void *  opaque,
size_t *  nb_elems 
)

Write data from a user-provided callback into a FIFO.

Parameters
fthe FIFO buffer
read_cbCallback supplying the data to the FIFO. May be called multiple times.
opaqueopaque user data to be provided to read_cb
nb_elemsShould point to the maximum number of elements that can be written. Will be updated to contain the number of elements actually written.
Returns
non-negative number on success, a negative error code on failure

Definition at line 193 of file fifo.c.

Referenced by main(), and ring_write().

◆ av_fifo_read()

int av_fifo_read ( AVFifo f,
void *  buf,
size_t  nb_elems 
)

◆ av_fifo_read_to_cb()

int av_fifo_read_to_cb ( AVFifo f,
AVFifoCB  write_cb,
void *  opaque,
size_t *  nb_elems 
)

Feed data from a FIFO into a user-provided callback.

Parameters
fthe FIFO buffer
write_cbCallback the data will be supplied to. May be called multiple times.
opaqueopaque user data to be provided to write_cb
nb_elemsShould point to the maximum number of elements that can be read. Will be updated to contain the total number of elements actually sent to the callback.
Returns
non-negative number on success, a negative error code on failure

Definition at line 247 of file fifo.c.

Referenced by av_thread_message_flush(), flush_packet(), main(), and swf_write_video().

◆ av_fifo_peek()

int av_fifo_peek ( const AVFifo f,
void *  buf,
size_t  nb_elems,
size_t  offset 
)

Read data from a FIFO without modifying FIFO state.

Returns an error if an attempt is made to peek to nonexistent elements (i.e. if offset + nb_elems is larger than av_fifo_can_read(f)).

Parameters
fthe FIFO buffer
bufBuffer to store the data. nb_elems * av_fifo_elem_size(f) bytes will be written into buf.
nb_elemsnumber of elements to read from FIFO
offsetnumber of initial elements to skip.
Returns
a non-negative number on success, a negative error code on failure

Definition at line 255 of file fifo.c.

Referenced by amf_copy_buffer(), av_audio_fifo_peek_at(), d3d12va_get_valid_helper_objects(), dnn_detect_fill_side_data(), drain_input_pts(), dv_inject_audio(), filter_frame(), frame_data_apply(), libplacebo_activate(), main(), overflow_heartbeat(), receive_for_stream(), receive_samples(), ring_read(), and ringbuf_float_at().

◆ av_fifo_peek_to_cb()

int av_fifo_peek_to_cb ( const AVFifo f,
AVFifoCB  write_cb,
void *  opaque,
size_t *  nb_elems,
size_t  offset 
)

Feed data from a FIFO into a user-provided callback.

Parameters
fthe FIFO buffer
write_cbCallback the data will be supplied to. May be called multiple times.
opaqueopaque user data to be provided to write_cb
nb_elemsShould point to the maximum number of elements that can be read. Will be updated to contain the total number of elements actually sent to the callback.
offsetnumber of initial elements to skip; offset + *nb_elems must not be larger than av_fifo_can_read(f).
Returns
a non-negative number on success, a negative error code on failure

Definition at line 260 of file fifo.c.

Referenced by main().

◆ av_fifo_drain2()

void av_fifo_drain2 ( AVFifo f,
size_t  size 
)

Discard the specified amount of data from an AVFifo.

Parameters
sizenumber of elements to discard, MUST NOT be larger than av_fifo_can_read(f)

Definition at line 266 of file fifo.c.

Referenced by activate(), av_audio_fifo_drain(), av_fifo_read(), av_fifo_read_to_cb(), drain_input_pts(), dv_assemble_frame(), frame_data_apply(), receive_for_stream(), receive_samples(), ring_read(), and udp_read().

◆ av_fifo_reset2()

void av_fifo_reset2 ( AVFifo f)

Definition at line 280 of file fifo.c.

Referenced by av_audio_fifo_reset(), ff_nvenc_encode_flush(), and ring_reset().

◆ av_fifo_freep2()

void av_fifo_freep2 ( AVFifo **  f)