Lines Matching refs:Job

134     auto Job = new FuzzJob;  in CreateNewJob()  local
147 Job->DftTimeInSeconds = static_cast<int>(DftTimeInSeconds); in CreateNewJob()
150 Job->SeedListPath = in CreateNewJob()
152 WriteToFile(Seeds, Job->SeedListPath); in CreateNewJob()
153 Cmd.addFlag("seed_inputs", "@" + Job->SeedListPath); in CreateNewJob()
155 Job->LogPath = DirPlusFile(TempDir, std::to_string(JobId) + ".log"); in CreateNewJob()
156 Job->CorpusDir = DirPlusFile(TempDir, "C" + std::to_string(JobId)); in CreateNewJob()
157 Job->FeaturesDir = DirPlusFile(TempDir, "F" + std::to_string(JobId)); in CreateNewJob()
158 Job->CFPath = DirPlusFile(TempDir, std::to_string(JobId) + ".merge"); in CreateNewJob()
159 Job->JobId = JobId; in CreateNewJob()
162 Cmd.addArgument(Job->CorpusDir); in CreateNewJob()
163 Cmd.addFlag("features_dir", Job->FeaturesDir); in CreateNewJob()
165 for (auto &D : {Job->CorpusDir, Job->FeaturesDir}) { in CreateNewJob()
170 Cmd.setOutputFile(Job->LogPath); in CreateNewJob()
173 Job->Cmd = Cmd; in CreateNewJob()
176 Printf("Job %zd/%p Created: %s\n", JobId, Job, in CreateNewJob()
177 Job->Cmd.toString().c_str()); in CreateNewJob()
179 return Job; in CreateNewJob()
182 void RunOneMergeJob(FuzzJob *Job) { in RunOneMergeJob()
183 auto Stats = ParseFinalStatsFromLog(Job->LogPath); in RunOneMergeJob()
189 GetSizedFilesFromDir(Job->CorpusDir, &TempFiles); in RunOneMergeJob()
193 FeatureFile.replace(0, Job->CorpusDir.size(), Job->FeaturesDir); in RunOneMergeJob()
210 secondsSinceProcessStartUp(), Job->JobId, Job->DftTimeInSeconds); in RunOneMergeJob()
217 &NewFeatures, Cov, &NewCov, Job->CFPath, false); in RunOneMergeJob()
258 void Push(FuzzJob *Job) { in Push()
261 Qu.push(Job); in Push()
270 auto Job = Qu.front(); in Pop() local
272 return Job; in Pop()
277 while (auto Job = FuzzQ->Pop()) { in WorkerThread() local
279 Job->ExitCode = ExecuteCommand(Job->Cmd); in WorkerThread()
280 MergeQ->Push(Job); in WorkerThread()
348 std::unique_ptr<FuzzJob> Job(MergeQ.Pop()); in FuzzWithFork() local
349 if (!Job) in FuzzWithFork()
351 ExitCode = Job->ExitCode; in FuzzWithFork()
359 Env.RunOneMergeJob(Job.get()); in FuzzWithFork()
369 std::ifstream In(Job->LogPath); in FuzzWithFork()
378 FileToString(Job->LogPath).c_str()); in FuzzWithFork()