|
Lines 4-9
Link Here
|
| 4 |
# Licensed under the terms of 2-clause BSD license |
4 |
# Licensed under the terms of 2-clause BSD license |
| 5 |
|
5 |
|
| 6 |
import errno |
6 |
import errno |
|
|
7 |
import gc |
| 7 |
import multiprocessing |
8 |
import multiprocessing |
| 8 |
import os.path |
9 |
import os.path |
| 9 |
import sys |
10 |
import sys |
|
Lines 382-387
class ManifestRecursiveLoader(object):
Link Here
|
| 382 |
unconditionally of whether they match parent checksums. |
383 |
unconditionally of whether they match parent checksums. |
| 383 |
""" |
384 |
""" |
| 384 |
|
385 |
|
|
|
386 |
gc.disable() |
| 385 |
pool = multiprocessing.Pool(processes=self.max_jobs) |
387 |
pool = multiprocessing.Pool(processes=self.max_jobs) |
| 386 |
|
388 |
|
| 387 |
try: |
389 |
try: |
|
Lines 414-419
class ManifestRecursiveLoader(object):
Link Here
|
| 414 |
pool.join() |
416 |
pool.join() |
| 415 |
finally: |
417 |
finally: |
| 416 |
pool.terminate() |
418 |
pool.terminate() |
|
|
419 |
gc.enable() |
| 417 |
|
420 |
|
| 418 |
def find_timestamp(self): |
421 |
def find_timestamp(self): |
| 419 |
""" |
422 |
""" |
|
Lines 657-662
class ManifestRecursiveLoader(object):
Link Here
|
| 657 |
self.manifest_device, |
660 |
self.manifest_device, |
| 658 |
fail_handler, last_mtime) |
661 |
fail_handler, last_mtime) |
| 659 |
|
662 |
|
|
|
663 |
gc.disable() |
| 660 |
pool = multiprocessing.Pool(processes=self.max_jobs) |
664 |
pool = multiprocessing.Pool(processes=self.max_jobs) |
| 661 |
|
665 |
|
| 662 |
try: |
666 |
try: |
|
Lines 682-687
class ManifestRecursiveLoader(object):
Link Here
|
| 682 |
pool.join() |
686 |
pool.join() |
| 683 |
finally: |
687 |
finally: |
| 684 |
pool.terminate() |
688 |
pool.terminate() |
|
|
689 |
gc.enable() |
| 685 |
|
690 |
|
| 686 |
return ret |
691 |
return ret |
| 687 |
|
692 |
|
| 688 |
- |
|
|
