194     def __init__(self, cmdline, target, blocklist, allowlist, n_processes):  argument
195         self.cmdline = cmdline
196         self.target = target
197         self.blocklist = blocklist
198         self.allowlist = allowlist
199         self.skipped = []
200         self.parallel_tests = []
201         self.non_parallel_tests = []
202         self.n_processes = n_processes
203         self.active_processes = 0
211             self.avail_cmds = re.findall('test_register_(\w+)', symbols)
213             self.avail_cmds = None
219         self.logfile = open(logfile, "w")
221         self.csvwriter = csv.writer(csvfile)
224         self.csvwriter.writerow(["test_name", "test_result", "result_str"])
227     def __get_cmdline(self, cpu_nr):  argument
228         cmdline = ("taskset -c %i " % cpu_nr) + self.cmdline
232     def __process_result(self, result):  argument
240         total_time = int(cur_time - self.start)
252             self.fails += 1
255         self.log_buffers.append(log)
261                          (self.target, test_name), "w")
269         self.csvwriter.writerow([test_name, test_result, result_str])
274     def __filter_test(self, test):  argument
283         if self.blocklist and test_id in self.blocklist:
285         if self.allowlist and test_id not in self.allowlist:
289         if self.avail_cmds and test_cmd not in self.avail_cmds:
291             self.skipped.append(tuple(result))
296     def __run_test_group(self, test_group, worker_cmdlines):  argument
315             self.__process_result(init_result_queue.get())
319             result = pool.apply_async(run_test, (self.target, test))
336                 self.__process_result(res)
342     def run_all_tests(self):  argument
344         self.parallel_tests = list(
345             filter(self.__filter_test,
346                    self.parallel_tests)
348         self.non_parallel_tests = list(
349             filter(self.__filter_test,
350                    self.non_parallel_tests)
357             for proc in range(self.n_processes):
363                 numa_node = numa_nodes[self.active_processes % len(numa_nodes)]
365                 parallel_cmdlines += [self.__get_cmdline(cpu_nr)]
368                 self.active_processes += 1
370             parallel_cmdlines = [self.cmdline] * self.n_processes
372         print("Running tests with %d workers" % self.n_processes)
380         if len(self.skipped):
384             for result in self.skipped:
387                 self.csvwriter.writerow([test_name, test_result, result_str])
396         self.start = time.time()
400             if len(self.parallel_tests) > 0:
402                 self.__run_test_group(self.parallel_tests, parallel_cmdlines)
404             if len(self.non_parallel_tests) > 0:
406                 self.__run_test_group(self.non_parallel_tests, [self.cmdline])
410             total_time = int(cur_time - self.start)
416             if self.fails != 0:
417                 print("Number of failed tests: %s" % str(self.fails))
420             self.logfile.write("Summary\n")
421             self.logfile.write("Target: ".ljust(15) + "%s\n" % self.target)
422             self.logfile.write("Tests: ".ljust(15) + "%i\n" % self.n_tests)
423             self.logfile.write("Failed tests: ".ljust(
424                 15) + "%i\n" % self.fails)
428             self.fails = 1
431         for buf in self.log_buffers:
432             self.logfile.write(buf.replace("\r", ""))
434         return self.fails