|
@@ -33,13 +33,13 @@ public:
|
|
|
void start();
|
|
|
void stop();
|
|
|
|
|
|
- inline void add_input_buffer(const std::string& name, SharedQueue<std::shared_ptr<meta::MetaData>> buffer)
|
|
|
+ inline void add_input_buffer(const std::string& name, std::shared_ptr<SharedQueue<std::shared_ptr<meta::MetaData>>> buffer)
|
|
|
{
|
|
|
std::unique_lock<std::mutex> lock(mutex_);
|
|
|
input_buffers_[name] = buffer;
|
|
|
}
|
|
|
|
|
|
- inline void add_output_buffer(const std::string& name, SharedQueue<std::shared_ptr<meta::MetaData>> buffer)
|
|
|
+ inline void add_output_buffer(const std::string& name, std::shared_ptr<SharedQueue<std::shared_ptr<meta::MetaData>>> buffer)
|
|
|
{
|
|
|
std::unique_lock<std::mutex> lock(mutex_);
|
|
|
output_buffers_[name] = buffer;
|
|
@@ -83,8 +83,8 @@ protected:
|
|
|
std::shared_ptr<std::condition_variable> cond_var_ =
|
|
|
std::make_shared<std::condition_variable>();
|
|
|
bool running_ = false;
|
|
|
- std::unordered_map<std::string, SharedQueue<std::shared_ptr<meta::MetaData>>> input_buffers_;
|
|
|
- std::unordered_map<std::string, SharedQueue<std::shared_ptr<meta::MetaData>>> output_buffers_;
|
|
|
+ std::unordered_map<std::string, std::shared_ptr<SharedQueue<std::shared_ptr<meta::MetaData>>>> input_buffers_;
|
|
|
+ std::unordered_map<std::string, std::shared_ptr<SharedQueue<std::shared_ptr<meta::MetaData>>>> output_buffers_;
|
|
|
};
|
|
|
|
|
|
static inline void LinkNode(const std::shared_ptr<BaseNode> &front,
|