/base/security/device_auth/deps_adapter/os_adapter/impl/src/ |
D | hc_task_thread.c | 24 static HcTaskBase* PopTask(HcTaskThread* thread) in IMPLEMENT_HC_VECTOR() 26 if (thread == NULL) { in IMPLEMENT_HC_VECTOR() 30 thread->queueLock.lock(&thread->queueLock); in IMPLEMENT_HC_VECTOR() 32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task); in IMPLEMENT_HC_VECTOR() 33 thread->queueLock.unlock(&thread->queueLock); in IMPLEMENT_HC_VECTOR() 40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask() argument 42 if (thread == NULL || task == NULL) { in PushTask() 46 thread->queueLock.lock(&thread->queueLock); in PushTask() 49 thread->tasks.pushBack(&thread->tasks, &taskWarp); in PushTask() 50 thread->thread.notify(&thread->thread); in PushTask() [all …]
|
/base/security/device_auth/deps_adapter/os_adapter/impl/src/linux/ |
D | hc_thread.c | 28 HcThread* thread = (HcThread*)args; in StaticThreadFunc() local 29 if (thread == NULL) { in StaticThreadFunc() 34 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc() 39 thread->stackSize, StringGet(&thread->name)); in StaticThreadFunc() 43 if (thread->threadFunc) { in StaticThreadFunc() 44 thread->threadFunc(args); in StaticThreadFunc() 46 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc() 47 thread->running = HC_FALSE; in StaticThreadFunc() 48 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc() 49 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc() [all …]
|
/base/security/device_auth/deps_adapter/os_adapter/impl/src/liteos/ |
D | hc_thread.c | 24 HcThread *thread = (HcThread*)args; in StaticThreadFunc() local 25 if (thread == NULL) { in StaticThreadFunc() 30 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc() 36 if (thread->threadFunc) { in StaticThreadFunc() 37 thread->threadFunc(args); in StaticThreadFunc() 39 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc() 40 thread->running = HC_FALSE; in StaticThreadFunc() 41 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc() 42 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc() 46 int Start(struct HcThreadT *thread) in Start() argument [all …]
|
/base/hiviewdfx/hiview/test/resource/base/ |
D | plugin_config1 | 3 EngineEventVerify[thread:engine_event_verify]:0 static 4 EventDatabase[thread:event_db]:0 static 9 EventSerialize[thread:event_serialize]:0 static 10 EngineEventSource[thread:engine_event_source]:0 static 11 HiViewEventSource[thread:hiview_event_source]:0 static 15 DailyControl[thread:daily_control]:0 static 16 LogPacking[thread:log_packing]:0 static 17 UeEventVerify[thread:ue_event_verify]:0 static 18 RawEventDatabase[thread:raw_event_db]:0 static 19 ResourceLeakCollector[thread:resource_leak_collector]:0 static [all …]
|
D | bundletest_plugin_config | 2 EventProcessorExample4[thread:t-example-2]:0 static 3 EventProcessorExample1[thread:t-example-4]:0 static 4 EventProcessorExample2[thread:t-example-1]:0 static 5 EventProcessorExample3[thread:t-example-4]:0 static 6 EventSourceExample[thread:t-example-3]:0 static 7 EventProcessorExample5[thread:t-example-4]:0 static
|
D | plugin_config | 2 EventProcessorExample4[thread:t-example-2]:0 static 3 EventProcessorExample1[thread:t-example-4]:0 static 4 EventProcessorExample2[thread:t-example-1]:0 static 5 EventProcessorExample3[thread:t-example-4]:0 static 6 EventSourceExample[thread:t-example-3]:0 static 7 DynamicLoadPluginExample[thread:t-example-5]:0 dynamic
|
D | plugin_config_incomplete | 2 EventProcessorExample1[thread:example-2]:5 static 3 EventProcessorExample2[thread:example-1]:0 static 4 EventProcessorExample3[thread:example-2]:0 static 5 EventProcessorExample4[thread:example-1]:0 static
|
D | bundleplugintest_plugin_config | 2 BundlePluginExample1[thread:t-bundle_example-1]:0 static 3 BundlePluginExample2[thread:t-bundle_example-2]:0 static 4 BundlePluginExample3[thread:t-bundle_example-3]:0 static 5 BundleEventSourceExample[thread:t-event_source]:0 static
|
/base/security/device_auth/deps_adapter/os_adapter/interfaces/liteos/ |
D | hc_thread.h | 28 int (*start)(struct HcThreadT* thread); 29 void(*join)(struct HcThreadT* thread); 30 void (*wait)(struct HcThreadT* thread); 31 void (*notify)(struct HcThreadT* thread); 32 pthread_t thread; member 41 int32_t InitThread(HcThread* thread, ThreadFunc func, size_t stackSize, const char* threadName); 42 void DestroyThread(HcThread* thread);
|
/base/security/device_auth/deps_adapter/os_adapter/interfaces/ |
D | hc_thread.h | 32 int (*start)(struct HcThreadT* thread); 33 void(*join)(struct HcThreadT* thread); 34 void (*wait)(struct HcThreadT* thread); 35 void (*notify)(struct HcThreadT* thread); 36 pthread_t thread; member 45 int32_t InitThread(HcThread* thread, ThreadFunc func, size_t stackSize, const char* threadName); 46 void DestroyThread(HcThread* thread);
|
D | hc_task_thread.h | 34 HcThread thread; member 36 int32_t (*startThread)(struct HcTaskThreadT* thread); 37 void (*pushTask) (struct HcTaskThreadT* thread, HcTaskBase* task); 38 void (*clear) (struct HcTaskThreadT* thread); 39 void (*stopAndClear) (struct HcTaskThreadT* thread); 48 int32_t InitHcTaskThread(HcTaskThread* thread, size_t stackSize, const char* threadName); 49 void DestroyHcTaskThread(HcTaskThread* thread);
|
/base/hiviewdfx/hiview/test/resource/base/holistic_platform/ |
D | plugin_config | 2 EventProcessorExample4[thread:t-example-2]:0 static 3 EventProcessorExample1[thread:t-example-4]:0 static 4 EventProcessorExample2[thread:t-example-1]:0 static 5 EventProcessorExample3[thread:t-example-4]:0 static 6 EventProcessorExample5[thread:t-example-6]:0 static 7 EventSourceExample[thread:t-example-3]:0 static 8 DynamicLoadPluginExample[thread:t-example-5]:0 dynamic
|
/base/hiviewdfx/faultloggerd/tools/process_dump/ |
D | dfx_unwind_remote.cpp | 152 for (auto &thread : process->GetOtherThreads()) { in UnwindOtherThread() local 157 if (isVmProcAttach || thread->Attach(PTRACE_ATTATCH_OTHER_THREAD_TIMEOUT)) { in UnwindOtherThread() 158 Printer::PrintThreadHeaderByConfig(thread); in UnwindOtherThread() 159 auto regs = thread->GetThreadRegs(); in UnwindOtherThread() 162 auto pid = (vmPid != 0 && isVmProcAttach) ? vmPid : thread->threadInfo_.nsTid; in UnwindOtherThread() 164 thread->Detach(); in UnwindOtherThread() 165 thread->SetFrames(unwinder->GetFrames()); in UnwindOtherThread() 169 DFXLOG_INFO("%s, unwind tid(%d) finish.", __func__, thread->threadInfo_.nsTid); in UnwindOtherThread() 170 Printer::PrintThreadBacktraceByConfig(thread); in UnwindOtherThread() 193 for (auto &thread : process->GetOtherThreads()) { in InitOtherThreadRegs() local [all …]
|
D | printer.cpp | 160 void Printer::PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadHeaderByConfig() argument 163 if (DfxConfig::GetConfig().displayBacktrace && thread != nullptr) { in PrintThreadHeaderByConfig() 165 thread->threadInfo_.tid, thread->threadInfo_.threadName.c_str()); in PrintThreadHeaderByConfig() 166 …headerInfo << "Tid:" << thread->threadInfo_.tid << ", Name:" << thread->threadInfo_.threadName << … in PrintThreadHeaderByConfig() 195 void Printer::PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadBacktraceByConfig() argument 197 if (DfxConfig::GetConfig().displayBacktrace && thread != nullptr) { in PrintThreadBacktraceByConfig() 198 const auto& frames = thread->GetFrames(); in PrintThreadBacktraceByConfig() 228 void Printer::PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadRegsByConfig() argument 230 if (thread == nullptr) { in PrintThreadRegsByConfig() 234 auto regs = thread->GetThreadRegs(); in PrintThreadRegsByConfig() [all …]
|
D | printer.h | 40 static void PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread); 41 static void PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread); 42 static void PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread); 44 …intThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread,
|
D | dfx_stack_info_formatter.cpp | 117 Json::Value thread; in GetDumpInfo() local 118 thread["thread_name"] = process_->keyThread_->threadInfo_.threadName; in GetDumpInfo() 119 thread["tid"] = process_->keyThread_->threadInfo_.tid; in GetDumpInfo() 122 thread["frames"] = frames; in GetDumpInfo() 123 jsonInfo.append(thread); in GetDumpInfo() 132 bool DfxStackInfoFormatter::FillFrames(const std::shared_ptr<DfxThread>& thread, in FillFrames() argument 135 if (thread == nullptr) { in FillFrames() 139 const auto& threadFrames = thread->GetFrames(); in FillFrames()
|
/base/hiviewdfx/faultloggerd/test/unittest/process_dump/ |
D | process_dump_test.cpp | 124 auto thread = DfxThread::Create(pid, tid, tid); variable 125 EXPECT_EQ(true, thread != nullptr) << "DfxThreadTest001 failed"; 138 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable 140 thread->SetThreadRegs(inputrefs); 141 std::shared_ptr<DfxRegs> outputrefs = thread->GetThreadRegs(); 156 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable 159 process->keyThread_ = thread; 160 thread->Attach(); 161 thread->SetThreadRegs(DfxRegs::CreateRemoteRegs(pid)); 164 thread->Detach();
|
/base/hiviewdfx/hilog/frameworks/libhilog/socket/ |
D | hilog_input_socket_server.cpp | 35 if (m_serverThread.get_id() != std::thread().get_id()) { in RunServingThread() 39 m_serverThread = std::thread(&HilogInputSocketServer::ServingThread, this); in RunServingThread() 40 if (m_serverThread.get_id() != std::thread().get_id()) { in RunServingThread() 48 if (m_serverThread.get_id() == std::thread().get_id()) { in StopServingThread() 51 std::thread tmp; in StopServingThread()
|
/base/notification/eventhandler/frameworks/eventhandler/src/ |
D | event_runner.cpp | 99 thread_ = std::make_unique<std::thread>(&ThreadCollector::Run, this); in ReclaimCurrentThread() 105 bool Deposit(std::unique_ptr<std::thread> &thread, const ExitFunction &threadExit) in Deposit() argument 107 if ((!thread) || (!thread->joinable()) || (!threadExit)) { in Deposit() 108 auto threadState = thread ? (thread->joinable() ? "active" : "finished") : "null"; in Deposit() 113 auto threadId = thread->get_id(); in Deposit() 124 .thread = std::move(thread), in Deposit() 134 std::unique_ptr<std::thread> thread; member 173 std::unordered_map<std::thread::id, ThreadExitInfo>::iterator it, bool needCallExit = true) in DoReclaimLocked() 194 exitInfo.thread->join(); in DoReclaimLocked() 231 std::vector<std::thread::id> reclaims_; [all …]
|
/base/hiviewdfx/faultloggerd/test/unittest/backtrace/ |
D | backtrace_local_test.cpp | 101 BacktraceLocalThread thread(BACKTRACE_CURRENT_THREAD, unwinder); 102 ASSERT_EQ(true, thread.Unwind(0)); 104 const auto& frames = thread.GetFrames(); 137 std::thread backtraceThread(Test001); 145 BacktraceLocalThread thread(g_tid, unwinder); 146 ASSERT_EQ(true, thread.Unwind(0)); 148 const auto& frames = thread.GetFrames(); 150 auto backtraceStr = thread.GetFormattedStr(false); 175 std::thread backtraceThread(Test001);
|
/base/hiviewdfx/hiview/plugins/ |
D | adft_plugin_config | 2 SysEventSource[thread:sysevent_source]:0 static 3 SysEventStore[thread:sysevent_store]:0 static 4 SysEventDispatcher[thread:sysevent_store]:0 static
|
/base/hiviewdfx/faultloggerd/test/unittest/signal_handler/ |
D | signal_handler_test.cpp | 228 std::thread (TestThread, 1, SIGILL).join(); // 1 : first thread 229 std::thread (TestThread, 2, SIGILL).join(); // 2 : second thread 251 std::thread (TestThread, 1, SIGBUS).join(); // 1 : first thread 252 std::thread (TestThread, 2, SIGBUS).join(); // 2 : second thread 274 std::thread (TestThread, 1, SIGSEGV).join(); // 1 : first thread 275 std::thread (TestThread, 2, SIGSEGV).join(); // 2 : second thread 352 std::vector<std::thread> threads; 355 threads.push_back(std::thread(TestThread2, i, SIGSEGV, testThreadCount, false)); 358 for (auto& thread : threads) { variable 359 thread.join(); [all …]
|
/base/update/updater/services/applypatch/ |
D | update_progress.cpp | 43 void SetProgressExitFlag(pthread_t &thread) in SetProgressExitFlag() argument 46 pthread_join(thread, nullptr); in SetProgressExitFlag() 75 int CreateProgressThread(Uscript::UScriptEnv *env, pthread_t &thread) in CreateProgressThread() argument 79 return pthread_create(&thread, nullptr, OtaUpdateProgressThread, env); in CreateProgressThread()
|
/base/global/resource_management_lite/frameworks/resmgr_lite/test/unittest/lite/common/ |
D | string_utils_test.cpp | 84 std::vector<std::thread> threads; in TestThread() 86 threads.push_back(std::thread(FuncMultiThread, num, lock)); in TestThread() 88 for (auto &thread : threads) { in TestThread() local 89 thread.join(); in TestThread()
|
/base/global/resource_management/frameworks/resmgr/test/unittest/common/ |
D | string_utils_test.cpp | 83 std::vector<std::thread> threads; in TestThread() 85 threads.push_back(std::thread(FuncMultiThread, num, lock)); in TestThread() 87 for (auto &thread : threads) { in TestThread() local 88 thread.join(); in TestThread()
|