Searched defs:task_runner_ (Results 1 - 22 of 22) sorted by relevance

/external/libchrome/base/
H A Dthread_task_runner_handle.h36 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::ThreadTaskRunnerHandle
/external/libchrome/base/trace_event/
H A Dtrace_event_system_stats_monitor.h57 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::trace_event::TraceEventSystemStatsMonitor
/external/libchrome/base/files/
H A Dfile_path_watcher.h62 return task_runner_;
66 task_runner_ = std::move(runner);
79 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in class:base::FilePathWatcher::PlatformDelegate
H A Dimportant_file_writer.h122 const scoped_refptr<SequencedTaskRunner> task_runner_; member in class:base::ImportantFileWriter
H A Dfile_path_watcher_unittest.cc51 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 Dref_counted_delete_on_message_loop.h44 : 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 Ddevice_delegate.cc23 : 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 Dsecurity_manager_unittest.cc136 provider::test::FakeTaskRunner task_runner_; member in class:weave::privet::SecurityManagerTest
152 SecurityManager security_{&config_, &auth_manager_, &task_runner_};
H A Dwifi_bootstrap_manager.cc44 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 Daccess_api_handler_unittest.cc103 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::AccessApiHandlerTest
104 ComponentManagerImpl component_manager_{&task_runner_};
H A Dbase_api_handler_unittest.cc97 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::BaseApiHandlerTest
98 ComponentManagerImpl component_manager_{&task_runner_};
H A Ddevice_registration_info_unittest.cc153 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 Dweave_unittest.cc277 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 Dcomponent_manager_unittest.cc94 StrictMock<provider::test::FakeTaskRunner> task_runner_; member in class:weave::__anon11233::ComponentManagerTest
96 ComponentManagerImpl manager_{&task_runner_, &clock_};
/external/libweave/src/notification/
H A Dxmpp_iq_stanza_handler_unittest.cc79 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 Dxmpp_channel_unittest.cc90 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 Ddaemon.h68 : 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 Dcommand_queue_unittest.cc39 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 Dcloud_command_proxy_unittest.cc123 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 Dtimer.h138 // 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 Dmessage_loop.h296 return task_runner_;
536 scoped_refptr<SingleThreadTaskRunner> task_runner_; member in class:base::MessageLoop
/external/webrtc/webrtc/base/
H A Dtask_unittest.cc138 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...]

Completed in 268 milliseconds