Lines Matching defs:Job

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