#include <pipeline.h>
Public Member Functions | |
std::shared_ptr< profile > | get_active_profile () const |
std::shared_ptr< librealsense::context > | get_context () const |
pipeline (std::shared_ptr< librealsense::context > ctx) | |
bool | poll_for_frames (frame_holder *frame) |
std::shared_ptr< profile > | start (std::shared_ptr< config > conf, frame_callback_ptr callback=nullptr) |
void | stop () |
bool | try_wait_for_frames (frame_holder *frame, unsigned int timeout_ms) |
std::shared_ptr< device_interface > | wait_for_device (const std::chrono::milliseconds &timeout=std::chrono::hours::max(), const std::string &serial="") |
frame_holder | wait_for_frames (unsigned int timeout_ms) |
virtual | ~pipeline () |
Protected Member Functions | |
frame_callback_ptr | get_callback (std::vector< int > unique_ids) |
std::vector< int > | on_start (std::shared_ptr< profile > profile) |
void | unsafe_start (std::shared_ptr< config > conf) |
void | unsafe_stop () |
Protected Attributes | |
std::shared_ptr< profile > | _active_profile |
device_hub | _hub |
std::mutex | _mtx |
std::shared_ptr< config > | _prev_conf |
Private Member Functions | |
std::shared_ptr< profile > | unsafe_get_active_profile () const |
Private Attributes | |
std::unique_ptr< aggregator > | _aggregator |
std::shared_ptr< librealsense::context > | _ctx |
dispatcher | _dispatcher |
int | _playback_stopped_token = -1 |
frame_callback_ptr | _streams_callback |
std::vector< rs2_stream > | _synced_streams |
std::unique_ptr< syncer_process_unit > | _syncer |
Definition at line 20 of file pipeline.h.
|
explicit |
Definition at line 14 of file pipeline/pipeline.cpp.
|
virtual |
Definition at line 21 of file pipeline/pipeline.cpp.
std::shared_ptr< profile > librealsense::pipeline::pipeline::get_active_profile | ( | ) | const |
Definition at line 43 of file pipeline/pipeline.cpp.
|
protected |
Definition at line 197 of file pipeline/pipeline.cpp.
std::shared_ptr< librealsense::context > librealsense::pipeline::pipeline::get_context | ( | ) | const |
Definition at line 165 of file pipeline/pipeline.cpp.
|
protected |
Definition at line 170 of file pipeline/pipeline.cpp.
bool librealsense::pipeline::pipeline::poll_for_frames | ( | frame_holder * | frame | ) |
Definition at line 269 of file pipeline/pipeline.cpp.
std::shared_ptr< profile > librealsense::pipeline::pipeline::start | ( | std::shared_ptr< config > | conf, |
frame_callback_ptr | callback = nullptr |
||
) |
Definition at line 31 of file pipeline/pipeline.cpp.
void librealsense::pipeline::pipeline::stop | ( | ) |
Definition at line 120 of file pipeline/pipeline.cpp.
bool librealsense::pipeline::pipeline::try_wait_for_frames | ( | frame_holder * | frame, |
unsigned int | timeout_ms | ||
) |
Definition at line 289 of file pipeline/pipeline.cpp.
|
private |
Definition at line 49 of file pipeline/pipeline.cpp.
Definition at line 57 of file pipeline/pipeline.cpp.
|
protected |
Definition at line 130 of file pipeline/pipeline.cpp.
std::shared_ptr< device_interface > librealsense::pipeline::pipeline::wait_for_device | ( | const std::chrono::milliseconds & | timeout = std::chrono::hours::max() , |
const std::string & | serial = "" |
||
) |
Definition at line 159 of file pipeline/pipeline.cpp.
frame_holder librealsense::pipeline::pipeline::wait_for_frames | ( | unsigned int | timeout_ms | ) |
Definition at line 228 of file pipeline/pipeline.cpp.
|
protected |
Definition at line 46 of file pipeline.h.
|
private |
Definition at line 58 of file pipeline.h.
|
private |
Definition at line 53 of file pipeline.h.
|
private |
Definition at line 55 of file pipeline.h.
|
protected |
Definition at line 47 of file pipeline.h.
|
mutableprotected |
Definition at line 45 of file pipeline.h.
|
private |
Definition at line 54 of file pipeline.h.
|
protected |
Definition at line 48 of file pipeline.h.
|
private |
Definition at line 60 of file pipeline.h.
|
private |
Definition at line 61 of file pipeline.h.
|
private |
Definition at line 57 of file pipeline.h.