Home
last modified time | relevance | path

Searched refs:threadId (Results 1 - 25 of 32) sorted by relevance

12

/base/hiviewdfx/hisysevent/interfaces/js/kits/napi/include/
H A Dnapi_callback_context.h27 using CALLBACK_FUNC = std::function<void(const napi_env, const napi_ref, pid_t threadId)>;
28 using RELEASE_FUNC = std::function<void(pid_t threadId)>;
34 pid_t threadId; member
/base/hiviewdfx/hisysevent/interfaces/js/kits/napi/src/
H A Dnapi_hisysevent_querier.cpp48 if (callbackContext->threadId == getproctid()) { in ~NapiHiSysEventQuerier()
58 [this, sysEvents, seq] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnQuery()
59 if (threadId != getproctid()) { in OnQuery()
81 [this, reason, total, seq] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnComplete()
82 if (threadId != getproctid()) { in OnComplete()
101 }, [this] (pid_t threadId) { in OnComplete()
102 if (threadId != getproctid()) { in OnComplete()
H A Dnapi_hisysevent_listener.cpp47 if (callbackContext->threadId == getproctid()) { in ~NapiHiSysEventListener()
57 [this, domain, eventName, eventType, eventDetail] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnEvent()
58 if (threadId != getproctid()) { in OnEvent()
81 [this] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnServiceDied()
82 if (threadId != getproctid()) { in OnServiceDied()
H A Djs_callback_manager.cpp80 context->callback(context->env, context->ref, context->threadId); in RunCallback()
85 context->release(context->threadId); in RunCallback()
99 jsCallbacks.emplace(std::make_tuple(context, callback, [this, release] (pid_t threadId) { in Add()
105 release(threadId); in Add()
H A Dnapi_hisysevent_js.cpp146 callbackContext->threadId = getproctid(); in AddWatcher()
156 listeners[callbackContext->ref] = std::make_pair(callbackContext->threadId, listener); in AddWatcher()
234 callbackContext->threadId = getproctid(); in Query()
252 queriers[callbackContext->ref] = std::make_pair(callbackContext->threadId, querier); in Query()
/base/security/security_guard/frameworks/js/napi/
H A Dnapi_security_event_querier.cpp31 if (callbackContext_->threadId == getproctid()) { in ~NapiSecurityEventQuerier()
131 context->callback(context->env, context->ref, context->threadId, context->events); in RunCallback()
135 context->release(context->threadId); in RunCallback()
147 [this] (const napi_env env, const napi_ref ref, pid_t threadId, in OnQuery()
150 if (threadId != getproctid() || !NapiRequestDataManager::GetInstance().GetDataCallback(env)) { in OnQuery()
193 RunCallback(callbackContext_, [] (const napi_env env, const napi_ref ref, pid_t threadId, in OnComplete()
205 }, [this] (pid_t threadId) { in OnComplete()
207 if (threadId != getproctid()) { in OnComplete()
219 RunCallback(callbackContext_, [message] (const napi_env env, const napi_ref ref, pid_t threadId, in OnError()
233 }, [this] (pid_t threadId) { in OnError()
[all...]
H A Dsecurity_guard_napi.h47 pid_t threadId; member
116 using CALLBACK_FUNC = std::function<void(const napi_env, const napi_ref, pid_t threadId,
118 using RELEASE_FUNC = std::function<void(pid_t threadId)>;
126 threadId(context->threadId), in QuerySecurityEventContext()
133 pid_t threadId; member
161 bool throwAble = false) : env(napiEnv), threadId(thId), throwErr(throwAble) {}; in CommonAsyncContext()
183 std::thread::id threadId; member
/base/startup/init/ueventd/standard/
H A Dueventd_parameter.c36 pthread_t threadId; member
47 .threadId = 0
111 if (parameterCtrl->threadId == 0) { in AddParameter()
112 (void)pthread_create(&(parameterCtrl->threadId), NULL, ThreadRun, (void *)parameterCtrl); in AddParameter()
/base/inputmethod/imf/frameworks/js/napi/common/
H A Djs_callback_object.cpp23 JSCallbackObject::JSCallbackObject(napi_env env, napi_value callback, std::thread::id threadId) in JSCallbackObject() argument
24 : env_(env), threadId_(threadId) in JSCallbackObject()
H A Djs_callback_object.h28 JSCallbackObject(napi_env env, napi_value callback, std::thread::id threadId);
/base/notification/eventhandler/frameworks/test/moduletest/
H A Devent_handler_test_common.h125 static inline void PushbackThread(const std::string threadId) in PushbackThread() argument
127 threads_.push_back(threadId); in PushbackThread()
/base/hiviewdfx/hilog/services/hilogd/
H A Dcmd_executor.cpp109 for (auto threadId : m_finishedClients) { in CleanFinishedClients()
111 [&threadId](const std::unique_ptr<ClientThread>& ct) { in CleanFinishedClients()
112 return ct->m_clientThread.get_id() == threadId; in CleanFinishedClients()
/base/startup/init/services/modules/bootchart/
H A Dbootchart.h27 pthread_t threadId; member
/base/inputmethod/imf/test/unittest/cpp_test/src/
H A Dblock_queue_test.cpp87 auto threadId = GetThreadId(); in TestImfBlockQueue() local
88 IMSA_HILOGI("consume:%{public}" PRId64 ",threadId:%{public}" PRId64 "", consume, threadId); in TestImfBlockQueue()
/base/security/access_token/interfaces/kits/js/napi/common/include/
H A Dnapi_common.h31 bool IsCurrentThread(std::thread::id threadId);
32 bool CompareCallbackRef(const napi_env env, napi_ref subscriberRef, napi_ref unsubscriberRef, std::thread::id threadId);
/base/security/access_token/frameworks/js/napi/common/src/
H A Dnapi_common.cpp25 bool IsCurrentThread(std::thread::id threadId) in IsCurrentThread() argument
28 if (threadId != currentThread) { in IsCurrentThread()
29 ACCESSTOKEN_LOG_ERROR(LABEL, "Napi_ref can not be compared,different threadId"); in IsCurrentThread()
34 bool CompareCallbackRef(const napi_env env, napi_ref subscriberRef, napi_ref unsubscriberRef, std::thread::id threadId) in CompareCallbackRef() argument
36 if (!IsCurrentThread(threadId)) { in CompareCallbackRef()
/base/notification/eventhandler/frameworks/eventhandler/src/
H A Devent_runner.cpp83 auto threadId = std::this_thread::get_id(); in ReclaimCurrentThread() local
84 HILOGD("Thread id: %{public}zu", CalculateHashCode(threadId)); in ReclaimCurrentThread()
94 reclaims_.emplace_back(threadId); in ReclaimCurrentThread()
117 auto threadId = thread->get_id(); in Deposit() local
118 HILOGD("New thread id: %{public}zu", CalculateHashCode(threadId)); in Deposit()
126 depositMap_.emplace(threadId, in Deposit()
184 auto threadId = it->first; in DoReclaimLocked() local
191 size_t hashThreadId = CalculateHashCode(threadId); in DoReclaimLocked()
213 auto threadId = reclaims_.back(); in Run() local
215 DoReclaimLocked(lock, depositMap_.find(threadId), fals in Run()
[all...]
H A Devent_handler.cpp379 int64_t threadId = getproctid(); in DeliveryTimeAction() local
380 std::string threadIdCharacter = std::to_string(threadId); in DeliveryTimeAction()
384 std::string handOutTag = "threadId: " + threadIdCharacter + "," + "threadName: " + threadName + "," + in DeliveryTimeAction()
408 int64_t threadId = getproctid(); in DistributeTimeAction() local
409 std::string threadIdCharacter = std::to_string(threadId); in DistributeTimeAction()
414 std::string executeTag = "threadId: " + threadIdCharacter + "," + "threadName: " + threadName + "," + in DistributeTimeAction()
/base/hiviewdfx/faultloggerd/test/unittest/signal_handler/
H A Dsignal_handler_test.cpp121 int TestThread(int threadId, int sig) in TestThread() argument
123 std::string subThreadName = "SubTestThread" + to_string(threadId); in TestThread()
129 if (threadId == cashThreadId) { in TestThread()
320 int TestThread2(int threadId, int sig, int total, bool exitEarly) in TestThread2() argument
322 std::string subThreadName = "SubTestThread" + to_string(threadId); in TestThread2()
327 if (threadId == total - 1) { in TestThread2()
333 sleep(total - threadId); in TestThread2()
/base/startup/appspawn/test/moduletest/threadpool/
H A Dthread_manager.c27 pthread_t threadId; member
288 mgr->threadNode[index].threadId = INVALID_THREAD_ID; in CreateThreadMgr()
292 int ret = pthread_create(&mgr->threadNode[0].threadId, NULL, ManagerThreadProc, (void *)&mgr->threadNode[0]); in CreateThreadMgr()
311 if (mgr->threadNode[index].threadId != INVALID_THREAD_ID) { in DestroyThreadMgr()
320 if (mgr->threadNode[index].threadId != INVALID_THREAD_ID) { in DestroyThreadMgr()
321 pthread_join(mgr->threadNode[index].threadId, NULL); in DestroyThreadMgr()
474 if (mgr->threadNode[index].threadId != INVALID_THREAD_ID) { in CheckAndCreateNewThread()
477 int ret = pthread_create(&mgr->threadNode[index].threadId, in CheckAndCreateNewThread()
/base/hiviewdfx/hiview/plugins/faultlogger/common/
H A Dfaultlog_util.h36 std::string GetThreadStack(const std::string& path, int32_t threadId);
H A Dfaultlog_util.cpp193 std::string GetThreadStack(const std::string& path, int32_t threadId) in GetThreadStack() argument
211 std::string regTidString = "^Tid:" + std::to_string(threadId) + ", Name:(.{0,32})$"; in GetThreadStack()
/base/security/access_token/interfaces/kits/cj/accesstoken/src/
H A Dat_manager_impl.cpp109 static bool IsCurrentThread(std::thread::id threadId) in IsCurrentThread() argument
112 if (threadId != currentThread) { in IsCurrentThread()
113 LOGE("Ref can not be compared, different threadId!"); in IsCurrentThread()
119 static bool CompareCallbackRef(int64_t subscriberRef, int64_t unsubscriberRef, std::thread::id threadId) in CompareCallbackRef() argument
121 if (!IsCurrentThread(threadId)) { in CompareCallbackRef()
713 registerPermStateChangeInfo.threadId = std::this_thread::get_id(); in FillPermStateChangeInfo()
745 unregisterPermStateChangeInfo.threadId = std::this_thread::get_id(); in FillUnregisterPermStateChangeInfo()
757 if (!CompareCallbackRef(item->callbackRef, unregisterPermStateChangeInfo->callbackRef, item->threadId)) { in FindAndGetSubscriberInVector()
762 if (!IsCurrentThread(item->threadId)) { in FindAndGetSubscriberInVector()
790 CompareCallbackRef((*item)->callbackRef, subscriberRef, (*item)->threadId)) { in DeleteRegisterFromVector()
[all...]
/base/hiviewdfx/faultloggerd/test/fuzztest/faultloggerdserver_fuzzer/
H A Dfaultloggerdserver_fuzzer.cpp78 pthread_t threadId; in HandleRequestTestCommon() local
79 if (pthread_create(&threadId, nullptr, startRoutine, reinterpret_cast<void*>(socketFd[1])) != 0) { in HandleRequestTestCommon()
88 pthread_join(threadId, nullptr); in HandleRequestTestCommon()
/base/msdp/device_status/utils/common/src/
H A Dutil.cpp85 std::string threadId = GetThisThreadIdOfString(); in GetThisThreadId() local
86 uint64_t tid = std::stoull(threadId); in GetThisThreadId()

Completed in 14 milliseconds

12