Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • src/tests/pybin/tools.py

    rf3b9efc rd142ec5  
    168168def jobCount( options, tests ):
    169169        # check if the user already passed in a number of jobs for multi-threading
    170         make_flags = os.environ.get('MAKEFLAGS')
    171         make_jobs_fds = re.search("--jobserver-(auth|fds)=\s*([0-9]+),([0-9]+)", make_flags) if make_flags else None
    172         if make_jobs_fds :
    173                 tokens = os.read(int(make_jobs_fds.group(2)), 1024)
    174                 options.jobs = len(tokens)
    175                 os.write(int(make_jobs_fds.group(3)), tokens)
     170        if not options.jobs:
     171                make_flags = os.environ.get('MAKEFLAGS')
     172                force = bool(make_flags)
     173                make_jobs_fds = re.search("--jobserver-(auth|fds)=\s*([0-9]+),([0-9]+)", make_flags) if make_flags else None
     174                if make_jobs_fds :
     175                        tokens = os.read(int(make_jobs_fds.group(2)), 1024)
     176                        options.jobs = len(tokens)
     177                        os.write(int(make_jobs_fds.group(3)), tokens)
     178                else :
     179                        options.jobs = multiprocessing.cpu_count()
    176180        else :
    177                 options.jobs = multiprocessing.cpu_count()
     181                force = True
    178182
    179183        # make sure we have a valid number of jobs that corresponds to user input
     
    182186                sys.exit(1)
    183187
    184         return min( options.jobs, len(tests) ), True if make_flags else False
     188        return min( options.jobs, len(tests) ), force
    185189
    186190# setup a proper processor pool with correct signal handling
Note: See TracChangeset for help on using the changeset viewer.