@@ -1465,22 +1465,6 @@ def process_profilelog(fn, pout = None):
pout.flush()
-#
-# Was present to work around multiprocessing pool bugs in python < 2.7.3
-#
-def multiprocessingpool(*args, **kwargs):
-
- #multiprocessing.util.log_to_stderr(10)
- # Deal with a multiprocessing bug where signals to the processes would be delayed until the work
- # completes. Putting in a timeout means the signals (like SIGINT/SIGTERM) get processed.
- def wrapper(func):
- def wrap(self, timeout=None):
- return func(self, timeout=timeout if timeout is not None else 1e100)
- return wrap
- multiprocessing.pool.IMapIterator.next = wrapper(multiprocessing.pool.IMapIterator.next)
-
- return multiprocessing.Pool(*args, **kwargs)
-
def exec_flat_python_func(func, *args, **kwargs):
"""Execute a flat python function (defined with ``def funcname(args): ...``)
This API is no longer used and bitbake has moved beyond Python 2.7.3 as the minimum version, so remove it. Signed-off-by: Joshua Watt <JPEWhacker@gmail.com> --- bitbake/lib/bb/utils.py | 16 ---------------- 1 file changed, 16 deletions(-)