/external/compiler-rt/test/tsan/ |
H A D | fork_atexit.cc | 13 void *worker(void *unused) { function 19 pthread_create(&t, NULL, worker, NULL);
|
H A D | pthread_atfork_deadlock.c | 11 void *worker(void *unused) { function 26 pthread_create(&t, NULL, worker, NULL);
|
/external/apache-xml/src/main/java/org/apache/xml/utils/ |
H A D | ThreadControllerWrapper.java | 38 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 D | worker.cpp | 17 #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 D | gl_compositor.cpp | 87 GLWorker worker; member in struct:android::GLCompositor::priv_data 182 return priv_->worker.Init(); 285 ret = priv_->worker.DoWork(&work);
|
H A D | glworker.cpp | 841 GLWorker *worker = (GLWorker *)arg; local 842 worker->WorkerRoutine();
|
/external/libunwind/tests/ |
H A D | Gtest-concurrent.c | 73 worker (void *arg UNUSED) function 94 if (pthread_create (th + i, &attr, worker, NULL))
|
/external/libvpx/libvpx/vp9/common/ |
H A D | vp9_thread.c | 10 // 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 D | ShadowAsyncTask.java | 23 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 D | vp9_thread_test.cc | 38 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 D | vp9_decoder.c | 92 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 D | vp9_dthread.c | 182 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 D | vp9_decodeframe.c | 977 // 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 D | thread.c | 10 // 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 D | pcap-canusb-linux.c | 84 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 D | alpha.c | 383 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 D | analysis.c | 394 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 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 284 var worker; variable [all...] |
/external/valgrind/drd/tests/ |
H A D | tsan_thread_wrappers_pthread.h | 346 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 D | frame.c | 357 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 D | ftgrays.c | 295 #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 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 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 D | ftraster.c | 412 #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 D | ss.c | 1293 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 D | ftraster.c | 413 #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...] |