An xrt_frame_sink queue, any frames received will be pushed to the downstream consumer on the queue thread. More...

Inheritance diagram for u_sink_queue:

Collaboration diagram for u_sink_queue:

[legend]

Data Fields
struct xrt_frame_sink	base
	Base sink. More...

struct xrt_frame_node	node
	For tracking on the frame context. More...

struct xrt_frame_sink *	consumer
	The consumer of the frames that are queued. More...

struct u_sink_queue_elem *	front
	Front of the queue (oldest frame, first to be consumed) More...

struct u_sink_queue_elem *	back
	Back of the queue (newest frame, back->next is always null) More...

uint64_t	size
	Number of currently enqueued frames. More...

uint64_t	max_size
	Max amount of frames before dropping new ones. 0 means unbounded. More...

pthread_t	thread

pthread_mutex_t	mutex

pthread_cond_t	cond
	So we can wake the mainloop up. More...

bool	running
	Should we keep running. More...

struct xrt_frame *	frame
	The current queued frame. More...

struct {
uint64_t current

uint64_t last

}	seq

Data Fields inherited from xrt_frame_sink
void(*	push_frame )(struct xrt_frame_sink sink, struct xrt_frame frame)
	Push a frame into the sink. More...

Data Fields inherited from xrt_frame_node
struct xrt_frame_node *	next

void(*	break_apart )(struct xrt_frame_node *node)
	Called first in when the graph is being destroyed, remove any references frames and other objects and stop threads. More...

void(*	destroy )(struct xrt_frame_node *node)
	Do the actual freeing of the objects. More...

Additional Inherited Members
Public Member Functions inherited from xrt_frame_sink
void	u_sink_create_format_converter (struct xrt_frame_context xfctx, enum xrt_format f, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_r8g8b8_or_l8 (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_r8g8b8_bayer_or_l8 (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_rgb_yuv_yuyv_uyvy_or_l8 (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_yuv_yuyv_uyvy_or_l8 (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_yuv_or_yuyv (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_create_to_r8g8b8_r8g8b8a8_r8g8b8x8_or_l8 (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_deinterleaver_create (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

bool	u_sink_queue_create (struct xrt_frame_context xfctx, uint64_t max_size, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

bool	u_sink_simple_queue_create (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct xrt_frame_sink **out_xfs)

void	u_sink_quirk_create (struct xrt_frame_context xfctx, struct xrt_frame_sink downstream, struct u_sink_quirk_params params, struct xrt_frame_sink *out_xfs)

void	u_sink_split_create (struct xrt_frame_context xfctx, struct xrt_frame_sink left, struct xrt_frame_sink right, struct xrt_frame_sink *out_xfs)

Static Public Member Functions inherited from xrt_frame_sink
static void	xrt_sink_push_frame (struct xrt_frame_sink sink, struct xrt_frame frame)
	Push a frame into the sink. More...

Detailed Description

An xrt_frame_sink queue, any frames received will be pushed to the downstream consumer on the queue thread.

Will drop frames should multiple frames be queued up.

Field Documentation

◆ back

struct u_sink_queue_elem* u_sink_queue::back

Back of the queue (newest frame, back->next is always null)

Referenced by queue_pop(), queue_refclear(), and queue_try_refpush().

◆ base

struct xrt_frame_sink u_sink_queue::base

Base sink.

Referenced by xrt_frame_sink::u_sink_queue_create(), and xrt_frame_sink::u_sink_simple_queue_create().

◆ cond

pthread_cond_t u_sink_queue::cond

So we can wake the mainloop up.

◆ consumer

struct xrt_frame_sink * u_sink_queue::consumer

The consumer of the frames that are queued.

◆ frame

struct xrt_frame* u_sink_queue::frame

The current queued frame.

◆ front

struct u_sink_queue_elem* u_sink_queue::front

Front of the queue (oldest frame, first to be consumed)

Referenced by queue_pop(), queue_refclear(), and queue_try_refpush().

◆ max_size

uint64_t u_sink_queue::max_size

Max amount of frames before dropping new ones. 0 means unbounded.

Referenced by queue_is_full().

◆ node

struct xrt_frame_node u_sink_queue::node

For tracking on the frame context.

◆ running

bool u_sink_queue::running

Should we keep running.

◆ size

uint64_t u_sink_queue::size

Number of currently enqueued frames.

Referenced by queue_is_empty(), queue_is_full(), queue_pop(), queue_refclear(), and queue_try_refpush().

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

auxiliary/util/u_sink_queue.c
auxiliary/util/u_sink_simple_queue.c

Data Fields

Additional Inherited Members