#include <aggregator.h>

Inheritance diagram for librealsense::pipeline::aggregator:

[legend]

Public Member Functions
	aggregator (const std::vector< int > &streams_to_aggregate, const std::vector< int > &streams_to_sync)

bool	dequeue (frame_holder *item, unsigned int timeout_ms)

void	start ()

void	stop ()

bool	try_dequeue (frame_holder *item)

Public Member Functions inherited from librealsense::processing_block
synthetic_source_interface &	get_source () override

void	invoke (frame_holder frames) override

	processing_block (const char *name)

void	set_output_callback (frame_callback_ptr callback) override

void	set_processing_callback (frame_processor_callback_ptr callback) override

virtual	~processing_block ()

Public Member Functions inherited from librealsense::processing_block_interface
virtual	~processing_block_interface ()=default

Public Member Functions inherited from librealsense::options_interface
virtual	~options_interface ()=default

Public Member Functions inherited from librealsense::recordable< options_interface >
virtual	~recordable ()=default

Public Member Functions inherited from librealsense::info_interface
virtual	~info_interface ()=default

Public Member Functions inherited from librealsense::recordable< info_interface >
virtual	~recordable ()=default

Public Member Functions inherited from librealsense::options_container
void	create_snapshot (std::shared_ptr< options_interface > &snapshot) const override

void	enable_recording (std::function< void(const options_interface &)> record_action) override

option &	get_option (rs2_option id) override

const option &	get_option (rs2_option id) const override

std::shared_ptr< option >	get_option_handler (rs2_option id)

std::shared_ptr< option >	get_option_handler (rs2_option id) const

virtual const char *	get_option_name (rs2_option option) const override

std::vector< rs2_option >	get_supported_options () const override

void	register_option (rs2_option id, std::shared_ptr< option > option)

bool	supports_option (rs2_option id) const override

void	unregister_option (rs2_option id)

void	update (std::shared_ptr< extension_snapshot > ext) override

Public Member Functions inherited from librealsense::extension_snapshot
virtual	~extension_snapshot ()=default

Public Member Functions inherited from librealsense::info_container
void	create_snapshot (std::shared_ptr< info_interface > &snapshot) const override

void	enable_recording (std::function< void(const info_interface &)> record_action) override

const std::string &	get_info (rs2_camera_info info) const override

void	register_info (rs2_camera_info info, const std::string &val)

bool	supports_info (rs2_camera_info info) const override

void	update (std::shared_ptr< extension_snapshot > ext) override

void	update_info (rs2_camera_info info, const std::string &val)

Private Member Functions
void	handle_frame (frame_holder frame, synthetic_source_interface *source)

Private Attributes
std::atomic< bool >	_accepting

std::map< stream_id, frame_holder >	_last_set

std::mutex	_mutex

std::unique_ptr< single_consumer_frame_queue< frame_holder > >	_queue

std::vector< int >	_streams_to_aggregate_ids

std::vector< int >	_streams_to_sync_ids

Additional Inherited Members
Protected Attributes inherited from librealsense::processing_block
frame_processor_callback_ptr	_callback

std::mutex	_mutex

frame_source	_source

synthetic_source	_source_wrapper

Protected Attributes inherited from librealsense::options_container
std::map< rs2_option, std::shared_ptr< option > >	_options

std::function< void(const options_interface &)>	_recording_function = [](const options_interface&) {}

Detailed Description

Definition at line 14 of file aggregator.h.

Constructor & Destructor Documentation

librealsense::pipeline::aggregator::aggregator	(	const std::vector< int > &	streams_to_aggregate,
		const std::vector< int > &	streams_to_sync
	)

Definition at line 12 of file aggregator.cpp.

Member Function Documentation

bool librealsense::pipeline::aggregator::dequeue	(	frame_holder *	item,
		unsigned int	timeout_ms
	)

Definition at line 105 of file aggregator.cpp.

void librealsense::pipeline::aggregator::handle_frame	(	frame_holder	frame,
		synthetic_source_interface *	source
	)

private

Definition at line 28 of file aggregator.cpp.

void librealsense::pipeline::aggregator::start ( )

Definition at line 115 of file aggregator.cpp.

void librealsense::pipeline::aggregator::stop ( )

Definition at line 120 of file aggregator.cpp.

bool librealsense::pipeline::aggregator::try_dequeue ( frame_holder * item )

Definition at line 110 of file aggregator.cpp.

Member Data Documentation

std::atomic<bool> librealsense::pipeline::aggregator::_accepting

private

Definition at line 21 of file aggregator.h.

std::map<stream_id, frame_holder> librealsense::pipeline::aggregator::_last_set

private

Definition at line 17 of file aggregator.h.

std::mutex librealsense::pipeline::aggregator::_mutex

private

Definition at line 16 of file aggregator.h.

std::unique_ptr<single_consumer_frame_queue<frame_holder> > librealsense::pipeline::aggregator::_queue

private

Definition at line 18 of file aggregator.h.

std::vector<int> librealsense::pipeline::aggregator::_streams_to_aggregate_ids

private

Definition at line 19 of file aggregator.h.

std::vector<int> librealsense::pipeline::aggregator::_streams_to_sync_ids

private

Definition at line 20 of file aggregator.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation