| /external/skqp/bin/ |
| D | try.py | 48 jobs = json.loads(subprocess.check_output([
50 return (BUCKET_SKIA_INTERNAL, jobs)
67 jobs = []
69 jobs.append((BUCKET_SKIA_PRIMARY, json.load(f)))
71 jobs.append(get_jobs(REPO_INTERNAL))
72 jobs.extend(update_meta_config.CQ_INCLUDE_CHROMIUM_TRYBOTS)
75 for bucket, job_list in jobs:
79 jobs = filtered_jobs
82 if len(jobs) == 0:
86 for bucket, job_list in jobs:
[all …]
|
| /external/zstd/contrib/seekable_format/examples/ |
| D | parallel_compression.c | 141 struct job* jobs = malloc_orDie(sizeof(struct job) * numFrames); in compressFile_orDie() local
150 jobs[i].src = in; in compressFile_orDie()
151 jobs[i].srcSize = inSize; in compressFile_orDie()
152 jobs[i].dst = out; in compressFile_orDie()
153 jobs[i].dstSize = dstSize; in compressFile_orDie()
154 jobs[i].compressionLevel = cLevel; in compressFile_orDie()
155 jobs[i].done = 0; in compressFile_orDie()
156 POOL_add(pool, compressFrame, &jobs[i]); in compressFile_orDie()
162 while (!jobs[i].done) SLEEP(5); /* wake up every 5 milliseconds to check */ in compressFile_orDie()
163 fwrite_orDie(jobs[i].dst, jobs[i].dstSize, fout); in compressFile_orDie()
[all …]
|
| /external/mesa3d/src/intel/vulkan/tests/ |
| D | state_pool_no_free.c | 38 } jobs[NUM_THREADS]; variable
71 jobs[i].pool = &state_pool; in run_test()
72 jobs[i].id = i; in run_test()
73 pthread_create(&jobs[i].thread, NULL, alloc_states, &jobs[i]); in run_test()
77 pthread_join(jobs[i].thread, NULL); in run_test()
92 if (thread_max < jobs[i].offsets[next[i]]) { in run_test()
93 thread_max = jobs[i].offsets[next[i]]; in run_test()
105 ASSERT(jobs[max_thread_idx].offsets[next[max_thread_idx]] > highest); in run_test()
107 highest = jobs[max_thread_idx].offsets[next[max_thread_idx]]; in run_test()
|
| D | block_pool_no_free.c | 39 } jobs[NUM_THREADS]; variable
45 uint32_t job_id = job - jobs; in alloc_blocks()
124 jobs[i].pool = &pool; in run_test()
125 jobs[i].id = i; in run_test()
126 pthread_create(&jobs[i].thread, NULL, alloc_blocks, &jobs[i]); in run_test()
130 pthread_join(jobs[i].thread, NULL); in run_test()
135 block_ptrs[i] = jobs[i].blocks; in run_test()
140 block_ptrs[i] = jobs[i].back_blocks; in run_test()
|
| D | state_pool_test_helper.h | 30 } jobs[NUM_THREADS]; variable
64 jobs[i].pool = state_pool; in run_state_pool_test()
65 jobs[i].id = i; in run_state_pool_test()
66 pthread_create(&jobs[i].thread, NULL, alloc_states, &jobs[i]); in run_state_pool_test()
70 pthread_join(jobs[i].thread, NULL); in run_state_pool_test()
|
| /external/skia/bin/ |
| D | try.py | 62 jobs = json.loads(subprocess.check_output([
64 return (BUCKET_SKIA_INTERNAL, jobs)
106 jobs = []
118 jobs.append((BUCKET_SKIA_PRIMARY, skia_primary_jobs))
120 jobs.append(get_jobs(REPO_INTERNAL))
123 for bucket, job_list in jobs:
127 jobs = filtered_jobs
130 if len(jobs) == 0:
134 for bucket, job_list in jobs:
137 for bucket, job_list in jobs:
[all …]
|
| /external/grpc-grpc/tools/profiling/microbenchmarks/bm_diff/ |
| D | bm_build.py | 57 def _make_cmd(cfg, benchmarks, jobs): argument
58 return ['make'] + benchmarks + ['CONFIG=%s' % cfg, '-j', '%d' % jobs]
61 def build(name, benchmarks, jobs, counters): argument
65 subprocess.check_call(_make_cmd('opt', benchmarks, jobs))
67 subprocess.check_call(_make_cmd('counters', benchmarks, jobs))
70 subprocess.check_call(_make_cmd('opt', benchmarks, jobs))
72 subprocess.check_call(_make_cmd('counters', benchmarks, jobs))
81 build(args.name, args.benchmarks, args.jobs, args.counters)
|
| /external/zstd/lib/compress/ |
| D | zstdmt_compress.c | 808 ZSTDMT_jobDescription* jobs; member
872 ZSTDMT_freeJobsTable(mtctx->jobs, mtctx->jobIDMask+1, mtctx->cMem); in ZSTDMT_expandJobsTable()
874 mtctx->jobs = ZSTDMT_createJobsTable(&nbJobs, mtctx->cMem); in ZSTDMT_expandJobsTable()
875 if (mtctx->jobs==NULL) return ERROR(memory_allocation); in ZSTDMT_expandJobsTable()
916 mtctx->jobs = ZSTDMT_createJobsTable(&nbJobs, cMem); in ZSTDMT_createCCtx_advanced_internal()
924 …if (!mtctx->factory | !mtctx->jobs | !mtctx->bufPool | !mtctx->cctxPool | !mtctx->seqPool | initEr… in ZSTDMT_createCCtx_advanced_internal()
953 ZSTD_pthread_mutex_t const mutex = mtctx->jobs[jobID].job_mutex; in ZSTDMT_releaseAllJobResources()
954 ZSTD_pthread_cond_t const cond = mtctx->jobs[jobID].job_cond; in ZSTDMT_releaseAllJobResources()
956 …DEBUGLOG(4, "job%02u: release dst address %08X", jobID, (U32)(size_t)mtctx->jobs[jobID].dstBuff.st… in ZSTDMT_releaseAllJobResources()
957 ZSTDMT_releaseBuffer(mtctx->bufPool, mtctx->jobs[jobID].dstBuff); in ZSTDMT_releaseAllJobResources()
[all …]
|
| /external/libcups/templates/da/ |
| D | jobs-header.tmpl | 1 …?:<FORM ACTION="{?printer_name=?/jobs:{printer_uri_supported}}" METHOD="GET"><INPUT TYPE="SUBMIT" …
2 …=?/jobs:{printer_uri_supported}}" METHOD="GET"><INPUT TYPE="HIDDEN" NAME="which_jobs" VALUE="compl…
3 …_name=?/jobs:{printer_uri_supported}}" METHOD="GET"><INPUT TYPE="HIDDEN" NAME="which_jobs" VALUE="…
5 <P ALIGN="CENTER">{?which_jobs=?Jobs oplistet i udskrivningsrækkefølge - tilbageholdte jobs vises f…
|
| D | class.tmpl | 3 {printer_is_accepting_jobs=0?Afviser jobs:Accepterer jobs},
12 …_is_accepting_jobs=0?<OPTION VALUE="accept-jobs">Accepter jobs</OPTION>:<OPTION VALUE="reject-jobs…
13 <OPTION VALUE="move-jobs">Flyt alle jobs</OPTION>
14 <OPTION VALUE="purge-jobs">Annuller alle jobs</OPTION>
|
| D | printer.tmpl | 3 {printer_is_accepting_jobs=0?Afviser jobs:Accepterer jobs},
14 …_is_accepting_jobs=0?<OPTION VALUE="accept-jobs">Accepter jobs</OPTION>:<OPTION VALUE="reject-jobs…
15 <OPTION VALUE="move-jobs">Flyt alle jobs</OPTION>
16 <OPTION VALUE="cancel-jobs">Annuller alle jobs</OPTION>
|
| /external/mesa3d/src/util/ |
| D | u_queue.c | 297 job = queue->jobs[queue->read_idx]; in util_queue_thread_func()
298 memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job)); in util_queue_thread_func()
320 if (queue->jobs[i].job) { in util_queue_thread_func()
321 util_queue_fence_signal(queue->jobs[i].fence); in util_queue_thread_func()
322 queue->jobs[i].job = NULL; in util_queue_thread_func()
439 queue->jobs = (struct util_queue_job*) in util_queue_init()
441 if (!queue->jobs) in util_queue_init()
475 if (queue->jobs) { in util_queue_init()
479 free(queue->jobs); in util_queue_init()
527 free(queue->jobs); in util_queue_destroy()
[all …]
|
| /external/crosvm/devices/src/utils/ |
| D | async_job_queue.rs | 14 jobs: Mutex<Vec<Box<dyn FnMut() + Send>>>, field
23 jobs: Mutex::new(Vec::new()), in init()
37 self.jobs.lock().push(Box::new(cb)); in queue_job()
53 let jobs = mem::replace(&mut *self.jobs.lock(), Vec::new()); in on_event() localVariable
54 for mut cb in jobs { in on_event()
|
| /external/vixl/tools/ |
| D | test.py | 258 def RunLinter(jobs): argument
261 jobs = args.jobs, progress_prefix = 'cpp lint: ')
264 def RunClangFormat(clang_path, jobs): argument
267 jobs = jobs,
270 def RunClangTidy(clang_path, jobs): argument
273 jobs = jobs,
276 def BuildAll(build_options, jobs, environment_options): argument
277 scons_command = ['scons', '-C', dir_root, 'all', '-j', str(jobs)]
364 rc.Combine(RunLinter(args.jobs))
367 rc.Combine(RunClangFormat(args.clang_format, args.jobs))
[all …]
|
| /external/libdrm/tests/exynos/ |
| D | exynos_fimg2d_event.c | 110 static void wait_all_jobs(struct g2d_job* jobs, unsigned num_jobs) in wait_all_jobs() argument
115 while (jobs[i].busy) in wait_all_jobs()
121 static struct g2d_job* free_job(struct g2d_job* jobs, unsigned num_jobs) in free_job() argument
126 if (jobs[i].busy == 0) in free_job()
127 return &jobs[i]; in free_job()
136 struct g2d_job *jobs = calloc(num_jobs, sizeof(struct g2d_job)); in g2d_work() local
142 jobs[i].id = i; in g2d_work()
150 j = free_job(jobs, num_jobs); in g2d_work()
189 wait_all_jobs(jobs, num_jobs); in g2d_work()
190 free(jobs); in g2d_work()
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | job_status_unittest.py | 66 jobs = [FakeJob(0, [FakeStatus('GOOD', 'T0', ''),
83 for status in jobs[4].statuses:
86 job_id_set = set([job.id for job in jobs])
88 [jobs[1]],
89 [jobs[0], jobs[2]],
90 jobs[3:6]
103 waiter.add_jobs(jobs)
105 for job in jobs[:6]: # the 'GOOD' SERVER_JOB shouldn't be there.
|
| /external/llvm-project/lld/test/ELF/lto/ |
| D | thinlto.ll | 9 ; RUN: ld.lld -save-temps --thinlto-jobs=1 -shared %t1.o %t2.o -o %t3
15 ; RUN: ld.lld -save-temps --thinlto-jobs=2 -shared %t1.o %t2.o -o %t3
19 ;; --plugin-opt=jobs= is an alias.
21 ; RUN: ld.lld -save-temps --plugin-opt=jobs=2 -shared %t1.o %t2.o -o %t3
25 ;; --thinlto-jobs= defaults to --threads=.
31 ;; --thinlto-jobs= overrides --threads=.
33 ; RUN: ld.lld -save-temps --threads=1 --plugin-opt=jobs=2 -shared %t1.o %t2.o -o %t3
39 ; RUN: ld.lld -save-temps --thinlto-jobs=all -shared %t1.o %t2.o -o %t3
45 ; RUN: ld.lld -save-temps --thinlto-jobs=100 -shared %t1.o %t2.o -o %t3
51 ; RUN: not ld.lld -save-temps --thinlto-jobs=foo -shared %t1.o %t2.o -o %t3 2>&1 | FileCheck %s --c…
[all …]
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 52 val jobs = ArrayList<Job>(coroutines) in <lambda>() constant
54 jobs += GlobalScope.launch { in <lambda>()
63 jobs.forEach { it.join() } in <lambda>()
70 val jobs = ArrayList<Job>(coroutines) in <lambda>() constant
72 jobs += GlobalScope.launch { in <lambda>()
81 jobs.forEach { it.join() } in <lambda>()
|
| /external/llvm-project/lld/test/wasm/lto/ |
| D | thinlto.ll | 7 ; RUN: wasm-ld -r -save-temps --thinlto-jobs=1 %t1.o %t2.o -o %t3
13 ; RUN: wasm-ld -r -save-temps --thinlto-jobs=2 %t1.o %t2.o -o %t3
17 ;; --thinlto-jobs= defaults to --threads=.
23 ;; --thinlto-jobs= overrides --threads=.
25 ; RUN: wasm-ld -r -save-temps --threads=1 --thinlto-jobs=2 %t1.o %t2.o -o %t3
31 ; RUN: wasm-ld -r -save-temps --thinlto-jobs=all %t1.o %t2.o -o %t3
37 ; RUN: wasm-ld -r -save-temps --thinlto-jobs=100 %t1.o %t2.o -o %t3
43 ; RUN: not wasm-ld -r -save-temps --thinlto-jobs=foo %t1.o %t2.o -o %t3 2>&1 | FileCheck %s --check…
44 ; BAD-JOBS: error: --thinlto-jobs: invalid job count: foo
46 ; Check without --thinlto-jobs (which currently defaults to heavyweight_hardware_concurrency, meann…
|
| /external/rust/crates/grpcio-sys/grpc/tools/profiling/qps/ |
| D | qps_diff.py | 62 def _make_cmd(jobs): argument
63 return ['make', '-j', '%d' % jobs, 'qps_json_driver', 'qps_worker']
66 def build(name, jobs): argument
70 subprocess.check_call(_make_cmd(jobs))
73 subprocess.check_call(_make_cmd(jobs))
143 build('new', args.jobs)
150 build('old', args.jobs)
|
| /external/grpc-grpc/tools/profiling/qps/ |
| D | qps_diff.py | 64 def _make_cmd(jobs): argument
65 return ['make', '-j', '%d' % jobs, 'qps_json_driver', 'qps_worker']
68 def build(name, jobs): argument
72 subprocess.check_call(_make_cmd(jobs))
75 subprocess.check_call(_make_cmd(jobs))
145 build('new', args.jobs)
152 build('old', args.jobs)
|
| /external/autotest/frontend/afe/ |
| D | direct_afe_unittest.py | 14 jobs = afe.get_jobs()
15 self.assertEquals(len(jobs), 0)
25 jobs = afe.get_jobs()
26 self.assertEquals(len(jobs), 1)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharedFlowStressTest.kt | 47 val jobs = ArrayList<Job>() in <lambda>() constant
48 jobs += List(nProducers) { producerIndex -> in <lambda>()
58 jobs += List(nConsumers) { consumerIndex -> in <lambda>()
83 jobs.forEach { it.cancel() } in <lambda>()
84 jobs.forEach { it.join() } in <lambda>()
|
| /external/fonttools/Tests/ttx/ |
| D | ttx_test.py | 86 jobs, _ = ttx.parseOptions([temp_path])
87 self.assertEqual(jobs[0][0].__name__, "ttDump")
89 jobs[0][1:],
101 jobs, _ = ttx.parseOptions([temp_path])
102 self.assertEqual(jobs[0][0].__name__, "ttDump")
104 jobs[0][1:],
115 jobs, _ = ttx.parseOptions([temp_path])
116 self.assertEqual(jobs[0][0].__name__, "ttCompile")
118 jobs[0][1:],
130 jobs, _ = ttx.parseOptions([temp_path])
[all …]
|
| /external/libcups/test/ |
| D | 4.1-requests.test | 19 OPERATION get-jobs
33 OPERATION get-jobs
51 OPERATION get-jobs
69 OPERATION get-jobs
88 OPERATION get-jobs
107 OPERATION get-jobs
127 OPERATION get-jobs
133 ATTR uri job-uri $scheme://$hostname:$port/jobs
147 OPERATION get-jobs
|