Home
last modified time | relevance | path

Searched refs:thread (Results 1 - 25 of 777) sorted by relevance

12345678910>>...32

/base/security/device_auth/deps_adapter/os_adapter/impl/src/linux/
H A Dhc_thread.c31 HcThread* thread = (HcThread*)args; in StaticThreadFunc() local
32 if (thread == NULL) { in StaticThreadFunc()
37 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc()
42 thread->stackSize, StringGet(&thread->name)); in StaticThreadFunc()
46 if (thread->threadFunc) { in StaticThreadFunc()
47 thread->threadFunc(args); in StaticThreadFunc()
49 (void)LockHcMutex(&thread->threadLock); in StaticThreadFunc()
50 thread->running = HC_FALSE; in StaticThreadFunc()
51 thread in StaticThreadFunc()
56 Start(struct HcThreadT *thread) Start() argument
88 Join(struct HcThreadT *thread) Join() argument
100 BizWait(struct HcThreadT *thread) BizWait() argument
108 BizNotify(struct HcThreadT *thread) BizNotify() argument
116 InitThread(HcThread *thread, ThreadFunc func, size_t stackSize, const char *threadName) InitThread() argument
154 DestroyThread(HcThread *thread) DestroyThread() argument
[all...]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/
H A Dhc_task_thread.c24 static HcTaskBase* PopTask(HcTaskThread* thread) in PopTask() argument
26 if (thread == NULL) { in PopTask()
30 (void)LockHcMutex(&thread->queueLock); in PopTask()
32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task); in PopTask()
33 UnlockHcMutex(&thread->queueLock); in PopTask()
40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask() argument
42 if (thread == NULL || task == NULL) { in PushTask()
46 (void)LockHcMutex(&thread->queueLock); in PushTask()
49 thread in PushTask()
54 Clear(struct HcTaskThreadT* thread) Clear() argument
69 StopAndClear(struct HcTaskThreadT* thread) StopAndClear() argument
80 StartTaskThread(struct HcTaskThreadT* thread) StartTaskThread() argument
96 HcTaskThread* thread = (HcTaskThread*)args; TaskThreadLoop() local
121 InitHcTaskThread(HcTaskThread* thread, size_t stackSize, const char* threadName) InitHcTaskThread() argument
144 DestroyHcTaskThread(HcTaskThread* thread) DestroyHcTaskThread() argument
[all...]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/liteos/
H A Dhc_thread.c27 HcThread *thread = (HcThread*)args; in StaticThreadFunc() local
28 if (thread == NULL) { in StaticThreadFunc()
33 int res = pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc()
39 if (thread->threadFunc) { in StaticThreadFunc()
40 thread->threadFunc(args); in StaticThreadFunc()
42 (void)LockHcMutex(&thread->threadLock); in StaticThreadFunc()
43 thread->running = HC_FALSE; in StaticThreadFunc()
44 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc()
45 UnlockHcMutex(&thread in StaticThreadFunc()
49 Start(struct HcThreadT *thread) Start() argument
81 Join(struct HcThreadT *thread) Join() argument
99 BizWait(struct HcThreadT *thread) BizWait() argument
107 BizNotify(struct HcThreadT *thread) BizNotify() argument
115 InitThread(HcThread *thread, ThreadFunc func, size_t stackSize, const char *threadName) InitThread() argument
154 DestroyThread(HcThread *thread) DestroyThread() argument
[all...]
/base/security/device_auth/deps_adapter/os_adapter/interfaces/
H A Dhc_task_thread.h34 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);
H A Dhc_thread.h32 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);
/base/security/device_auth/deps_adapter/os_adapter/interfaces/liteos/
H A Dhc_thread.h28 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/hiviewdfx/hilog/frameworks/libhilog/socket/
H A Dhilog_input_socket_server.cpp23 #include <thread>
35 if (m_serverThread.get_id() != std::thread().get_id()) { in RunServingThread()
39 m_serverThread = std::thread([this]() { in RunServingThread()
42 if (m_serverThread.get_id() != std::thread().get_id()) { in RunServingThread()
50 if (m_serverThread.get_id() == std::thread().get_id()) { in StopServingThread()
53 std::thread tmp; in StopServingThread()
/base/hiviewdfx/faultloggerd/tools/process_dump/
H A Ddfx_unwind_remote.cpp54 void GetThreadKernelStack(std::shared_ptr<DfxThread> thread) in GetThreadKernelStack() argument
57 pid_t tid = thread->threadInfo_.nsTid; in GetThreadKernelStack()
69 thread->SetFrames(threadStack.frames); in GetThreadKernelStack()
94 // dumpt -p -t will not unwind other thread in UnwindProcess()
102 DFXLOGW("%{public}s::unwind vm thread is not initialized.", __func__); in UnwindProcess()
108 DFXLOGW("%{public}s::unwind key thread is not initialized.", __func__); in UnwindProcess()
123 DFXLOGW("success unwind thread cnt is %{public}d", unwCnt); in UnwindProcess()
136 DFXLOGW("%{public}s::unwind thread is not initialized.", __func__); in UnwindKeyThread()
186 for (auto &thread : process->GetOtherThreads()) { in UnwindOtherThread()
191 if (isVmProcAttach || thread in UnwindOtherThread()
[all...]
H A Dprinter.cpp87 headerInfo += "Fault thread info:\n"; in PrintDumpHeader()
88 DfxRingBufferWrapper::GetInstance().AppendMsg("Fault thread info:\n"); in PrintDumpHeader()
146 " current thread stack low address = %" PRIX64_ADDR ", probably caused by stack-buffer-overflow", in PrintReason()
175 DfxRingBufferWrapper::GetInstance().AppendMsg("Other thread info:\n"); in PrintOtherThreadHeaderByConfig()
179 void Printer::PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread) in PrintThreadHeaderByConfig() argument
182 if (DfxConfig::GetConfig().displayBacktrace && thread != nullptr) { in PrintThreadHeaderByConfig()
184 thread->threadInfo_.tid, thread->threadInfo_.threadName.c_str()); in PrintThreadHeaderByConfig()
185 headerInfo = "Tid:" + std::to_string(thread->threadInfo_.tid) + in PrintThreadHeaderByConfig()
186 ", Name:" + thread in PrintThreadHeaderByConfig()
217 PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread) PrintThreadBacktraceByConfig() argument
252 PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread) PrintThreadRegsByConfig() argument
276 PrintThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread, std::shared_ptr<Unwinder> unwinder) PrintThreadFaultStackByConfig() argument
[all...]
H A Ddfx_process.cpp68 DFXLOGD("skip recycle thread:%{public}d.", nstids[i]); in InitOtherThreads()
73 DFXLOGD("skip key thread:%{public}d.", nstids[i]); in InitOtherThreads()
77 auto thread = DfxThread::Create(processInfo_.pid, tids[i], nstids[i]); in InitOtherThreads() local
79 thread->Attach(PTRACE_ATTATCH_OTHER_THREAD_TIMEOUT); in InitOtherThreads()
81 otherThreads_.push_back(thread); in InitOtherThreads()
133 for (auto thread : otherThreads_) { in Attach()
134 if (thread->threadInfo_.nsTid == processInfo_.nsPid) { in Attach()
135 thread->Attach(PTRACE_ATTATCH_KEY_THREAD_TIMEOUT); in Attach()
138 thread->Attach(PTRACE_ATTATCH_OTHER_THREAD_TIMEOUT); in Attach()
148 for (auto thread in Detach()
[all...]
H A Dprinter.h40 static void PrintThreadHeaderByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread);
41 static void PrintThreadBacktraceByConfig(std::shared_ptr<DfxThread> thread, bool isKeyThread);
42 static void PrintThreadRegsByConfig(std::shared_ptr<DfxThread> thread);
44 static void PrintThreadFaultStackByConfig(std::shared_ptr<DfxProcess> process, std::shared_ptr<DfxThread> thread,
H A Ddfx_stack_info_formatter.cpp112 // fill other thread info in GetNativeCrashInfo()
123 Json::Value thread; in GetDumpInfo() local
124 thread["thread_name"] = process_->keyThread_->threadInfo_.threadName; in GetDumpInfo()
125 thread["tid"] = process_->keyThread_->threadInfo_.tid; in GetDumpInfo()
128 thread["frames"] = frames; in GetDumpInfo()
129 jsonInfo.append(thread); in GetDumpInfo()
131 // fill other thread info in GetDumpInfo()
138 bool DfxStackInfoFormatter::FillFrames(const std::shared_ptr<DfxThread>& thread, in FillFrames() argument
141 if (thread == nullptr) { in FillFrames()
142 DFXLOGE("FillFrames thread i in FillFrames()
[all...]
/base/global/resource_management_lite/frameworks/resmgr_lite/test/unittest/lite/common/
H A Dstring_utils_test.cpp19 #include <thread>
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()
89 thread.join(); in TestThread()
/base/update/updater/services/applypatch/
H A Dupdate_progress.cpp18 #include <thread>
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/update/updater/test/unittest/applypatch_test/
H A Dupdate_progress_unittest.cpp18 #include <thread>
62 pthread_t thread; in HWTEST_F() local
63 EXPECT_EQ(CreateProgressThread(&env, thread), 0); in HWTEST_F()
68 SetProgressExitFlag(thread); in HWTEST_F()
/base/inputmethod/imf/frameworks/js/napi/common/
H A Djs_callback_object.h18 #include <thread>
28 JSCallbackObject(napi_env env, napi_value callback, std::thread::id threadId);
32 std::thread::id threadId_;
/base/notification/eventhandler/frameworks/eventhandler/src/
H A Devent_runner.cpp21 #include <thread>
52 // Invoke system call to set name of current thread.
58 HILOGE("Failed to set thread name, %{public}s", errmsg); in SystemCallSetThreadName()
60 HILOGD("thread name is %{public}s", name.c_str()); in SystemCallSetThreadName()
71 // Thread collector is used to reclaim thread that needs to finish running.
82 // Get id of current thread. in ReclaimCurrentThread()
87 // Add thread id to list and notify to reclaim. in ReclaimCurrentThread()
102 // Start daemon thread to collect finished threads, if not exist. in ReclaimCurrentThread()
103 thread_ = std::make_unique<std::thread>(&ThreadCollector::Run, this); in ReclaimCurrentThread()
109 bool Deposit(std::unique_ptr<std::thread> argument
138 std::unique_ptr<std::thread> thread; global() member
429 Attach(std::unique_ptr<std::thread> &thread) Attach() argument
620 auto thread = Create() local
680 auto thread = StartRunningForNoWait() local
[all...]
/base/hiviewdfx/faultloggerd/test/unittest/process_dump/
H A Dprocess_dump_test.cpp167 auto thread = DfxThread::Create(pid, tid, tid); in HWTEST_F() local
168 EXPECT_EQ(true, thread != nullptr) << "DfxThreadTest001 failed"; in HWTEST_F()
181 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); in HWTEST_F() local
183 thread->SetThreadRegs(inputrefs); in HWTEST_F()
184 std::shared_ptr<DfxRegs> outputrefs = thread->GetThreadRegs(); in HWTEST_F()
199 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); in HWTEST_F() local
202 process->keyThread_ = thread; in HWTEST_F()
203 thread->Attach(); in HWTEST_F()
204 thread->SetThreadRegs(DfxRegs::CreateRemoteRegs(pid)); in HWTEST_F()
207 thread in HWTEST_F()
231 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); HWTEST_F() local
290 std::shared_ptr<DfxThread> thread = DfxThread::Create(pid, tid, tid); HWTEST_F() local
[all...]
/base/hiviewdfx/faultloggerd/tools/crasher_cpp/faults/
H A Dmulti_thread_container_access.cpp24 #include <thread>
37 std::vector<std::thread> threads; in MultiThreadVectorAccess()
39 std::thread th( in MultiThreadVectorAccess()
59 std::vector<std::thread> threads; in MultiThreadMapAccess()
61 std::thread th( in MultiThreadMapAccess()
81 std::vector<std::thread> threads; in MultiThreadListAccess()
83 std::thread th( in MultiThreadListAccess()
/base/security/device_security_level/services/sa/standard/
H A Ddslm_service.cpp19 #include <thread>
44 std::thread thread([this]() { in OnStart()
52 thread.detach(); in OnStart()
/base/hiviewdfx/faultloggerd/interfaces/innerkits/backtrace/
H A Dbacktrace_local.cpp66 BacktraceLocalThread thread(tid, unwinder); in GetBacktraceFramesByTid()
67 bool ret = thread.Unwind(fast, maxFrameNums, skipFrameNum + 1); in GetBacktraceFramesByTid()
68 frames = thread.GetFrames(); in GetBacktraceFramesByTid()
154 BacktraceLocalThread thread(tid, unwinder); in GetProcessStacktrace()
155 if (thread.Unwind(false, maxFrameNums, 0)) { in GetProcessStacktrace()
156 ss += thread.GetFormattedStr(true) + "\n"; in GetProcessStacktrace()
161 thread.SetFrames(threadStack.frames); in GetProcessStacktrace()
162 ss += thread.GetFormattedStr(true) + "\n"; in GetProcessStacktrace()
/base/hiviewdfx/faultloggerd/test/unittest/signal_handler/
H A Dsignal_handler_test.cpp21 #include <thread>
115 char mes[] = "this is cash information of test thread"; in ThreadInfo()
117 GTEST_LOG_(INFO) << "Failed to set thread info"; in ThreadInfo()
138 * @tc.desc: test thread cash SignalHandler signo(SIGILL)
165 * @tc.desc: test thread cash SignalHandler signo(SIGBUS)
192 * @tc.desc: test thread cash SignalHandler signo(SIGSEGV)
219 * @tc.desc: test thread crash SignalHandler in multi-thread situation signo(SIGILL)
229 std::thread (TestThread, 1, SIGILL).join(); // 1 : first thread in HWTEST_F()
[all...]
/base/hiviewdfx/faultloggerd/test/unittest/backtrace/
H A Dbacktrace_local_test.cpp22 #include <thread>
98 * @tc.desc: test get backtrace of current thread
106 BacktraceLocalThread thread(BACKTRACE_CURRENT_THREAD, unwinder); in HWTEST_F()
107 ASSERT_EQ(true, thread.Unwind(false)); in HWTEST_F()
109 const auto& frames = thread.GetFrames(); in HWTEST_F()
111 GTEST_LOG_(INFO) << thread.GetFormattedStr(); in HWTEST_F()
133 * @tc.desc: test get backtrace of a child thread
140 std::thread backtraceThread(Test001); in HWTEST_F()
143 FAIL() << "Failed to create child thread.\n"; in HWTEST_F()
148 BacktraceLocalThread thread(g_ti in HWTEST_F()
[all...]
/base/hiviewdfx/hilog/services/hilogd/
H A Dcmd_executor.cpp20 #include <thread>
73 newVal->m_clientThread = std::thread([this](std::unique_ptr<Socket> handler) { in OnAcceptedConnection()
105 std::list<std::thread> threadsToJoin; in CleanFinishedClients()
121 for (auto& thread : threadsToJoin) { in CleanFinishedClients()
122 if (thread.joinable()) { in CleanFinishedClients()
123 thread.join(); in CleanFinishedClients()
/base/update/updater/services/include/applypatch/
H A Dupdate_progress.h25 void SetProgressExitFlag(pthread_t &thread);
27 int32_t CreateProgressThread(Uscript::UScriptEnv *env, pthread_t &thread);

Completed in 11 milliseconds

12345678910>>...32