Searched refs:nr_jobs (Results 1 – 2 of 2) sorted by relevance
77 atomic_t nr_jobs; member512 if (atomic_dec_and_test(&kc->nr_jobs)) in run_complete_job()683 atomic_inc(&kc->nr_jobs); in dispatch_job()769 atomic_inc(&master_job->kc->nr_jobs); in split_job()879 atomic_inc(&kc->nr_jobs); in dm_kcopyd_prepare_callback()959 atomic_set(&kc->nr_jobs, 0); in dm_kcopyd_client_create()979 wait_event(kc->destroyq, !atomic_read(&kc->nr_jobs)); in dm_kcopyd_client_destroy()
192 def DoRunWork(worklist, nr_jobs, verbosity): argument208 while len(running) < nr_jobs and len(not_started):253 def RunWork(worklist, nr_jobs=NumberOfCPUs(), verbosity=Verbosity()): argument255 return DoRunWork(worklist, nr_jobs, verbosity)