17 _streams_to_aggregate_ids(streams_to_aggregate),
18 _streams_to_sync_ids(streams_to_sync),
39 for (
auto i = 0;
i < comp->get_embedded_frames_count();
i++)
54 std::vector<frame_holder> sync_set;
56 std::vector<frame_holder> async_set;
59 sync_set.push_back(
s.second.clone());
63 async_set.push_back(
s.second.clone());
69 if (!sync_fref || !async_fref)
71 LOG_ERROR(
"Failed to allocate composite frame");
87 std::vector<frame_holder> sync_set;
89 sync_set.push_back(
s.second.clone());
94 LOG_ERROR(
"Failed to allocate composite frame");
105 return _queue->dequeue(item, timeout_ms);
110 return _queue->try_dequeue(item);