317   GlobalEnv Env;  in FuzzWithFork()  local
318   Env.Args = Args;  in FuzzWithFork()
319   Env.CorpusDirs = CorpusDirs;  in FuzzWithFork()
320   Env.Rand = &Rand;  in FuzzWithFork()
321   Env.Verbosity = Options.Verbosity;  in FuzzWithFork()
322   Env.ProcessStartTime = std::chrono::system_clock::now();  in FuzzWithFork()
323   Env.DataFlowBinary = Options.CollectDataFlow;  in FuzzWithFork()
324   Env.Group = Options.ForkCorpusGroups;  in FuzzWithFork()
330   Env.TempDir = TempPath("FuzzWithFork", ".dir");  in FuzzWithFork()
331   Env.DFTDir = DirPlusFile(Env.TempDir, "DFT");  in FuzzWithFork()
332   RmDirRecursive(Env.TempDir);  // in case there is a leftover from old runs.  in FuzzWithFork()
333   MkDir(Env.TempDir);  in FuzzWithFork()
334   MkDir(Env.DFTDir);  in FuzzWithFork()
338     MkDir(Env.MainCorpusDir = DirPlusFile(Env.TempDir, "C"));  in FuzzWithFork()
340     Env.MainCorpusDir = CorpusDirs[0];  in FuzzWithFork()
344       Env.Files.push_back(File.File);  in FuzzWithFork()
346     auto CFPath = DirPlusFile(Env.TempDir, "merge.txt");  in FuzzWithFork()
348     CrashResistantMerge(Env.Args, {}, SeedFiles, &Env.Files, Env.Features,  in FuzzWithFork()
349                         &NewFeatures, Env.Cov, &NewCov, CFPath,  in FuzzWithFork()
351     Env.Features.insert(NewFeatures.begin(), NewFeatures.end());  in FuzzWithFork()
352     Env.Cov.insert(NewCov.begin(), NewCov.end());  in FuzzWithFork()
356   if (Env.Group) {  in FuzzWithFork()
357     for (auto &path : Env.Files)  in FuzzWithFork()
358       Env.FilesSizes.push_back(FileSize(path));  in FuzzWithFork()
362          Env.Files.size(), Env.TempDir.c_str());  in FuzzWithFork()
372     WriteToFile(Unit({1}), Env.StopFile());  in FuzzWithFork()
381     FuzzQ.Push(Env.CreateNewJob(JobId++));  in FuzzWithFork()
396     Env.RunOneMergeJob(Job.get());  in FuzzWithFork()
400     if (Env.Group && JobExecuted >= MergeCycle) {  in FuzzWithFork()
406       auto CFPath = DirPlusFile(Env.TempDir, "merge.txt");  in FuzzWithFork()
409       Env.Files.clear();  in FuzzWithFork()
410       Env.FilesSizes.clear();  in FuzzWithFork()
411       CrashResistantMerge(Env.Args, {}, CurrentSeedFiles, &Env.Files,  in FuzzWithFork()
414       for (auto &path : Env.Files)  in FuzzWithFork()
415         Env.FilesSizes.push_back(FileSize(path));  in FuzzWithFork()
424     if (Env.Files.size() < 2000)  in FuzzWithFork()
425       Env.NumCorpuses = 12;  in FuzzWithFork()
426     else if (Env.Files.size() < 6000)  in FuzzWithFork()
427       Env.NumCorpuses = 20;  in FuzzWithFork()
428     else if (Env.Files.size() < 12000)  in FuzzWithFork()
429       Env.NumCorpuses = 32;  in FuzzWithFork()
430     else if (Env.Files.size() < 16000)  in FuzzWithFork()
431       Env.NumCorpuses = 40;  in FuzzWithFork()
432     else if (Env.Files.size() < 24000)  in FuzzWithFork()
433       Env.NumCorpuses = 60;  in FuzzWithFork()
435       Env.NumCorpuses = 80;  in FuzzWithFork()
439       Env.NumTimeouts++;  in FuzzWithFork()
441       Env.NumOOMs++;  in FuzzWithFork()
443       Env.NumCrashes++;  in FuzzWithFork()
465         Env.secondsSinceProcessStartUp() >= (size_t)Options.MaxTotalTimeSec) {  in FuzzWithFork()
467              Env.secondsSinceProcessStartUp());  in FuzzWithFork()
471     if (Env.NumRuns >= Options.MaxNumberOfRuns) {  in FuzzWithFork()
473              Env.NumRuns);  in FuzzWithFork()
478     FuzzQ.Push(Env.CreateNewJob(JobId++));  in FuzzWithFork()
486   RmDirRecursive(Env.TempDir);  in FuzzWithFork()
490          Env.secondsSinceProcessStartUp());  in FuzzWithFork()