| /ohos5.0/base/hiviewdfx/faultloggerd/tools/process_dump/ |
| H A D | dfx_unwind_async_thread.cpp | 36 if (unwinder_ == nullptr || thread_ == nullptr) { in UnwindStack()
42 auto regs = thread_->GetThreadRegs(); in UnwindStack()
44 pid_t tid = thread_->threadInfo_.nsTid; in UnwindStack()
58 thread_->SetFrames(unwinder_->GetFrames()); in UnwindStack()
69 thread_->SetFrames(unwinder_->GetFrames()); in UnwindStack()
73 thread_->Detach(); in UnwindStack()
119 auto frames = thread_->GetFrames(); in MergeStack()
121 thread_->SetFrames(frames); in MergeStack()
170 auto frames = thread_->GetFrames(); in UnwindThreadByParseStackIfNeed()
176 thread_->InitFaultStack(needParseStack); in UnwindThreadByParseStackIfNeed()
[all …]
|
| /ohos5.0/foundation/filemanagement/dfs_service/utils/system/include/ |
| H A D | dfsu_thread.h | 44 if (thread_ != nullptr) { in Run()
55 if (thread_ != nullptr) {
59 thread_ = std::make_unique<std::thread>([this, task, interval, retryTimes] {
79 if (thread_ != nullptr) {
104 if (thread_ == nullptr) { in Stop()
113 if (thread_->joinable()) { in Stop()
114 thread_->join(); in Stop()
116 thread_ = nullptr; in Stop()
122 if (thread_ == nullptr) {
125 return thread_->get_id() == id;
[all …]
|
| /ohos5.0/foundation/ai/intelligent_voice_framework/utils/ |
| H A D | thread_wrapper.cpp | 30 if (thread_ != nullptr) { in Start()
37 …thread_ = std::make_unique<ffrt::thread>(name.c_str(), Convert2FfrtQos(qos), &ThreadWrapper::RunIn… in Start()
40 thread_ = std::make_unique<std::thread>(&ThreadWrapper::RunInThread, this); in Start()
43 if (thread_ == nullptr) { in Start()
49 pthread_setname_np(thread_->native_handle(), name.c_str()); in Start()
57 if (thread_ == nullptr) { in Join()
60 if (thread_->joinable()) { in Join()
62 thread_->join(); in Join()
65 thread_.reset(); in Join()
|
| /ohos5.0/foundation/ai/ai_engine/services/common/platform/threadpool/source/ |
| H A D | thread.cpp | 26 IWorker::IWorker() : counter_(0), thread_(nullptr), status_(IDLE) in IWorker()
32 thread_ = nullptr; in ~IWorker()
37 CHK_RET(thread_ == nullptr, RETCODE_FAILURE); in GetThreadId()
38 return thread_->GetThreadId(); in GetThreadId()
44 InitThread(thread_); in Thread()
103 int retCode = CreateOneThread(thread_, pattr, Thread::ThreadProc, this); in StartThread()
211 return GetThreadIdUnix(thread_); in GetThreadId()
229 (void)WaitThread(thread_); in WaitForEnd()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | picture_manager_thread.cpp | 40 : thread_(nullptr), in PictureManagerThread()
67 if (thread_ == nullptr) { in Start()
68 thread_ = std::make_unique<std::thread>(&PictureManagerThread::Run, this); in Start()
78 if (thread_ != nullptr) { in Stop()
82 if (thread_->joinable()) { in Stop()
83 thread_->join(); // wait for thread finished in Stop()
85 thread_ = nullptr; in Stop()
93 if (thread_ != nullptr) { in Pause()
102 if (thread_ != nullptr) { in Resume()
|
| /ohos5.0/foundation/multimedia/player_framework/services/utils/ |
| H A D | watchdog.cpp | 44 thread_ = std::make_unique<std::thread>([this] () -> void { this->WatchDogThread(); }); in EnableWatchDog()
57 if (thread_ != nullptr && thread_->joinable()) { in DisableWatchDog()
58 thread_->join(); in DisableWatchDog()
59 thread_.reset(); in DisableWatchDog()
60 thread_ = nullptr; in DisableWatchDog()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/ |
| H A D | dispatcher.cpp | 36 thread_ = std::make_unique<std::thread>(&Dispatcher::Run, this, std::move(startPromise)); in Initialize()
47 if (thread_ && thread_->joinable()) { in Uninitialize()
48 thread_->join(); in Uninitialize()
49 thread_ = nullptr; in Uninitialize()
|
| /ohos5.0/foundation/communication/nfc/services/src/utils/ |
| H A D | nfc_watch_dog.cpp | 23 …: threadName_(threadName), timeout_(timeout), canceled_(false), thread_(nullptr), nciNfccProxy_(nf… in NfcWatchDog()
29 if (thread_ && thread_->joinable()) { in ~NfcWatchDog()
31 thread_->join(); in ~NfcWatchDog()
68 thread_ = std::make_unique<std::thread>([this]() { this->MainLoop(); }); in Run()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine.cpp | 33 thread_(thread), in Engine()
90 bool isStarted = thread_->StartThread(&worker_); in Initialize()
102 if (thread_) { in Uninitialize()
103 thread_->StopThread(); in Uninitialize()
106 threadPool->Push(thread_); in Uninitialize()
107 thread_ = nullptr; in Uninitialize()
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/monitor/server/ |
| H A D | monitor_server.cpp | 44 if (thread_ != nullptr) { in ~MonitorServer()
45 if (thread_->joinable()) { in ~MonitorServer()
47 thread_->join(); in ~MonitorServer()
49 thread_.reset(); in ~MonitorServer()
50 thread_ = nullptr; in ~MonitorServer()
130 if (thread_ != nullptr) { in EnableMonitor()
131 if (thread_->joinable()) { in EnableMonitor()
132 thread_->join(); in EnableMonitor()
134 thread_.reset(); in EnableMonitor()
135 thread_ = nullptr; in EnableMonitor()
[all …]
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
| H A D | worker_thread.h | 117 int ret = pthread_create(&thread_, &attr_, ThreadFunc, args); in Start()
124 ret = pthread_create(&thread_, &attr_, ThreadFunc, args); in Start()
137 pthread_join(thread_, nullptr); in Join()
145 pthread_detach(thread_); in Detach()
154 return this->thread_; in GetThread()
203 pthread_t thread_{0};
|
| /ohos5.0/commonlibrary/c_utils/base/src/ |
| H A D | thread_ex.cpp | 98 : thread_(INVALID_PTHREAD_T), status_(ThreadStatus::OK), exitPending_(false), running_(false) in Thread()
116 thread_ = INVALID_PTHREAD_T; in Start()
125 bool res = CreatePThread(para, stack, &thread_); in Start()
129 thread_ = INVALID_PTHREAD_T; in Start()
139 if (pthread_equal(thread_, pthread_self()) != 0) { in NotifyExitSync()
200 self->thread_ = INVALID_PTHREAD_T; in ThreadStart()
|
| H A D | timer.cpp | 40 if (thread_.joinable()) { // avoid double assign to an active thread in Setup()
45 thread_.swap(loop_thread); in Setup()
52 if (!thread_.joinable()) { in Shutdown()
71 thread_.detach(); in Shutdown()
76 thread_.detach(); in Shutdown()
79 thread_.join(); in Shutdown()
|
| /ohos5.0/drivers/peripheral/input/ddk_service/src/emit_event_manager/ |
| H A D | inject_thread.cpp | 34 if (thread_.joinable()) { in ~InjectThread()
35 thread_.join(); in ~InjectThread()
41 thread_ = std::thread([this] {this->RunThread(this);}); in Start()
42 pthread_setname_np(thread_.native_handle(), "emitEvent"); in Start()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netconnmanager/src/ |
| H A D | probe_thread.cpp | 65 if (thread_.joinable()) { in ~ProbeThread()
66 thread_.join(); in ~ProbeThread()
75 thread_ = std::thread([probeThead] { return NetProbeThread(probeThead);}); in Start()
77 pthread_setname_np(thread_.native_handle(), threadName.c_str()); in Start()
78 thread_.detach(); in Start()
|
| /ohos5.0/drivers/peripheral/display/hal/default_standard/src/display_device/vsync/ |
| H A D | sorft_vsync.cpp | 28 thread_ = std::make_unique<std::thread>([this]() { WorkThread(); }); in Init()
29 … DISPLAY_CHK_RETURN((thread_ == nullptr), DISPLAY_FAILURE, DISPLAY_LOGE("can not create thread")); in Init()
55 if (thread_ != nullptr) { in ~SorftVsync()
56 thread_->join(); in ~SorftVsync()
|
| /ohos5.0/drivers/peripheral/bluetooth/hci/hdi_service/implement/ |
| H A D | hci_watcher.cpp | 80 thread_ = std::thread(std::bind(&HciWatcher::WatcherThread, this)); in Start()
81 if (!thread_.joinable()) { in Start()
89 if (pthread_setschedparam(thread_.native_handle(), policy, ¶ms) != 0) { in Start()
90 … HDF_LOGW("pthread_setschedparam failed tid[%lu] policy[%d]", thread_.native_handle(), policy); in Start()
103 thread_.join(); in Stop()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket_listener.cpp | 51 thread_ = std::make_unique<std::thread>(&SocketThread::OnListenEvents, this); in Initialize()
61 if (thread_ && thread_->joinable()) { in Uninitialize()
62 thread_->join(); in Uninitialize()
63 thread_ = nullptr; in Uninitialize()
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor.h | 59 : thread_([this, name] { in Executor()
66 thread_.detach();
70 : thread_([this] { in Executor()
76 thread_.detach();
136 std::thread thread_; variable
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | threaded_task_queue.cpp | 52 thread_ = std::thread([this]() { ProcessTasks(); }); in Build()
69 if (thread_.joinable()) { in Shutdown()
70 thread_.join(); in Shutdown()
125 std::thread thread_; member in ThreadedTaskQueue
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/internal/ |
| H A D | timer_linux.cpp | 51 std::unique_ptr<std::thread> thread_ {}; member in utility::TimerManager
64 thread_ = std::make_unique<std::thread>(&TimerManager::OnTimer, this, std::move(startPromise)); in TimerManager()
71 if (thread_ && thread_->joinable()) { in ~TimerManager()
72 thread_->join(); in ~TimerManager()
|
| /ohos5.0/base/msdp/device_status/libs/src/ |
| H A D | devicestatus_msdp_mock.cpp | 58 if (thread_.joinable()) { in ~DeviceStatusMsdpMock()
59 thread_.join(); in ~DeviceStatusMsdpMock()
98 if (thread_.joinable()) { in Disable()
99 thread_.join(); in Disable()
234 thread_ = std::thread([this] { this->LoopingThreadEntry(); }); in StartThread()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_client/unittest/pipeline/ |
| H A D | rs_render_thread_test.cpp | 345 RSRenderThread::Instance().thread_ = nullptr;
350 EXPECT_TRUE(RSRenderThread::Instance().thread_);
356 EXPECT_TRUE(RSRenderThread::Instance().thread_);
368 EXPECT_TRUE(RSRenderThread::Instance().thread_);
371 EXPECT_TRUE(RSRenderThread::Instance().thread_);
374 EXPECT_TRUE(RSRenderThread::Instance().thread_);
377 EXPECT_TRUE(RSRenderThread::Instance().thread_);
|
| /ohos5.0/foundation/ai/ai_engine/services/common/platform/threadpool/include/ |
| H A D | thread.h | 114 thread_ = thread; in SetThread()
122 Thread *thread_;
196 PthreadData thread_; variable
|
| /ohos5.0/foundation/multimedia/player_framework/services/dfx/ |
| H A D | dfx_log_dump.cpp | 37 thread_ = std::make_unique<std::thread>([this] () -> void { this->TaskProcessor(); }); in DfxLogDump()
47 if (thread_ != nullptr && thread_->joinable()) { in ~DfxLogDump()
48 thread_->join(); in ~DfxLogDump()
|