| /external/chromium_org/third_party/WebKit/Source/modules/serviceworkers/ |
| ServiceWorker.cpp | 37 ServiceWorker::ServiceWorker(PassOwnPtr<blink::WebServiceWorker> worker)
38 : m_outerWorker(worker)
|
| ServiceWorker.h | 48 static PassRefPtr<ServiceWorker> create(PassOwnPtr<blink::WebServiceWorker> worker)
50 return adoptRef(new ServiceWorker(worker));
55 static PassRefPtr<ServiceWorker> from(WebType* worker)
57 return create(adoptPtr(worker));
|
| /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/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...] |
| thread.h | 10 // Multi-threaded worker
45 // State of the worker thread object
52 // Function to be called by the worker thread. Takes two opaque pointers as
56 // Synchronize object used to launch job in the worker thread
71 void WebPWorkerInit(WebPWorker* const worker);
74 int WebPWorkerReset(WebPWorker* const worker);
75 // Makes sure the previous work is finished. Returns true if worker->had_error
77 int WebPWorkerSync(WebPWorker* const worker);
81 void WebPWorkerLaunch(WebPWorker* const worker);
84 void WebPWorkerEnd(WebPWorker* const worker);
[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...] |
| thread.h | 10 // Multi-threaded worker
45 // State of the worker thread object
52 // Function to be called by the worker thread. Takes two opaque pointers as
56 // Synchronize object used to launch job in the worker thread
71 void WebPWorkerInit(WebPWorker* const worker);
74 int WebPWorkerReset(WebPWorker* const worker);
75 // Makes sure the previous work is finished. Returns true if worker->had_error
77 int WebPWorkerSync(WebPWorker* const worker);
81 void WebPWorkerLaunch(WebPWorker* const worker);
84 void WebPWorkerEnd(WebPWorker* const worker);
[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...] |
| vp9_thread.h | 10 // Multi-threaded worker
46 // State of the worker thread object
53 // Function to be called by the worker thread. Takes two opaque pointers as
57 // Synchronize object used to launch job in the worker thread
72 void vp9_worker_init(VP9Worker* const worker);
75 int vp9_worker_reset(VP9Worker* const worker);
76 // Makes sure the previous work is finished. Returns true if worker->had_error
78 int vp9_worker_sync(VP9Worker* const worker);
82 void vp9_worker_launch(VP9Worker* const worker);
87 void vp9_worker_execute(VP9Worker* const worker);
[all...] |
| /external/chromium_org/content/browser/service_worker/ |
| embedded_worker_instance_unittest.cc | 69 scoped_ptr<EmbeddedWorkerInstance> worker = local
71 EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status());
77 const GURL url("http://example.com/worker.js");
80 EXPECT_FALSE(worker->Start(service_worker_version_id, url));
81 EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status());
83 // Simulate adding one process to the worker.
84 worker->AddProcessReference(process_id);
88 EXPECT_TRUE(worker->Start(service_worker_version_id, url));
89 EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status());
91 // Simulate an upcall from embedded worker to notify that it's started
113 scoped_ptr<EmbeddedWorkerInstance> worker = local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/modules/filesystem/ |
| WorkerGlobalScopeFileSystem.cpp | 48 void WorkerGlobalScopeFileSystem::webkitRequestFileSystem(WorkerGlobalScope* worker, int type, long long size, PassOwnPtr<FileSystemCallback> successCallback, PassOwnPtr<ErrorCallback> errorCallback)
50 ExecutionContext* secureContext = worker->executionContext();
52 DOMFileSystem::scheduleCallback(worker, errorCallback, FileError::create(FileError::SECURITY_ERR));
58 DOMFileSystem::scheduleCallback(worker, errorCallback, FileError::create(FileError::INVALID_MODIFICATION_ERR));
62 LocalFileSystem::from(worker)->requestFileSystem(worker, fileSystemType, size, FileSystemCallbacks::create(successCallback, errorCallback, worker, fileSystemType));
65 PassRefPtr<DOMFileSystemSync> WorkerGlobalScopeFileSystem::webkitRequestFileSystemSync(WorkerGlobalScope* worker, int type, long long size, ExceptionState& exceptionState)
67 ExecutionContext* secureContext = worker->executionContext();
80 OwnPtr<AsyncFileSystemCallbacks> callbacks = FileSystemCallbacks::create(helper.successCallback(), helper.errorCallback(), worker, fileSystemType)
[all...] |
| /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...] |
| worker_common.js | 1 // Track the number of clients for this worker - tests can use this to ensure
6 // This is a shared worker - mimic dedicated worker APIs
|
| /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/third_party/WebKit/Source/web/ |
| WorkerGlobalScopeProxyProviderImpl.cpp | 42 #include "core/workers/Worker.h"
53 WebCore::WorkerGlobalScopeProxy* WorkerGlobalScopeProxyProviderImpl::createWorkerGlobalScopeProxy(Worker* worker)
55 if (worker->executionContext()->isDocument()) {
56 Document* document = toDocument(worker->executionContext());
62 return new WorkerMessagingProxy(worker, workerClients.release());
|
| SharedWorkerRepositoryClientImpl.cpp | 60 // Callback class that keeps the SharedWorker and WebSharedWorker objects alive while loads are potentially happening, and also translates load errors into error events on the worker.
63 SharedWorkerScriptLoader(PassRefPtr<SharedWorker> worker, const KURL& url, const String& name, PassOwnPtr<WebMessagePortChannel> channel, PassOwnPtr<WebSharedWorkerConnector> webWorkerConnector)
64 : m_worker(worker)
106 // If the shared worker is not yet running, load the script resource for it, otherwise just send it a connect event.
110 // Keep the worker + JS wrapper alive until the resource load is complete in case we need to dispatch an error event.
131 // Pass the script off to the worker, then send a connect event.
155 void SharedWorkerRepositoryClientImpl::connect(PassRefPtr<SharedWorker> worker, PassOwnPtr<WebMessagePortChannel> port, const KURL& url, const String& name, ExceptionState& exceptionState)
160 ASSERT(worker->executionContext()->isDocument());
161 Document* document = toDocument(worker->executionContext());
164 // Existing worker does not match this url, so return an error back to the caller
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/ |
| print-test-ordering | 39 parser.description = "Prints out lists of tests run on each worker as per the stats.json file."
54 worker = "worker/" + str(data["results"][0])
55 if worker not in stats_by_worker:
56 stats_by_worker[worker] = []
58 stats_by_worker[worker].append({
63 for worker in sorted(stats_by_worker.keys()):
64 print worker + ':'
65 for test in sorted(stats_by_worker[worker], key=lambda test:test["number"]):
|
| /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/clang/test/SemaCXX/ |
| arrow-operator.cpp | 53 class Worker {
60 wrapped_ptr<Worker> worker(new Worker);
61 worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean to use '->' instead of '.'?}}
62 worker.DoSamething(); // expected-error {{no member named 'DoSamething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'}}
63 worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean 'Check'?}
[all...] |
| /external/chromium_org/third_party/WebKit/Source/core/workers/ |
| Worker.cpp | 29 #include "core/workers/Worker.h"
46 inline Worker::Worker(ExecutionContext* context)
53 PassRefPtr<Worker> Worker::create(ExecutionContext* context, const String& url, ExceptionState& exceptionState)
62 RefPtr<Worker> worker = adoptRef(new Worker(context)); local
64 worker->suspendIfNeeded();
66 KURL scriptURL = worker->resolveURL(url, exceptionState)
[all...] |
| SharedWorker.cpp | 62 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); local
65 worker->m_port = channel->port1();
69 worker->suspendIfNeeded();
78 KURL scriptURL = worker->resolveURL(url, exceptionState);
83 document->page()->sharedWorkerRepositoryClient()->connect(worker.get(), remotePort.release(), scriptURL, name, exceptionState);
85 return worker.release();
|
| /external/chromium_org/content/renderer/service_worker/ |
| embedded_worker_dispatcher.cc | 29 explicit WorkerWrapper(blink::WebEmbeddedWorker* worker) : worker_(worker) {}
32 blink::WebEmbeddedWorker* worker() { return worker_.get(); } function in class:content::EmbeddedWorkerDispatcher::WorkerWrapper
77 wrapper->worker()->startWorkerContext(start_data);
84 LOG(WARNING) << "Got OnTerminateWorker for nonexistent worker";
89 // a delayed task to forcibly abort the worker context if we find it
91 wrapper->worker()->terminateWorkerContext();
|
| /external/chromium/chrome/browser/printing/ |
| print_job_unittest.cc | 43 // We're screwing up here since we're calling worker from the main thread.
45 TestPrintJobWorker* worker(new TestPrintJobWorker(new_owner));
46 EXPECT_TRUE(worker->Start());
47 worker->printing_context()->UseDefaultSettings();
48 settings_ = worker->printing_context()->settings();
49 return worker;
|
| /external/chromium/chrome/browser/notifications/ |
| notification_object_proxy.cc | 14 int notification_id, bool worker)
18 worker_(worker) {
47 // TODO(johnnyg): http://crbug.com/23065 Worker support coming soon.
|
| /external/chromium_org/net/data/websocket/ |
| websocket_worker_simple.js | 6 // This is a shared worker - mimic dedicated worker APIs
19 // This test is compatible with shared-worker-simple.html layout test.
44 postMessage("FAIL: worker: Unexpected exception: " + e);
|
