| /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/compiler-rt/test/tsan/ |
| fork_atexit.cc | 13 void *worker(void *unused) { function
19 pthread_create(&t, NULL, worker, NULL);
|
| pthread_atfork_deadlock.c | 13 void *worker(void *unused) { function
27 pthread_create(&t, NULL, worker, NULL);
|
| /external/chromium_org/third_party/WebKit/Source/bindings/v8/custom/ |
| V8ServiceWorkerCustom.cpp | 21 ServiceWorker* worker = V8ServiceWorker::toNative(info.Holder()); local
34 worker->postMessage(message.release(), &ports, exceptionState);
|
| V8WorkerCustom.cpp | 38 #include "core/workers/Worker.h"
46 ExceptionState exceptionState(ExceptionState::ExecutionContext, "postMessage", "Worker", info.Holder(), info.GetIsolate());
47 Worker* worker = V8Worker::toNative(info.Holder()); local
60 worker->postMessage(message.release(), &ports, exceptionState);
|
| /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 | 64 RefPtrWillBeRawPtr<SharedWorker> worker = adoptRefWillBeRefCountedGarbageCollected(new SharedWorker(context)); local
67 worker->m_port = channel->port1();
71 worker->suspendIfNeeded();
80 KURL scriptURL = worker->resolveURL(url, exceptionState);
85 document->frame()->loader().client()->sharedWorkerRepositoryClient()->connect(worker.get(), remotePort.release(), scriptURL, name, exceptionState);
87 return worker.release();
|
| Worker.cpp | 29 #include "core/workers/Worker.h"
46 inline Worker::Worker(ExecutionContext* context)
53 PassRefPtrWillBeRawPtr<Worker> Worker::create(ExecutionContext* context, const String& url, ExceptionState& exceptionState)
65 RefPtrWillBeRawPtr<Worker> worker = adoptRefWillBeRefCountedGarbageCollected(new Worker(context)); local
67 worker->suspendIfNeeded();
69 KURL scriptURL = worker->resolveURL(url, exceptionState)
[all...] |
| /external/chromium_org/third_party/libvpx/source/libvpx/vp9/decoder/ |
| vp9_thread.c | 10 // Multi-threaded worker
30 VP9Worker* const worker = (VP9Worker*)ptr; local
33 pthread_mutex_lock(&worker->mutex_);
34 while (worker->status_ == OK) { // wait in idling mode
35 pthread_cond_wait(&worker->condition_, &worker->mutex_);
37 if (worker->status_ == WORK) {
38 vp9_worker_execute(worker);
39 worker->status_ = OK;
40 } else if (worker->status_ == NOT_OK) { // finish the worke
[all...] |
| vp9_decoder.c | 94 VP9Worker *const worker = &pbi->tile_workers[i]; local
95 vp9_worker_end(worker);
96 vpx_free(worker->data1);
97 vpx_free(worker->data2);
|
| /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/libvpx/libvpx/vp9/decoder/ |
| vp9_thread.c | 10 // Multi-threaded worker
30 VP9Worker* const worker = (VP9Worker*)ptr; local
33 pthread_mutex_lock(&worker->mutex_);
34 while (worker->status_ == OK) { // wait in idling mode
35 pthread_cond_wait(&worker->condition_, &worker->mutex_);
37 if (worker->status_ == WORK) {
38 vp9_worker_execute(worker);
39 worker->status_ = OK;
40 } else if (worker->status_ == NOT_OK) { // finish the worke
[all...] |
| /hardware/intel/common/omx-components/videocodec/libvpx_internal/libvpx/vp9/decoder/ |
| vp9_thread.c | 10 // Multi-threaded worker
30 VP9Worker* const worker = (VP9Worker*)ptr; local
33 pthread_mutex_lock(&worker->mutex_);
34 while (worker->status_ == OK) { // wait in idling mode
35 pthread_cond_wait(&worker->condition_, &worker->mutex_);
37 if (worker->status_ == WORK) {
38 vp9_worker_execute(worker);
39 worker->status_ = OK;
40 } else if (worker->status_ == NOT_OK) { // finish the worke
[all...] |
| /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_org/chrome/browser/sync/glue/ |
| browser_thread_model_worker_unittest.cc | 35 BrowserThreadModelWorker* worker() { return worker_.get(); } function in class:browser_sync::__anon9314::SyncBrowserThreadModelWorkerTest
53 worker()->DoWorkAndWaitUntilDone(c);
|
| /external/chromium_org/content/browser/service_worker/ |
| embedded_worker_instance_unittest.cc | 58 scoped_ptr<EmbeddedWorkerInstance> worker = local
60 EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status());
62 const int embedded_worker_id = worker->embedded_worker_id();
65 const GURL url("http://example.com/worker.js");
67 // Simulate adding one process to the worker.
73 worker->Start(
81 EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status());
84 // Worker started message should be notified (by EmbeddedWorkerTestHelper).
85 EXPECT_EQ(EmbeddedWorkerInstance::RUNNING, worker->status());
86 EXPECT_EQ(kRenderProcessId, worker->process_id())
104 scoped_ptr<EmbeddedWorkerInstance> worker = local
134 scoped_ptr<EmbeddedWorkerInstance> worker = local
[all...] |
| embedded_worker_test_helper.cc | 38 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
39 ASSERT_TRUE(worker);
41 worker->AddProcessReference(process_id);
81 // By default just notify the sender that the worker is started.
86 // By default just notify the sender that the worker is stopped.
140 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
141 ASSERT_TRUE(worker != NULL);
143 worker->process_id(),
150 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
151 if (worker != NULL
163 EmbeddedWorkerInstance* worker = local
178 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
191 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
[all...] |
| /external/chromium_org/content/renderer/service_worker/ |
| embedded_worker_dispatcher.cc | 31 WorkerWrapper(blink::WebEmbeddedWorker* worker, int devtools_agent_route_id)
32 : worker_(worker),
34 new EmbeddedWorkerDevToolsAgent(worker, devtools_agent_route_id)) {}
37 blink::WebEmbeddedWorker* worker() { return worker_.get(); } function in class:content::EmbeddedWorkerDispatcher::WorkerWrapper
89 wrapper->worker()->startWorkerContext(start_data);
96 LOG(WARNING) << "Got OnStopWorker for nonexistent worker";
101 // a delayed task to forcibly abort the worker context if we find it
103 wrapper->worker()->terminateWorkerContext();
|
| /external/libunwind/tests/ |
| Gtest-concurrent.c | 73 worker (void *arg UNUSED) function
94 if (pthread_create (th + i, &attr, worker, NULL))
|
| /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 | 275 // The worker creates tasks with references to itself and puts them into
284 scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker = local
290 worker->StartCheckIsDefault();
|
| /external/chromium_org/third_party/WebKit/Source/modules/serviceworkers/ |
| ServiceWorker.cpp | 141 PassRefPtr<ServiceWorker> ServiceWorker::from(ExecutionContext* executionContext, WebType* worker)
143 if (!worker)
146 blink::WebServiceWorkerProxy* proxy = worker->proxy();
153 return create(executionContext, adoptPtr(worker));
156 PassRefPtr<ServiceWorker> ServiceWorker::from(ScriptPromiseResolverWithContext* resolver, WebType* worker)
158 RefPtr<ServiceWorker> serviceWorker = ServiceWorker::from(resolver->scriptState()->executionContext(), worker);
224 RefPtr<ServiceWorker> worker = adoptRef(new ServiceWorker(executionContext, outerWorker)); local
225 worker->suspendIfNeeded();
226 return worker.release();
229 ServiceWorker::ServiceWorker(ExecutionContext* executionContext, PassOwnPtr<blink::WebServiceWorker> worker)
[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 {
|
