Public Member Functions | Private Member Functions | Private Attributes | List of all members
librealsense::pipeline::aggregator Class Reference

#include <aggregator.h>

Inheritance diagram for librealsense::pipeline::aggregator:
Inheritance graph

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_interfaceget_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
optionget_option (rs2_option id) override
const optionget_option (rs2_option id) const override
std::shared_ptr< optionget_option_handler (rs2_option id)
std::shared_ptr< optionget_option_handler (rs2_option id) const
virtual const char * get_option_name (rs2_option option) const override
std::vector< rs2_optionget_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::stringget_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 

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

Definition at line 21 of file aggregator.h.

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

Definition at line 17 of file aggregator.h.

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

Definition at line 16 of file aggregator.h.

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

Definition at line 18 of file aggregator.h.

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

Definition at line 19 of file aggregator.h.

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

Definition at line 20 of file aggregator.h.

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

Author(s): Sergey Dorodnicov , Doron Hirshberg , Mark Horn , Reagan Lopez , Itay Carpis
autogenerated on Mon May 3 2021 02:50:39