| /external/libchrome/base/ |
| H A D | thread_task_runner_handle.h | 36 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::ThreadTaskRunnerHandle
|
| /external/libchrome/base/trace_event/ |
| H A D | trace_event_system_stats_monitor.h | 57 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::trace_event::TraceEventSystemStatsMonitor
|
| /external/libchrome/base/files/ |
| H A D | file_path_watcher.h | 62 return task_runner_;
66 task_runner_ = std::move(runner);
79 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:base::FilePathWatcher::PlatformDelegate
|
| H A D | important_file_writer.h | 122 const scoped_refptr<SequencedTaskRunner> task_runner_; member in class:base::ImportantFileWriter
|
| H A D | file_path_watcher_unittest.cc | 51 NotificationCollector() : task_runner_(base::ThreadTaskRunnerHandle::Get()) {}
55 task_runner_->PostTask(
78 ASSERT_TRUE(task_runner_->BelongsToCurrentThread());
84 task_runner_->PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure());
94 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:base::__anon8989::NotificationCollector
|
| /external/libchrome/base/memory/ |
| H A D | ref_counted_delete_on_message_loop.h | 44 : task_runner_(task_runner) {
45 DCHECK(task_runner_);
63 if (task_runner_->BelongsToCurrentThread())
66 task_runner_->DeleteSoon(FROM_HERE, t);
69 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::RefCountedDeleteOnMessageLoop
|
| /external/libweave/src/privet/ |
| H A D | device_delegate.cc | 23 : task_runner_{task_runner},
42 task_runner_->PostDelayedTask(from_here, task, delay);
46 provider::TaskRunner* task_runner_; member in class:weave::privet::__anon11250::DeviceDelegateImpl
|
| H A D | security_manager_unittest.cc | 136 provider::test::FakeTaskRunner task_runner_; member in class:weave::privet::SecurityManagerTest
152 SecurityManager security_{&config_, &auth_manager_, &task_runner_};
|
| H A D | wifi_bootstrap_manager.cc | 44 task_runner_{task_runner},
50 CHECK(task_runner_); variable
84 task_runner_->PostDelayedTask(
107 task_runner_->PostDelayedTask(
138 task_runner_->PostDelayedTask(
190 task_runner_->PostDelayedTask(
|
| /external/libweave/src/ |
| H A D | access_api_handler_unittest.cc | 103 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::AccessApiHandlerTest
104 ComponentManagerImpl component_manager_{&task_runner_};
|
| H A D | base_api_handler_unittest.cc | 97 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::BaseApiHandlerTest
98 ComponentManagerImpl component_manager_{&task_runner_};
|
| H A D | device_registration_info_unittest.cc | 153 config_.get(), &component_manager_, &task_runner_, &http_client_,
199 provider::test::FakeTaskRunner task_runner_; member in class:weave::DeviceRegistrationInfoTest
213 ComponentManagerImpl component_manager_{&task_runner_};
552 task_runner_.Break();
562 task_runner_.Run();
574 task_runner_.Break();
584 task_runner_.Run();
640 task_runner_.RunOnce();
|
| H A D | weave_unittest.cc | 277 device_ = weave::Device::Create(&config_store_, &task_runner_,
320 task_runner_.Run();
331 task_runner_.PostDelayedTask(FROM_HERE, base::Bind(task), delay);
340 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::WeaveTest
361 device_ = weave::Device::Create(&config_store_, &task_runner_, &http_client_,
371 device_ = weave::Device::Create(&config_store_, &task_runner_, &http_client_,
378 task_runner_.Run();
427 task_runner_.Break();
430 task_runner_.Run();
437 task_runner_
[all...] |
| H A D | component_manager_unittest.cc | 94 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::__anon11233::ComponentManagerTest
96 ComponentManagerImpl manager_{&task_runner_, &clock_};
|
| /external/libweave/src/notification/ |
| H A D | xmpp_iq_stanza_handler_unittest.cc | 79 provider::test::FakeTaskRunner task_runner_; member in class:weave::IqStanzaHandlerTest
80 IqStanzaHandler iq_stanza_handler_{&mock_xmpp_channel_, &task_runner_};
139 task_runner_.Run();
157 task_runner_.Run();
168 task_runner_.Run();
|
| H A D | xmpp_channel_unittest.cc | 90 stream_{new test::FakeStream{task_runner_}},
146 task_runner_.RunOnce();
150 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::XmppChannelTest
152 FakeXmppChannel xmpp_client_{&task_runner_, &network_};
|
| /external/libweave/examples/daemon/common/ |
| H A D | daemon.h | 68 : task_runner_{new weave::examples::EventTaskRunner},
71 task_runner_.get())},
72 http_client_{new weave::examples::CurlHttpClient(task_runner_.get())},
73 network_{new weave::examples::EventNetworkImpl(task_runner_.get())},
80 new weave::examples::HttpServerImpl{task_runner_.get()});
83 new weave::examples::WifiImpl{task_runner_.get(), network_.get()});
85 device_ = weave::Device::Create(config_store_.get(), task_runner_.get(),
96 void Run() { task_runner_->Run(); }
101 return task_runner_.get();
113 std::unique_ptr<weave::examples::EventTaskRunner> task_runner_; member in class:Daemon
[all...] |
| /external/libweave/src/commands/ |
| H A D | command_queue_unittest.cc | 39 return queue_.Cleanup(task_runner_.GetClock()->Now() + interval);
46 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::CommandQueueTest
47 CommandQueue queue_{&task_runner_, task_runner_.GetClock()};
140 ASSERT_EQ(1u, task_runner_.GetTaskQueueSize());
142 task_runner_.RunOnce();
145 EXPECT_EQ(0u, task_runner_.GetTaskQueueSize());
156 task_runner_.PostDelayedTask(FROM_HERE, base::Bind(remove_task, id2),
159 ASSERT_EQ(2u, task_runner_.GetTaskQueueSize());
160 task_runner_
[all...] |
| H A D | cloud_command_proxy_unittest.cc | 123 new TestBackoffEntry{&policy, task_runner_.GetClock()}};
128 std::move(backoff), &task_runner_, local
145 testing::StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::__anon11228::CloudCommandProxyTest
164 task_runner_.RunOnce();
196 task_runner_.RunOnce();
227 auto started = task_runner_.GetClock()->Now();
230 task_runner_.Run();
234 task_runner_.Run();
235 EXPECT_GE(task_runner_.GetClock()->Now() - started,
239 task_runner_
[all...] |
| /external/libchrome/base/timer/ |
| H A D | timer.h | 138 // corresponding task_runner_ field is null, the task runner for the current
161 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::Timer
|
| /external/libchrome/base/message_loop/ |
| H A D | message_loop.h | 296 return task_runner_;
536 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::MessageLoop
|
| /external/webrtc/webrtc/base/ |
| H A D | task_unittest.cc | 138 stuck_[i].task_ = new StuckTask(&task_runner_);
149 happy_[i].task_ = new HappyTask(&task_runner_);
188 task_runner_.RunTasks();
193 for (int i = 0; !task_runner_.AllChildrenDone() && i < STUCK_TASK_COUNT;
202 task_runner_.PollTasks();
259 EXPECT_TRUE(task_runner_.AllChildrenDone());
285 MyTaskRunner task_runner_; member in class:rtc::TaskTest
320 Task *abort_task = new AbortTask(&task_runner_);
325 task_runner_.RunTasks();
333 MyTaskRunner task_runner_; member in class:rtc::TaskAbortTest
396 MyTaskRunner task_runner_; member in class:rtc::AbortShouldWakeTest
475 MyTaskRunner task_runner_; member in class:rtc::TimeoutChangeTest
[all...] |