HomeSort by relevance Sort by last modified time
    Searched defs:worker (Results 1 - 25 of 73) sorted by null

1 2 3

  /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 vp9_worker_execute(worker);
149 worker->status_ = OK;
150 } else if (worker->status_ == NOT_OK) { // finish the worke
    [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/cts/deviceTests/opengl/src/com/android/cts/opengl/primitive/
GLPrimitiveActivity.java 80 // Spawns a worker to run the benchmark.
81 Worker worker = new Worker(); local
82 worker.start();
122 private class Worker extends Thread implements WatchDog.TimeoutCallback {
  /cts/suite/cts/deviceTests/opengl/src/com/android/cts/opengl/reference/
GLGameActivity.java 76 // Spawns a worker.
77 Worker worker = new Worker(new Handler() { local
87 worker.start();
100 private class Worker extends Thread implements WatchDog.TimeoutCallback {
105 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();

Completed in 5411 milliseconds

1 2 3