/external/chromium_org/webkit/child/ |
worker_task_runner_unittest.cc | 15 task_runner_.OnWorkerRunLoopStarted(WebKit::WebWorkerRunLoop()); 18 task_runner_.OnWorkerRunLoopStopped(WebKit::WebWorkerRunLoop()); 20 WorkerTaskRunner task_runner_; member in class:webkit_glue::WorkerTaskRunnerTest 37 ASSERT_EQ(0, task_runner_.CurrentWorkerId()); 41 task_runner_.AddStopObserver(&o); 42 ASSERT_LT(0, task_runner_.CurrentWorkerId()); 49 o.runner_ = &task_runner_; 52 task_runner_.AddStopObserver(&o);
|
/external/chromium_org/remoting/client/ |
frame_consumer_proxy.cc | 16 : task_runner_(task_runner) { 23 if (!task_runner_->BelongsToCurrentThread()) { 24 task_runner_->PostTask(FROM_HERE, base::Bind( 35 if (!task_runner_->BelongsToCurrentThread()) { 36 task_runner_->PostTask(FROM_HERE, base::Bind( 47 if (!task_runner_->BelongsToCurrentThread()) { 48 task_runner_->PostTask(FROM_HERE, base::Bind( 59 DCHECK(task_runner_->BelongsToCurrentThread());
|
chromoting_client.cc | 35 task_runner_(client_context->main_task_runner()), 58 DCHECK(task_runner_->BelongsToCurrentThread()); 89 DCHECK(task_runner_->BelongsToCurrentThread()); 95 DCHECK(task_runner_->BelongsToCurrentThread()); 117 DCHECK(task_runner_->BelongsToCurrentThread()); 124 DCHECK(task_runner_->BelongsToCurrentThread()); 131 DCHECK(task_runner_->BelongsToCurrentThread()); 138 DCHECK(task_runner_->BelongsToCurrentThread()); 146 DCHECK(task_runner_->BelongsToCurrentThread()); 163 DCHECK(task_runner_->BelongsToCurrentThread()) [all...] |
/external/chromium_org/chrome/browser/policy/cloud/ |
rate_limiter_unittest.cc | 19 : task_runner_(new base::TestSimpleTaskRunner()), 28 task_runner_, 37 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::RateLimiterTest 53 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 61 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); 67 task_runner_->RunPendingTasks(); 69 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 80 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 94 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 103 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()) [all...] |
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...] |
external_policy_data_updater_unittest.cc | 71 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::ExternalPolicyDataUpdaterTest 77 task_runner_ = new base::TestSimpleTaskRunner(); 82 task_runner_, 144 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); 178 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 211 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 243 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 268 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 271 task_runner_->RunPendingTasks(); 272 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()) [all...] |
/external/chromium_org/remoting/base/ |
auto_thread_task_runner.cc | 15 task_runner_(task_runner) { 23 CHECK(task_runner_->PostDelayedTask(from_here, task, delay)); 31 CHECK(task_runner_->PostNonNestableDelayedTask(from_here, task, delay)); 36 return task_runner_->RunsTasksOnCurrentThread(); 40 CHECK(task_runner_->PostTask(FROM_HERE, stop_task_));
|
/external/chromium_org/base/ |
thread_task_runner_handle.cc | 24 return current->task_runner_; 34 : task_runner_(task_runner) { 35 DCHECK(task_runner_->BelongsToCurrentThread()); 41 DCHECK(task_runner_->BelongsToCurrentThread());
|
thread_task_runner_handle.h | 35 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::ThreadTaskRunnerHandle
|
/external/chromium_org/webkit/browser/fileapi/ |
file_system_operation_context.cc | 15 task_runner_(file_system_context_->default_file_task_runner()), 23 task_runner_(task_runner),
|
timed_task_helper.cc | 25 : task_runner_(task_runner), 30 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 36 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 51 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 72 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 86 task_runner_->PostDelayedTask(
|
/external/chromium_org/remoting/host/ |
local_input_monitor_unittest.cc | 44 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::LocalInputMonitorTest 59 task_runner_ = new AutoThreadTaskRunner( 80 LocalInputMonitor::Create(task_runner_, 81 task_runner_, 82 task_runner_, 84 task_runner_ = NULL;
|
video_scheduler_unittest.cc | 86 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::VideoSchedulerTest 110 task_runner_ = new AutoThreadTaskRunner( 119 task_runner_, // Capture 120 task_runner_, // Encode 121 task_runner_, // Network 187 task_runner_ = NULL;
|
/external/chromium_org/base/mac/ |
libdispatch_task_runner_unittest.cc | 16 task_runner_ = new base::mac::LibDispatchTaskRunner( 23 dispatch_async(task_runner_->GetDispatchQueue(), ^{ 28 task_runner_->Shutdown(); 58 scoped_refptr<base::mac::LibDispatchTaskRunner> task_runner_; member in class:LibDispatchTaskRunnerTest 92 task_runner_->PostTask(FROM_HERE, BoundRecordTaskOrder(this, "Basic Task")); 102 task_runner_->PostTask(FROM_HERE, base::BindBlock(^{ 104 task_runner_->PostTask(FROM_HERE, BoundRecordTaskOrder(this, "Inner")); 118 task_runner_->PostTask(FROM_HERE, base::BindBlock(^{ 132 dispatch_async(task_runner_->GetDispatchQueue(), ^{ 135 task_runner_->PostTask(FROM_HERE, BoundRecordTaskOrder(this, "First Task")) [all...] |
/external/chromium_org/chrome/browser/ |
image_decoder.cc | 22 task_runner_(NULL) { 28 task_runner_ = task_runner; 47 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 53 DCHECK(task_runner_->RunsTasksOnCurrentThread()); 62 utility_process_host = UtilityProcessHost::Create(this, task_runner_.get());
|
/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...] |
/external/chromium_org/chrome/browser/chromeos/system/ |
automatic_reboot_manager_unittest.cc | 114 scoped_refptr<MockTimeSingleThreadTaskRunner> task_runner_; member in class:chromeos::system::__anon7048::MockTimeTickClock 161 scoped_refptr<MockTimeSingleThreadTaskRunner> task_runner_; member in class:chromeos::system::AutomaticRebootManagerBasicTest 320 : task_runner_(task_runner) { 327 return task_runner_->Now(); 333 task_runner_(new MockTimeSingleThreadTaskRunner), 337 ui_thread_task_runner_handle_(task_runner_), 349 task_runner_->SetUptimeFile(uptime_file); 377 task_runner_->RunUntilIdle(); 397 task_runner_->RunUntilIdle(); 413 task_runner_->RunUntilIdle() [all...] |
/external/chromium_org/chrome/browser/policy/ |
policy_statistics_collector_unittest.cc | 61 task_runner_(new base::TestSimpleTaskRunner()) { 92 task_runner_)); 101 if (task_runner_->GetPendingTasks().empty()) { 105 return task_runner_->GetPendingTasks().front().delay; 119 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::PolicyStatisticsCollectorTest 133 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 148 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 159 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size()); 176 EXPECT_EQ(1u, task_runner_->GetPendingTasks().size());
|
/external/chromium_org/cc/scheduler/ |
rate_limiter.cc | 29 task_runner_(task_runner) { 41 task_runner_->PostTask(FROM_HERE,
|
/external/chromium_org/net/cert/ |
cert_database_mac.cc | 35 task_runner_ = message_loop->message_loop_proxy(); 36 task_runner_->PostTask(FROM_HERE, 41 // Should be called from the |task_runner_|'s thread. Use Shutdown() 46 if (registered_ && task_runner_->RunsTasksOnCurrentThread()) 52 if (!task_runner_->DeleteSoon(FROM_HERE, this)) { 77 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:net::CertDatabase::Notifier
|
/external/chromium_org/net/quic/ |
quic_connection_helper.cc | 26 task_runner_(task_runner), 44 task_runner_->PostDelayedTask( 76 base::TaskRunner* task_runner_; member in class:net::__anon11323::QuicChromeAlarm 88 task_runner_(task_runner), 145 return new QuicChromeAlarm(clock_, task_runner_, delegate);
|
/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;
|
/external/chromium_org/content/browser/dom_storage/ |
dom_storage_namespace.cc | 23 task_runner_(task_runner) { 33 task_runner_(task_runner), 48 area = new DOMStorageArea(origin, directory_, task_runner_.get()); 52 session_storage_database_.get(), task_runner_.get()); 81 session_storage_database_.get(), task_runner_.get()); 91 task_runner_->PostShutdownBlockingTask( 110 new DOMStorageArea(origin, directory_, task_runner_.get());
|
/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/content/browser/indexed_db/ |
indexed_db_unittest.cc | 32 task_runner_(new base::TestSimpleTaskRunner), 40 void FlushIndexedDBTaskRunner() { task_runner_->RunUntilIdle(); } 43 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:content::IndexedDBTest 62 temp_dir.path(), special_storage_policy_, NULL, task_runner_); 93 temp_dir.path(), special_storage_policy_, NULL, task_runner_); 149 temp_dir.path(), special_storage_policy_, NULL, task_runner_);
|