| /external/chromium_org/sync/test/engine/ |
| 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_;
|
| injectable_sync_context_proxy.h | 45 ModelTypeSyncWorker* worker_; member in class:syncer::InjectableSyncContextProxy
|
| /external/libvpx/libvpx/test/ |
| vp9_thread_test.cc | 28 vp9_worker_init(&worker_);
32 vp9_worker_end(&worker_);
35 VP9Worker worker_; member in class:__anon4358::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/ |
| 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_.get())
[all...] |
| 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_->IsRunning())
[all...] |
| printer_query.h | 76 scoped_ptr<PrintJobWorker> worker_; member in class:printing::PrinterQuery
|
| /external/chromium_org/third_party/webrtc/base/ |
| 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_.Stop()
[all...] |
| signalthread.h | 74 Thread* worker() { return &worker_; }
145 Worker worker_; member in class:rtc::SignalThread
|
| /external/chromium_org/third_party/libvpx/source/libvpx/test/ |
| vp9_thread_test.cc | 31 vp9_get_worker_interface()->init(&worker_);
35 vp9_get_worker_interface()->end(&worker_);
47 VP9Worker worker_; member in class:__anon17640::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_), 0)
[all...] |
| /external/chromium_org/net/dns/ |
| serial_worker_unittest.cc | 101 worker_ = new TestSerialWorker(this);
106 worker_->Cancel();
132 scoped_refptr<TestSerialWorker> worker_; member in class:net::__anon13840::SerialWorkerTest
140 worker_->WorkNow();
149 worker_->WorkNow();
151 worker_->WorkNow();
|
| /external/chromium_org/media/audio/ |
| fake_audio_consumer.h | 48 const scoped_refptr<Worker> worker_; member in class:media::FakeAudioConsumer
|
| 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/chrome/browser/sync/glue/ |
| 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::__anon9384::SyncBrowserThreadModelWorkerTest
|
| 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/third_party/libjingle/source/talk/p2p/client/ |
| 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_ == rtc::Thread::Current())
[all...] |
| /external/chromium_org/content/renderer/service_worker/ |
| 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/ |
| stunserver_unittest.cc | 48 worker_(ss_.get()) {
56 worker_.Start();
80 rtc::Thread worker_; member in class:StunServerTest
|
| /external/chromium_org/ipc/ |
| 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:__anon13127::TestUnixSocketConnection
|
| /external/chromium_org/sync/engine/ |
| non_blocking_type_commit_contribution.h | 41 ModelTypeSyncWorkerImpl* const worker_; member in class:syncer::NonBlockingTypeCommitContribution
|
| 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...] |
| non_blocking_type_commit_contribution.cc | 18 : worker_(worker),
93 worker_->OnCommitResponse(response_list);
|
| directory_update_handler.h | 97 scoped_refptr<ModelSafeWorker> worker_; member in class:syncer::DirectoryUpdateHandler
|
| /external/chromium_org/content/browser/service_worker/ |
| 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_->Stop()
403 scoped_ptr<EmbeddedWorkerInstance> worker_; member in class:content::EmbeddedWorkerBrowserTest
[all...] |
| /external/chromium_org/chrome/browser/media/ |
| native_desktop_media_list.h | 58 // Post a task for the |worker_| to update list of windows and get thumbnails.
61 // Called by |worker_| to refresh the model. First it posts tasks for
69 // Capturers specified in SetCapturers() and passed to the |worker_| later.
85 // Task runner used for the |worker_|.
91 scoped_ptr<Worker> worker_; member in class:NativeDesktopMediaList
|
| /external/chromium_org/chrome/browser/media_galleries/ |
| media_folder_finder.h | 72 // Callback that handles the |reply| from |worker_| for a scanned |path|.
85 Worker* worker_; member in class:MediaFolderFinder
|
