| /external/grpc-grpc/tools/run_tests/ |
| D | run_microbenchmark.py | 23 import python_utils.jobset as jobset namespace
93 jobset.JobSpec(
102 jobset.JobSpec(
112 cleanup.append(jobset.JobSpec(['rm', '%s.trace' % fnize(line)]))
120 jobset.run(
123 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
124 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
130 jobset.run(benchmarks, maxjobs=max(1, multiprocessing.cpu_count() / 2))
131 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
132 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
[all …]
|
| D | run_performance_tests.py | 36 import python_utils.jobset as jobset namespace
56 self._job = jobset.Job(
61 return self._job and self._job.state() == jobset._RUNNING
100 jobspec = jobset.JobSpec(
132 return jobset.JobSpec(
150 return jobset.JobSpec(
182 return jobset.JobSpec(
206 archive_job = jobset.JobSpec(
209 jobset.message('START', 'Archiving local repository.', do_newline=True)
210 num_failures, _ = jobset.run(
[all …]
|
| D | task_runner.py | 26 import python_utils.jobset as jobset namespace
92 num_failures, _ = jobset.run(
95 jobset.message('FAILED', 'Pre-build phase failed.', do_newline=True)
105 jobset.message('START', 'Building targets.', do_newline=True)
106 num_failures, resultset = jobset.run(
111 jobset.message(
114 jobset.message('FAILED', 'Failed to build targets.', do_newline=True)
|
| D | run_tests_matrix.py | 24 import python_utils.jobset as jobset namespace
68 test_job = jobset.JobSpec(
95 test_job = jobset.JobSpec(
544 jobset.message(
580 jobset.message('START', 'Running test matrix.', do_newline=True)
581 num_failures, resultset = jobset.run(
585 ignored_num_skipped_failures, skipped_results = jobset.run(
594 jobset.message(
599 jobset.message(
|
| D | run_tests.py | 43 import python_utils.jobset as jobset namespace
105 return jobset.platform_string()
124 if jobset.platform_string() == 'windows':
167 return jobset.JobSpec(
1469 jobset.measure_cpu_costs = args.measure_cpu_costs
1493 if jobset.platform_string() == 'linux':
1591 jobset.JobSpec(
1603 jobset.JobSpec(
1611 jobset.JobSpec(
1643 jobset.JobSpec(
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_microbenchmark.py | 23 import python_utils.jobset as jobset namespace
101 jobset.JobSpec([
110 jobset.JobSpec([
119 cleanup.append(jobset.JobSpec(['rm', '%s.trace' % fnize(line)]))
127 jobset.run(benchmarks,
130 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
131 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
137 jobset.run(benchmarks, maxjobs=max(1, multiprocessing.cpu_count() / 2))
138 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
139 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
[all …]
|
| D | run_performance_tests.py | 36 import python_utils.jobset as jobset namespace
61 self._job = jobset.Job(self._spec,
68 return self._job and self._job.state() == jobset._RUNNING
106 jobspec = jobset.JobSpec(
136 return jobset.JobSpec(cmdline=[cmd],
153 return jobset.JobSpec(cmdline=[cmd],
184 return jobset.JobSpec(cmdline=[cmd],
201 archive_job = jobset.JobSpec(cmdline=cmdline,
205 jobset.message('START', 'Archiving local repository.', do_newline=True)
206 num_failures, _ = jobset.run([archive_job],
[all …]
|
| D | run_grpclb_interop_tests.py | 35 import python_utils.jobset as jobset namespace
232 jobset.message('IDLE',
235 test_job = jobset.JobSpec(cmdline=docker_cmdline,
288 jobset.message('IDLE',
291 server_job = jobset.JobSpec(cmdline=docker_cmdline,
315 jobset.message('IDLE',
318 server_job = jobset.JobSpec(cmdline=docker_cmdline,
332 build_job = jobset.JobSpec(
437 jobset.message('START', 'Building interop docker images.', do_newline=True)
439 num_failures, _ = jobset.run(build_jobs,
[all …]
|
| D | task_runner.py | 26 import python_utils.jobset as jobset namespace
98 num_failures, _ = jobset.run(prebuild_jobs,
102 jobset.message('FAILED', 'Pre-build phase failed.', do_newline=True)
112 jobset.message('START', 'Building targets.', do_newline=True)
113 num_failures, resultset = jobset.run(build_jobs,
120 jobset.message('SUCCESS',
124 jobset.message('FAILED', 'Failed to build targets.', do_newline=True)
|
| D | run_tests_matrix.py | 24 import python_utils.jobset as jobset namespace
78 test_job = jobset.JobSpec(cmdline=[
105 test_job = jobset.JobSpec(cmdline=[
492 jobset.message('FAILED',
526 jobset.message('START', 'Running test matrix.', do_newline=True)
527 num_failures, resultset = jobset.run(jobs,
533 ignored_num_skipped_failures, skipped_results = jobset.run(
542 jobset.message('SUCCESS',
546 jobset.message('FAILED',
|
| D | run_tests.py | 43 import python_utils.jobset as jobset namespace
70 return jobset.platform_string()
90 if jobset.platform_string() == 'windows':
133 return jobset.JobSpec(
1531 jobset.measure_cpu_costs = args.measure_cpu_costs
1555 if jobset.platform_string() == 'linux':
1635 jobset.JobSpec([
1646 jobset.JobSpec(
1654 jobset.JobSpec(
1686 jobset.JobSpec(cmdline,
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/tools/interop_matrix/ |
| D | create_matrix_images.py | 35 import jobset
110 jobset.message('FAILED',
134 jobset.message('START', 'Repackaging %s' % image, do_newline=True)
155 build_job = jobset.JobSpec(cmdline=[image_builder_path],
178 jobset.message('SKIPPED',
188 jobset.message('SUCCESS',
216 jobset.message('START', 'Building interop docker images.', do_newline=True)
219 num_failures, _ = jobset.run(build_jobs,
223 jobset.message('FAILED',
229 jobset.message('SUCCESS',
[all …]
|
| D | run_interop_matrix_tests.py | 36 import jobset
105 jobset.message('SKIPPED',
155 jobset.message('START', 'Cleanup docker image %s' % image, do_newline=True)
196 spec = jobset.JobSpec(cmdline=line,
212 return jobset.JobSpec(cmdline=cmdline,
226 jobset.message('FAILED', 'No test cases were found.', do_newline=True)
229 num_failures, resultset = jobset.run(job_spec_list,
238 jobset.message('FAILED', 'Tests were skipped', do_newline=True)
272 pull_failures, _ = jobset.run(pull_specs,
276 jobset.message(
[all …]
|
| /external/grpc-grpc/tools/interop_matrix/ |
| D | run_interop_matrix_tests.py | 36 import jobset
112 jobset.message(
135 jobset.message(
140 jobset.message(
192 spec = jobset.JobSpec(
200 jobset.message(
205 jobset.message('FAILED', err, do_newline=True)
220 jobset.message('START', 'Testing %s' % image, do_newline=True)
227 jobset.message(
231 num_failures, resultset = jobset.run(
[all …]
|
| D | create_matrix_images.py | 35 import jobset
118 jobset.message(
141 jobset.message('START', 'Repackaging %s' % image, do_newline=True)
162 build_job = jobset.JobSpec(
186 jobset.message(
196 jobset.message(
225 jobset.message('START', 'Building interop docker images.', do_newline=True)
228 num_failures, _ = jobset.run(
233 jobset.message(
238 jobset.message(
[all …]
|
| /external/grpc-grpc/tools/buildgen/ |
| D | generate_projects.py | 30 import jobset
70 jobset.JobSpec(cmd, shortname='preprocess', timeout_seconds=None))
92 jobs.append(jobset.JobSpec(cmd, shortname=out, timeout_seconds=None))
94 jobset.run(pre_jobs, maxjobs=args.jobs)
95 jobset.run(jobs, maxjobs=args.jobs)
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/artifacts/ |
| D | package_targets.py | 21 import python_utils.jobset as jobset namespace
42 jobspec = jobset.JobSpec(
62 jobspec = jobset.JobSpec(cmdline=cmdline,
|
| /external/grpc-grpc/tools/run_tests/artifacts/ |
| D | package_targets.py | 21 import python_utils.jobset as jobset namespace
42 jobspec = jobset.JobSpec(
62 jobspec = jobset.JobSpec(
|
| /external/rust/crates/grpcio-sys/grpc/tools/distrib/ |
| D | run_clang_tidy.py | 25 import jobset
57 jobset.JobSpec(
63 num_fails, res_set = jobset.run(jobs, maxjobs=args.jobs, quiet_success=True)
|
| /external/grpc-grpc/tools/distrib/ |
| D | run_clang_tidy.py | 25 import jobset
61 jobs.append(jobset.JobSpec(
66 num_fails, res_set = jobset.run(jobs, maxjobs=args.jobs)
|
| /external/rust/crates/grpcio-sys/grpc/tools/buildgen/ |
| D | generate_projects.py | 35 jobset = _utils.import_python_module( variable
87 def generate_template_render_jobs(templates: List[str]) -> List[jobset.JobSpec]:
110 jobs.append(jobset.JobSpec(cmd, shortname=out,
126 err_cnt, _ = jobset.run(generate_template_render_jobs(templates),
|
| /external/grpc-grpc/tools/run_tests/python_utils/ |
| D | dockerjob.py | 24 import jobset
116 self._job = jobset.Job(
135 return self._job.state() == jobset._RUNNING
|
| /external/rust/crates/grpcio-sys/grpc/tools/profiling/microbenchmarks/bm_diff/ |
| D | bm_run.py | 27 import jobset
96 jobset.JobSpec(cmd,
121 jobset.run(jobs_list, maxjobs=args.jobs)
|
| /external/grpc-grpc/tools/profiling/microbenchmarks/bm_diff/ |
| D | bm_run.py | 32 import jobset
98 jobset.JobSpec(
124 jobset.run(jobs_list, maxjobs=args.jobs)
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/python_utils/ |
| D | dockerjob.py | 25 import jobset
132 self._job = jobset.Job(spec,
156 return self._job.state() == jobset._RUNNING
|