Method pickFrameToRender

Engine/OutputSchedulerThread.cpp:806–868

}

int
OutputSchedulerThread::pickFrameToRender(RenderThreadTask* thread,
                                         bool* enableRenderStats,
                                         std::vector<ViewIdx>* viewsToRender)
{
    ///Flag the thread as inactive
    {
        QMutexLocker l(&_imp->renderThreadsMutex);
        RenderThreads::iterator found = _imp->getRunnableIterator(thread);
        assert( found != _imp->renderThreads.end() );
        found->active = false;

        ///Wake up the scheduler if it is waiting for all threads do be inactive
        _imp->allRenderThreadsInactiveCond.wakeOne();
    }


    bool gotFrame = false;
    int frame = -1;
    {
        QMutexLocker l(&_imp->framesToRenderMutex);
        while ( _imp->framesToRender.empty() && !thread->mustQuit() ) {
            ///Notify that we're no longer doing work
            thread->notifyIsRunning(false);

            _imp->framesToRenderNotEmptyCond.wait(l.mutex());
        }

        if ( !_imp->framesToRender.empty() ) {
            ///Notify that we're running for good, will do nothing if flagged already running
            thread->notifyIsRunning(true);

            frame = _imp->framesToRender.front();

            _imp->framesToRender.pop_front();

            gotFrame = true;
        }
    }

    // thread is quitting, make sure we notified the application it is no longer running
    if (!gotFrame) {
        thread->notifyIsRunning(false);

        *enableRenderStats = false;

        return -1;
    } else {
        ///Flag the thread as active
        {
            QMutexLocker l(&_imp->renderThreadsMutex);
            RenderThreads::iterator found = _imp->getRunnableIterator(thread);
            assert( found != _imp->renderThreads.end() );
            found->active = true;
        }

        OutputSchedulerThreadStartArgsPtr args = _imp->runArgs.lock();
        *enableRenderStats = args->enableRenderStats;