/external/chromium_org/content/child/ |
H A D | worker_task_runner_unittest.cc | 16 task_runner_.OnWorkerRunLoopStarted(blink::WebWorkerRunLoop()); 19 task_runner_.OnWorkerRunLoopStopped(blink::WebWorkerRunLoop()); 21 WorkerTaskRunner task_runner_; member in class:content::WorkerTaskRunnerTest 38 ASSERT_EQ(0, task_runner_.CurrentWorkerId()); 42 task_runner_.AddStopObserver(&o); 43 ASSERT_LT(0, task_runner_.CurrentWorkerId()); 50 o.runner_ = &task_runner_; 53 task_runner_.AddStopObserver(&o);
|
/external/chromium_org/media/audio/ |
H A D | audio_output_dispatcher.cc | 16 task_runner_(audio_manager->GetTaskRunner()), 20 // |task_runner_| member will point to the wrong message loop! 25 DCHECK(task_runner_->BelongsToCurrentThread());
|
H A D | null_audio_sink.cc | 19 task_runner_(task_runner) { 27 fake_consumer_.reset(new FakeAudioConsumer(task_runner_, params)); 33 DCHECK(task_runner_->BelongsToCurrentThread()); 38 DCHECK(task_runner_->BelongsToCurrentThread()); 46 DCHECK(task_runner_->BelongsToCurrentThread()); 58 DCHECK(task_runner_->BelongsToCurrentThread()); 73 DCHECK(task_runner_->BelongsToCurrentThread());
|
H A D | scoped_task_runner_observer.cc | 14 : task_runner_(task_runner) { 26 if (task_runner_->BelongsToCurrentThread()) { 35 if (task_runner_->PostTask(FROM_HERE,
|
H A D | audio_input_controller.cc | 93 controller->task_runner_ = audio_manager->GetTaskRunner(); 97 if (!controller->task_runner_->PostTask(FROM_HERE, 124 controller->task_runner_ = audio_manager->GetTaskRunner(); 128 if (!controller->task_runner_->PostTask(FROM_HERE, 151 controller->task_runner_ = task_runner; 158 if (!controller->task_runner_->PostTask( 169 task_runner_->PostTask(FROM_HERE, base::Bind( 177 task_runner_->PostTaskAndReply( 182 task_runner_->PostTask(FROM_HERE, base::Bind( 187 task_runner_ [all...] |
/external/chromium_org/components/policy/core/common/cloud/ |
H A D | 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_ [all...] |
H A D | policy_header_io_helper_unittest.cc | 21 task_runner_ = make_scoped_refptr(new base::TestSimpleTaskRunner()); 28 task_runner_)); 29 task_runner_->RunUntilIdle(); 32 task_runner_->RunUntilIdle(); 46 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::__anon6500::PolicyHeaderIOHelperTest 68 task_runner_->RunUntilIdle(); 77 task_runner_->RunUntilIdle();
|
H A D | cloud_policy_refresh_scheduler_unittest.cc | 35 : task_runner_(new base::TestSimpleTaskRunner()), 56 EXPECT_EQ(0u, task_runner_->GetPendingTasks().size()); 58 new CloudPolicyRefreshScheduler(&client_, &store_, task_runner_); 70 task_runner_->GetPendingTasks(); 85 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); 141 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; member in class:policy::CloudPolicyRefreshSchedulerTest 151 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); 154 task_runner_->RunUntilIdle(); 162 task_runner_->RunUntilIdle(); 167 EXPECT_FALSE(task_runner_ [all...] |
/external/chromium_org/remoting/base/ |
H A D | 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/remoting/client/ |
H A D | frame_consumer_proxy.cc | 20 task_runner_(task_runner) { 29 if (!task_runner_->BelongsToCurrentThread()) { 30 task_runner_->PostTask(FROM_HERE, base::Bind( 41 if (!task_runner_->BelongsToCurrentThread()) { 42 task_runner_->PostTask(FROM_HERE, base::Bind( 54 if (!task_runner_->BelongsToCurrentThread()) { 55 task_runner_->PostTask(FROM_HERE, base::Bind(
|
/external/chromium_org/base/ |
H A D | 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());
|
/external/chromium_org/media/cast/test/ |
H A D | skewed_single_thread_task_runner.cc | 18 task_runner_(task_runner) { 31 return task_runner_->PostDelayedTask( 38 return task_runner_->RunsTasksOnCurrentThread(); 45 return task_runner_->PostNonNestableDelayedTask(
|
/external/chromium_org/cc/base/ |
H A D | unique_notifier.cc | 16 : task_runner_(task_runner), 29 task_runner_->PostTask(
|
/external/chromium_org/webkit/browser/fileapi/ |
H A D | file_system_operation_context.cc | 15 task_runner_(file_system_context_->default_file_task_runner()), 23 task_runner_(task_runner),
|
/external/chromium_org/remoting/host/ |
H A D | local_input_monitor_unittest.cc | 43 scoped_refptr<AutoThreadTaskRunner> task_runner_; member in class:remoting::LocalInputMonitorTest 58 task_runner_ = new AutoThreadTaskRunner( 79 LocalInputMonitor::Create(task_runner_, 80 task_runner_, 81 task_runner_, 83 task_runner_ = NULL;
|
/external/chromium_org/base/mac/ |
H A D | 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_ [all...] |
/external/chromium_org/media/cast/audio_sender/ |
H A D | audio_sender_unittest.cc | 62 task_runner_ = new test::FakeSingleThreadTaskRunner(testing_clock_); 65 task_runner_, 66 task_runner_, 67 task_runner_); 84 task_runner_, 88 task_runner_->RunTasks(); 100 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; member in class:media::cast::AudioSenderTest 115 task_runner_->RunTasks(); 129 task_runner_->RunTasks(); 135 task_runner_ [all...] |
/external/chromium_org/media/cast/video_sender/ |
H A D | external_video_encoder_unittest.cc | 109 task_runner_ = new test::FakeSingleThreadTaskRunner(testing_clock_); 112 task_runner_, 113 task_runner_, 114 task_runner_); 116 fake_vea_ = new test::FakeVideoEncodeAccelerator(task_runner_); 122 task_runner_, 133 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; member in class:media::cast::ExternalVideoEncoderTest 142 task_runner_->RunTasks(); // Run the initializer on the correct thread. 153 task_runner_->RunTasks(); 160 task_runner_ [all...] |
H A D | video_encoder_impl_unittest.cc | 93 task_runner_ = new test::FakeSingleThreadTaskRunner(testing_clock_); 96 task_runner_, 97 task_runner_, 98 task_runner_); 103 task_runner_->RunTasks(); 114 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; member in class:media::cast::VideoEncoderImplTest 135 task_runner_->RunTasks(); 142 task_runner_->RunTasks(); 149 task_runner_->RunTasks(); 158 task_runner_ [all...] |
/external/chromium_org/media/base/android/ |
H A D | media_player_listener.cc | 26 : task_runner_(task_runner), 28 DCHECK(task_runner_.get()); 56 task_runner_->PostTask(FROM_HERE, base::Bind( 62 task_runner_->PostTask(FROM_HERE, base::Bind( 69 task_runner_->PostTask(FROM_HERE, base::Bind( 75 task_runner_->PostTask(FROM_HERE, base::Bind( 81 task_runner_->PostTask(FROM_HERE, base::Bind( 87 task_runner_->PostTask(FROM_HERE, base::Bind( 93 task_runner_->PostTask(FROM_HERE, base::Bind(
|
/external/chromium_org/chrome/browser/ |
H A D | 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/device/bluetooth/ |
H A D | bluetooth_socket_thread.cc | 37 task_runner_ = NULL; 53 task_runner_ = NULL; 66 task_runner_ = thread_->message_loop_proxy(); 73 DCHECK(task_runner_); 75 return task_runner_;
|
/external/chromium_org/net/quic/ |
H A D | quic_connection_helper.cc | 27 task_runner_(task_runner), 50 task_runner_->PostDelayedTask( 82 base::TaskRunner* task_runner_; member in class:net::__anon8857::QuicChromeAlarm 98 task_runner_(task_runner), 115 return new QuicChromeAlarm(clock_, task_runner_, delegate);
|
/external/chromium_org/third_party/libjingle/source/talk/base/ |
H A D | 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/third_party/webrtc/base/ |
H A D | task_unittest.cc | 139 stuck_[i].task_ = new StuckTask(&task_runner_); 150 happy_[i].task_ = new HappyTask(&task_runner_); 189 task_runner_.RunTasks(); 194 for (int i = 0; !task_runner_.AllChildrenDone() && i < STUCK_TASK_COUNT; 203 task_runner_.PollTasks(); 260 EXPECT_TRUE(task_runner_.AllChildrenDone()); 286 MyTaskRunner task_runner_; member in class:rtc::TaskTest 321 Task *abort_task = new AbortTask(&task_runner_); 326 task_runner_.RunTasks(); 334 MyTaskRunner task_runner_; member in class:rtc::TaskAbortTest 397 MyTaskRunner task_runner_; member in class:rtc::AbortShouldWakeTest 476 MyTaskRunner task_runner_; member in class:rtc::TimeoutChangeTest [all...] |