Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 175) sorted by relevance

1234567

/base/security/device_auth/deps_adapter/os_adapter/impl/src/linux/
Dhc_thread.c28 HcThread* thread = (HcThread*)args; in StaticThreadFunc() local
29 if (thread == NULL) { in StaticThreadFunc()
33 if (thread->threadFunc) { in StaticThreadFunc()
34 thread->threadFunc(args); in StaticThreadFunc()
36 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc()
37 thread->running = HC_FALSE; in StaticThreadFunc()
38 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc()
39 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc()
43 int Start(struct HcThreadT* thread) in Start() argument
45 if (thread == NULL) { in Start()
[all …]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/liteos/
Dhc_thread.c22 HcThread *thread = (HcThread*)args; in StaticThreadFunc() local
23 if (thread == NULL) { in StaticThreadFunc()
27 (void)pthread_setname_np(pthread_self(), StringGet(&thread->name)); in StaticThreadFunc()
29 if (thread->threadFunc) { in StaticThreadFunc()
30 thread->threadFunc(args); in StaticThreadFunc()
32 thread->threadLock.lock(&thread->threadLock); in StaticThreadFunc()
33 thread->running = HC_FALSE; in StaticThreadFunc()
34 thread->threadWaitObj.notifyWithoutLock(&thread->threadWaitObj); in StaticThreadFunc()
35 thread->threadLock.unlock(&thread->threadLock); in StaticThreadFunc()
39 int Start(struct HcThreadT *thread) in Start() argument
[all …]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/
Dhc_task_thread.c24 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/hiviewdfx/hiview/test/resource/base/
Dplugin_config13 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 …]
Dplugin_config2 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
Dbundletest_plugin_config2 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
Dplugin_config_incomplete2 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
Dbundleplugintest_plugin_config2 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/
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/security/device_auth/deps_adapter/os_adapter/interfaces/
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);
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);
44 int32_t InitHcTaskThread(HcTaskThread* thread, size_t stackSize, const char* threadName);
45 void DestroyHcTaskThread(HcTaskThread* thread);
/base/hiviewdfx/hiview/test/resource/base/holistic_platform/
Dplugin_config2 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/
Ddfx_unwind_remote.cpp100 for (auto thread : threads) { in UnwindProcess() local
108 if (thread->Attach()) { in UnwindProcess()
109 UnwindThread(process, thread); in UnwindProcess()
110 thread->Detach(); in UnwindProcess()
113 if (thread->GetIsCrashThread() && (!process->GetIsSignalDump())) { in UnwindProcess()
167 std::shared_ptr<DfxThread> & thread, unw_cursor_t & cursor, std::shared_ptr<DfxProcess> process) in DfxUnwindRemoteDoUnwindStep() argument
207 ret = UpdateAndPrintFrameInfo(cursor, thread, frame, in DfxUnwindRemoteDoUnwindStep()
208 (thread->GetIsCrashThread() && !process->GetIsSignalDump())); in DfxUnwindRemoteDoUnwindStep()
210 thread->AddFrame(frame); in DfxUnwindRemoteDoUnwindStep()
217 …l DfxUnwindRemote::UpdateAndPrintFrameInfo(unw_cursor_t& cursor, std::shared_ptr<DfxThread> thread, in UpdateAndPrintFrameInfo() argument
[all …]
Ddfx_unwind_remote.h43 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);
48 … std::shared_ptr<DfxThread> & thread, unw_cursor_t & cursor, std::shared_ptr<DfxProcess> process);
50 bool UpdateAndPrintFrameInfo(unw_cursor_t& cursor, std::shared_ptr<DfxThread> thread,
/base/notification/eventhandler/frameworks/eventhandler/src/
Devent_runner.cpp88 thread_ = std::make_unique<std::thread>(&ThreadCollector::Run, this); in ReclaimCurrentThread()
94 bool Deposit(std::unique_ptr<std::thread> &thread, const ExitFunction &threadExit) in Deposit() argument
96 if ((!thread) || (!thread->joinable()) || (!threadExit)) { in Deposit()
97 auto threadState = thread ? (thread->joinable() ? "active" : "finished") : "null"; in Deposit()
102 auto threadId = thread->get_id(); in Deposit()
113 .thread = std::move(thread), in Deposit()
123 std::unique_ptr<std::thread> thread; member
160 std::unordered_map<std::thread::id, ThreadExitInfo>::iterator it, bool needCallExit = true) in DoReclaimLocked()
181 exitInfo.thread->join(); in DoReclaimLocked()
218 std::vector<std::thread::id> reclaims_;
[all …]
/base/hiviewdfx/hilog/frameworks/libhilog/socket/
Dhilog_input_socket_server.cpp35 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/global/resource_management/frameworks/resmgr/test/unittest/common/
Dstring_utils_test.cpp83 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()
/base/global/resource_management_lite/frameworks/resmgr_lite/test/unittest/lite/common/
Dstring_utils_test.cpp84 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/update/updater/services/ui/
Dupdater_ui.cpp104 std::thread { in OnRebootEvt()
126 std::thread { in OnLabelSDCardEvt()
150 std::thread { in OnLabelSDCardNoDelayEvt()
183 std::thread { in OnLabelOkEvt()
210 std::thread { in OnConfirmRstEvt()
236 std::thread { in OnMenuShutdownEvt()
248 std::thread { in OnMenuClearCacheEvt()
274 std::thread t { [lastdownCount = downCount] () { in StartLongPressTimer()
/base/hiviewdfx/hilog/services/hilogd/
Dcmd_executor.cpp73 … newVal->m_clientThread = std::thread(&CmdExecutor::ClientEventLoop, this, std::move(handler)); in OnAcceptedConnection()
103 std::list<std::thread> threadsToJoin; in CleanFinishedClients()
119 for (auto& thread : threadsToJoin) { in CleanFinishedClients() local
120 if (thread.joinable()) { in CleanFinishedClients()
121 thread.join(); in CleanFinishedClients()
/base/security/device_security_level/services/sa/standard/
Ddslm_service.cpp43 std::thread thread([this]() { in OnStart() local
51 thread.detach(); in OnStart()
/base/hiviewdfx/faultloggerd/test/unittest/process_dump/src/
Dprocess_dump_test.cpp600 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid, context); variable
601 pid_t processID = thread->GetProcessId();
617 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid, context); variable
618 pid_t threadId = thread->GetThreadId();
633 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable
634 pid_t threadId = thread->GetThreadId();
648 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable
649 std::string threadName = thread->GetThreadName();
664 std::shared_ptr<DfxThread> thread = std::make_shared<DfxThread>(pid, tid, tid); variable
666 thread->SetThreadRegs(inputrefs);
[all …]
/base/inputmethod/imf/interfaces/kits/js/napi/inputmethodability/
Djs_callback_object.h27 JSCallbackObject(napi_env env, napi_value callback, std::thread::id threadId);
31 std::thread::id threadId_;
/base/startup/init/test/moduletest/
Dparam_test_cmds.c66 static pthread_t thread = 0; in BShellParamCmdRead() local
67 PLUGIN_LOGV("BShellParamCmdWatch %s, threadId %d", argv[1], thread); in BShellParamCmdRead()
69 if (thread != 0) { in BShellParamCmdRead()
73 pthread_create(&thread, NULL, CmdReader, argv[1]); in BShellParamCmdRead()
75 if (thread == 0) { in BShellParamCmdRead()
80 pthread_join(thread, NULL); in BShellParamCmdRead()
81 thread = 0; in BShellParamCmdRead()
88 pthread_t thread; member
173 pthread_create(&context[i]->thread, NULL, CmdThreadWatcher, context[i]); in StartWatcherInThread()
Dsyspara_moduleTest.cpp146 std::thread(GetAllParameterTestFunc).join();
156 std::thread(GetUdidTestFunc, udid, UDID_LEN).join();
170 std::thread(SetParameterTestFunc, key1, value1).join();
171 std::thread(SetParameterTestFunc, key2, value2).join();
172 std::thread(SetParameterTestFunc, key3, value3).join();
314 std::thread(GetParameterTestReInt, key.c_str(), "", retValue, PARAM_VALUE_LEN_MAX).join();
317 std::thread(GetParameterTestFuncReStr, key, "").join();
335 std::thread(ParamSetFun, key1, value1).join();
339 std::thread(ParamSetFun, key2, "*****").join();
353 std::thread(TestParameterWatchChange).join();
[all …]

1234567