Searched refs:worker (Results 1 - 25 of 144) sorted by relevance

123456

/external/libvpx/libvpx/vp9/decoder/
H A Dvp9_thread.c10 // 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
51 change_state(VP9Worker* const worker, VP9WorkerStatus new_status) argument
73 vp9_worker_init(VP9Worker* const worker) argument
78 vp9_worker_sync(VP9Worker* const worker) argument
86 vp9_worker_reset(VP9Worker* const worker) argument
109 vp9_worker_execute(VP9Worker* const worker) argument
115 vp9_worker_launch(VP9Worker* const worker) argument
123 vp9_worker_end(VP9Worker* const worker) argument
[all...]
/external/chromium_org/third_party/libvpx/source/libvpx/vp9/common/
H A Dvp9_thread.c10 // 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/chromium_org/third_party/libwebp/utils/
H A Dthread.c10 // 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...]
H A Dthread.h10 // Multi-threaded worker
27 // State of the worker thread object
34 // Function to be called by the worker thread. Takes two opaque pointers as
38 // Platform-dependent implementation details for the worker.
41 // Synchronization object used to launch job in the worker thread
51 // The interface for all thread-worker related functions. All these functions
55 void (*Init)(WebPWorker* const worker);
58 int (*Reset)(WebPWorker* const worker);
59 // Makes sure the previous work is finished. Returns true if worker->had_error
61 int (*Sync)(WebPWorker* const worker);
[all...]
/external/webp/src/utils/
H A Dthread.c10 // 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...]
H A Dthread.h10 // Multi-threaded worker
27 // State of the worker thread object
34 // Function to be called by the worker thread. Takes two opaque pointers as
38 // Platform-dependent implementation details for the worker.
41 // Synchronization object used to launch job in the worker thread
51 // The interface for all thread-worker related functions. All these functions
55 void (*Init)(WebPWorker* const worker);
58 int (*Reset)(WebPWorker* const worker);
59 // Makes sure the previous work is finished. Returns true if worker->had_error
61 int (*Sync)(WebPWorker* const worker);
[all...]
/external/chromium_org/content/test/data/workers/
H A Dworker_utils.js4 // 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;
/external/chromium_org/third_party/WebKit/Source/modules/filesystem/
H A DWorkerGlobalScopeFileSystem.cpp48 void WorkerGlobalScopeFileSystem::webkitRequestFileSystem(WorkerGlobalScope& worker, int type, long long size, FileSystemCallback* successCallback, ErrorCallback* errorCallback) argument
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 DOMFileSystemSync* WorkerGlobalScopeFileSystem::webkitRequestFileSystemSync(WorkerGlobalScope& worker, int type, long long size, ExceptionState& exceptionState) argument
67 ExecutionContext* secureContext = worker.executionContext();
80 OwnPtr<AsyncFileSystemCallbacks> callbacks = FileSystemCallbacks::create(helper->successCallback(), helper->errorCallback(), &worker, fileSystemTyp
87 webkitResolveLocalFileSystemURL(WorkerGlobalScope& worker, const String& url, EntryCallback* successCallback, ErrorCallback* errorCallback) argument
104 webkitResolveLocalFileSystemSyncURL(WorkerGlobalScope& worker, const String& url, ExceptionState& exceptionState) argument
[all...]
/external/apache-xml/src/main/java/org/apache/xml/utils/
H A DThreadControllerWrapper.java38 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/chromium_org/sync/test/engine/
H A Dinjectable_sync_context_proxy.cc13 ModelTypeSyncWorker* worker)
14 : is_worker_connected_(false), worker_(worker) {
31 scoped_ptr<ModelTypeSyncWorker> worker(worker_);
33 type_sync_proxy->OnConnect(worker.Pass());
37 // This should delete the worker, but we don't own it.
12 InjectableSyncContextProxy( ModelTypeSyncWorker* worker) argument
/external/chromium_org/third_party/WebKit/Source/web/
H A DWorkerGlobalScopeProxyProviderImpl.cpp52 WorkerGlobalScopeProxy* WorkerGlobalScopeProxyProviderImpl::createWorkerGlobalScopeProxy(Worker* worker) argument
54 if (worker->executionContext()->isDocument()) {
55 Document* document = toDocument(worker->executionContext());
61 return new WorkerMessagingProxy(worker, workerClients.release());
H A DSharedWorkerRepositoryClientImpl.cpp60 SharedWorkerConnector(PassRefPtrWillBeRawPtr<SharedWorker> worker, const KURL& url, const String& name, PassOwnPtr<WebMessagePortChannel> channel, PassOwnPtr<WebSharedWorkerConnector> webWorkerConnector) argument
61 : m_worker(worker)
112 void SharedWorkerRepositoryClientImpl::connect(PassRefPtrWillBeRawPtr<SharedWorker> worker, PassOwnPtr<WebMessagePortChannel> port, const KURL& url, const String& name, ExceptionState& exceptionState) argument
117 ASSERT(worker->executionContext()->isDocument());
118 Document* document = toDocument(worker->executionContext());
119 OwnPtr<WebSharedWorkerConnector> webWorkerConnector = adoptPtr(m_client->createSharedWorkerConnector(url, name, getId(document), worker->executionContext()->contentSecurityPolicy()->deprecatedHeader(), static_cast<WebContentSecurityPolicyType>(worker->executionContext()->contentSecurityPolicy()->deprecatedHeaderType())));
121 // Existing worker does not match this url, so return an error back to the caller.
126 // The connector object manages its own lifecycle (and the lifecycles of the two worker objects).
128 SharedWorkerConnector* connector = new SharedWorkerConnector(worker, ur
[all...]
/external/chromium_org/v8/test/mjsunit/regress/
H A Dregress-crbug-138887.js34 function factory(worker) {
37 return 1 + worker(call_depth - 1);
H A Dregress-crbug-147475.js34 function factory(worker) {
37 return 1 + worker(call_depth - 1);
/external/compiler-rt/test/tsan/
H A Dpthread_atfork_deadlock.c13 void *worker(void *unused) { function
27 pthread_create(&t, NULL, worker, NULL);
H A Dfork_atexit.cc13 void *worker(void *unused) { function
19 pthread_create(&t, NULL, worker, NULL);
/external/chromium_org/content/browser/service_worker/
H A Dembedded_worker_instance_unittest.cc59 scoped_ptr<EmbeddedWorkerInstance> worker = local
61 EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status());
65 const GURL url("http://example.com/worker.js");
73 worker->Start(
81 EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status());
85 EXPECT_EQ(EmbeddedWorkerInstance::RUNNING, worker->status());
86 EXPECT_EQ(kRenderProcessId, worker->process_id());
88 // Stop the worker.
89 EXPECT_EQ(SERVICE_WORKER_OK, worker->Stop());
90 EXPECT_EQ(EmbeddedWorkerInstance::STOPPING, worker
104 scoped_ptr<EmbeddedWorkerInstance> worker = local
[all...]
H A Dembedded_worker_test_helper.cc104 // By default just notify the sender that the worker is stopped.
156 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
157 ASSERT_TRUE(worker != NULL);
158 registry()->OnPausedAfterDownload(worker->process_id(), embedded_worker_id);
163 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
164 ASSERT_TRUE(worker != NULL);
165 registry()->OnWorkerReadyForInspection(worker->process_id(),
171 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
172 ASSERT_TRUE(worker != NULL);
174 worker
179 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
188 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
201 EmbeddedWorkerInstance* worker = local
218 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
228 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
241 EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); local
[all...]
/external/chromium_org/third_party/WebKit/Tools/Scripts/
H A Dprint-test-ordering39 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/clang/test/SemaCXX/
H A Darrow-operator.cpp60 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'?}}
/external/chromium_org/third_party/WebKit/Source/core/workers/
H A DSharedWorker.cpp64 RefPtrWillBeRawPtr<SharedWorker> worker = adoptRefWillBeNoop(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();
H A DWorker.cpp64 RefPtrWillBeRawPtr<Worker> worker = adoptRefWillBeNoop(new Worker(context)); local
66 worker->suspendIfNeeded();
68 KURL scriptURL = worker->resolveURL(url, exceptionState);
72 worker->m_scriptLoader = WorkerScriptLoader::create();
73 worker->m_scriptLoader->loadAsynchronously(*context, scriptURL, DenyCrossOriginRequests, worker.get());
74 worker->m_contextProxy = proxyProvider->createWorkerGlobalScopeProxy(worker.get());
75 return worker.release();
83 ASSERT(executionContext()); // The context is protected by worker contex
[all...]
/external/chromium_org/content/child/service_worker/
H A Dweb_service_worker_registration_impl.cc17 blink::WebServiceWorker* worker)
19 worker(worker) {
85 proxy_->setInstalling(it->worker);
87 proxy_->setWaiting(it->worker);
89 proxy_->setActive(it->worker);
100 if (it->worker && !it->worker->proxy())
101 delete it->worker;
15 QueuedTask( QueuedTaskType type, blink::WebServiceWorker* worker) argument
/external/chromium_org/content/renderer/service_worker/
H A Dembedded_worker_dispatcher.cc31 WorkerWrapper(blink::WebEmbeddedWorker* worker, int devtools_agent_route_id) argument
32 : worker_(worker),
34 new EmbeddedWorkerDevToolsAgent(worker, devtools_agent_route_id)) {}
37 blink::WebEmbeddedWorker* worker() { return worker_.get(); } function in class:content::EmbeddedWorkerDispatcher::WorkerWrapper
104 wrapper->worker()->startWorkerContext(start_data);
112 LOG(WARNING) << "Got OnStopWorker for nonexistent worker";
117 // a delayed task to forcibly abort the worker context if we find it
119 wrapper->worker()->terminateWorkerContext();
127 LOG(WARNING) << "Got OnResumeAfterDownload for nonexistent worker";
130 wrapper->worker()
[all...]
/external/chromium_org/third_party/WebKit/Source/modules/serviceworkers/
H A DServiceWorker.cpp153 PassRefPtrWillBeRawPtr<ServiceWorker> ServiceWorker::from(ExecutionContext* executionContext, WebType* worker) argument
155 if (!worker)
158 RefPtrWillBeRawPtr<ServiceWorker> serviceWorker = getOrCreate(executionContext, worker);
164 PassRefPtrWillBeRawPtr<ServiceWorker> ServiceWorker::take(ScriptPromiseResolver* resolver, WebType* worker) argument
166 if (!worker)
169 RefPtrWillBeRawPtr<ServiceWorker> serviceWorker = getOrCreate(resolver->scriptState()->executionContext(), worker);
176 void ServiceWorker::dispose(WebType* worker) argument
178 if (worker && !worker->proxy())
179 delete worker;
252 RefPtrWillBeRawPtr<ServiceWorker> worker = adoptRefWillBeNoop(new ServiceWorker(executionContext, adoptPtr(outerWorker))); local
257 ServiceWorker(ExecutionContext* executionContext, PassOwnPtr<WebServiceWorker> worker) argument
[all...]

Completed in 1483 milliseconds

123456