From 34c2bd84ee6f699e348d602a82d2d0963384cdec Mon Sep 17 00:00:00 2001 From: Richard Purdie Date: Fri, 20 Jul 2018 15:19:57 +0000 Subject: lib/oe/utils: Drop now unused multiprocess_exec (From OE-Core rev: f3b30def2cd1c9ede7630489c3949a45b6eba6ed) Signed-off-by: Richard Purdie --- meta/lib/oe/utils.py | 34 ---------------------------------- 1 file changed, 34 deletions(-) (limited to 'meta') diff --git a/meta/lib/oe/utils.py b/meta/lib/oe/utils.py index 753b577555..814ac0fd51 100644 --- a/meta/lib/oe/utils.py +++ b/meta/lib/oe/utils.py @@ -248,40 +248,6 @@ def execute_pre_post_process(d, cmds): bb.note("Executing %s ..." % cmd) bb.build.exec_func(cmd, d) -def multiprocess_exec(commands, function): - import signal - import multiprocessing - - if not commands: - return [] - - def init_worker(): - signal.signal(signal.SIGINT, signal.SIG_IGN) - - fails = [] - - def failures(res): - fails.append(res) - - nproc = min(multiprocessing.cpu_count(), len(commands)) - pool = bb.utils.multiprocessingpool(nproc, init_worker) - - try: - mapresult = pool.map_async(function, commands, error_callback=failures) - - pool.close() - pool.join() - results = mapresult.get() - except KeyboardInterrupt: - pool.terminate() - pool.join() - raise - - if fails: - raise fails[0] - - return results - # For each item in items, call the function 'target' with item as the first # argument, extraargs as the other arguments and handle any exceptions in the # parent thread -- cgit v1.2.3-54-g00ecf