BatchPolicy Class Reference

Detailed Description

Definition at line 183 of file sources/libs/nvstreammux/include/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 ()
	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/4]

BatchPolicy::BatchPolicy ( )

inline

Definition at line 186 of file sources/libs/nvstreammux/include/nvstreammux_batch.h.

BatchPolicy() [2/4]

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

BatchPolicy() [3/4]

BatchPolicy::BatchPolicy ( )

inline

Definition at line 186 of file 9.0/sources/libs/nvstreammux/include/nvstreammux_batch.h.

BatchPolicy() [4/4]

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

Member Function Documentation

calculate_delay() [1/2]

NanoSecondsType BatchPolicy::calculate_delay

(

)

calculate_delay() [2/2]

NanoSecondsType BatchPolicy::calculate_delay

(

)

calculate_wait() [1/2]

NanoSecondsType BatchPolicy::calculate_wait

(

)

calculate_wait() [2/2]

NanoSecondsType BatchPolicy::calculate_wait

(

)

check_and_update_defaults() [1/2]

void BatchPolicy::check_and_update_defaults

(

unsigned int

source_id

)

check_and_update_defaults() [2/2]

void BatchPolicy::check_and_update_defaults

(

unsigned int

source_id

)

check_past_min() [1/2]

bool BatchPolicy::check_past_min

(

)

check_past_min() [2/2]

bool BatchPolicy::check_past_min

(

)

check_repeats_per_batch() [1/4]

unsigned int BatchPolicy::check_repeats_per_batch

(

)

check_repeats_per_batch() [2/4]

unsigned int BatchPolicy::check_repeats_per_batch

(

)

check_repeats_per_batch() [3/4]

unsigned int BatchPolicy::check_repeats_per_batch

(

unsigned int

source_id

)

check_repeats_per_batch() [4/4]

unsigned int BatchPolicy::check_repeats_per_batch

(

unsigned int

source_id

)

form_batch() [1/2]

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

form_batch() [2/2]

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

get_batch_size() [1/2]

unsigned int BatchPolicy::get_batch_size

(

)

get_batch_size() [2/2]

unsigned int BatchPolicy::get_batch_size

(

)

get_config() [1/2]

BatchPolicyConfig BatchPolicy::get_config

(

)

get_config() [2/2]

BatchPolicyConfig BatchPolicy::get_config

(

)

get_config_batch_size() [1/2]

unsigned int BatchPolicy::get_config_batch_size

(

)

get_config_batch_size() [2/2]

unsigned int BatchPolicy::get_config_batch_size

(

)

get_eos_sources() [1/2]

unsigned int BatchPolicy::get_eos_sources

(

)

get_eos_sources() [2/2]

unsigned int BatchPolicy::get_eos_sources

(

)

get_max_duration_delay() [1/2]

NanoSecondsType BatchPolicy::get_max_duration_delay

(

)

get_max_duration_delay() [2/2]

NanoSecondsType BatchPolicy::get_max_duration_delay

(

)

get_min_fps_duration() [1/2]

NanoSecondsType BatchPolicy::get_min_fps_duration

(

)

get_min_fps_duration() [2/2]

NanoSecondsType BatchPolicy::get_min_fps_duration

(

)

is_max_fps_control_enabled() [1/2]

bool BatchPolicy::is_max_fps_control_enabled

(

)

is_max_fps_control_enabled() [2/2]

bool BatchPolicy::is_max_fps_control_enabled

(

)

is_ready() [1/2]

bool BatchPolicy::is_ready

(

Batch *

b

)

is_ready() [2/2]

bool BatchPolicy::is_ready

(

Batch *

b

)

is_ready_or_due() [1/2]

bool BatchPolicy::is_ready_or_due

(

Batch *

b

)

is_ready_or_due() [2/2]

bool BatchPolicy::is_ready_or_due

(

Batch *

b

)

set_batch_push_timeout() [1/2]

void BatchPolicy::set_batch_push_timeout

(

unsigned int

)

set_batch_push_timeout() [2/2]

void BatchPolicy::set_batch_push_timeout

(

unsigned int

)

set_batch_size() [1/2]

void BatchPolicy::set_batch_size

(

unsigned int

)

set_batch_size() [2/2]

void BatchPolicy::set_batch_size

(

unsigned int

)

set_num_surfaces() [1/2]

void BatchPolicy::set_num_surfaces

(

unsigned int

)

Set num_surfaces_per_frame.

set_num_surfaces() [2/2]

void BatchPolicy::set_num_surfaces

(

unsigned int

)

Set num_surfaces_per_frame.

set_synch_buffer_iface() [1/2]

void BatchPolicy::set_synch_buffer_iface

(

ISynchronizeBuffer *

synch_buffer_iface

)

set_synch_buffer_iface() [2/2]

void BatchPolicy::set_synch_buffer_iface

(

ISynchronizeBuffer *

synch_buffer_iface

)

Referenced by NvStreamMux::set_policy().

synchronize_buffers_in_pad() [1/2]

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

synchronize_buffers_in_pad() [2/2]

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() [1/2]

void BatchPolicy::update_eos_sources

(

unsigned int

eos_count

)

update_eos_sources() [2/2]

void BatchPolicy::update_eos_sources

(

unsigned int

eos_count

)

update_idle_sources() [1/2]

void BatchPolicy::update_idle_sources

(

unsigned int

idle_count

)

update_idle_sources() [2/2]

void BatchPolicy::update_idle_sources

(

unsigned int

idle_count

)

update_last_batch_time() [1/2]

void BatchPolicy::update_last_batch_time

(

)

update_last_batch_time() [2/2]

void BatchPolicy::update_last_batch_time

(

)

update_push_stats() [1/2]

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

update_push_stats() [2/2]

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

update_with_source() [1/2]

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

update_with_source() [2/2]

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 261 of file sources/libs/nvstreammux/include/nvstreammux_batch.h.

Referenced by NvStreamMux::set_policy().

---

The documentation for this class was generated from the following file:

• sources/libs/nvstreammux/include/nvstreammux_batch.h