15 _streams_to_aggregate_ids(streams_to_aggregate),
16 _streams_to_sync_ids(streams_to_sync),
41 for (
auto i = 0;
i < comp->get_embedded_frames_count();
i++)
56 std::vector<frame_holder> sync_set;
58 std::vector<frame_holder> async_set;
61 sync_set.push_back(
s.second.clone());
65 async_set.push_back(
s.second.clone());
71 if (!sync_fref || !async_fref)
73 LOG_ERROR(
"Failed to allocate composite frame");
89 std::vector<frame_holder> sync_set;
91 sync_set.push_back(
s.second.clone());
96 LOG_ERROR(
"Failed to allocate composite frame");
107 return _queue->dequeue(item, timeout_ms);
112 return _queue->try_dequeue(item);