Lines Matching refs:Job

137     auto Job = new FuzzJob;  in CreateNewJob()  local
164 Job->DftTimeInSeconds = static_cast<int>(DftTimeInSeconds); in CreateNewJob()
167 Job->SeedListPath = in CreateNewJob()
169 WriteToFile(Seeds, Job->SeedListPath); in CreateNewJob()
170 Cmd.addFlag("seed_inputs", "@" + Job->SeedListPath); in CreateNewJob()
172 Job->LogPath = DirPlusFile(TempDir, std::to_string(JobId) + ".log"); in CreateNewJob()
173 Job->CorpusDir = DirPlusFile(TempDir, "C" + std::to_string(JobId)); in CreateNewJob()
174 Job->FeaturesDir = DirPlusFile(TempDir, "F" + std::to_string(JobId)); in CreateNewJob()
175 Job->CFPath = DirPlusFile(TempDir, std::to_string(JobId) + ".merge"); in CreateNewJob()
176 Job->JobId = JobId; in CreateNewJob()
179 Cmd.addArgument(Job->CorpusDir); in CreateNewJob()
180 Cmd.addFlag("features_dir", Job->FeaturesDir); in CreateNewJob()
182 for (auto &D : {Job->CorpusDir, Job->FeaturesDir}) { in CreateNewJob()
187 Cmd.setOutputFile(Job->LogPath); in CreateNewJob()
190 Job->Cmd = Cmd; in CreateNewJob()
193 Printf("Job %zd/%p Created: %s\n", JobId, Job, in CreateNewJob()
194 Job->Cmd.toString().c_str()); in CreateNewJob()
196 return Job; in CreateNewJob()
199 void RunOneMergeJob(FuzzJob *Job) { in RunOneMergeJob()
200 auto Stats = ParseFinalStatsFromLog(Job->LogPath); in RunOneMergeJob()
206 GetSizedFilesFromDir(Job->CorpusDir, &TempFiles); in RunOneMergeJob()
210 FeatureFile.replace(0, Job->CorpusDir.size(), Job->FeaturesDir); in RunOneMergeJob()
227 secondsSinceProcessStartUp(), Job->JobId, Job->DftTimeInSeconds); in RunOneMergeJob()
234 !Job->Cmd.getFlagValue("set_cover_merge").compare("1"); in RunOneMergeJob()
236 &NewFeatures, Cov, &NewCov, Job->CFPath, false, in RunOneMergeJob()
285 void Push(FuzzJob *Job) { in Push()
288 Qu.push(Job); in Push()
297 auto Job = Qu.front(); in Pop() local
299 return Job; in Pop()
304 while (auto Job = FuzzQ->Pop()) { in WorkerThread() local
306 Job->ExitCode = ExecuteCommand(Job->Cmd); in WorkerThread()
307 MergeQ->Push(Job); in WorkerThread()
385 std::unique_ptr<FuzzJob> Job(MergeQ.Pop()); in FuzzWithFork() local
386 if (!Job) in FuzzWithFork()
388 ExitCode = Job->ExitCode; in FuzzWithFork()
396 Env.RunOneMergeJob(Job.get()); in FuzzWithFork()
445 std::ifstream In(Job->LogPath); in FuzzWithFork()
454 FileToString(Job->LogPath).c_str()); in FuzzWithFork()