| /external/chromium_org/remoting/jingle_glue/ |
| xmpp_signal_strategy.h | 95 scoped_ptr<talk_base::TaskRunner> task_runner_; member in class:remoting::XmppSignalStrategy
|
| /external/chromium_org/webkit/browser/fileapi/ |
| file_system_operation_context.h | 54 base::SequencedTaskRunner* task_runner() const { return task_runner_.get(); }
82 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:fileapi::FileSystemOperationContext
|
| test_file_system_backend.cc | 34 task_runner_(task_runner) {
35 update_observers_ = update_observers_.AddObserver(this, task_runner_.get());
124 base::SequencedTaskRunner* task_runner() { return task_runner_.get(); }
129 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:fileapi::TestFileSystemBackend::QuotaUtil
|
| /external/chromium_org/chrome/browser/chromeos/login/ |
| wallpaper_manager.h | 356 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:chromeos::WallpaperManager
|
| /external/chromium_org/chrome/browser/policy/cloud/ |
| cloud_external_data_manager_base.cc | 48 // UI thread but from then on, is accessed via the |task_runner_| only.
119 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:policy::CloudExternalDataManagerBase::Backend
150 task_runner_(task_runner),
164 updater_.reset(new ExternalPolicyDataUpdater(task_runner_,
|
| cloud_policy_invalidator.h | 141 const scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:policy::CloudPolicyInvalidator
|
| cloud_policy_refresh_scheduler_unittest.cc | 37 : task_runner_(new base::TestSimpleTaskRunner()),
58 EXPECT_EQ(0u, task_runner_->GetPendingTasks().size());
60 new CloudPolicyRefreshScheduler(&client_, &store_, task_runner_);
63 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size());
64 task_runner_->RunPendingTasks();
75 task_runner_->GetPendingTasks();
90 EXPECT_FALSE(task_runner_->GetPendingTasks().empty());
146 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::CloudPolicyRefreshSchedulerTest
156 EXPECT_FALSE(task_runner_->GetPendingTasks().empty());
159 task_runner_->RunUntilIdle()
[all...] |
| cloud_policy_invalidator_unittest.cc | 145 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::CloudPolicyInvalidatorTest
184 : task_runner_(new base::TestSimpleTaskRunner()),
212 task_runner_));
284 task_runner_->RunUntilIdle();
301 if (task_runner_->GetPendingTasks().empty())
303 base::TimeDelta actual_delay = task_runner_->GetPendingTasks().back().delay;
310 task_runner_->RunUntilIdle();
|
| cloud_policy_manager_unittest.cc | 202 task_runner_ = new base::TestSimpleTaskRunner();
207 task_runner_));
254 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::__anon7866::CloudPolicyManagerTest
|
| component_cloud_policy_service.cc | 92 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:policy::ComponentCloudPolicyService::Backend
106 task_runner_(task_runner),
143 task_runner_, request_context, store_.get()));
|
| component_cloud_policy_service_unittest.cc | 85 : task_runner_(task_runner) {}
91 return task_runner_;
97 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:policy::__anon7875::TestURLRequestContextGetter
|
| /external/chromium_org/content/browser/dom_storage/ |
| dom_storage_context_impl_unittest.cc | 43 task_runner_ =
48 task_runner_.get());
70 scoped_refptr<MockDOMStorageTaskRunner> task_runner_; member in class:content::DOMStorageContextImplTest
199 task_runner_.get());
223 storage_policy_.get(), task_runner_.get());
247 storage_policy_.get(), task_runner_.get());
|
| /external/chromium_org/content/browser/indexed_db/ |
| indexed_db_quota_client_unittest.cc | 42 task_runner_(new base::TestSimpleTaskRunner),
58 task_runner_);
63 void FlushIndexedDBTaskRunner() { task_runner_->RunUntilIdle(); }
167 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:content::IndexedDBQuotaClientTest
|
| /external/chromium_org/remoting/host/ |
| input_injector_mac.cc | 86 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:remoting::__anon12154::InputInjectorMac::Core
127 : task_runner_(task_runner),
145 if (!task_runner_->BelongsToCurrentThread()) {
146 task_runner_->PostTask(
267 if (!task_runner_->BelongsToCurrentThread()) {
268 task_runner_->PostTask(
278 if (!task_runner_->BelongsToCurrentThread()) {
279 task_runner_->PostTask(FROM_HERE, base::Bind(&Core::Stop, this));
|
| input_injector_linux.cc | 103 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:remoting::__anon12153::InputInjectorLinux::Core
166 : task_runner_(task_runner),
178 if (!task_runner_->BelongsToCurrentThread())
179 task_runner_->PostTask(FROM_HERE, base::Bind(&Core::InitClipboard, this));
201 if (!task_runner_->BelongsToCurrentThread()) {
202 task_runner_->PostTask(
216 if (!task_runner_->BelongsToCurrentThread()) {
217 task_runner_->PostTask(FROM_HERE,
264 DCHECK(task_runner_->BelongsToCurrentThread());
296 if (!task_runner_->BelongsToCurrentThread())
[all...] |
| ipc_desktop_environment_unittest.cc | 169 // Runs until there are references to |task_runner_|.
172 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::IpcDesktopEnvironmentTest
232 task_runner_ = new AutoThreadTaskRunner(
236 "IPC thread", task_runner_, base::MessageLoop::TYPE_IO);
277 task_runner_,
278 task_runner_,
279 task_runner_,
367 EXPECT_TRUE(task_runner_.get());
379 desktop_process_.reset(new DesktopProcess(task_runner_,
442 task_runner_ = NULL
[all...] |
| chromoting_host_unittest.cc | 71 task_runner_ = new AutoThreadTaskRunner(
91 task_runner_, // Audio
92 task_runner_, // Input
93 task_runner_, // Video capture
94 task_runner_, // Video encode
95 task_runner_, // Network
96 task_runner_)); // UI
186 task_runner_, // Audio
187 task_runner_, // Input
188 task_runner_, // Video captur
395 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::ChromotingHostTest
[all...] |
| /external/chromium_org/remoting/host/win/ |
| rdp_client_unittest.cc | 97 // more references to |task_runner_|.
100 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::RdpClientTest
121 task_runner_ = new AutoThreadTaskRunner(
164 rdp_client_.reset(new RdpClient(task_runner_, task_runner_,
167 task_runner_ = NULL;
|
| worker_process_launcher_unittest.cc | 156 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::WorkerProcessLauncherTest
192 task_runner_ = new AutoThreadTaskRunner(
245 task_runner_->PostTask(
257 task_runner_->PostTask(
282 task_runner_));
328 task_runner_ = NULL;
369 task_runner_));
|
| /external/chromium_org/base/files/ |
| file_util_proxy.cc | 30 : task_runner_(task_runner),
38 task_runner_->PostTask(
54 scoped_refptr<TaskRunner> task_runner_; member in class:base::__anon6143::CreateOrOpenHelper
65 : task_runner_(task_runner),
72 task_runner_.get(), file_handle_, FileUtilProxy::StatusCallback());
97 scoped_refptr<TaskRunner> task_runner_; member in class:base::__anon6143::CreateTemporaryHelper
|
| /external/chromium_org/content/browser/renderer_host/media/ |
| desktop_capture_device.cc | 52 // Helper methods that run on the |task_runner_|. Posted from the
62 // Method that is scheduled on |task_runner_| to be called on regular interval
70 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:content::DesktopCaptureDevice::Core
105 // |task_runner_|.
117 : task_runner_(task_runner),
140 task_runner_->PostTask(
146 task_runner_->PostTask(
151 task_runner_->PostTask(
160 task_runner_->PostTask(FROM_HERE, base::Bind(&Core::DoDeAllocate, this));
170 DCHECK(task_runner_->RunsTasksOnCurrentThread())
[all...] |
| /external/chromium_org/base/threading/ |
| sequenced_worker_pool_unittest.cc | 858 task_runner_ = pool_owner_->pool()->GetTaskRunnerWithShutdownBehavior(
863 return task_runner_;
882 scoped_refptr<TaskRunner> task_runner_; member in class:base::__anon6376::SequencedWorkerPoolTaskRunnerWithShutdownBehaviorTestDelegate
899 task_runner_ = pool_owner_->pool()->GetSequencedTaskRunner(
904 return task_runner_;
923 scoped_refptr<SequencedTaskRunner> task_runner_; member in class:base::__anon6376::SequencedWorkerPoolSequencedTaskRunnerTestDelegate
[all...] |
| /external/chromium_org/cc/trees/ |
| layer_tree_host_unittest_scroll.cc | 872 : task_runner_(runner), received_stop_flinging_(received_stop_flinging) {}
880 if (!task_runner_->BelongsToCurrentThread())
885 if (!task_runner_->BelongsToCurrentThread())
891 if (!task_runner_->BelongsToCurrentThread())
896 base::SingleThreadTaskRunner* task_runner_; member in class:cc::__anon6578::ThreadCheckingInputHandlerClient
[all...] |
| /external/chromium_org/chrome/browser/chromeos/app_mode/ |
| kiosk_app_data.cc | 97 task_runner_ = pool->GetSequencedTaskRunnerWithShutdownBehavior(
100 task_runner_->PostTask(FROM_HERE,
112 DCHECK(task_runner_->RunsTasksOnCurrentThread());
123 image_decoder->Start(task_runner_);
127 DCHECK(task_runner_->RunsTasksOnCurrentThread());
170 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in class:chromeos::KioskAppData::IconLoader
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| task_unittest.cc | 156 stuck_[i].task_ = new StuckTask(&task_runner_);
167 happy_[i].task_ = new HappyTask(&task_runner_);
206 task_runner_.RunTasks();
211 for (int i = 0; !task_runner_.AllChildrenDone() && i < STUCK_TASK_COUNT;
220 task_runner_.PollTasks();
277 EXPECT_TRUE(task_runner_.AllChildrenDone());
303 MyTaskRunner task_runner_; member in class:talk_base::TaskTest
338 Task *abort_task = new AbortTask(&task_runner_);
343 task_runner_.RunTasks();
351 MyTaskRunner task_runner_; member in class:talk_base::TaskAbortTest
414 MyTaskRunner task_runner_; member in class:talk_base::AbortShouldWakeTest
493 MyTaskRunner task_runner_; member in class:talk_base::TimeoutChangeTest
[all...] |
