sync_pipelines()

Vruta::SoundRoutine MayaFlux::Kriya::CycleCoordinator::sync_pipelines	(	std::vector< std::reference_wrapper< BufferPipeline > >	pipelines,
		uint32_t	sync_every_n_cycles = 1,
		uint64_t	samples_per_cycle = 1
	)

Create a synchronization routine for multiple pipelines.

Parameters

pipelines	Vector of pipeline references to synchronize
sync_every_n_cycles	Synchronization interval in cycles
samples_per_cycle	Number of samples per cycle for timing

Returns

SoundRoutine that manages pipeline synchronization

Definition at line 16 of file CycleCoordinator.cpp.

{
 
    auto& promise = co_await GetAudioPromise {};
    uint32_t cycle = 0;
 
    while (true) {
        if (promise.should_terminate) {
            break;
        }
 
        if (cycle % sync_every_n_cycles == 0) {
            for (auto& pipeline_ref : pipelines) {
                auto& pipeline = pipeline_ref.get();
                if (pipeline.has_pending_data()) {
                    MF_WARN(Journal::Component::Kriya, Journal::Context::CoroutineScheduling, "Sync point: Pipeline has stale data at cycle {}", cycle);
                }
            }
        }
 
        for (auto& pipeline_ref : pipelines) {
            pipeline_ref.get().execute_once();
        }
 
        ++cycle;
        co_await SampleDelay { samples_per_cycle };
    }
}

References MayaFlux::Journal::CoroutineScheduling, MayaFlux::Journal::Kriya, and MF_WARN.

Referenced by sync_pipelines_at_rate().

Here is the caller graph for this function: