/external/chromium_org/content/test/data/workers/ |
worker_utils.js | 4 // Create either a dedicated or shared worker, depending on flags 7 // Make a shared worker that looks like a worker 8 var worker = new SharedWorker(worker_url, "name" + ++shared_worker_count); 9 worker.port.onmessage = function(evt) { 10 worker.onmessage(evt); 12 worker.postMessage = function(msg, port) { 13 worker.port.postMessage(msg, port); 15 return worker; 17 return new Worker(worker_url) [all...] |
/external/chromium/chrome/browser/sync/engine/ |
model_changing_syncer_command.cc | 21 ModelSafeWorker* worker = session->workers()[i]; local 22 ModelSafeGroup group = worker->GetModelSafeGroup(); 28 worker->DoWorkAndWaitUntilDone(c.get());
|
/external/chromium_org/third_party/WebKit/Source/bindings/v8/custom/ |
V8WorkerCustom.cpp | 39 #include "core/workers/Worker.h" 47 Worker* worker = V8Worker::toNative(args.Holder()); local 64 worker->postMessage(message.release(), &ports, es);
|
/external/chromium_org/sync/engine/ |
model_changing_syncer_command.cc | 23 ModelSafeWorker* worker = session->context()->workers()[i].get(); local 24 ModelSafeGroup group = worker->GetModelSafeGroup(); 27 DVLOG(2) << "Skipping worker for group " 41 SyncerError this_worker_result = worker->DoWorkAndWaitUntilDone(c);
|
/sdk/hierarchyviewer/src/com/android/hierarchyviewer/ui/action/ |
BackgroundAction.java | 23 protected void executeBackgroundTask(SwingWorker<?, ?> worker) { 24 if (worker != null) { 25 worker.execute();
|
/external/chromium_org/third_party/WebKit/Source/core/workers/ |
SharedWorker.cpp | 59 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); local 62 worker->m_port = channel->port1(); 66 worker->suspendIfNeeded(); 68 KURL scriptURL = worker->resolveURL(url, es); 80 SharedWorkerRepository::connect(worker.get(), remotePort.release(), scriptURL, name, es); 82 return worker.release();
|
Worker.cpp | 29 #include "core/workers/Worker.h" 49 inline Worker::Worker(ScriptExecutionContext* context) 56 PassRefPtr<Worker> Worker::create(ScriptExecutionContext* context, const String& url, ExceptionState& es) 61 RefPtr<Worker> worker = adoptRef(new Worker(context)); local 63 worker->suspendIfNeeded(); 65 KURL scriptURL = worker->resolveURL(url, es) [all...] |
/external/chromium_org/third_party/sqlite/src/test/ |
threadtest2.c | 72 ** This is the worker thread 74 void *worker(void *workerArg){ function 79 fprintf(stderr, "Starting worker %d\n", id); 91 fprintf(stderr, "Worker %d finished\n", id); 121 pthread_create(&aThread[i], 0, worker, (void*)i);
|
/external/apache-xml/src/main/java/org/apache/xml/utils/ |
ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) 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) 92 worker.join();
|
/external/chromium/base/threading/ |
worker_pool_posix.cc | 130 // We have enough worker threads. 136 WorkerThread* worker = local 138 PlatformThread::CreateNonJoinable(kWorkerThreadStackSize, worker);
|
/external/chromium/chrome/browser/sync/glue/ |
database_model_worker_unittest.cc | 30 DatabaseModelWorker* worker() { return worker_.get(); } function in class:__anon4884::DatabaseModelWorkerTest 43 worker()->DoWorkAndWaitUntilDone(c.get());
|
/external/chromium_org/chrome/browser/sync/glue/ |
browser_thread_model_worker_unittest.cc | 35 BrowserThreadModelWorker* worker() { return worker_.get(); } function in class:browser_sync::__anon8204::SyncBrowserThreadModelWorkerTest 53 worker()->DoWorkAndWaitUntilDone(c);
|
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
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/chromium_org/base/threading/ |
worker_pool_posix.cc | 163 // We have enough worker threads. 169 WorkerThread* worker = local 171 PlatformThread::CreateNonJoinable(kWorkerThreadStackSize, worker);
|
/external/chromium_org/chrome/browser/external_protocol/ |
external_protocol_handler.cc | 266 // The worker creates tasks with references to itself and puts them into 275 scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker = local 281 worker->StartCheckIsDefault();
|
/external/chromium_org/third_party/libjingle/source/talk/base/ |
messagequeue_unittest.cc | 49 // We have to do this on a worker thread, or else the TryEnter will 51 Thread worker; local 52 worker.Start(); 53 return worker.Invoke<bool>(
|
/external/chromium_org/third_party/libwebp/utils/ |
thread.c | 10 // Multi-threaded worker 137 WebPWorker* const worker = (WebPWorker*)ptr; local 140 pthread_mutex_lock(&worker->mutex_); 141 while (worker->status_ == OK) { // wait in idling mode 142 pthread_cond_wait(&worker->condition_, &worker->mutex_); 144 if (worker->status_ == WORK) { 145 if (worker->hook) { 146 worker->had_error |= !worker->hook(worker->data1, worker->data2) [all...] |
/external/libvpx/libvpx/vp9/decoder/ |
vp9_thread.c | 10 // Multi-threaded worker 140 VP9Worker* const worker = (VP9Worker*)ptr; local 143 pthread_mutex_lock(&worker->mutex_); 144 while (worker->status_ == OK) { // wait in idling mode 145 pthread_cond_wait(&worker->condition_, &worker->mutex_); 147 if (worker->status_ == WORK) { 148 if (worker->hook) { 149 worker->had_error |= !worker->hook(worker->data1, worker->data2) [all...] |
/external/webp/src/utils/ |
thread.c | 10 // Multi-threaded worker 137 WebPWorker* const worker = (WebPWorker*)ptr; local 140 pthread_mutex_lock(&worker->mutex_); 141 while (worker->status_ == OK) { // wait in idling mode 142 pthread_cond_wait(&worker->condition_, &worker->mutex_); 144 if (worker->status_ == WORK) { 145 if (worker->hook) { 146 worker->had_error |= !worker->hook(worker->data1, worker->data2) [all...] |
/packages/apps/Browser/src/com/android/browser/ |
OpenDownloadReceiver.java | 56 Runnable worker = new Runnable() { local 63 sAsyncHandler.post(worker);
|
/cts/suite/pts/deviceTests/opengl/src/com/android/pts/opengl/primitive/ |
GLPrimitiveActivity.java | 83 // Spawns a worker to run the benchmark. 84 Worker worker = new Worker(); local 85 worker.start(); 125 private class Worker extends Thread implements WatchDog.TimeoutCallback {
|
/cts/suite/pts/deviceTests/opengl/src/com/android/pts/opengl/reference/ |
GLGameActivity.java | 78 // Spawns a worker. 79 Worker worker = new Worker(new Handler() { local 89 worker.start(); 102 private class Worker extends Thread implements WatchDog.TimeoutCallback { 107 public Worker(Handler handler) {
|
/external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
UnixSocketTest.java | 46 Socket worker = pingServer.accept(); local 52 InputStream in = worker.getInputStream(); 55 OutputStream out = worker.getOutputStream(); 57 worker.close();
|
/libcore/luni/src/test/java/libcore/java/net/ |
OldUnixSocketTest.java | 42 Socket worker = pingServer.accept(); local 48 InputStream in = worker.getInputStream(); 51 OutputStream out = worker.getOutputStream(); 53 worker.close();
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
PipedInputStreamTest.java | 355 static class Worker extends Thread { 358 Worker(PipedOutputStream pos) { 376 Thread worker = new Worker(out); local 377 worker.start(); 380 worker.join();
|