| /external/libvpx/libvpx/vp9/common/ |
| D | vp9_thread.c | 31 static void execute(VP9Worker *const worker); // Forward declaration.
34 VP9Worker *const worker = (VP9Worker*)ptr; in thread_loop() local
37 pthread_mutex_lock(&worker->impl_->mutex_); in thread_loop()
38 while (worker->status_ == OK) { // wait in idling mode in thread_loop()
39 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in thread_loop()
41 if (worker->status_ == WORK) { in thread_loop()
42 execute(worker); in thread_loop()
43 worker->status_ = OK; in thread_loop()
44 } else if (worker->status_ == NOT_OK) { // finish the worker in thread_loop()
48 pthread_cond_signal(&worker->impl_->condition_); in thread_loop()
[all …]
|
| D | vp9_thread.h | 182 void (*init)(VP9Worker *const worker);
185 int (*reset)(VP9Worker *const worker);
188 int (*sync)(VP9Worker *const worker);
192 void (*launch)(VP9Worker *const worker);
197 void (*execute)(VP9Worker *const worker);
200 void (*end)(VP9Worker *const worker);
|
| /external/webp/src/utils/ |
| D | thread.c | 156 static void Execute(WebPWorker* const worker); // Forward declaration.
159 WebPWorker* const worker = (WebPWorker*)ptr; in ThreadLoop() local
162 pthread_mutex_lock(&worker->impl_->mutex_); in ThreadLoop()
163 while (worker->status_ == OK) { // wait in idling mode in ThreadLoop()
164 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_); in ThreadLoop()
166 if (worker->status_ == WORK) { in ThreadLoop()
167 Execute(worker); in ThreadLoop()
168 worker->status_ = OK; in ThreadLoop()
169 } else if (worker->status_ == NOT_OK) { // finish the worker in ThreadLoop()
173 pthread_cond_signal(&worker->impl_->condition_); in ThreadLoop()
[all …]
|
| D | thread.h | 55 void (*Init)(WebPWorker* const worker);
58 int (*Reset)(WebPWorker* const worker);
61 int (*Sync)(WebPWorker* const worker);
65 void (*Launch)(WebPWorker* const worker);
70 void (*Execute)(WebPWorker* const worker);
73 void (*End)(WebPWorker* const worker);
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 38 void Run(VP9Worker* worker) { in Run() argument
41 vp9_get_worker_interface()->execute(worker); in Run()
43 vp9_get_worker_interface()->launch(worker); in Run()
205 void Init(VP9Worker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init() argument
207 int Sync(VP9Worker *const worker) { return !worker->had_error; } in Sync() argument
209 void Execute(VP9Worker *const worker) { in Execute() argument
210 worker->had_error |= worker->hook(worker->data1, worker->data2); in Execute()
213 void Launch(VP9Worker *const worker) { Execute(worker); } in Launch() argument
|
| /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/drm_hwcomposer/ |
| D | worker.cpp | 145 Worker *worker = (Worker *)arg; in InternalRoutine() local
147 setpriority(PRIO_PROCESS, 0, worker->priority_); in InternalRoutine()
150 int ret = worker->Lock(); in InternalRoutine()
152 ALOGE("Failed to lock %s thread %d", worker->name_.c_str(), ret); in InternalRoutine()
156 bool exit = worker->exit_; in InternalRoutine()
158 ret = worker->Unlock(); in InternalRoutine()
160 ALOGE("Failed to unlock %s thread %d", worker->name_.c_str(), ret); in InternalRoutine()
166 worker->Routine(); in InternalRoutine()
|
| /external/chromium-trace/trace-viewer/third_party/Paste/paste/ |
| D | httpserver.py | 655 for worker in self.workers:
656 if not hasattr(worker, 'thread_id'):
659 time_started, info = self.worker_tracker.get(worker.thread_id,
696 for worker in self.workers:
697 if not hasattr(worker, 'thread_id'):
701 time_started, info = self.worker_tracker.get(worker.thread_id,
705 result['hung'].append(worker)
707 result['busy'].append(worker)
709 result['idle'].append(worker)
710 for thread_id, (time_killed, worker) in self.dying_threads.items():
[all …]
|
| /external/apache-xml/src/main/java/org/apache/xml/utils/ |
| D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) in waitThread() argument
41 m_tpool.waitThread(worker, task); in waitThread()
87 public void waitThread(Thread worker, Runnable task) in waitThread() argument
92 worker.join(); in waitThread()
|
| /external/webp/src/enc/ |
| D | alpha.c | 383 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncInitAlpha() local
384 WebPGetWorkerInterface()->Init(worker); in VP8EncInitAlpha()
385 worker->data1 = enc; in VP8EncInitAlpha()
386 worker->data2 = NULL; in VP8EncInitAlpha()
387 worker->hook = (WebPWorkerHook)CompressAlphaJob; in VP8EncInitAlpha()
394 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncStartAlpha() local
396 if (!WebPGetWorkerInterface()->Reset(worker)) { in VP8EncStartAlpha()
399 WebPGetWorkerInterface()->Launch(worker); in VP8EncStartAlpha()
411 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncFinishAlpha() local
412 if (!WebPGetWorkerInterface()->Sync(worker)) return 0; // error in VP8EncFinishAlpha()
[all …]
|
| D | analysis.c | 394 WebPWorker worker; member
427 WebPGetWorkerInterface()->Init(&job->worker); in InitSegmentJob()
428 job->worker.data1 = job; in InitSegmentJob()
429 job->worker.data2 = &job->it; in InitSegmentJob()
430 job->worker.hook = (WebPWorkerHook)DoSegmentsJob; in InitSegmentJob()
471 ok &= worker_interface->Reset(&side_job.worker); in VP8EncAnalyze()
474 worker_interface->Launch(&side_job.worker); in VP8EncAnalyze()
475 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
476 ok &= worker_interface->Sync(&side_job.worker); in VP8EncAnalyze()
477 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
[all …]
|
| /external/clang/test/SemaCXX/ |
| D | arrow-operator.cpp | 60 wrapped_ptr<Worker> worker(new Worker); in test() local
61 …worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped… in test()
62 …worker.DoSamething(); // expected-error {{no member named 'DoSamething' in 'arrow_suggest::wrapped… in test()
64 …worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_s… in test()
|
| /external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
| D | UnixSocketTest.java | 46 Socket worker = pingServer.accept(); in test_getInputStream() local
52 InputStream in = worker.getInputStream(); in test_getInputStream()
55 OutputStream out = worker.getOutputStream(); in test_getInputStream()
57 worker.close(); in test_getInputStream()
|
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowAsyncTask.java | 23 private final BackgroundWorker worker; field in ShadowAsyncTask
27 worker = new BackgroundWorker(); in ShadowAsyncTask()
28 future = new FutureTask<Result>(worker) { in ShadowAsyncTask()
80 worker.params = params; in execute()
|
| /external/google-breakpad/src/tools/mac/upload_system_symbols/ |
| D | upload_system_symbols.go | 178 uq.WorkerPool = StartWorkerPool(5, uq.worker)
193 func (uq *UploadQueue) worker() { func
234 dq.WorkerPool = StartWorkerPool(12, dq.worker)
261 func (dq *DumpQueue) worker() { func
322 fq.WorkerPool = StartWorkerPool(12, fq.worker)
368 func (fq *findQueue) worker() { func
|
| /external/v8/test/mjsunit/regress/ |
| D | regress-crbug-147475.js | 34 function factory(worker) { argument
37 return 1 + worker(call_depth - 1);
|
| D | regress-crbug-138887.js | 34 function factory(worker) { argument
37 return 1 + worker(call_depth - 1);
|
| /external/compiler-rt/test/tsan/ |
| D | fork_atexit.cc | 13 void *worker(void *unused) { in worker() function
19 pthread_create(&t, NULL, worker, NULL); in main()
|
| D | pthread_atfork_deadlock.c | 11 void *worker(void *unused) { in worker() function
26 pthread_create(&t, NULL, worker, NULL); in main()
|
| /external/libvpx/libvpx/vp9/decoder/ |
| D | vp9_dthread.c | 182 VP9Worker *const worker = &pbi->tile_workers[i]; in vp9_loop_filter_frame_mt() local
183 TileWorkerData *const tile_data = (TileWorkerData*)worker->data1; in vp9_loop_filter_frame_mt()
186 worker->hook = (VP9WorkerHook)loop_filter_row_worker; in vp9_loop_filter_frame_mt()
201 winterface->execute(worker); in vp9_loop_filter_frame_mt()
203 winterface->launch(worker); in vp9_loop_filter_frame_mt()
|
| D | vp9_decoder.c | 92 VP9Worker *const worker = &pbi->tile_workers[i]; in vp9_decoder_remove() local
93 vp9_get_worker_interface()->end(worker); in vp9_decoder_remove()
94 vpx_free(worker->data1); in vp9_decoder_remove()
95 vpx_free(worker->data2); in vp9_decoder_remove()
|
| /external/chromium-trace/trace-viewer/tracing/third_party/gl-matrix/spec/gl-matrix/ |
| D | worker-spec.js | 30 var worker = new Worker(URL.createObjectURL(blob));
31 worker.onmessage = function(e) {
|
| /external/pdfium/third_party/freetype/src/smooth/ |
| D | ftgrays.c | 275 #define RAS_ARG gray_PWorker worker
276 #define RAS_ARG_ gray_PWorker worker,
278 #define RAS_VAR worker
279 #define RAS_VAR_ worker,
459 #define ras (*worker)
471 gray_PWorker worker; member
1151 gray_PWorker worker ) in gray_move_to() argument
1166 worker->x = x; in gray_move_to()
1167 worker->y = y; in gray_move_to()
1174 gray_PWorker worker ) in gray_line_to() argument
[all …]
|
| /external/jetty/src/java/org/eclipse/jetty/server/session/ |
| D | HashSessionIdManager.java | 94 … String worker=request==null?null:(String)request.getAttribute("org.eclipse.jetty.ajp.JVMRoute"); in getNodeId() local
95 if (worker!=null) in getNodeId()
96 return clusterId+'.'+worker; in getNodeId()
|
| /external/libunwind/tests/ |
| D | Gtest-concurrent.c | 73 worker (void *arg UNUSED) in worker() function
94 if (pthread_create (th + i, &attr, worker, NULL)) in doit()
|