diff options
Diffstat (limited to 'meta/lib/oe/package_manager.py')
| -rw-r--r-- | meta/lib/oe/package_manager.py | 32 |
1 files changed, 4 insertions, 28 deletions
diff --git a/meta/lib/oe/package_manager.py b/meta/lib/oe/package_manager.py index 8be3d41706..f8fc3c28bf 100644 --- a/meta/lib/oe/package_manager.py +++ b/meta/lib/oe/package_manager.py @@ -7,6 +7,7 @@ import multiprocessing import re import bb import tempfile +import oe.utils # this can be used by all PM backends to create the index files in parallel @@ -116,16 +117,7 @@ class RpmIndexer(Indexer): bb.note("There are no packages in %s" % self.deploy_dir) return - nproc = multiprocessing.cpu_count() - pool = bb.utils.multiprocessingpool(nproc) - results = list(pool.imap(create_index, index_cmds)) - pool.close() - pool.join() - - for result in results: - if result is not None: - return(result) - + oe.utils.multiprocess_exec(index_cmds, create_index) class OpkgIndexer(Indexer): def write_index(self): @@ -161,15 +153,7 @@ class OpkgIndexer(Indexer): bb.note("There are no packages in %s!" % self.deploy_dir) return - nproc = multiprocessing.cpu_count() - pool = bb.utils.multiprocessingpool(nproc) - results = list(pool.imap(create_index, index_cmds)) - pool.close() - pool.join() - - for result in results: - if result is not None: - return(result) + oe.utils.multiprocess_exec(index_cmds, create_index) class DpkgIndexer(Indexer): @@ -210,15 +194,7 @@ class DpkgIndexer(Indexer): bb.note("There are no packages in %s" % self.deploy_dir) return - nproc = multiprocessing.cpu_count() - pool = bb.utils.multiprocessingpool(nproc) - results = list(pool.imap(create_index, index_cmds)) - pool.close() - pool.join() - - for result in results: - if result is not None: - return(result) + oe.utils.multiprocess_exec(index_cmds, create_index) class PkgsList(object): |