/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...] |