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 14 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()) {
                    std::cout << "Sync point: Pipeline has stale data at cycle " << cycle << '\n';
                }
            }
        }
 
        for (auto& pipeline_ref : pipelines) {
            pipeline_ref.get().execute_once();
        }
 
        ++cycle;
        co_await SampleDelay { samples_per_cycle };
    }
}

Referenced by sync_pipelines_at_rate().

Here is the caller graph for this function: