diff options
-rw-r--r-- | bitbake/lib/bb/utils.py | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/bitbake/lib/bb/utils.py b/bitbake/lib/bb/utils.py index 5c464b18d3..0cf3b1814c 100644 --- a/bitbake/lib/bb/utils.py +++ b/bitbake/lib/bb/utils.py | |||
@@ -1479,22 +1479,6 @@ def process_profilelog(fn, fn_out = None): | |||
1479 | p.print_callers() | 1479 | p.print_callers() |
1480 | 1480 | ||
1481 | 1481 | ||
1482 | # | ||
1483 | # Was present to work around multiprocessing pool bugs in python < 2.7.3 | ||
1484 | # | ||
1485 | def multiprocessingpool(*args, **kwargs): | ||
1486 | |||
1487 | #multiprocessing.util.log_to_stderr(10) | ||
1488 | # Deal with a multiprocessing bug where signals to the processes would be delayed until the work | ||
1489 | # completes. Putting in a timeout means the signals (like SIGINT/SIGTERM) get processed. | ||
1490 | def wrapper(func): | ||
1491 | def wrap(self, timeout=None): | ||
1492 | return func(self, timeout=timeout if timeout is not None else 1e100) | ||
1493 | return wrap | ||
1494 | multiprocessing.pool.IMapIterator.next = wrapper(multiprocessing.pool.IMapIterator.next) | ||
1495 | |||
1496 | return multiprocessing.Pool(*args, **kwargs) | ||
1497 | |||
1498 | def exec_flat_python_func(func, *args, **kwargs): | 1482 | def exec_flat_python_func(func, *args, **kwargs): |
1499 | """Execute a flat python function (defined with ``def funcname(args): ...``) | 1483 | """Execute a flat python function (defined with ``def funcname(args): ...``) |
1500 | 1484 | ||