aggregator.h
Go to the documentation of this file.
1 // License: Apache 2.0. See LICENSE file in root directory.
2 // Copyright(c) 2015 Intel Corporation. All Rights Reserved.
3 
4 #pragma once
5 
6 #include "sync.h"
9 
10 namespace librealsense
11 {
12  namespace pipeline
13  {
15  {
16  std::mutex _mutex;
17  std::map<stream_id, frame_holder> _last_set;
18  std::unique_ptr<single_consumer_frame_queue<frame_holder>> _queue;
19  std::vector<int> _streams_to_aggregate_ids;
20  std::vector<int> _streams_to_sync_ids;
21  std::atomic<bool> _accepting;
23  public:
24  aggregator(const std::vector<int>& streams_to_aggregate, const std::vector<int>& streams_to_sync);
25  bool dequeue(frame_holder* item, unsigned int timeout_ms);
26  bool try_dequeue(frame_holder* item);
27  void start();
28  void stop();
29  };
30  }
31 }
GLsizei GLsizei GLchar * source
bool dequeue(frame_holder *item, unsigned int timeout_ms)
Definition: aggregator.cpp:105
std::vector< int > _streams_to_aggregate_ids
Definition: aggregator.h:19
bool try_dequeue(frame_holder *item)
Definition: aggregator.cpp:110
std::map< stream_id, frame_holder > _last_set
Definition: aggregator.h:17
aggregator(const std::vector< int > &streams_to_aggregate, const std::vector< int > &streams_to_sync)
Definition: aggregator.cpp:12
std::unique_ptr< single_consumer_frame_queue< frame_holder > > _queue
Definition: aggregator.h:18
std::atomic< bool > _accepting
Definition: aggregator.h:21
void handle_frame(frame_holder frame, synthetic_source_interface *source)
Definition: aggregator.cpp:28
std::vector< int > _streams_to_sync_ids
Definition: aggregator.h:20


librealsense2
Author(s): LibRealSense ROS Team
autogenerated on Thu Dec 22 2022 03:41:41