--- mga-gnome/trunk/mga-gnome 2013/02/13 18:31:26 7322 +++ mga-gnome/trunk/mga-gnome 2013/05/25 14:48:34 8389 @@ -52,6 +52,8 @@ # check-latest import requests +import multiprocessing + SLEEP_INITIAL=180 SLEEP_REPEAT=30 SLEEP_TIMES=30 @@ -674,13 +676,18 @@ fdst.flush() os.rename(fdst.name, path) +def cmd_co_multi(l): + package, module, package_version, spec_version, downstream_files = l + + print "%s => %s" % (module, package) + try: + Downstream.co(package) + except subprocess.CalledProcessError: + pass + def cmd_co(options, parser): - for package, module, package_version, spec_version, downstream_files in sorted(join_streams()): - print "%s => %s" % (module, package) - try: - Downstream.co(package) - except subprocess.CalledProcessError: - pass + p = multiprocessing.Pool(5) + p.map(cmd_co_multi, sorted(join_streams())) def join_streams(show_version=False, only_diff_version=False): root = os.path.expanduser(Downstream.PKGROOT)