| /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()
33 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc()
38 if (thread->threadFunc) { in StaticThreadFunc()
39 thread->threadFunc(args); in StaticThreadFunc()
41 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc()
42 thread->running = HC_FALSE; in StaticThreadFunc()
43 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc()
44 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc()
48 int Start(struct HcThreadT *thread) in Start() argument
[all …]
|
| /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/liteos/ |
| D | hc_thread.c | 24 HcThread *thread = (HcThread*)args; in StaticThreadFunc() local
25 if (thread == NULL) { in StaticThreadFunc()
29 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc()
34 if (thread->threadFunc) { in StaticThreadFunc()
35 thread->threadFunc(args); in StaticThreadFunc()
37 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc()
38 thread->running = HC_FALSE; in StaticThreadFunc()
39 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc()
40 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc()
44 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/test/unittest/process_dump/ |
| D | process_dump_test.cpp | 142 auto thread = DfxThread::Create(pid, tid, tid); variable
143 EXPECT_EQ(true, thread != nullptr) << "DfxThreadTest001 failed";
156 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable
158 thread->SetThreadRegs(inputrefs);
159 std::shared_ptr<DfxRegs> outputrefs = thread->GetThreadRegs();
174 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable
176 process->keyThread_ = thread;
177 thread->Attach();
179 thread->Detach();
194 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); variable
[all …]
|
| /base/hiviewdfx/faultloggerd/tools/process_dump/ |
| D | printer.cpp | 88 void Printer::PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadHeaderByConfig() argument
92 thread->threadInfo_.tid, thread->threadInfo_.threadName.c_str()); in PrintThreadHeaderByConfig()
96 void Printer::PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadBacktraceByConfig() argument
99 const auto& frames = thread->GetFrames(); in PrintThreadBacktraceByConfig()
101 DFXLOG_WARN("Tid:%d frame is null", thread->threadInfo_.tid); in PrintThreadBacktraceByConfig()
110 void Printer::PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread) in PrintThreadRegsByConfig() argument
113 std::shared_ptr<DfxRegs> regs = thread->GetThreadRegs(); in PrintThreadRegsByConfig()
120 …intThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread) in PrintThreadFaultStackByConfig() argument
123 auto faultstack = std::unique_ptr<FaultStack>(new FaultStack(thread->threadInfo_.nsTid)); in PrintThreadFaultStackByConfig()
127 faultstack->CollectStackInfo(thread->GetFrames()); in PrintThreadFaultStackByConfig()
[all …]
|
| D | dfx_unwind_remote.cpp | 110 for (auto thread : threads) { in UnwindProcess() local
119 if (thread->Attach()) { in UnwindProcess()
120 Printer::PrintThreadHeaderByConfig(thread); in UnwindProcess()
121 UnwindThread(process, thread); in UnwindProcess()
122 thread->Detach(); in UnwindProcess()
179 std::shared_ptr<DfxThread>& thread, unw_cursor_t& cursor, std::shared_ptr<DfxProcess> process) in DoUnwindStep() argument
218 ret = UpdateAndFillFrame(cursor, frame, thread, ProcessDumper::GetInstance().IsCrash()); in DoUnwindStep()
220 thread->AddFrame(frame); in DoUnwindStep()
228 std::shared_ptr<DfxThread> thread, bool enableBuildId) in UpdateAndFillFrame() argument
238 isGetFuncName = GetArkJsHeapFuncName(funcName, thread); in UpdateAndFillFrame()
[all …]
|
| D | printer.h | 34 static void PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread);
35 static void PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread);
36 static void PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread);
37 …ntThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread);
|
| D | dfx_unwind_remote.h | 43 bool UnwindThread(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread);
44 … void UnwindThreadFallback(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread);
45 bool GetArkJsHeapFuncName(std::string& funcName, std::shared_ptr<DfxThread> thread);
49 … std::shared_ptr<DfxThread> &thread, unw_cursor_t &cursor, std::shared_ptr<DfxProcess> process);
52 std::shared_ptr<DfxThread> thread, bool enableBuildId);
|
| D | dfx_process.cpp | 74 auto thread = DfxThread::Create(processInfo_.pid, tids[i], nstids[i]); in InitOtherThreads() local
76 thread->Attach(); in InitOtherThreads()
78 otherThreads_.push_back(thread); in InitOtherThreads()
130 for (auto thread : otherThreads_) { in Attach() local
131 thread->Attach(); in Attach()
141 for (auto thread : otherThreads_) { in Detach() local
142 thread->Detach(); in Detach()
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| D | event_runner.cpp | 91 thread_ = std::make_unique<std::thread>(&ThreadCollector::Run, this); in ReclaimCurrentThread()
97 bool Deposit(std::unique_ptr<std::thread> &thread, const ExitFunction &threadExit) in Deposit() argument
99 if ((!thread) || (!thread->joinable()) || (!threadExit)) { in Deposit()
100 auto threadState = thread ? (thread->joinable() ? "active" : "finished") : "null"; in Deposit()
105 auto threadId = thread->get_id(); in Deposit()
116 .thread = std::move(thread), in Deposit()
126 std::unique_ptr<std::thread> thread; member
163 std::unordered_map<std::thread::id, ThreadExitInfo>::iterator it, bool needCallExit = true) in DoReclaimLocked()
184 exitInfo.thread->join(); in DoReclaimLocked()
221 std::vector<std::thread::id> reclaims_;
[all …]
|
| /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/hiviewdfx/faultloggerd/interfaces/innerkits/callstack/src/ |
| D | callstack.cpp | 79 const VirtualThread &thread) in fillUDI() argument
117 const int32_t ehFrameMmapIndex = thread.FindMapByOffset(curMemMaps, ehFrameHdrElfOffset); in fillUDI()
140 const int32_t targetIndex = thread.FindMapByOffset(curMemMaps, SectionFileOffset); in fillUDI()
166 const VirtualThread &thread) in fillUDI() argument
203 const MemMapItem *ehFrameMmap = thread.FindMapByFileInfo(mmap.name_, ehFrameHdrElfOffset); in fillUDI()
225 const MemMapItem *targetMmap = thread.FindMapByFileInfo(mmap.name_, SectionFileOffset); in fillUDI()
266 if (dynInfoProcessMap.find(unwindInfoPtr->thread.pid_) == dynInfoProcessMap.end()) {
267 dynInfoProcessMap.emplace(unwindInfoPtr->thread.pid_, dsoUnwDynInfoMap {});
269 dsoUnwDynInfoMap &dynFileMap = dynInfoProcessMap[unwindInfoPtr->thread.pid_];
288 if (fillUDI(newdi, *symbolsFile, curMemMapsPair, unwindInfoPtr->thread)) {
[all …]
|
| /base/hiviewdfx/faultloggerd/interfaces/innerkits/backtrace/ |
| D | backtrace_local.cpp | 48 BacktraceLocalThread thread(tid); in GetBacktraceFramesByTid() local
51 ret = thread.Unwind(nullptr, nullptr, skipFrameNum, fast); in GetBacktraceFramesByTid()
62 ret = thread.Unwind(as, symbol, skipFrameNum, fast); in GetBacktraceFramesByTid()
67 frames = thread.GetFrames(); in GetBacktraceFramesByTid()
154 BacktraceLocalThread thread(tid); in GetProcessStacktrace() local
155 if (thread.Unwind(as, symbol, 0)) { in GetProcessStacktrace()
156 ss << thread.GetFormatedStr(true) << std::endl; in GetProcessStacktrace()
|
| D | catchframe_local.cpp | 158 BacktraceLocalThread thread(BACKTRACE_CURRENT_THREAD); in CatchFrameCurrTid() local
159 if (!thread.Unwind(as_, symbol_, skipFrameNum, false, releaseThread)) { in CatchFrameCurrTid()
164 frames = thread.GetFrames(); in CatchFrameCurrTid()
173 BacktraceLocalThread thread(tid); in CatchFrameLocalTid() local
174 if (!thread.Unwind(as_, symbol_, skipFrameNum, false, releaseThread)) { in CatchFrameLocalTid()
179 frames = thread.GetFrames(); in CatchFrameLocalTid()
|
| /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()
|