Impala Documentation

void Impala::Core::VideoJob::Manager::CreateInitialStageJobs ( ) [inline, private]

Definition at line 402 of file Manager.h.

References Impala::Job::State::CREATED, Impala::Core::VideoJob::ProcessDefinition::FirstStepOfStage(), Impala::Core::Database::RawDataSet::GetAsPath(), Impala::Core::VideoJob::ProcessDefinition::IsIndividualStage(), Impala::Core::VideoJob::Data::IsValid(), Impala::Core::VideoJob::Data::mAllJobs, mCompactedVideoSetSize, Impala::Core::VideoJob::Data::mCountOfWaitingJobs, mCurrentStage, mData, Impala::Core::VideoJob::Data::mProcessDef, Impala::Core::VideoJob::Data::mVideos, mVideoSet, UpdateVideoSet(), and Impala::Core::VideoJob::Data::VideoSetSize().

Referenced by EvaluateStage(), and Start().

00403     {
00404         int firstStepOfStage =
00405             mData.mProcessDef->FirstStepOfStage(mCurrentStage);
00406         std::vector<String> validVideos;
00407         if (mData.mProcessDef->IsIndividualStage(mCurrentStage))
00408         {
00409             for (int v = 0; v < mData.VideoSetSize(); v++)
00410             {
00411                 if (mData.IsValid(v))
00412                 {
00413                     VideoJob* newJob = new VideoJob;
00414                     newJob->stepNr = firstStepOfStage;
00415                     newJob->videoNr = v;
00416                     const int compactedVideoNr = validVideos.size();
00417                     newJob->videoNrCompact = compactedVideoNr;
00418                     newJob->isIndiv = true;
00419                     newJob->state = Job::State::CREATED;
00420                     mData.mVideos[v].jobs.push_back(newJob);
00421 
00422                     mData.mAllJobs.push_back(newJob);
00423                     mData.mCountOfWaitingJobs++;
00424 
00425                     validVideos.push_back(mVideoSet->GetAsPath(v));
00426                 }
00427             }
00428         }
00429         else
00430         {
00431             VideoJob* newJob = new VideoJob;
00432             newJob->stepNr = firstStepOfStage;
00433             newJob->videoNr = -1;
00434             newJob->videoNrCompact = -1;
00435             newJob->isIndiv = false;
00436             newJob->state = Job::State::CREATED;
00437             for (int v = 0; v < mData.VideoSetSize(); v++)
00438             {
00439                 if (mData.IsValid(v))
00440                 {
00441                     mData.mVideos[v].jobs.push_back(newJob);
00442 
00443                     validVideos.push_back(mVideoSet->GetAsPath(v));
00444                 }
00445             }
00446 
00447             mData.mAllJobs.push_back(newJob);
00448             mData.mCountOfWaitingJobs++;
00449         }
00450 
00451         if (validVideos.size() < mCompactedVideoSetSize)
00452         {
00453             UpdateVideoSet(validVideos);
00454             mCompactedVideoSetSize = validVideos.size();
00455         }
00456     }

Here is the call graph for this function: