Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 63) sorted by relevance

123

/external/libvpx/libvpx/vpx_util/
Dvpx_thread.c31 static void execute(VPxWorker *const worker); // Forward declaration.
34 VPxWorker *const worker = (VPxWorker*)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 …]
Dvpx_thread.h186 void (*init)(VPxWorker *const worker);
189 int (*reset)(VPxWorker *const worker);
192 int (*sync)(VPxWorker *const worker);
196 void (*launch)(VPxWorker *const worker);
201 void (*execute)(VPxWorker *const worker);
204 void (*end)(VPxWorker *const worker);
/external/webp/src/utils/
Dthread.c156 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 …]
Dthread.h55 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/vp9/decoder/
Dvp9_dthread.c20 void vp9_frameworker_lock_stats(VPxWorker *const worker) { in vp9_frameworker_lock_stats() argument
22 FrameWorkerData *const worker_data = worker->data1; in vp9_frameworker_lock_stats()
25 (void)worker; in vp9_frameworker_lock_stats()
29 void vp9_frameworker_unlock_stats(VPxWorker *const worker) { in vp9_frameworker_unlock_stats() argument
31 FrameWorkerData *const worker_data = worker->data1; in vp9_frameworker_unlock_stats()
34 (void)worker; in vp9_frameworker_unlock_stats()
38 void vp9_frameworker_signal_stats(VPxWorker *const worker) { in vp9_frameworker_signal_stats() argument
40 FrameWorkerData *const worker_data = worker->data1; in vp9_frameworker_signal_stats()
50 (void)worker; in vp9_frameworker_signal_stats()
62 void vp9_frameworker_wait(VPxWorker *const worker, RefCntBuffer *const ref_buf, in vp9_frameworker_wait() argument
[all …]
Dvp9_dthread.h47 void vp9_frameworker_lock_stats(VPxWorker *const worker);
48 void vp9_frameworker_unlock_stats(VPxWorker *const worker);
49 void vp9_frameworker_signal_stats(VPxWorker *const worker);
55 void vp9_frameworker_wait(VPxWorker *const worker, RefCntBuffer *const ref_buf,
Dvp9_decoder.c133 VPxWorker *const worker = &pbi->tile_workers[i]; in vp9_decoder_remove() local
134 vpx_get_worker_interface()->end(worker); in vp9_decoder_remove()
314 VPxWorker *const worker = pbi->frame_worker_owner; in vp9_receive_compressed_data() local
315 vp9_frameworker_lock_stats(worker); in vp9_receive_compressed_data()
316 frame_bufs[cm->new_fb_idx].frame_worker_owner = worker; in vp9_receive_compressed_data()
321 vp9_frameworker_unlock_stats(worker); in vp9_receive_compressed_data()
390 VPxWorker *const worker = pbi->frame_worker_owner; in vp9_receive_compressed_data() local
391 FrameWorkerData *const frame_worker_data = worker->data1; in vp9_receive_compressed_data()
392 vp9_frameworker_lock_stats(worker); in vp9_receive_compressed_data()
399 vp9_frameworker_signal_stats(worker); in vp9_receive_compressed_data()
[all …]
/external/libvpx/libvpx/vp9/encoder/
Dvp9_ethread.c94 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt() local
98 winterface->init(worker); in vp9_encode_tiles_mt()
118 if (!winterface->reset(worker)) in vp9_encode_tiles_mt()
127 winterface->sync(worker); in vp9_encode_tiles_mt()
132 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt() local
135 worker->hook = (VPxWorkerHook)enc_worker_hook; in vp9_encode_tiles_mt()
136 worker->data1 = &cpi->tile_thr_data[i]; in vp9_encode_tiles_mt()
137 worker->data2 = NULL; in vp9_encode_tiles_mt()
138 thread_data = (EncWorkerData*)worker->data1; in vp9_encode_tiles_mt()
170 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt() local
[all …]
/external/libvpx/libvpx/vp9/
Dvp9_dx_iface.c115 VPxWorker *const worker = &ctx->frame_workers[i]; in decoder_destroy() local
117 (FrameWorkerData *)worker->data1; in decoder_destroy()
118 vpx_get_worker_interface()->end(worker); in decoder_destroy()
291 VPxWorker *const worker = &ctx->frame_workers[i]; in init_buffer_callbacks() local
292 FrameWorkerData *const frame_worker_data = (FrameWorkerData *)worker->data1; in init_buffer_callbacks()
348 VPxWorker *const worker = frame_worker_data->pbi->frame_worker_owner; in frame_worker_hook() local
351 vp9_frameworker_lock_stats(worker); in frame_worker_hook()
357 vp9_frameworker_signal_stats(worker); in frame_worker_hook()
358 vp9_frameworker_unlock_stats(worker); in frame_worker_hook()
407 VPxWorker *const worker = &ctx->frame_workers[i]; in init_decoder() local
[all …]
/external/libvpx/libvpx/test/
Dvp9_thread_test.cc38 void Run(VPxWorker* worker) { in Run() argument
41 vpx_get_worker_interface()->execute(worker); in Run()
43 vpx_get_worker_interface()->launch(worker); in Run()
205 void Init(VPxWorker *const worker) { memset(worker, 0, sizeof(*worker)); } in Init() argument
207 int Sync(VPxWorker *const worker) { return !worker->had_error; } in Sync() argument
209 void Execute(VPxWorker *const worker) { in Execute() argument
210 worker->had_error |= !worker->hook(worker->data1, worker->data2); in Execute()
213 void Launch(VPxWorker *const worker) { Execute(worker); } in Launch() argument
/external/v8/tools/profviz/
Dprofviz.js43 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/
Dworker.cpp145 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/
Dhttpserver.py655 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/
DThreadControllerWrapper.java38 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/
Dalpha.c383 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 …]
Danalysis.c394 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/
Darrow-operator.cpp60 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/
DUnixSocketTest.java46 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/
DShadowAsyncTask.java23 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/
Dupload_system_symbols.go178 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/
Dregress-crbug-147475.js34 function factory(worker) { argument
37 return 1 + worker(call_depth - 1);
Dregress-crbug-138887.js34 function factory(worker) { argument
37 return 1 + worker(call_depth - 1);
/external/compiler-rt/test/tsan/
Dfork_atexit.cc13 void *worker(void *unused) { in worker() function
19 pthread_create(&t, NULL, worker, NULL); in main()
Dpthread_atfork_deadlock.c11 void *worker(void *unused) { in worker() function
26 pthread_create(&t, NULL, worker, NULL); in main()
/external/chromium-trace/trace-viewer/tracing/third_party/gl-matrix/spec/gl-matrix/
Dworker-spec.js30 var worker = new Worker(URL.createObjectURL(blob));
31 worker.onmessage = function(e) {

123