From 0388906beeef0537af2ca938fb59d337d638232a Mon Sep 17 00:00:00 2001 From: Bogdan Popescu <68062990+bopopescu@users.noreply.github.com> Date: Fri, 24 Jul 2020 13:45:52 +0300 Subject: [PATCH] Changing the master-slave vocabulary --- ImportLCmp.py | 2 +- processing_4EU.py | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/ImportLCmp.py b/ImportLCmp.py index 4e44faa..1177348 100644 --- a/ImportLCmp.py +++ b/ImportLCmp.py @@ -336,7 +336,7 @@ def Import_and_Process_LC(folder, nProc=1, outfile = "LC-MS.msh5", # and close HF.flush() if nProc>1: - Pool.close() # finally closes multiprocessing slaves + Pool.close() # finally closes multiprocessing subordinates return data class Proc_Parameters(object): diff --git a/processing_4EU.py b/processing_4EU.py index 3b2ba91..ed85ee2 100644 --- a/processing_4EU.py +++ b/processing_4EU.py @@ -843,7 +843,7 @@ def main(argv = None): if v != 0.0: opt_param[p] = v if param.mp: - Pool = mp.Pool(param.nproc) # if multiprocessing, creates slaves early, while memory is empty ! + Pool = mp.Pool(param.nproc) # if multiprocessing, creates subordinates early, while memory is empty ! param.report() logflux.log.flush() # flush logfile ######## determine files and load inputfile @@ -1026,7 +1026,7 @@ def main(argv = None): hfar.close() if param.mp: - Pool.close() # finally closes multiprocessing slaves + Pool.close() # finally closes multiprocessing subordinates logflux.log.flush() # flush logfile # default values @@ -1035,8 +1035,8 @@ def main(argv = None): if mpiutil.MPI_size < 2: # this is single processor main() else: # this is a MPI run - if mpiutil.MPI_rank == 0: # master proc + if mpiutil.MPI_rank == 0: # main proc main() mpiutil.shutdown() - else: # slave proc - mpiutil.slave() + else: # subordinate proc + mpiutil.subordinate()