Searched refs:task_runner_ (Results 1 - 25 of 291) sorted by relevance

1234567891011>>

/external/chromium_org/content/child/
H A Dworker_task_runner_unittest.cc16 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 Daudio_output_dispatcher.cc16 task_runner_(audio_manager->GetTaskRunner()),
20 // |task_runner_| member will point to the wrong message loop!
25 DCHECK(task_runner_->BelongsToCurrentThread());
H A Dnull_audio_sink.cc19 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 Dscoped_task_runner_observer.cc14 : task_runner_(task_runner) {
26 if (task_runner_->BelongsToCurrentThread()) {
35 if (task_runner_->PostTask(FROM_HERE,
H A Daudio_input_controller.cc93 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 Drate_limiter_unittest.cc19 : 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 Dpolicy_header_io_helper_unittest.cc21 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 Dcloud_policy_refresh_scheduler_unittest.cc35 : 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 Dauto_thread_task_runner.cc15 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 Dframe_consumer_proxy.cc20 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 Dthread_task_runner_handle.cc24 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 Dskewed_single_thread_task_runner.cc18 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 Dunique_notifier.cc16 : task_runner_(task_runner),
29 task_runner_->PostTask(
/external/chromium_org/webkit/browser/fileapi/
H A Dfile_system_operation_context.cc15 task_runner_(file_system_context_->default_file_task_runner()),
23 task_runner_(task_runner),
/external/chromium_org/remoting/host/
H A Dlocal_input_monitor_unittest.cc43 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 Dlibdispatch_task_runner_unittest.cc16 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 Daudio_sender_unittest.cc62 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 Dexternal_video_encoder_unittest.cc109 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 Dvideo_encoder_impl_unittest.cc93 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 Dmedia_player_listener.cc26 : 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 Dimage_decoder.cc22 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 Dbluetooth_socket_thread.cc37 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 Dquic_connection_helper.cc27 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 Dtask_unittest.cc156 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 Dtask_unittest.cc139 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...]

Completed in 670 milliseconds

1234567891011>>