/external/chromium_org/sync/test/engine/ |
H A D | injectable_sync_context_proxy.cc | 14 : is_worker_connected_(false), worker_(worker) { 31 scoped_ptr<ModelTypeSyncWorker> worker(worker_); 38 worker_ = NULL; 43 return scoped_ptr<SyncContextProxy>(new InjectableSyncContextProxy(worker_)); 47 return worker_;
|
H A D | injectable_sync_context_proxy.h | 45 ModelTypeSyncWorker* worker_; member in class:syncer::InjectableSyncContextProxy
|
/external/libvpx/libvpx/test/ |
H A D | vp9_thread_test.cc | 28 vp9_worker_init(&worker_); 32 vp9_worker_end(&worker_); 35 VP9Worker worker_; member in class:__anon24806::VP9WorkerThreadTest 45 EXPECT_NE(vp9_worker_sync(&worker_), 0); // should be a no-op. 48 EXPECT_NE(vp9_worker_reset(&worker_), 0); 52 worker_.hook = ThreadHook; 53 worker_.data1 = &hook_data; 54 worker_.data2 = &return_value; 58 vp9_worker_execute(&worker_); 60 vp9_worker_launch(&worker_); [all...] |
/external/chromium_org/chrome/browser/printing/ |
H A D | printer_query.cc | 17 : worker_(new PrintJobWorker(render_process_id, render_view_id, this)), 28 DCHECK(!worker_.get()); 52 DCHECK(worker_.get()); 54 worker_->SetNewOwner(new_owner); 55 return worker_.release(); 79 worker_->PostTask(FROM_HERE, 81 base::Unretained(worker_.get()), 92 worker_->PostTask(FROM_HERE, 94 base::Unretained(worker_.get()), 100 DCHECK(worker_ [all...] |
H A D | print_job.cc | 41 worker_(), 57 DCHECK(!worker_ || !worker_->IsRunning()); 65 DCHECK(!worker_.get()); 70 worker_.reset(job->DetachWorker(this)); 124 DCHECK(worker_->IsRunning()); 126 if (!worker_->IsRunning() || is_job_pending_) 130 worker_->PostTask(FROM_HERE, 134 base::Unretained(worker_.get()), 161 if (worker_ [all...] |
H A D | printer_query.h | 76 scoped_ptr<PrintJobWorker> worker_; member in class:printing::PrinterQuery
|
/external/chromium_org/third_party/webrtc/base/ |
H A D | signalthread.cc | 23 worker_(this), 28 worker_.SetName("SignalThread", this); 39 return worker_.SetName(name, obj); 46 return worker_.SetPriority(priority); 55 worker_.Start(); 70 worker_.Quit(); 75 worker_.Stop(); 99 ASSERT(worker_.IsCurrent()); 100 return worker_.ProcessMessages(0); 125 worker_ [all...] |
H A D | signalthread.h | 74 Thread* worker() { return &worker_; } 145 Worker worker_; member in class:rtc::SignalThread
|
/external/chromium_org/third_party/libvpx/source/libvpx/test/ |
H A D | vp9_thread_test.cc | 31 vp9_get_worker_interface()->init(&worker_); 35 vp9_get_worker_interface()->end(&worker_); 47 VP9Worker worker_; member in class:__anon13015::VP9WorkerThreadTest 58 EXPECT_NE(vp9_get_worker_interface()->sync(&worker_), 0); 61 EXPECT_NE(vp9_get_worker_interface()->reset(&worker_), 0); 65 worker_.hook = ThreadHook; 66 worker_.data1 = &hook_data; 67 worker_.data2 = &return_value; 69 Run(&worker_); 70 EXPECT_NE(vp9_get_worker_interface()->sync(&worker_), [all...] |
/external/chromium_org/net/dns/ |
H A D | serial_worker_unittest.cc | 101 worker_ = new TestSerialWorker(this); 106 worker_->Cancel(); 132 scoped_refptr<TestSerialWorker> worker_; member in class:net::__anon9215::SerialWorkerTest 140 worker_->WorkNow(); 149 worker_->WorkNow(); 151 worker_->WorkNow();
|
/external/chromium_org/chrome/browser/sync/glue/ |
H A D | browser_thread_model_worker_unittest.cc | 35 BrowserThreadModelWorker* worker() { return worker_.get(); } 76 worker_ = new DatabaseModelWorker(NULL); 80 worker_ = NULL; 85 scoped_refptr<BrowserThreadModelWorker> worker_; member in class:browser_sync::__anon4759::SyncBrowserThreadModelWorkerTest
|
H A D | ui_model_worker_unittest.cc | 46 explicit Syncer(UIModelWorker* worker) : worker_(worker) {} 53 worker_->DoWorkAndWaitUntilDone(c); 56 scoped_refptr<UIModelWorker> worker_; member in class:Syncer
|
/external/chromium_org/media/audio/ |
H A D | fake_audio_consumer.h | 48 const scoped_refptr<Worker> worker_; member in class:media::FakeAudioConsumer
|
H A D | fake_audio_consumer.cc | 66 : worker_(new Worker(worker_task_runner, params)) { 70 DCHECK(worker_->IsStopped()); 74 DCHECK(worker_->IsStopped()); 75 worker_->Start(read_cb); 79 worker_->Stop();
|
/external/chromium_org/ui/file_manager/image_loader/ |
H A D | image_loader.js | 24 this.worker_ = new Worker(); 40 Promise.all(initPromises).then(this.worker_.start.bind(this.worker_)); 97 this.worker_.remove(requestId); 102 this.worker_.add(requestTask);
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/client/ |
H A D | connectivitychecker.cc | 106 : worker_(worker), 123 worker_->Clear(this, MSG_TIMEOUT); 124 worker_->Send(this, MSG_STOP); 132 socket_factory_.reset(CreateSocketFactory(worker_)); 143 worker_->Post(this, MSG_START); 148 ASSERT(worker_ == rtc::Thread::Current()); 202 ASSERT(worker_ == rtc::Thread::Current()); 203 worker_->PostDelayed(timeout_ms_, this, MSG_TIMEOUT); 224 ASSERT(worker_ == rtc::Thread::Current()); 231 ASSERT(worker_ [all...] |
/external/chromium_org/content/renderer/service_worker/ |
H A D | embedded_worker_dispatcher.cc | 32 : worker_(worker), 37 blink::WebEmbeddedWorker* worker() { return worker_.get(); } 41 scoped_ptr<blink::WebEmbeddedWorker> worker_; member in class:content::EmbeddedWorkerDispatcher::WorkerWrapper
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | stunserver_unittest.cc | 48 worker_(ss_.get()) { 56 worker_.Start(); 80 rtc::Thread worker_; member in class:StunServerTest
|
/external/chromium_org/ipc/ |
H A D | unix_domain_socket_util_unittest.cc | 93 : worker_("WorkerThread"), 100 worker_.StartWithOptions(options); 111 worker_.message_loop_proxy().get())); 141 base::Thread worker_; member in class:__anon8502::TestUnixSocketConnection
|
/external/chromium_org/sync/engine/ |
H A D | non_blocking_type_commit_contribution.h | 41 ModelTypeSyncWorkerImpl* const worker_; member in class:syncer::NonBlockingTypeCommitContribution
|
H A D | model_type_sync_worker_impl_unittest.cc | 120 // Returns true if the |worker_| is ready to commit something. 127 // Read commit messages the worker_ sent to the emulated server. 212 scoped_ptr<ModelTypeSyncWorkerImpl> worker_; member in class:syncer::ModelTypeSyncWorkerImplTest 220 // harness, the |worker_| is both of them. 270 DCHECK(!worker_); 272 // We don't get to own this object. The |worker_| keeps a scoped_ptr to it. 281 worker_.reset(new ModelTypeSyncWorkerImpl(kModelType, 329 if (worker_) { 330 worker_->UpdateCryptographer( 345 if (worker_) { [all...] |
H A D | non_blocking_type_commit_contribution.cc | 18 : worker_(worker), 93 worker_->OnCommitResponse(response_list);
|
H A D | model_type_sync_proxy_impl.h | 130 scoped_ptr<ModelTypeSyncWorker> worker_; member in class:syncer::ModelTypeSyncProxyImpl
|
/external/chromium_org/content/browser/service_worker/ |
H A D | service_worker_browsertest.cc | 317 if (worker_) { 318 worker_->RemoveListener(this); 319 worker_.reset(); 325 worker_ = wrapper()->context()->embedded_worker_registry()->CreateWorker(); 326 EXPECT_EQ(EmbeddedWorkerInstance::STOPPED, worker_->status()); 327 worker_->AddListener(this); 338 worker_->Start( 346 last_worker_status_ = worker_->status(); 356 EXPECT_EQ(EmbeddedWorkerInstance::RUNNING, worker_->status()); 358 ServiceWorkerStatusCode status = worker_ 403 scoped_ptr<EmbeddedWorkerInstance> worker_; member in class:content::EmbeddedWorkerBrowserTest [all...] |
/external/chromium_org/chrome/browser/media_galleries/ |
H A D | media_folder_finder.h | 72 // Callback that handles the |reply| from |worker_| for a scanned |path|. 85 Worker* worker_; member in class:MediaFolderFinder
|