/external/libvpx/libvpx/vp9/decoder/ |
H A D | 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 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 D | vp9_thread.c | 10 // 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 D | thread.c | 10 // 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 D | thread.h | 10 // 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 D | thread.c | 10 // 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 D | thread.h | 10 // 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 D | 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;
|
/external/chromium_org/third_party/WebKit/Source/modules/filesystem/ |
H A D | WorkerGlobalScopeFileSystem.cpp | 48 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 D | ThreadControllerWrapper.java | 38 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 D | injectable_sync_context_proxy.cc | 13 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 D | WorkerGlobalScopeProxyProviderImpl.cpp | 52 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 D | SharedWorkerRepositoryClientImpl.cpp | 60 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 D | regress-crbug-138887.js | 34 function factory(worker) { 37 return 1 + worker(call_depth - 1);
|
H A D | regress-crbug-147475.js | 34 function factory(worker) { 37 return 1 + worker(call_depth - 1);
|
/external/compiler-rt/test/tsan/ |
H A D | pthread_atfork_deadlock.c | 13 void *worker(void *unused) { function 27 pthread_create(&t, NULL, worker, NULL);
|
H A D | fork_atexit.cc | 13 void *worker(void *unused) { function 19 pthread_create(&t, NULL, worker, NULL);
|
/external/chromium_org/content/browser/service_worker/ |
H A D | embedded_worker_instance_unittest.cc | 59 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 D | embedded_worker_test_helper.cc | 104 // 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 D | 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/clang/test/SemaCXX/ |
H A D | arrow-operator.cpp | 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'?}}
|
/external/chromium_org/third_party/WebKit/Source/core/workers/ |
H A D | SharedWorker.cpp | 64 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 D | Worker.cpp | 64 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 D | web_service_worker_registration_impl.cc | 17 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 D | embedded_worker_dispatcher.cc | 31 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 D | ServiceWorker.cpp | 153 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...] |