|
@@ -116,7 +116,7 @@ static inline void LinkNode(const std::shared_ptr<BaseNode> &front,
|
|
const std::shared_ptr<BaseNode> &back, int queue_size = 100, OverflowStrategy strategy = OverflowStrategy::Block)
|
|
const std::shared_ptr<BaseNode> &back, int queue_size = 100, OverflowStrategy strategy = OverflowStrategy::Block)
|
|
{
|
|
{
|
|
PLOGI.printf("Link Node %s --> %s", front->get_name().c_str(), back->get_name().c_str());
|
|
PLOGI.printf("Link Node %s --> %s", front->get_name().c_str(), back->get_name().c_str());
|
|
- auto queue = std::make_shared<SharedQueue<std::shared_ptr<meta::MetaData>>>();
|
|
|
|
|
|
+ auto queue = std::make_shared<SharedQueue<std::shared_ptr<meta::MetaData>>>(queue_size, strategy);
|
|
back->add_input_buffer(front->get_name(), queue);
|
|
back->add_input_buffer(front->get_name(), queue);
|
|
front->add_output_buffer(back->get_name(), queue);
|
|
front->add_output_buffer(back->get_name(), queue);
|
|
}
|
|
}
|