| /system/bt/common/test/ |
| D | thread_performance_test.cc | 101 thread_ = thread_new("OsiThreadMessageLoopPerformanceTest thread"); in SetUp()
102 thread_post(thread_, &MessageLoopPerformanceTest::RunThread, this); in SetUp()
109 thread_free(thread_); in TearDown()
110 thread_ = nullptr; in TearDown()
114 thread_t* thread_ = nullptr; member in OsiThreadMessageLoopPerformanceTest
146 thread_ = new std::thread(&MessageLoopPerformanceTest::RunThread, this); in SetUp()
153 thread_->join(); in TearDown()
154 delete thread_; in TearDown()
155 thread_ = nullptr; in TearDown()
159 std::thread* thread_ = nullptr; member in StlThreadMessageLoopPerformanceTest
[all …]
|
| /system/bt/common/benchmark/ |
| D | thread_performance_benchmark.cc | 118 thread_ = thread_new("BM_MessageLoopOnOsiThread thread"); in SetUp()
119 thread_post(thread_, &BM_MessageLoop::RunThread, this); in SetUp()
126 thread_free(thread_); in TearDown()
127 thread_ = nullptr; in TearDown()
131 thread_t* thread_ = nullptr; member in BM_MessageLoopOsiThread
165 thread_ = new std::thread(&BM_MessageLoop::RunThread, this); in SetUp()
172 thread_->join(); in TearDown()
173 delete thread_; in TearDown()
174 thread_ = nullptr; in TearDown()
178 std::thread* thread_ = nullptr; member in BM_MessageLoopStlThread
[all …]
|
| /system/bt/gd/os/linux_generic/ |
| D | handler_unittest.cc | 31 thread_ = new Thread("test_thread", Thread::Priority::NORMAL); in SetUp()
32 handler_ = new Handler(thread_); in SetUp()
36 delete thread_; in TearDown()
40 Thread* thread_; member in bluetooth::os::__anon922b30580111::HandlerTest
|
| D | alarm_unittest.cc | 30 thread_ = new Thread("test_thread", Thread::Priority::NORMAL); in SetUp()
31 alarm_ = new Alarm(thread_); in SetUp()
36 delete thread_; in TearDown()
41 Thread* thread_; member in bluetooth::os::__anon994815070111::AlarmTest
|
| D | handler.cc | 35 : thread_(thread), in Handler()
39 reactable_ = thread_->GetReactor()->Register(fd_, [this] { this->handle_next_event(); }, nullptr); in Handler()
43 thread_->GetReactor()->Unregister(reactable_); in ~Handler()
|
| D | alarm.cc | 36 : thread_(thread), in Alarm()
40 token_ = thread_->GetReactor()->Register(fd_, [this] { on_fire(); }, nullptr); in Alarm()
44 thread_->GetReactor()->Unregister(token_); in ~Alarm()
|
| D | repeating_alarm.cc | 36 : thread_(thread), in RepeatingAlarm()
40 token_ = thread_->GetReactor()->Register(fd_, [this] { on_fire(); }, nullptr); in RepeatingAlarm()
44 thread_->GetReactor()->Unregister(token_); in ~RepeatingAlarm()
|
| D | thread_unittest.cc | 32 …explicit SampleReactable(Thread* thread) : thread_(thread), fd_(eventfd(0, 0)), is_same_thread_che… in SampleReactable()
41 EXPECT_TRUE(thread_->IsSameThread()); in OnReadReady()
51 Thread* thread_; member in bluetooth::os::__anon52d6cbf20111::SampleReactable
|
| D | repeating_alarm_unittest.cc | 32 thread_ = new Thread("test_thread", Thread::Priority::NORMAL); in SetUp()
33 alarm_ = new RepeatingAlarm(thread_); in SetUp()
38 delete thread_; in TearDown()
65 Thread* thread_; member in bluetooth::os::__anon0179fb050111::RepeatingAlarmTest
|
| /system/bt/gd/os/ |
| D | thread_benchmark.cc | 62 thread_ = std::make_unique<Thread>("BM_ReactorThread thread", Thread::Priority::NORMAL); in SetUp()
63 handler_ = std::make_unique<Handler>(thread_.get()); in SetUp()
67 thread_->Stop(); in TearDown()
68 thread_ = nullptr; in TearDown()
71 std::unique_ptr<Thread> thread_; member in BM_ReactorThread
|
| D | alarm_benchmark.cc | 36 thread_ = std::make_unique<Thread>("timer_benchmark", Thread::Priority::REAL_TIME); in SetUp()
37 alarm_ = std::make_unique<Alarm>(thread_.get()); in SetUp()
38 repeating_alarm_ = std::make_unique<RepeatingAlarm>(thread_.get()); in SetUp()
50 thread_->Stop(); in TearDown()
51 thread_ = nullptr; in TearDown()
77 std::unique_ptr<Thread> thread_; member in BM_ReactableAlarm
|
| D | handler.h | 51 Thread* thread_; variable
|
| D | repeating_alarm.h | 50 Thread* thread_; variable
|
| D | alarm.h | 50 Thread* thread_; variable
|
| /system/bt/common/ |
| D | message_loop_thread.cc | 35 thread_(nullptr), in MessageLoopThread()
48 if (thread_ != nullptr) { in StartUp()
53 thread_ = new std::thread(&MessageLoopThread::RunThread, this, in StartUp()
86 if (thread_ == nullptr) { in ShutDown()
109 thread_->join(); in ShutDown()
112 delete thread_; in ShutDown()
113 thread_ = nullptr; in ShutDown()
|
| /system/core/adb/ |
| D | fdevent_test.h | 76 thread_ = std::thread([]() { fdevent_loop(); }); in PrepareThread()
88 thread_.join(); in TerminateThread()
92 std::thread thread_; variable
|
| D | transport_fd.cpp | 145 thread_ = std::thread([this]() { in Start()
155 thread_.join(); in Stop()
215 std::thread thread_; member
|
| /system/bt/vendor_libs/test_vendor_lib/model/setup/ |
| D | async_manager.cc | 134 if (std::this_thread::get_id() != thread_.get_id()) { in stopThread()
135 thread_.join(); in stopThread()
170 thread_ = std::thread([this]() { ThreadRoutine(); }); in tryStartThread()
171 if (!thread_.joinable()) { in tryStartThread()
261 std::thread thread_; member in test_vendor_lib::AsyncManager::AsyncFdWatcher
310 if (std::this_thread::get_id() != thread_.get_id()) { in stopThread()
311 thread_.join(); in stopThread()
396 thread_ = std::thread([this]() { ThreadRoutine(); }); in tryStartThread()
397 if (!thread_.joinable()) { in tryStartThread()
445 std::thread thread_; member in test_vendor_lib::AsyncManager::AsyncTaskManager
|
| /system/bt/service/ipc/ |
| D | ipc_handler_linux.cc | 35 thread_("IPCHandlerLinux"), in IPCHandlerLinux()
106 if (!thread_.StartWithOptions(options)) { in Run()
112 thread_.task_runner()->PostTask( in Run()
128 thread_.Stop(); in Stop()
177 thread_.Stop(); in ShutDownOnOriginThread()
|
| D | ipc_handler_linux.h | 77 base::Thread thread_; variable
|
| /system/bt/vendor_libs/linux/interface/ |
| D | async_fd_watcher.cc | 81 thread_ = std::thread([this]() { ThreadRoutine(); }); in tryStartThread()
82 if (!thread_.joinable()) return -1; in tryStartThread()
91 if (std::this_thread::get_id() != thread_.get_id()) { in stopThread()
92 thread_.join(); in stopThread()
|
| D | async_fd_watcher.h | 52 std::thread thread_; variable
|
| /system/core/libappfuse/tests/ |
| D | FuseBridgeLoopTest.cc | 48 std::thread thread_; member in android::fuse::__anon36125ebe0111::FuseBridgeLoopTest
57 thread_ = std::thread([this] { in SetUp()
119 if (thread_.joinable()) { in Close()
120 thread_.join(); in Close()
|
| D | FuseAppLoopTest.cc | 85 std::thread thread_; member in android::fuse::__anon239256b20111::FuseAppLoopTest
97 thread_ = std::thread([this] { loop_->Start(&callback_); }); in SetUp()
123 if (thread_.joinable()) { in Close()
124 thread_.join(); in Close()
293 if (thread_.joinable()) { in TEST_F()
294 thread_.join(); in TEST_F()
|
| /system/iorap/src/manager/ |
| D | event_manager.cc | 121 borrowed<observe_on_one_worker*> thread_; // not null member
130 thread_ = thread; in AppLaunchEventState()
131 DCHECK(thread_ != nullptr); in AppLaunchEventState()
252 .observe_on(*thread_) // All work prior to 'observe_on' is handled on thread_. in StartTracing()
253 .subscribe_on(*thread_) // All work prior to 'observe_on' is handled on thread_. in StartTracing()
|