Detailed Description

Definition at line 194 of file nvstreammux_batch.h.

Public Member Functions
	BatchPolicy ()

	BatchPolicy (BatchPolicyConfig policy, std::unordered_map< unsigned int, SinkPad * > ins, INvStreammuxDebug a_debug_iface)

unsigned int	check_repeats_per_batch ()

unsigned int	check_repeats_per_batch (unsigned int source_id)

Batch *	form_batch (Batch *b, unsigned int batch_size)

unsigned int	get_batch_size ()

unsigned int	get_config_batch_size ()

void	set_batch_size (unsigned int)

void	set_batch_push_timeout (unsigned int)

void	set_num_surfaces (unsigned int)
	Set num_surfaces_per_frame. More...

void	update_with_source (Batch *batch, unsigned int source_id)

NanoSecondsType	calculate_wait ()

void	update_last_batch_time ()

NanoSecondsType	get_max_duration_delay ()

NanoSecondsType	calculate_delay ()

bool	is_ready (Batch *b)

bool	is_ready_or_due (Batch *b)

void	check_and_update_defaults (unsigned int source_id)

bool	check_past_min ()

void	update_idle_sources (unsigned int idle_count)

void	update_eos_sources (unsigned int eos_count)

unsigned int	get_eos_sources ()

void	update_push_stats (unsigned int source_id, unsigned int num_pushed)

bool	is_max_fps_control_enabled ()

void	set_synch_buffer_iface (ISynchronizeBuffer *synch_buffer_iface)

unsigned int	synchronize_buffers_in_pad (SinkPad *pad, unsigned int allowed_buffers)
	Synchronize the buffers in queue for provided pad. More...

NanoSecondsType	get_min_fps_duration ()

BatchPolicyConfig	get_config ()

Data Fields
unsigned int	total_buf_available

Constructor & Destructor Documentation

◆ BatchPolicy() [1/2]

BatchPolicy::BatchPolicy ( )

inline

Definition at line 197 of file nvstreammux_batch.h.

◆ BatchPolicy() [2/2]

BatchPolicy::BatchPolicy	(	BatchPolicyConfig	policy,
		std::unordered_map< unsigned int, SinkPad * > *	ins,
		INvStreammuxDebug *	a_debug_iface
	)

Member Function Documentation

◆ calculate_delay()

NanoSecondsType BatchPolicy::calculate_delay ( )

◆ calculate_wait()

NanoSecondsType BatchPolicy::calculate_wait ( )

◆ check_and_update_defaults()

void BatchPolicy::check_and_update_defaults ( unsigned int source_id )

◆ check_past_min()

bool BatchPolicy::check_past_min ( )

◆ check_repeats_per_batch() [1/2]

unsigned int BatchPolicy::check_repeats_per_batch ( )

◆ check_repeats_per_batch() [2/2]

unsigned int BatchPolicy::check_repeats_per_batch ( unsigned int source_id )

◆ form_batch()

Batch* BatchPolicy::form_batch	(	Batch *	b,
		unsigned int	batch_size
	)

◆ get_batch_size()

unsigned int BatchPolicy::get_batch_size ( )

◆ get_config()

BatchPolicyConfig BatchPolicy::get_config ( )

◆ get_config_batch_size()

unsigned int BatchPolicy::get_config_batch_size ( )

◆ get_eos_sources()

unsigned int BatchPolicy::get_eos_sources ( )

◆ get_max_duration_delay()

NanoSecondsType BatchPolicy::get_max_duration_delay ( )

◆ get_min_fps_duration()

NanoSecondsType BatchPolicy::get_min_fps_duration ( )

◆ is_max_fps_control_enabled()

bool BatchPolicy::is_max_fps_control_enabled ( )

◆ is_ready()

bool BatchPolicy::is_ready ( Batch * b )

◆ is_ready_or_due()

bool BatchPolicy::is_ready_or_due ( Batch * b )

◆ set_batch_push_timeout()

void BatchPolicy::set_batch_push_timeout ( unsigned int )

◆ set_batch_size()

void BatchPolicy::set_batch_size ( unsigned int )

◆ set_num_surfaces()

void BatchPolicy::set_num_surfaces ( unsigned int )

Set num_surfaces_per_frame.

◆ set_synch_buffer_iface()

void BatchPolicy::set_synch_buffer_iface ( ISynchronizeBuffer * synch_buffer_iface )

Referenced by NvStreamMux::set_policy().

◆ synchronize_buffers_in_pad()

unsigned int BatchPolicy::synchronize_buffers_in_pad	(	SinkPad *	pad,
		unsigned int	allowed_buffers
	)

Synchronize the buffers in queue for provided pad.

Returns: The number of on time buffers in the pad queue

◆ update_eos_sources()

void BatchPolicy::update_eos_sources ( unsigned int eos_count )

◆ update_idle_sources()

void BatchPolicy::update_idle_sources ( unsigned int idle_count )

◆ update_last_batch_time()

void BatchPolicy::update_last_batch_time ( )

◆ update_push_stats()

void BatchPolicy::update_push_stats	(	unsigned int	source_id,
		unsigned int	num_pushed
	)

◆ update_with_source()

void BatchPolicy::update_with_source	(	Batch *	batch,
		unsigned int	source_id
	)

Field Documentation

◆ total_buf_available

unsigned int BatchPolicy::total_buf_available

Definition at line 272 of file nvstreammux_batch.h.