Searched defs:worker (Results 1 - 25 of 33) sorted by relevance

12

/external/compiler-rt/test/tsan/
H A Dfork_atexit.cc13 void *worker(void *unused) { function
19 pthread_create(&t, NULL, worker, NULL);
H A Dpthread_atfork_deadlock.c11 void *worker(void *unused) { function
26 pthread_create(&t, NULL, worker, NULL);
/external/apache-xml/src/main/java/org/apache/xml/utils/
H A DThreadControllerWrapper.java38 public static void waitThread(Thread worker, Runnable task) argument
41 m_tpool.waitThread(worker, task);
79 * Wait until the task is completed on the worker
82 * NEEDSDOC @param worker
87 public void waitThread(Thread worker, Runnable task) argument
92 worker.join();
/external/drm_hwcomposer/
H A Dworker.cpp17 #define LOG_TAG "hwc-drm-worker"
19 #include "worker.h"
145 Worker *worker = (Worker *)arg; local
147 setpriority(PRIO_PROCESS, 0, worker->priority_);
150 int ret = worker->Lock();
152 ALOGE("Failed to lock %s thread %d", worker->name_.c_str(), ret);
156 bool exit = worker->exit_;
158 ret = worker->Unlock();
160 ALOGE("Failed to unlock %s thread %d", worker->name_.c_str(), ret);
166 worker
[all...]
H A Dgl_compositor.cpp87 GLWorker worker; member in struct:android::GLCompositor::priv_data
182 return priv_->worker.Init();
285 ret = priv_->worker.DoWork(&work);
H A Dglworker.cpp841 GLWorker *worker = (GLWorker *)arg; local
842 worker->WorkerRoutine();
/external/libunwind/tests/
H A DGtest-concurrent.c73 worker (void *arg UNUSED) function
94 if (pthread_create (th + i, &attr, worker, NULL))
/external/libvpx/libvpx/vp9/common/
H A Dvp9_thread.c10 // Multi-threaded worker
31 static void execute(VP9Worker *const worker); // Forward declaration.
34 VP9Worker *const worker = (VP9Worker*)ptr; local
37 pthread_mutex_lock(&worker->impl_->mutex_);
38 while (worker->status_ == OK) { // wait in idling mode
39 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_);
41 if (worker->status_ == WORK) {
42 execute(worker);
43 worker
55 change_state(VP9Worker *const worker, VP9WorkerStatus new_status) argument
81 init(VP9Worker *const worker) argument
86 sync(VP9Worker *const worker) argument
94 reset(VP9Worker *const worker) argument
132 execute(VP9Worker *const worker) argument
138 launch(VP9Worker *const worker) argument
146 end(VP9Worker *const worker) argument
[all...]
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/
H A DShadowAsyncTask.java23 private final BackgroundWorker worker; field in class:ShadowAsyncTask
27 worker = new BackgroundWorker();
28 future = new FutureTask<Result>(worker) {
80 worker.params = params;
/external/libvpx/libvpx/test/
H A Dvp9_thread_test.cc38 void Run(VP9Worker* worker) { argument
41 vp9_get_worker_interface()->execute(worker);
43 vp9_get_worker_interface()->launch(worker);
200 // Trivial serialized thread worker interface implementation.
201 // Note any worker that requires synchronization between other workers will
205 void Init(VP9Worker *const worker) { memset(worker, 0, sizeof(*worker)); } argument
206 int Reset(VP9Worker *const /*worker*/) { return 1; }
207 int Sync(VP9Worker *const worker) { retur argument
209 Execute(VP9Worker *const worker) argument
213 Launch(VP9Worker *const worker) argument
[all...]
/external/libvpx/libvpx/vp9/decoder/
H A Dvp9_decoder.c92 VP9Worker *const worker = &pbi->tile_workers[i]; local
93 vp9_get_worker_interface()->end(worker);
94 vpx_free(worker->data1);
95 vpx_free(worker->data2);
H A Dvp9_dthread.c182 VP9Worker *const worker = &pbi->tile_workers[i]; local
183 TileWorkerData *const tile_data = (TileWorkerData*)worker->data1;
186 worker->hook = (VP9WorkerHook)loop_filter_row_worker;
201 winterface->execute(worker);
203 winterface->launch(worker);
H A Dvp9_decodeframe.c977 // TODO(jzern): Allocate one less worker, as in the current code we only
982 VP9Worker *const worker = &pbi->tile_workers[i]; local
985 winterface->init(worker);
986 CHECK_MEM_ERROR(cm, worker->data1,
988 CHECK_MEM_ERROR(cm, worker->data2, vpx_malloc(sizeof(TileInfo)));
989 if (i < num_threads - 1 && !winterface->reset(worker)) {
1018 // waiting for a worker to complete.
1035 VP9Worker *const worker = &pbi->tile_workers[i]; local
1036 TileWorkerData *const tile_data = (TileWorkerData*)worker->data1;
1037 TileInfo *const tile = (TileInfo*)worker
1065 VP9Worker *const worker = &pbi->tile_workers[i - 1]; local
[all...]
/external/webp/src/utils/
H A Dthread.c10 // Multi-threaded worker
156 static void Execute(WebPWorker* const worker); // Forward declaration.
159 WebPWorker* const worker = (WebPWorker*)ptr; local
162 pthread_mutex_lock(&worker->impl_->mutex_);
163 while (worker->status_ == OK) { // wait in idling mode
164 pthread_cond_wait(&worker->impl_->condition_, &worker->impl_->mutex_);
166 if (worker->status_ == WORK) {
167 Execute(worker);
168 worker
180 ChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) argument
206 Init(WebPWorker* const worker) argument
211 Sync(WebPWorker* const worker) argument
219 Reset(WebPWorker* const worker) argument
257 Execute(WebPWorker* const worker) argument
263 Launch(WebPWorker* const worker) argument
271 End(WebPWorker* const worker) argument
[all...]
/external/libpcap/
H A Dpcap-canusb-linux.c84 pthread_t worker; member in struct:pcap_canusb
299 pthread_create(&this->worker, NULL, canusb_capture_thread, this);
323 pthread_join(canusb->worker, NULL);
/external/webp/src/enc/
H A Dalpha.c383 WebPWorker* const worker = &enc->alpha_worker_; local
384 WebPGetWorkerInterface()->Init(worker);
385 worker->data1 = enc;
386 worker->data2 = NULL;
387 worker->hook = (WebPWorkerHook)CompressAlphaJob;
394 WebPWorker* const worker = &enc->alpha_worker_; local
395 // Makes sure worker is good to go.
396 if (!WebPGetWorkerInterface()->Reset(worker)) {
399 WebPGetWorkerInterface()->Launch(worker);
411 WebPWorker* const worker local
421 WebPWorker* const worker = &enc->alpha_worker_; local
[all...]
H A Danalysis.c394 WebPWorker worker; member in struct:__anon16950
427 WebPGetWorkerInterface()->Init(&job->worker);
428 job->worker.data1 = job;
429 job->worker.data2 = &job->it;
430 job->worker.hook = (WebPWorkerHook)DoSegmentsJob;
469 // we don't need to call Reset() on main_job.worker, since we're calling
471 ok &= worker_interface->Reset(&side_job.worker);
474 worker_interface->Launch(&side_job.worker);
475 worker_interface->Execute(&main_job.worker);
476 ok &= worker_interface->Sync(&side_job.worker);
[all...]
/external/v8/tools/profviz/
H A 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
284 var worker; variable
[all...]
/external/valgrind/drd/tests/
H A Dtsan_thread_wrappers_pthread.h346 MyThread(worker_t worker, void *arg = NULL, const char *name = NULL) argument
347 :w_(worker), arg_(arg), name_(name) {}
348 MyThread(void (*worker)(void), void *arg = NULL, const char *name = NULL) argument
349 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {}
350 MyThread(void (*worker)(void *), void *arg = NULL, const char *name = NULL)
351 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {}
/external/webp/src/dec/
H A Dframe.c357 WebPWorker* const worker = &dec->worker_; local
359 ok &= WebPGetWorkerInterface()->Sync(worker);
360 assert(worker->status_ == OK);
380 WebPGetWorkerInterface()->Launch(worker);
486 // Initialize multi/single-thread worker
490 WebPWorker* const worker = &dec->worker_; local
491 if (!WebPGetWorkerInterface()->Reset(worker)) {
495 worker->data1 = dec;
496 worker->data2 = (void*)&dec->thread_ctx_.io_;
497 worker
[all...]
/external/freetype/src/smooth/
H A Dftgrays.c295 #define RAS_ARG gray_PWorker worker
296 #define RAS_ARG_ gray_PWorker worker,
298 #define RAS_VAR worker
299 #define RAS_VAR_ worker,
479 #define ras (*worker)
1167 gray_PWorker worker )
1182 worker->x = x;
1183 worker->y = y;
1190 gray_PWorker worker )
1200 gray_PWorker worker )
1943 gray_TWorker worker[1]; local
[all...]
/external/pdfium/third_party/freetype/src/smooth/
H A Dftgrays.c275 #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 in struct:gray_TRaster_
1151 gray_PWorker worker )
1166 worker->x = x;
1167 worker->y = y;
1174 gray_PWorker worker )
1923 gray_PWorker worker; local
2079 gray_PWorker worker = (gray_PWorker)pool_base; local
[all...]
/external/freetype/src/raster/
H A Dftraster.c412 #define RAS_ARGS black_PWorker worker,
413 #define RAS_ARG black_PWorker worker
415 #define RAS_VARS worker,
416 #define RAS_VAR worker
418 #define FT_UNUSED_RASTER FT_UNUSED( worker )
551 #define ras (*worker)
3139 black_TWorker worker[1]; local
3181 worker->buff = buffer;
3182 worker->sizeBuff = (&buffer)[1]; /* Points to right after buffer. */
/external/iproute2/misc/
H A Dss.c1293 int (*worker)(char*, const struct filter *, int),
1310 if (worker(line, f, fam) < 0)
1292 generic_record_read(FILE *fp, int (*worker)(char*, const struct filter *, int), const struct filter *f, int fam) argument
/external/pdfium/third_party/freetype/src/raster/
H A Dftraster.c413 #define RAS_ARGS black_PWorker worker,
414 #define RAS_ARG black_PWorker worker
416 #define RAS_VARS worker,
417 #define RAS_VAR worker
419 #define FT_UNUSED_RASTER FT_UNUSED( worker )
568 black_PWorker worker; member in struct:black_TRaster_
581 #define ras (*worker)
3527 black_PWorker worker = (black_PWorker)pool_base; local
3530 raster->buffer = pool_base + ( ( sizeof ( *worker ) + 7 ) & ~7 );
3533 raster->worker
3580 black_PWorker worker; local
[all...]

Completed in 3070 milliseconds

12