/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...] |