| /external/libvpx/libvpx/vpx_util/ |
| D | vpx_thread.c | 30 static void execute(VPxWorker *const worker); // Forward declaration.
33 VPxWorker *const worker = (VPxWorker *)ptr; in thread_loop() local
36 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
37 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
38 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
40 if (worker->status_ == WORK) { in thread_loop()
41 execute(worker); in thread_loop()
42 worker->status_ = OK; in thread_loop()
43 } else if (worker->status_ == NOT_OK) { // finish the worker in thread_loop()
47 pthread_cond_signal(&worker->impl_->condition_); in thread_loop()
[all …]
|
| /external/webp/src/utils/ |
| D | thread_utils.c | 205 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
206 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ThreadLoop()
210 while (worker->status_ == OK) { // wait in idling mode in ThreadLoop()
213 if (worker->status_ == WORK) { in ThreadLoop()
214 WebPGetWorkerInterface()->Execute(worker); in ThreadLoop()
215 worker->status_ = OK; in ThreadLoop()
216 } else if (worker->status_ == NOT_OK) { // finish the worker in ThreadLoop()
227 static void ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) { in ChangeState() argument
231 WebPWorkerImpl* const impl = (WebPWorkerImpl*)worker->impl_; in ChangeState()
235 if (worker->status_ >= OK) { in ChangeState()
[all …]
|
| D | thread_utils.h | 52 void (*Init)(WebPWorker* const worker);
55 int (*Reset)(WebPWorker* const worker);
58 int (*Sync)(WebPWorker* const worker);
62 void (*Launch)(WebPWorker* const worker);
67 void (*Execute)(WebPWorker* const worker);
70 void (*End)(WebPWorker* const worker);
|
| /external/drm_hwcomposer/tests/ |
| D | worker_test.cpp | 57 TestWorker worker; member
60 worker.Init(); in SetUp()
70 ASSERT_TRUE(worker.initialized()); in TEST_F()
72 int val = worker.value; in TEST_F()
76 ASSERT_EQ(val, worker.value); in TEST_F()
78 worker.Control(true); in TEST_F()
82 worker.Lock(); in TEST_F()
83 val = worker.value; in TEST_F()
85 ASSERT_EQ(val, worker.value); in TEST_F()
86 worker.Unlock(); in TEST_F()
[all …]
|
| /external/ltp/testcases/kernel/io/direct_io/ |
| D | dma_thread_diotest.c | 155 static worker_t *worker; variable
161 worker_t *worker = (worker_t *)arg; in worker_thread() local
162 int offset = worker->offset; in worker_thread()
163 int fd = worker->fd; in worker_thread()
164 unsigned char *buffer = worker->buffer; in worker_thread()
165 int pattern = worker->pattern; in worker_thread()
166 int length = worker->length; in worker_thread()
177 worker->worker_number, strerror(errno)); in worker_thread()
261 worker[j].fd = SAFE_OPEN(cleanup, filename, in dma_thread_diotest_verify()
263 worker[j].pattern = n; in dma_thread_diotest_verify()
[all …]
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | worker_service.proto | 23 import "tensorflow/core/protobuf/worker.proto";
30 // A worker service keeps track of multiple "registered graphs". Each
32 // only the nodes that should execute on this worker (and any
39 // See worker.proto for details.
42 // See worker.proto for details.
46 // See worker.proto for details.
50 // See worker.proto for details.
53 // See worker.proto for details.
56 // See worker.proto for details.
59 // See worker.proto for details.
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 34 void Run(VPxWorker *worker) { in Run() argument
37 vpx_get_worker_interface()->execute(worker); in Run()
39 vpx_get_worker_interface()->launch(worker); in Run()
201 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init() argument
203 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync() argument
205 void Execute(VPxWorker *const worker) { in Execute() argument
206 worker->had_error |= !worker->hook(worker->data1, worker->data2); in Execute()
209 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch() argument
|
| /external/autotest/site_utils/lxc/container_pool/ |
| D | pool.py | 218 for worker in self._workers:
219 worker.cancel()
241 for worker in self._workers:
242 worker.join(timeout)
243 if worker.is_alive():
293 worker = _Worker(self._factory,
296 worker.start()
297 self._workers.append(worker)
311 for worker in self._workers:
312 if worker.check_health():
[all …]
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| D | WorkerMain.java | 17 package com.google.caliper.worker;
50 Worker worker = workerComponent.getWorker(); in main() local
55 worker.setUpBenchmark(); in main()
57 worker.bootstrap(); in main()
62 worker.preMeasure(isInWarmup); in main()
65 ShouldContinueMessage message = log.notifyMeasurementEnding(worker.measure()); in main()
69 worker.postMeasure(); in main()
76 worker.tearDownBenchmark(); in main()
|
| /external/v8/tools/profviz/ |
| D | profviz.js | 43 var worker = null;
47 worker = new Worker("worker.js");
50 worker.postMessage({ "call" : "load scripts",
53 worker.addEventListener("message", function(event) {
76 worker.postMessage({ 'call' : 'run', 'args' : args });
80 if (worker) worker.terminate();
230 worker.run(file, kResX, kResY, distortion, range[0], range[1]);
275 worker = new plotWorker();
276 worker.reset();
284 var worker; variable
|
| /external/tensorflow/tensorflow/contrib/batching/python/ops/ |
| D | batch_ops_test.py | 51 def worker(): function
55 worker_thread = threading.Thread(target=worker)
92 def worker(): function
96 worker_thread = threading.Thread(target=worker)
125 def worker(): function
130 worker_thread = threading.Thread(target=worker)
178 def worker(): function
181 worker_thread = threading.Thread(target=worker)
198 def worker(): function
201 worker_thread = threading.Thread(target=worker)
[all …]
|
| /external/libxcam/modules/soft/ |
| D | soft_blender.cpp | 312 SmartPtr<GaussScaleGray> worker = new GaussScaleGray; in scale_down_masks() local
314 worker->set_local_size (size); in scale_down_masks()
315 worker->set_global_size (size); in scale_down_masks()
316 XCamReturn ret = worker->work (args); in scale_down_masks()
330 SmartPtr<SoftWorker> worker = pyr_layer[level].scale_task[idx]; in start_scaler() local
331 XCAM_ASSERT (worker.ptr ()); in start_scaler()
366 WorkSize work_unit = worker->get_work_uint (); in start_scaler()
374 worker->set_local_size (local_size); in start_scaler()
375 worker->set_global_size (global_size); in start_scaler()
377 return worker->work (args); in start_scaler()
[all …]
|
| /external/perfetto/docs/ |
| D | ftrace.md | 26 worker #0 [splice ...] [wakeup] [block ............] [splice]
28 worker #1 [splice ...] [wakeup] [block ........] [splice]
30 worker #2 [splice ..........................................]
37 granularity. This call allows every per-cpu worker to sleep until there
40 When a worker wakes up, it will attempt to move as many pages as
44 will block the calling worker until the main thread has drained the
47 When at least one worker has woken up, we schedule a drain operation
50 every worker having pending data. After this, each waiting worker is
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| D | WorkerProcessTest.java | 28 import com.google.caliper.worker.WorkerMain;
110 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_waitFor() local
113 worker.waitFor(); in shutdownHook_waitFor()
118 Process worker = createWorkerProcess( in shutdownHook_exitValueThrows() local
124 worker.exitValue(); in shutdownHook_exitValueThrows()
129 worker.destroy(); // clean up in shutdownHook_exitValueThrows()
134 Process worker = createWorkerProcess(FakeWorkers.Exit.class, "0").startWorker(); in shutdownHook_exitValue() local
137 worker.exitValue(); in shutdownHook_exitValue()
147 Process worker = createWorkerProcess( in shutdownHook_destroy() local
149 worker.destroy(); in shutdownHook_destroy()
|
| /external/tensorflow/tensorflow/docs_src/deploy/ |
| D | distributed.md | 38 "worker" that executes operations in the graph. A cluster can also be divided
72 "worker": [
81 </pre></td><td><code>/job:worker/task:0</code><br/><code>/job:worker/task:1</code><br/><code>/job:w…
132 with tf.device("/job:worker/task:7"):
145 and the compute-intensive part of the model is created in the `worker`
147 (from `ps` to `worker` for the forward pass, and from `worker` to `ps` for
153 tasks in a `worker` job training the same model on different mini-batches of
162 each pinned to a different task in `/job:worker`.
165 for each `/job:worker` task, typically in the same process as the worker
171 `/job:worker`.
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_session.cc | 30 wrapped_->ReleaseWorker(p.first, p.second.worker); in ~WorkerFreeListCache()
42 return p->second.worker; in CreateWorker()
45 state.worker = wrapped_->CreateWorker(target); in CreateWorker()
46 if (state.worker != nullptr) { in CreateWorker()
49 return state.worker; in CreateWorker()
52 void ReleaseWorker(const string& target, WorkerInterface* worker) override { in ReleaseWorker() argument
79 WorkerInterface* worker; member
|
| /external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/output/ |
| D | TcpClientOutput.java | 35 private Thread worker; field in TcpClientOutput
52 worker = new Thread(new Runnable() { in startup()
61 worker.setName(getClass().getName()); in startup()
62 worker.setDaemon(true); in startup()
63 worker.start(); in startup()
68 worker.join(); in shutdown()
|
| D | TcpServerOutput.java | 39 private Thread worker; field in TcpServerOutput
54 worker = new Thread(new Runnable() { in startup()
74 worker.setName(getClass().getName()); in startup()
75 worker.setDaemon(true); in startup()
76 worker.start(); in startup()
86 worker.join(); in shutdown()
|
| /external/tensorflow/tensorflow/tools/dist_test/scripts/ |
| D | k8s_tensorflow_lib.py | 175 for worker in range(num_workers):
178 'task_id': worker
185 worker_id=worker,
195 worker_id=worker,
199 worker_id=worker,
255 for worker in range(num_workers):
256 spec += '%s-worker%d:%d' % (name_prefix, worker, port)
257 if worker != num_workers-1:
|
| /external/ltp/testcases/kernel/fs/fs_fill/ |
| D | fs_fill.c | 37 static struct worker *workers;
39 struct worker { struct
43 static void *worker(void *p) in worker() argument
45 struct worker *w = p; in worker()
83 SAFE_PTHREAD_CREATE(&threads[i], NULL, worker, &workers[i]); in testrun()
107 workers = SAFE_MALLOC(sizeof(struct worker) * nthreads); in setup()
|
| /external/webp/src/enc/ |
| D | alpha_enc.c | 393 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncInitAlpha() local
394 WebPGetWorkerInterface()->Init(worker); in VP8EncInitAlpha()
395 worker->data1 = enc; in VP8EncInitAlpha()
396 worker->data2 = NULL; in VP8EncInitAlpha()
397 worker->hook = (WebPWorkerHook)CompressAlphaJob; in VP8EncInitAlpha()
404 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncStartAlpha() local
406 if (!WebPGetWorkerInterface()->Reset(worker)) { in VP8EncStartAlpha()
409 WebPGetWorkerInterface()->Launch(worker); in VP8EncStartAlpha()
421 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncFinishAlpha() local
422 if (!WebPGetWorkerInterface()->Sync(worker)) return 0; // error in VP8EncFinishAlpha()
[all …]
|
| D | analysis_enc.c | 429 WebPWorker worker; member
462 WebPGetWorkerInterface()->Init(&job->worker); in InitSegmentJob()
463 job->worker.data1 = job; in InitSegmentJob()
464 job->worker.data2 = &job->it; in InitSegmentJob()
465 job->worker.hook = (WebPWorkerHook)DoSegmentsJob; in InitSegmentJob()
506 ok &= worker_interface->Reset(&side_job.worker); in VP8EncAnalyze()
509 worker_interface->Launch(&side_job.worker); in VP8EncAnalyze()
510 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
511 ok &= worker_interface->Sync(&side_job.worker); in VP8EncAnalyze()
512 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
[all …]
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| D | iterator_ops_cluster_test.py | 45 worker, _ = test_util.create_local_cluster(
58 with session.Session(worker[0].target) as sess:
98 worker, _ = test_util.create_local_cluster(
103 worker[0].target)
113 worker, _ = test_util.create_local_cluster(1, 1)
136 with session.Session(worker[0].target) as sess:
141 with session.Session(worker[0].target) as sess:
151 worker, _ = test_util.create_local_cluster(1, 1)
168 with session.Session(worker[0].target) as sess:
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | runtest_mp.py | 163 for worker in workers:
164 worker.start()
168 for worker in workers:
169 current_test = worker.current_test
172 dt = time.monotonic() - worker.start_time
234 running = [worker.current_test for worker in workers]
244 for worker in workers:
245 worker.join(WAIT_PROGRESS)
|
| /external/python/cpython2/Doc/includes/ |
| D | mp_pool.py | 246 for worker in pool._pool:
247 assert worker.is_alive()
255 for worker in pool._pool:
256 assert not worker.is_alive()
273 for worker in pool._pool:
274 assert not worker.is_alive()
294 for worker in processes:
295 assert not worker.is_alive()
|