#include "libavutil/avassert.h"
#include "libavutil/avstring.h"
#include "libavutil/error.h"
#include "libavutil/fifo.h"
#include "libavutil/log.h"
#include "libavutil/opt.h"
#include "libavutil/thread.h"
#include "url.h"
#include <stdint.h>

Data Structures
struct	RingBuffer

struct	Context

Macros
#define	BUFFER_CAPACITY (4 * 1024 * 1024)
	support timeout support work with concatdec, hls More...

#define	READ_BACK_CAPACITY (4 * 1024 * 1024)

#define	SHORT_SEEK_THRESHOLD (256 * 1024)

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

#define	D AV_OPT_FLAG_DECODING_PARAM

Functions
static int	ring_init (RingBuffer *ring, unsigned int capacity, int read_back_capacity)

static void	ring_destroy (RingBuffer *ring)

static void	ring_reset (RingBuffer *ring)

static int	ring_size (RingBuffer *ring)

static int	ring_space (RingBuffer *ring)

static int	ring_generic_read (RingBuffer ring, void dest, int buf_size, void(func)(void , void *, int))

static int	ring_generic_write (RingBuffer ring, void src, int size, int(func)(void , void *, int))

static int	ring_size_of_read_back (RingBuffer *ring)

static int	ring_drain (RingBuffer *ring, int offset)

static int	async_check_interrupt (void *arg)

static int	wrapped_url_read (void src, void dst, int size)

static void *	async_buffer_task (void *arg)

static int	async_open (URLContext h, const char arg, int flags, AVDictionary **options)

static int	async_close (URLContext *h)

static int	async_read_internal (URLContext h, void dest, int size, int read_complete, void(func)(void , void *, int))

static int	async_read (URLContext h, unsigned char buf, int size)

static void	fifo_do_not_copy_func (void dest, void src, int size)

static int64_t	async_seek (URLContext *h, int64_t pos, int whence)

Variables
static const AVOption	options []

static const AVClass	async_context_class

const URLProtocol	ff_async_protocol

Macro Definition Documentation

◆ BUFFER_CAPACITY

#define BUFFER_CAPACITY (4 * 1024 * 1024)

support timeout support work with concatdec, hls

Definition at line 44 of file async.c.

Referenced by async_open().

◆ READ_BACK_CAPACITY

#define READ_BACK_CAPACITY (4 * 1024 * 1024)

Definition at line 45 of file async.c.

Referenced by async_open().

◆ SHORT_SEEK_THRESHOLD

#define SHORT_SEEK_THRESHOLD (256 * 1024)

Definition at line 46 of file async.c.

Referenced by async_seek().

◆ OFFSET

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

Definition at line 465 of file async.c.

◆ D

#define D AV_OPT_FLAG_DECODING_PARAM

Definition at line 466 of file async.c.

Function Documentation

◆ ring_init()

static int ring_init	(	RingBuffer *	ring,
		unsigned int	capacity,
		int	read_back_capacity
	)

static

Definition at line 83 of file async.c.

Referenced by async_open().

◆ ring_destroy()

static void ring_destroy ( RingBuffer * ring )

static

Definition at line 94 of file async.c.

Referenced by async_close(), and async_open().

◆ ring_reset()

static void ring_reset ( RingBuffer * ring )

static

Definition at line 99 of file async.c.

Referenced by async_buffer_task().

◆ ring_size()

static int ring_size ( RingBuffer * ring )

static

Definition at line 105 of file async.c.

Referenced by async_read_internal(), async_seek(), encode_plane(), encode_rgb_frame(), ring_drain(), and ring_generic_read().

◆ ring_space()

static int ring_space ( RingBuffer * ring )

static

Definition at line 110 of file async.c.

Referenced by async_buffer_task(), and ring_generic_write().

◆ ring_generic_read()

static int ring_generic_read	(	RingBuffer *	ring,
		void *	dest,
		int	buf_size,
		void()(void , void *, int)	func
	)

static

Definition at line 115 of file async.c.

Referenced by async_read_internal().

◆ ring_generic_write()

static int ring_generic_write	(	RingBuffer *	ring,
		void *	src,
		int	size,
		int()(void , void *, int)	func
	)

static

Definition at line 131 of file async.c.

Referenced by async_buffer_task().

◆ ring_size_of_read_back()

static int ring_size_of_read_back ( RingBuffer * ring )

static

Definition at line 137 of file async.c.

Referenced by async_seek(), and ring_drain().

◆ ring_drain()

static int ring_drain	(	RingBuffer *	ring,
		int	offset
	)

static

Definition at line 142 of file async.c.

Referenced by async_seek().

◆ async_check_interrupt()

static int async_check_interrupt ( void * arg )

static

Definition at line 150 of file async.c.

Referenced by async_buffer_task(), async_open(), async_read_internal(), and async_seek().

◆ wrapped_url_read()

static int wrapped_url_read	(	void *	src,
		void *	dst,
		int	size
	)

static

Definition at line 164 of file async.c.

Referenced by async_buffer_task().

◆ async_buffer_task()

static void* async_buffer_task ( void * arg )

static

Definition at line 176 of file async.c.

Referenced by async_open().

◆ async_open()

static int async_open	(	URLContext *	h,
		const char *	arg,
		int	flags,
		AVDictionary **	options
	)

static

Definition at line 240 of file async.c.

◆ async_close()

static int async_close ( URLContext * h )

static

Definition at line 303 of file async.c.

◆ async_read_internal()

static int async_read_internal	(	URLContext *	h,
		void *	dest,
		int	size,
		int	read_complete,
		void()(void , void *, int)	func
	)

static

Definition at line 326 of file async.c.

Referenced by async_read(), and async_seek().

◆ async_read()

static int async_read	(	URLContext *	h,
		unsigned char *	buf,
		int	size
	)

static

Definition at line 373 of file async.c.

◆ fifo_do_not_copy_func()

static void fifo_do_not_copy_func	(	void *	dest,
		void *	src,
		int	size
	)

static

Definition at line 378 of file async.c.

Referenced by async_seek().

◆ async_seek()

static int64_t async_seek	(	URLContext *	h,
		int64_t	pos,
		int	whence
	)

static

Definition at line 382 of file async.c.

Variable Documentation

◆ options

const AVOption options[]

static

Initial value:

= {
    {NULL},
}

Definition at line 468 of file async.c.

◆ async_context_class

const AVClass async_context_class

static

Initial value:

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

Definition at line 475 of file async.c.

◆ ff_async_protocol

const URLProtocol ff_async_protocol

Initial value:

= {
    .name                = "async",
    .url_open2           = async_open,
    .url_read            = async_read,
    .url_seek            = async_seek,
    .url_close           = async_close,
    .priv_data_size      = sizeof(Context),
    .priv_data_class     = &async_context_class,
}

Definition at line 482 of file async.c.

Data Structures

Macros

Functions

Variables

Macro Definition Documentation

◆ BUFFER_CAPACITY

◆ READ_BACK_CAPACITY

◆ SHORT_SEEK_THRESHOLD

◆ OFFSET

◆ D

Function Documentation

◆ ring_init()

◆ ring_destroy()

◆ ring_reset()

◆ ring_size()

◆ ring_space()

◆ ring_generic_read()

◆ ring_generic_write()

◆ ring_size_of_read_back()

◆ ring_drain()

◆ async_check_interrupt()

◆ wrapped_url_read()

◆ async_buffer_task()

◆ async_open()

◆ async_close()

◆ async_read_internal()

◆ async_read()

◆ fifo_do_not_copy_func()

◆ async_seek()

Variable Documentation

◆ options

◆ async_context_class

◆ ff_async_protocol