cellinfo
/
iprbench
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cleanup by removing debug traces and replacing them with useful messages

This commit is contained in:
Guillaume Raffy 2022-05-31 19:03:00 +02:00
parent 9b12ce7cd2
commit e643be2435
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
.ipr/starbench.py
View File

@ -98,7 +98,6 @@ class StarBencher():
would give to subprocess.Popen. would give to subprocess.Popen.
""" """
def run_in_thread(popen_args, on_exit): def run_in_thread(popen_args, on_exit):
print('popen_args', popen_args)
stdout = None stdout = None
stderr = None stderr = None
if stdout_filepath is not None: if stdout_filepath is not None:
@ -150,14 +149,13 @@ class StarBencher():
else: else:
do_stop = self.stop_condition.should_stop(self) do_stop = self.stop_condition.should_stop(self)
if not do_stop: if not do_stop:
print('adding a run') # print('adding a run')
self._start_run(run.worker_id) # reuse the same worker as the run that has just finished self._start_run(run.worker_id) # reuse the same worker as the run that has just finished
if self._all_runs_have_finished(): if self._all_runs_have_finished():
# tell the main thread that all the runs have finished # tell the main thread that all the runs have finished
self._finished_event.set() self._finished_event.set()
def _start_run(self, worker_id: int): def _start_run(self, worker_id: int):
print(self.run_command)
worker_as_str = '%03d' % worker_id worker_as_str = '%03d' % worker_id
run_command = [str(s).replace('<worker_id>', worker_as_str) for s in self.run_command] run_command = [str(s).replace('<worker_id>', worker_as_str) for s in self.run_command]
run_command_cwd = str(self.run_command_cwd).replace('<worker_id>', worker_as_str) run_command_cwd = str(self.run_command_cwd).replace('<worker_id>', worker_as_str)
@ -184,7 +182,6 @@ class StarBencher():
raise Exception('at least one run failed') raise Exception('at least one run failed')
mean_duration, num_runs = self._get_run_mean_duration() mean_duration, num_runs = self._get_run_mean_duration()
print('mean duration : %.3f s (%d runs)' % (mean_duration, num_runs)) print('mean duration : %.3f s (%d runs)' % (mean_duration, num_runs))
print('finished')
return mean_duration return mean_duration
@ -199,6 +196,7 @@ def measure_hibridon_perf(hibridon_version: str, tmp_dir: Path, num_cores: int,
for compiler in ['gfortran']: # , 'ifort']: for compiler in ['gfortran']: # , 'ifort']:
# we need one build for each parallel run, otherwise running ctest on parallel would overwrite the same file, which causes the test to randomkly fail depnding on race conditions # we need one build for each parallel run, otherwise running ctest on parallel would overwrite the same file, which causes the test to randomkly fail depnding on race conditions
build_dir = tmp_dir / compiler / 'worker<worker_id>' build_dir = tmp_dir / compiler / 'worker<worker_id>'
print('creating build directory %s' % build_dir)
create_build_dir = StarBencher( create_build_dir = StarBencher(
run_command=['mkdir', '-p', build_dir], run_command=['mkdir', '-p', build_dir],
num_cores_per_run=1, num_cores_per_run=1,
@ -210,6 +208,7 @@ def measure_hibridon_perf(hibridon_version: str, tmp_dir: Path, num_cores: int,
create_build_dir_duration = create_build_dir.run() # noqa: F841 create_build_dir_duration = create_build_dir.run() # noqa: F841
# build_dir.mkdir(exist_ok=True) # build_dir.mkdir(exist_ok=True)
print('configuring %s into %s ...' % (src_dir, build_dir))
configure = StarBencher( configure = StarBencher(
run_command=['cmake', '-DCMAKE_BUILD_TYPE=Release', '-DBUILD_TESTING=ON', src_dir], run_command=['cmake', '-DCMAKE_BUILD_TYPE=Release', '-DBUILD_TESTING=ON', src_dir],
num_cores_per_run=1, num_cores_per_run=1,
@ -221,6 +220,7 @@ def measure_hibridon_perf(hibridon_version: str, tmp_dir: Path, num_cores: int,
stderr_filepath=build_dir / 'configure_stderr.txt') stderr_filepath=build_dir / 'configure_stderr.txt')
configure_duration = configure.run() # noqa: F841 configure_duration = configure.run() # noqa: F841
print('building %s ...' % (build_dir))
build = StarBencher( build = StarBencher(
run_command=['make'], run_command=['make'],
num_cores_per_run=1, num_cores_per_run=1,
@ -232,6 +232,7 @@ def measure_hibridon_perf(hibridon_version: str, tmp_dir: Path, num_cores: int,
stderr_filepath=build_dir / 'build_stderr.txt') stderr_filepath=build_dir / 'build_stderr.txt')
build_duration = build.run() # noqa: F841 build_duration = build.run() # noqa: F841
print('benchmarking %s ...' % (build_dir))
stop_condition = StopAfterSingleRun() stop_condition = StopAfterSingleRun()
bench = StarBencher( bench = StarBencher(
run_command=['ctest', '--output-on-failure', '-L', '^arch4_quick$'], run_command=['ctest', '--output-on-failure', '-L', '^arch4_quick$'],