20 void init(std::shared_ptr<metadata_parser_map> metadata_parsers);
39 double get_time()
const {
return _ts ? _ts->get_time() : 0; }
41 void set_sensor(std::shared_ptr<sensor_interface> s);
46 mutable std::mutex _callback_mutex;
48 std::map<rs2_extension, std::shared_ptr<archive_interface>> _archive;
50 std::atomic<uint32_t> _max_publish_list_size;
52 std::shared_ptr<platform::time_service> _ts;
Definition: streaming.h:63
void init(std::shared_ptr< metadata_parser_map > metadata_parsers)
std::shared_ptr< rs2_frame_callback > frame_callback_ptr
Definition: types.h:822
Definition: syncer-processing-block.h:17
frame_interface * alloc_frame(rs2_extension type, size_t size, frame_additional_data additional_data, bool requires_memory) const
std::shared_ptr< option > get_published_size_option()
frame_callback_ptr get_callback() const
rs2_extension
Specifies advanced interfaces (capabilities) objects may implement.
Definition: rs_types.h:93
frame_source(uint32_t max_publish_list_size=16)
void set_callback(frame_callback_ptr callback)
void set_sensor(std::shared_ptr< sensor_interface > s)
virtual ~frame_source()
Definition: source.h:37
double get_time() const
Definition: source.h:39
void invoke_callback(frame_holder frame) const
callback_invocation_holder begin_callback()