pump_cross()

void MayaFlux::Vruta::TaskScheduler::pump_cross ( DelayContext  context, ProcessingToken  clock_token, uint64_t  processing_units  )

private

Pump the MULTI_RATE list from one clock's context.

Called as a fall-through from process_token when the driving token is SAMPLE_ACCURATE or FRAME_ACCURATE. Reads the driving clock's position and offers each cross routine a resume under the given context. The CrossRoutine gate decides eligibility and claims the resume atomically, so both threads may call this concurrently on the same list.

Parameters

context	SAMPLE_BASED from the audio thread, FRAME_BASED from graphics.
clock_token	The token whose clock position drives this pump.
processing_units	Units to advance, matching the driving token's call.

Definition at line 649 of file Scheduler.cpp.

{
    auto cross_tasks = get_tasks_for_token(ProcessingToken::MULTI_RATE);
    if (cross_tasks.empty()) {
        return;
    }
 
    auto clock_it = m_token_clocks.find(clock_token);
    if (clock_it == m_token_clocks.end()) {
        return;
    }
 
    if (processing_units == 0) {
        processing_units = 1;
    }
 
    uint64_t base = clock_it->second->current_position();
 
    for (uint64_t i = 0; i < processing_units; ++i) {
        uint64_t pos = base + i;
        for (auto& routine : cross_tasks) {
            if (routine && routine->is_active()) {
                routine->try_resume_with_context(pos, context);
            }
        }
    }
}

References get_tasks_for_token(), m_token_clocks, and MayaFlux::Vruta::MULTI_RATE.

Referenced by process_token().

Here is the call graph for this function:

Here is the caller graph for this function: