32 def _WriteJSONReportToFile(experiment, results_dir, json_report):  argument
34   has_llvm = any('llvm' in l.compiler for l in experiment.labels)
36   board = experiment.labels[0].board
57                experiment,  argument
62     self._experiment = experiment
63     self.l = log or logger.GetLogger(experiment.log_dir)
68     if experiment.log_level != 'verbose':
121   def _LockAllMachines(self, experiment):  argument
133       experiment.locked_machines = self.locked_machines
135       experiment.lock_mgr = lock_machine.LockManager(
138           experiment.labels[0].chromeos_root,
139           experiment.locks_dir,
142       for m in experiment.lock_mgr.machines:
143         machine_type = self._GetMachineType(experiment.lock_mgr, m)
145           experiment.lock_mgr.AddMachineToLocal(m)
147           experiment.lock_mgr.AddMachineToSkylab(m)
148       machine_states = experiment.lock_mgr.GetMachineStates('lock')
149       experiment.lock_mgr.CheckMachineLocks(machine_states, 'lock')
150       self.locked_machines = experiment.lock_mgr.UpdateMachines(True)
151       experiment.locked_machines = self.locked_machines
153       experiment.machine_manager.RemoveNonLockedMachines(self.locked_machines)
157   def _ClearCacheEntries(self, experiment):  argument
158     for br in experiment.benchmark_runs:
172   def _Run(self, experiment):  argument
179       if not experiment.skylab:
180         self._LockAllMachines(experiment)
183       experiment.SetCheckSums(forceSameImage=True)
185         schedv2 = Schedv2(experiment)
186         experiment.set_schedv2(schedv2)
187       if CacheConditions.FALSE in experiment.cache_conditions:
188         self._ClearCacheEntries(experiment)
189       status = ExperimentStatus(experiment)
190       experiment.Run()
194         if experiment.log_level != 'verbose':
196         while not experiment.IsComplete():
200             if experiment.log_level == 'verbose':
219         experiment.Terminate()
224         experiment.Terminate()
227       experiment.Cleanup()
229   def _PrintTable(self, experiment):  argument
230     self.l.LogOutput(TextResultsReport.FromExperiment(experiment).GetReport())
232   def _Email(self, experiment):  argument
235     for benchmark_run in experiment.benchmark_runs:
239     if (not send_mail and not experiment.email_to or
244     for label in experiment.labels:
246     subject = '%s: %s' % (experiment.name, ' vs. '.join(label_names))
248     text_report = TextResultsReport.FromExperiment(experiment, True).GetReport()
250                     experiment.results_directory)
252     html_report = HTMLResultsReport.FromExperiment(experiment).GetReport()
254     email_to = experiment.email_to or []
263   def _StoreResults(self, experiment):  argument
267     results_directory = experiment.results_directory
272     FileUtils().WriteFile(experiment_file_path, experiment.experiment_file)
281       for benchmark_run in experiment.benchmark_runs:
301     for benchmark_run in experiment.benchmark_runs:
306         if experiment.compress_results:
314     report = HTMLResultsReport.FromExperiment(experiment).GetReport()
317           experiment, json_args={'indent': 2})
318       _WriteJSONReportToFile(experiment, results_directory, json_report)
324     text_report = TextResultsReport.FromExperiment(experiment, True).GetReport()
326                     experiment.results_directory)
347   def __init__(self, experiment, json_report):  argument
348     super(MockExperimentRunner, self).__init__(experiment, json_report)
350   def _Run(self, experiment):  argument
352                      experiment.name)
354   def _PrintTable(self, experiment):  argument
357   def _Email(self, experiment):  argument
360   def _StoreResults(self, experiment):  argument