worker 381 android_webview/browser/aw_content_browser_client.cc bool worker) { worker 123 android_webview/browser/aw_content_browser_client.h bool worker) OVERRIDE; worker 322 base/message_loop/message_loop_unittest.cc Thread worker("RecursiveDenial2_worker"); worker 325 base/message_loop/message_loop_unittest.cc ASSERT_EQ(true, worker.StartWithOptions(options)); worker 328 base/message_loop/message_loop_unittest.cc worker.message_loop()->PostTask(FROM_HERE, worker 366 base/message_loop/message_loop_unittest.cc Thread worker("RecursiveSupport2_worker"); worker 369 base/message_loop/message_loop_unittest.cc ASSERT_EQ(true, worker.StartWithOptions(options)); worker 372 base/message_loop/message_loop_unittest.cc worker.message_loop()->PostTask(FROM_HERE, worker 169 base/threading/worker_pool_posix.cc WorkerThread* worker = worker 171 base/threading/worker_pool_posix.cc PlatformThread::CreateNonJoinable(kWorkerThreadStackSize, worker); worker 821 base/tracked_objects.cc ThreadData* worker = first_retired_worker_; worker 822 base/tracked_objects.cc CHECK_GT(worker->worker_thread_number_, 0); worker 823 base/tracked_objects.cc first_retired_worker_ = worker->next_retired_worker_; worker 824 base/tracked_objects.cc worker->next_retired_worker_ = NULL; worker 37 cc/resources/raster_worker_pool.cc scoped_ptr<base::DelegateSimpleThread> worker = worker 43 cc/resources/raster_worker_pool.cc worker->Start(); worker 45 cc/resources/raster_worker_pool.cc worker->SetThreadPriority(base::kThreadPriority_Background); worker 47 cc/resources/raster_worker_pool.cc workers_.push_back(worker.Pass()); worker 174 cc/resources/task_graph_runner_unittest.cc scoped_ptr<base::DelegateSimpleThread> worker = worker 176 cc/resources/task_graph_runner_unittest.cc worker->Start(); worker 177 cc/resources/task_graph_runner_unittest.cc workers_.push_back(worker.Pass()); worker 186 cc/resources/task_graph_runner_unittest.cc scoped_ptr<base::DelegateSimpleThread> worker = workers_.take_front(); worker 187 cc/resources/task_graph_runner_unittest.cc worker->Join(); worker 2057 chrome/browser/chrome_content_browser_client.cc bool worker) { worker 2072 chrome/browser/chrome_content_browser_client.cc worker ? DesktopNotificationService::WorkerNotification : worker 208 chrome/browser/chrome_content_browser_client.h bool worker) OVERRIDE; worker 252 chrome/browser/custom_handlers/protocol_handler_registry.cc ShellIntegration::DefaultProtocolClientWorker* worker) { worker 253 chrome/browser/custom_handlers/protocol_handler_registry.cc worker_ = worker; worker 303 chrome/browser/custom_handlers/protocol_handler_registry.cc scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker; worker 304 chrome/browser/custom_handlers/protocol_handler_registry.cc worker = CreateShellWorker(observer, protocol); worker 305 chrome/browser/custom_handlers/protocol_handler_registry.cc observer->SetWorker(worker.get()); worker 307 chrome/browser/custom_handlers/protocol_handler_registry.cc worker->StartSetAsDefault(); worker 476 chrome/browser/custom_handlers/protocol_handler_registry.cc scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker; worker 477 chrome/browser/custom_handlers/protocol_handler_registry.cc worker = delegate_->CreateShellWorker(observer, handler.protocol()); worker 478 chrome/browser/custom_handlers/protocol_handler_registry.cc observer->SetWorker(worker.get()); worker 480 chrome/browser/custom_handlers/protocol_handler_registry.cc worker->StartCheckIsDefault(); worker 56 chrome/browser/custom_handlers/protocol_handler_registry.h void SetWorker(ShellIntegration::DefaultProtocolClientWorker* worker); worker 172 chrome/browser/devtools/devtools_target_impl.cc WorkerTarget::WorkerTarget(const WorkerService::WorkerInfo& worker) { worker 174 chrome/browser/devtools/devtools_target_impl.cc DevToolsAgentHost::GetForWorker(worker.process_id, worker.route_id); worker 177 chrome/browser/devtools/devtools_target_impl.cc title_ = base::UTF16ToUTF8(worker.name); worker 179 chrome/browser/devtools/devtools_target_impl.cc base::StringPrintf("Worker pid:%d", base::GetProcId(worker.handle)); worker 180 chrome/browser/devtools/devtools_target_impl.cc url_ = worker.url; worker 182 chrome/browser/devtools/devtools_target_impl.cc process_id_ = worker.process_id; worker 183 chrome/browser/devtools/devtools_target_impl.cc route_id_ = worker.route_id; worker 282 chrome/browser/external_protocol/external_protocol_handler.cc scoped_refptr<ShellIntegration::DefaultProtocolClientWorker> worker = worker 288 chrome/browser/external_protocol/external_protocol_handler.cc worker->StartCheckIsDefault(); worker 13 chrome/browser/notifications/notification_object_proxy.cc int notification_id, bool worker) worker 17 chrome/browser/notifications/notification_object_proxy.cc worker_(worker), worker 21 chrome/browser/notifications/notification_object_proxy.h int notification_id, bool worker); worker 43 chrome/browser/printing/print_job_unittest.cc TestPrintJobWorker* worker(new TestPrintJobWorker(new_owner)); worker 44 chrome/browser/printing/print_job_unittest.cc EXPECT_TRUE(worker->Start()); worker 45 chrome/browser/printing/print_job_unittest.cc worker->printing_context()->UseDefaultSettings(); worker 46 chrome/browser/printing/print_job_unittest.cc settings_ = worker->printing_context()->settings(); worker 47 chrome/browser/printing/print_job_unittest.cc return worker; worker 53 chrome/browser/sync/glue/browser_thread_model_worker_unittest.cc worker()->DoWorkAndWaitUntilDone(c); worker 46 chrome/browser/sync/glue/ui_model_worker_unittest.cc explicit Syncer(UIModelWorker* worker) : worker_(worker) {} worker 554 chrome/browser/web_applications/web_app_win.cc UpdateShortcutWorker* worker = new UpdateShortcutWorker(web_contents); worker 555 chrome/browser/web_applications/web_app_win.cc worker->Run(); worker 608 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc Worker *worker = reinterpret_cast<Worker *>(arg); worker 613 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc reinterpret_cast<void *>(worker)); worker 615 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc worker->RunToCompletion(); worker 616 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc worker = NULL; // RunToCompletion automatically Unrefs worker 642 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc reinterpret_cast<void *>(instance->worker()))) { worker 645 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc instance->worker()->Unref(); worker 652 chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc reinterpret_cast<void *>(instance->worker())); worker 239 content/browser/devtools/worker_devtools_manager.cc WorkerProcessHost* worker, worker 246 content/browser/devtools/worker_devtools_manager.cc WorkerId new_worker_id(worker->GetData().id, instance.worker_route_id()); worker 256 content/browser/devtools/worker_devtools_manager.cc WorkerProcessHost* worker, worker 259 content/browser/devtools/worker_devtools_manager.cc worker->GetData().id, worker 264 content/browser/devtools/worker_devtools_manager.cc WorkerId worker_id(worker->GetData().id, worker_route_id); worker 51 content/browser/service_worker/embedded_worker_instance_unittest.cc scoped_ptr<EmbeddedWorkerInstance> worker = worker 53 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status()); worker 55 content/browser/service_worker/embedded_worker_instance_unittest.cc const int embedded_worker_id = worker->embedded_worker_id(); worker 61 content/browser/service_worker/embedded_worker_instance_unittest.cc worker->Start(service_worker_version_id, url)); worker 62 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status()); worker 69 content/browser/service_worker/embedded_worker_instance_unittest.cc worker->Start(service_worker_version_id, url)); worker 70 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status()); worker 74 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::RUNNING, worker->status()); worker 75 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(kRenderProcessId, worker->process_id()); worker 78 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(SERVICE_WORKER_OK, worker->Stop()); worker 79 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STOPPING, worker->status()); worker 83 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status()); worker 93 content/browser/service_worker/embedded_worker_instance_unittest.cc scoped_ptr<EmbeddedWorkerInstance> worker = worker 95 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker->status()); worker 99 content/browser/service_worker/embedded_worker_instance_unittest.cc const int embedded_worker_id = worker->embedded_worker_id(); worker 109 content/browser/service_worker/embedded_worker_instance_unittest.cc worker->Start(1L, GURL("http://example.com/worker.js"))); worker 110 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status()); worker 111 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(3, worker->process_id()); worker 115 content/browser/service_worker/embedded_worker_instance_unittest.cc EXPECT_EQ(EmbeddedWorkerInstance::RUNNING, worker->status()); worker 23 content/browser/service_worker/embedded_worker_registry.cc scoped_ptr<EmbeddedWorkerInstance> worker( worker 25 content/browser/service_worker/embedded_worker_registry.cc worker_map_[next_embedded_worker_id_++] = worker.get(); worker 26 content/browser/service_worker/embedded_worker_registry.cc return worker.Pass(); worker 32 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 33 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker); worker 35 content/browser/service_worker/embedded_worker_test_helper.cc worker->AddProcessReference(process_id); worker 127 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 128 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker != NULL); worker 130 content/browser/service_worker/embedded_worker_test_helper.cc worker->process_id(), worker 137 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 138 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker != NULL); worker 139 content/browser/service_worker/embedded_worker_test_helper.cc registry()->OnWorkerStopped(worker->process_id(), embedded_worker_id); worker 151 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 152 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker != NULL); worker 153 content/browser/service_worker/embedded_worker_test_helper.cc EXPECT_EQ(EmbeddedWorkerInstance::STARTING, worker->status()); worker 164 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 165 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker != NULL); worker 178 content/browser/service_worker/embedded_worker_test_helper.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 179 content/browser/service_worker/embedded_worker_test_helper.cc ASSERT_TRUE(worker != NULL); worker 180 content/browser/service_worker/embedded_worker_test_helper.cc EXPECT_EQ(worker->thread_id(), thread_id); worker 130 content/browser/service_worker/service_worker_browsertest.cc void AssociateRendererProcessToWorker(EmbeddedWorkerInstance* worker) { worker 131 content/browser/service_worker/service_worker_browsertest.cc worker->AddProcessReference( worker 405 content/browser/service_worker/service_worker_job_unittest.cc EmbeddedWorkerInstance* worker = registry()->GetWorker(embedded_worker_id); worker 406 content/browser/service_worker/service_worker_job_unittest.cc registry()->OnWorkerStopped(worker->process_id(), embedded_worker_id); worker 400 content/browser/worker_host/worker_service_impl.cc WorkerProcessHost* worker = new WorkerProcessHost( worker 406 content/browser/worker_host/worker_service_impl.cc if (!worker->Init(first_filter->render_process_id(), worker 408 content/browser/worker_host/worker_service_impl.cc delete worker; worker 412 content/browser/worker_host/worker_service_impl.cc worker->CreateWorker( worker 414 content/browser/worker_host/worker_service_impl.cc WorkerDevToolsManager::GetInstance()->WorkerCreated(worker, instance)); worker 417 content/browser/worker_host/worker_service_impl.cc WorkerCreated(instance.url(), instance.name(), worker->GetData().id, worker 130 content/child/service_worker/service_worker_dispatcher.cc scoped_ptr<WebServiceWorkerImpl> worker( worker 132 content/child/service_worker/service_worker_dispatcher.cc callbacks->onSuccess(worker.release()); worker 471 content/public/browser/content_browser_client.h bool worker) {} worker 29 content/renderer/service_worker/embedded_worker_dispatcher.cc explicit WorkerWrapper(blink::WebEmbeddedWorker* worker) : worker_(worker) {} worker 79 content/renderer/service_worker/embedded_worker_dispatcher.cc wrapper->worker()->startWorkerContext(start_data); worker 93 content/renderer/service_worker/embedded_worker_dispatcher.cc wrapper->worker()->terminateWorkerContext(); worker 705 ipc/ipc_sync_channel_unittest.cc Worker* worker; worker 707 ipc/ipc_sync_channel_unittest.cc worker = new MultipleServer2(); worker 708 ipc/ipc_sync_channel_unittest.cc worker->OverrideThread(&worker_thread); worker 709 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 711 ipc/ipc_sync_channel_unittest.cc worker = new MultipleClient2( worker 713 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 715 ipc/ipc_sync_channel_unittest.cc worker = new MultipleServer1(server_pump); worker 716 ipc/ipc_sync_channel_unittest.cc worker->OverrideThread(&worker_thread); worker 717 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 719 ipc/ipc_sync_channel_unittest.cc worker = new MultipleClient1( worker 721 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 807 ipc/ipc_sync_channel_unittest.cc Worker* worker; worker 809 ipc/ipc_sync_channel_unittest.cc worker = new QueuedReplyServer(&server_worker_thread, worker 812 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 814 ipc/ipc_sync_channel_unittest.cc worker = new QueuedReplyServer(&server_worker_thread, worker 817 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 819 ipc/ipc_sync_channel_unittest.cc worker = new QueuedReplyClient(&client_worker_thread, worker 823 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 825 ipc/ipc_sync_channel_unittest.cc worker = new QueuedReplyClient(&client_worker_thread, worker 829 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 1038 ipc/ipc_sync_channel_unittest.cc Worker* worker, worker 1041 ipc/ipc_sync_channel_unittest.cc worker_(worker), worker 1881 ipc/ipc_sync_channel_unittest.cc Worker* worker; worker 1883 ipc/ipc_sync_channel_unittest.cc worker = new VerifiedServer(&server_worker_thread, worker 1886 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 1888 ipc/ipc_sync_channel_unittest.cc worker = new VerifiedClient(&client_worker_thread, worker 1891 ipc/ipc_sync_channel_unittest.cc workers.push_back(worker); worker 224 ipc/sync_socket_unittest.cc base::Thread worker("BlockingThread"); worker 225 ipc/sync_socket_unittest.cc worker.Start(); worker 230 ipc/sync_socket_unittest.cc worker.message_loop()->PostTask(FROM_HERE, worker 244 ipc/sync_socket_unittest.cc worker.Stop(); worker 254 ipc/sync_socket_unittest.cc base::Thread worker("BlockingThread"); worker 255 ipc/sync_socket_unittest.cc worker.Start(); worker 260 ipc/sync_socket_unittest.cc worker.message_loop()->PostTask(FROM_HERE, worker 274 ipc/sync_socket_unittest.cc worker.Stop(); worker 322 net/cert/multi_threaded_cert_verifier.cc CertVerifierJob(CertVerifierWorker* worker, worker 325 net/cert/multi_threaded_cert_verifier.cc worker_(worker), worker 457 net/cert/multi_threaded_cert_verifier.cc CertVerifierWorker* worker = worker 466 net/cert/multi_threaded_cert_verifier.cc worker, worker 468 net/cert/multi_threaded_cert_verifier.cc if (!worker->Start()) { worker 470 net/cert/multi_threaded_cert_verifier.cc delete worker; worker 432 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceWorker* worker = new ServerBoundCertServiceWorker( worker 436 net/ssl/server_bound_cert_service.cc if (!worker->Start(task_runner_)) { worker 527 net/ssl/server_bound_cert_service.cc ServerBoundCertServiceWorker* worker = new ServerBoundCertServiceWorker( worker 531 net/ssl/server_bound_cert_service.cc if (!worker->Start(task_runner_)) { worker 22 sync/engine/directory_update_handler.cc scoped_refptr<ModelSafeWorker> worker) worker 25 sync/engine/directory_update_handler.cc worker_(worker) {} worker 47 sync/engine/directory_update_handler.h scoped_refptr<ModelSafeWorker> worker); worker 721 sync/internal_api/sync_manager_impl_unittest.cc scoped_refptr<ModelSafeWorker> worker = new FakeModelWorker(GROUP_PASSIVE); worker 722 sync/internal_api/sync_manager_impl_unittest.cc workers.push_back(worker); worker 54 sync/sessions/model_type_registry.cc scoped_refptr<ModelSafeWorker> worker = worker_it->second; worker 59 sync/sessions/model_type_registry.cc new DirectoryUpdateHandler(directory_, type, worker); worker 348 third_party/libwebp/dec/frame.c WebPWorker* const worker = &dec->worker_; worker 350 third_party/libwebp/dec/frame.c ok &= WebPWorkerSync(worker); worker 351 third_party/libwebp/dec/frame.c assert(worker->status_ == OK); worker 370 third_party/libwebp/dec/frame.c WebPWorkerLaunch(worker); // (reconstruct)+filter in parallel worker 480 third_party/libwebp/dec/frame.c WebPWorker* const worker = &dec->worker_; worker 481 third_party/libwebp/dec/frame.c if (!WebPWorkerReset(worker)) { worker 485 third_party/libwebp/dec/frame.c worker->data1 = dec; worker 486 third_party/libwebp/dec/frame.c worker->data2 = (void*)&dec->thread_ctx_.io_; worker 487 third_party/libwebp/dec/frame.c worker->hook = (WebPWorkerHook)FinishRow; worker 363 third_party/libwebp/enc/alpha.c WebPWorker* const worker = &enc->alpha_worker_; worker 364 third_party/libwebp/enc/alpha.c WebPWorkerInit(worker); worker 365 third_party/libwebp/enc/alpha.c worker->data1 = enc; worker 366 third_party/libwebp/enc/alpha.c worker->data2 = NULL; worker 367 third_party/libwebp/enc/alpha.c worker->hook = (WebPWorkerHook)CompressAlphaJob; worker 374 third_party/libwebp/enc/alpha.c WebPWorker* const worker = &enc->alpha_worker_; worker 375 third_party/libwebp/enc/alpha.c if (!WebPWorkerReset(worker)) { // Makes sure worker is good to go. worker 378 third_party/libwebp/enc/alpha.c WebPWorkerLaunch(worker); worker 390 third_party/libwebp/enc/alpha.c WebPWorker* const worker = &enc->alpha_worker_; worker 391 third_party/libwebp/enc/alpha.c if (!WebPWorkerSync(worker)) return 0; // error worker 400 third_party/libwebp/enc/alpha.c WebPWorker* const worker = &enc->alpha_worker_; worker 401 third_party/libwebp/enc/alpha.c ok = WebPWorkerSync(worker); // finish anything left in flight worker 402 third_party/libwebp/enc/alpha.c WebPWorkerEnd(worker); // still need to end the worker, even if !ok worker 395 third_party/libwebp/enc/analysis.c WebPWorker worker; worker 428 third_party/libwebp/enc/analysis.c WebPWorkerInit(&job->worker); worker 429 third_party/libwebp/enc/analysis.c job->worker.data1 = job; worker 430 third_party/libwebp/enc/analysis.c job->worker.data2 = &job->it; worker 431 third_party/libwebp/enc/analysis.c job->worker.hook = (WebPWorkerHook)DoSegmentsJob; worker 470 third_party/libwebp/enc/analysis.c ok &= WebPWorkerReset(&side_job.worker); worker 473 third_party/libwebp/enc/analysis.c WebPWorkerLaunch(&side_job.worker); worker 474 third_party/libwebp/enc/analysis.c WebPWorkerExecute(&main_job.worker); worker 475 third_party/libwebp/enc/analysis.c ok &= WebPWorkerSync(&side_job.worker); worker 476 third_party/libwebp/enc/analysis.c ok &= WebPWorkerSync(&main_job.worker); worker 478 third_party/libwebp/enc/analysis.c WebPWorkerEnd(&side_job.worker); worker 483 third_party/libwebp/enc/analysis.c WebPWorkerExecute(&main_job.worker); worker 484 third_party/libwebp/enc/analysis.c ok &= WebPWorkerSync(&main_job.worker); worker 486 third_party/libwebp/enc/analysis.c WebPWorkerEnd(&main_job.worker); worker 133 third_party/libwebp/utils/thread.c WebPWorker* const worker = (WebPWorker*)ptr; worker 136 third_party/libwebp/utils/thread.c pthread_mutex_lock(&worker->mutex_); worker 137 third_party/libwebp/utils/thread.c while (worker->status_ == OK) { // wait in idling mode worker 138 third_party/libwebp/utils/thread.c pthread_cond_wait(&worker->condition_, &worker->mutex_); worker 140 third_party/libwebp/utils/thread.c if (worker->status_ == WORK) { worker 141 third_party/libwebp/utils/thread.c WebPWorkerExecute(worker); worker 142 third_party/libwebp/utils/thread.c worker->status_ = OK; worker 143 third_party/libwebp/utils/thread.c } else if (worker->status_ == NOT_OK) { // finish the worker worker 147 third_party/libwebp/utils/thread.c pthread_cond_signal(&worker->condition_); worker 148 third_party/libwebp/utils/thread.c pthread_mutex_unlock(&worker->mutex_); worker 154 third_party/libwebp/utils/thread.c static void ChangeState(WebPWorker* const worker, worker 157 third_party/libwebp/utils/thread.c if (worker->status_ < OK) return; worker 159 third_party/libwebp/utils/thread.c pthread_mutex_lock(&worker->mutex_); worker 161 third_party/libwebp/utils/thread.c while (worker->status_ != OK) { worker 162 third_party/libwebp/utils/thread.c pthread_cond_wait(&worker->condition_, &worker->mutex_); worker 166 third_party/libwebp/utils/thread.c worker->status_ = new_status; worker 167 third_party/libwebp/utils/thread.c pthread_cond_signal(&worker->condition_); worker 169 third_party/libwebp/utils/thread.c pthread_mutex_unlock(&worker->mutex_); worker 176 third_party/libwebp/utils/thread.c void WebPWorkerInit(WebPWorker* const worker) { worker 177 third_party/libwebp/utils/thread.c memset(worker, 0, sizeof(*worker)); worker 178 third_party/libwebp/utils/thread.c worker->status_ = NOT_OK; worker 181 third_party/libwebp/utils/thread.c int WebPWorkerSync(WebPWorker* const worker) { worker 183 third_party/libwebp/utils/thread.c ChangeState(worker, OK); worker 185 third_party/libwebp/utils/thread.c assert(worker->status_ <= OK); worker 186 third_party/libwebp/utils/thread.c return !worker->had_error; worker 189 third_party/libwebp/utils/thread.c int WebPWorkerReset(WebPWorker* const worker) { worker 191 third_party/libwebp/utils/thread.c worker->had_error = 0; worker 192 third_party/libwebp/utils/thread.c if (worker->status_ < OK) { worker 194 third_party/libwebp/utils/thread.c if (pthread_mutex_init(&worker->mutex_, NULL) || worker 195 third_party/libwebp/utils/thread.c pthread_cond_init(&worker->condition_, NULL)) { worker 198 third_party/libwebp/utils/thread.c pthread_mutex_lock(&worker->mutex_); worker 199 third_party/libwebp/utils/thread.c ok = !pthread_create(&worker->thread_, NULL, ThreadLoop, worker); worker 200 third_party/libwebp/utils/thread.c if (ok) worker->status_ = OK; worker 201 third_party/libwebp/utils/thread.c pthread_mutex_unlock(&worker->mutex_); worker 203 third_party/libwebp/utils/thread.c worker->status_ = OK; worker 205 third_party/libwebp/utils/thread.c } else if (worker->status_ > OK) { worker 206 third_party/libwebp/utils/thread.c ok = WebPWorkerSync(worker); worker 208 third_party/libwebp/utils/thread.c assert(!ok || (worker->status_ == OK)); worker 212 third_party/libwebp/utils/thread.c void WebPWorkerExecute(WebPWorker* const worker) { worker 213 third_party/libwebp/utils/thread.c if (worker->hook != NULL) { worker 214 third_party/libwebp/utils/thread.c worker->had_error |= !worker->hook(worker->data1, worker->data2); worker 218 third_party/libwebp/utils/thread.c void WebPWorkerLaunch(WebPWorker* const worker) { worker 220 third_party/libwebp/utils/thread.c ChangeState(worker, WORK); worker 222 third_party/libwebp/utils/thread.c WebPWorkerExecute(worker); worker 226 third_party/libwebp/utils/thread.c void WebPWorkerEnd(WebPWorker* const worker) { worker 227 third_party/libwebp/utils/thread.c if (worker->status_ >= OK) { worker 229 third_party/libwebp/utils/thread.c ChangeState(worker, NOT_OK); worker 230 third_party/libwebp/utils/thread.c pthread_join(worker->thread_, NULL); worker 231 third_party/libwebp/utils/thread.c pthread_mutex_destroy(&worker->mutex_); worker 232 third_party/libwebp/utils/thread.c pthread_cond_destroy(&worker->condition_); worker 234 third_party/libwebp/utils/thread.c worker->status_ = NOT_OK; worker 237 third_party/libwebp/utils/thread.c assert(worker->status_ == NOT_OK); worker 71 third_party/libwebp/utils/thread.h void WebPWorkerInit(WebPWorker* const worker); worker 74 third_party/libwebp/utils/thread.h int WebPWorkerReset(WebPWorker* const worker); worker 77 third_party/libwebp/utils/thread.h int WebPWorkerSync(WebPWorker* const worker); worker 81 third_party/libwebp/utils/thread.h void WebPWorkerLaunch(WebPWorker* const worker); worker 86 third_party/libwebp/utils/thread.h void WebPWorkerExecute(WebPWorker* const worker); worker 89 third_party/libwebp/utils/thread.h void WebPWorkerEnd(WebPWorker* const worker); worker 121 third_party/sqlite/src/test/threadtest2.c pthread_create(&aThread[i], 0, worker, (void*)i); worker 108 tools/binary_size/java/src/org/chromium/tools/binary_size/Addr2LineWorkerPool.java for (Addr2LineWorker worker : mWorkers) { worker 109 tools/binary_size/java/src/org/chromium/tools/binary_size/Addr2LineWorkerPool.java worker.stopIfQueueIsEmpty = true; worker 431 tools/binary_size/java/src/org/chromium/tools/binary_size/ParallelAddress2Line.java final Thread worker = new Thread(task, "pipe " + in + "->" + out); worker 432 tools/binary_size/java/src/org/chromium/tools/binary_size/ParallelAddress2Line.java worker.setDaemon(true); worker 433 tools/binary_size/java/src/org/chromium/tools/binary_size/ParallelAddress2Line.java worker.start();