| /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()
|