Home
last modified time | relevance | path

Searched refs:threadId (Results 1 – 25 of 116) sorted by relevance

12345

/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Drpc_process_skeleton.c117 static SocketThreadLockInfo *QueryThreadLockInfo(pthread_t threadId) in QueryThreadLockInfo() argument
123 if (pthread_equal(node->threadId, threadId) != 0) { in QueryThreadLockInfo()
147 void AddDataThreadInWait(pthread_t threadId) in AddDataThreadInWait() argument
149 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(threadId); in AddDataThreadInWait()
156 threadLockInfo->threadId = threadId; in AddDataThreadInWait()
174 IdleDataThread idleDataThread = {.threadId = threadId}; in AddDataThreadInWait()
186 void WakeUpDataThread(pthread_t threadId) in WakeUpDataThread() argument
216 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId) in PopDataInfoFromThread() argument
222 if (pthread_equal(node->threadId, threadId) != 0) { in PopDataInfoFromThread()
375 threadLockInfo->threadId = messageInfo->threadId; in AddSendThreadInWait()
[all …]
/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/include/
H A Drpc_process_skeleton.h50 pthread_t threadId; member
63 pthread_t threadId; member
75 pthread_t threadId; member
99 pthread_t threadId; member
113 void AddDataThreadInWait(pthread_t threadId);
116 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId);
135 void WakeUpDataThread(pthread_t threadId);
/ohos5.0/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() argument
59 if (threadId != getproctid()) { in OnQuery()
81 [this, reason, total, seq] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnComplete() argument
82 if (threadId != getproctid()) { in OnComplete()
101 }, [this] (pid_t threadId) { in OnComplete() argument
102 if (threadId != getproctid()) { in OnComplete()
H A Dnapi_hisysevent_listener.cpp47 if (callbackContext->threadId == getproctid()) { in ~NapiHiSysEventListener()
57 …main, eventName, eventType, eventDetail] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnEvent() argument
58 if (threadId != getproctid()) { in OnEvent()
81 [this] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnServiceDied() argument
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() argument
105 release(threadId); in Add()
/ohos5.0/base/security/security_guard/frameworks/js/napi/
H A Dnapi_security_event_querier.cpp30 if (callbackContext_->threadId == getproctid()) { in ~NapiSecurityEventQuerier()
128 context->callback(context->env, context->ref, context->threadId, context->events); in RunCallback()
132 context->release(context->threadId); in RunCallback()
144 [this] (const napi_env env, const napi_ref ref, pid_t threadId, in OnQuery()
147 … if (threadId != getproctid() || !NapiRequestDataManager::GetInstance().GetDataCallback(env)) { in OnQuery()
188 RunCallback(callbackContext_, [] (const napi_env env, const napi_ref ref, pid_t threadId, in OnComplete()
200 }, [this] (pid_t threadId) { in OnComplete() argument
202 if (threadId != getproctid()) { in OnComplete()
214 RunCallback(callbackContext_, [message] (const napi_env env, const napi_ref ref, pid_t threadId, in OnError()
228 }, [this] (pid_t threadId) { in OnError() argument
[all …]
H A Dsecurity_guard_napi.h46 pid_t threadId; member
113 using CALLBACK_FUNC = std::function<void(const napi_env, const napi_ref, pid_t threadId,
115 using RELEASE_FUNC = std::function<void(pid_t threadId)>;
123 threadId(context->threadId), in QuerySecurityEventContext()
130 pid_t threadId; member
157 bool throwAble = false) : env(napiEnv), threadId(thId), throwErr(throwAble) {};
179 std::thread::id threadId; member
/ohos5.0/foundation/communication/ipc/ipc/test/rpc/socket_trans/src/
H A Drpc_socket_trans.c176 pthread_t threadId; in OpenTcpServerSocket() local
177 pthread_create(&threadId, NULL, HandleAccept, (void *)&clientFd); in OpenTcpServerSocket()
178 pthread_detach(threadId); in OpenTcpServerSocket()
197 pthread_t threadId; in StartListen() local
198 pthread_create(&threadId, NULL, OpenTcpServerSocket, (void *)SaSessionName); in StartListen()
199 pthread_detach(threadId); in StartListen()
279 pthread_t threadId; in Connect() local
280 pthread_create(&threadId, NULL, HandleSendReply, (void *)sessionId); in Connect()
281 pthread_detach(threadId); in Connect()
H A Drpc_mini_socket_trans.c183 pthread_t threadId; in OpenTcpServerSocket() local
196 ret = pthread_create(&threadId, &threadAttr, HandleAccept, (void *)&clientFd); in OpenTcpServerSocket()
201 pthread_detach(threadId); in OpenTcpServerSocket()
217 pthread_t threadId; in StartListen() local
230 ret = pthread_create(&threadId, &threadAttr, OpenTcpServerSocket, (void *)saSessionName); in StartListen()
235 pthread_detach(threadId); in StartListen()
284 pthread_t threadId; in HandleConnect() local
299 ret = pthread_create(&threadId, &threadAttr, HandleSendReply, (void *)sessionId); in HandleConnect()
304 pthread_detach(threadId); in HandleConnect()
/ohos5.0/docs/zh-cn/application-dev/reference/apis-performance-analysis-kit/
H A D_hi_debug___thread_cpu_usage.md20 | uint32_t [threadId](#threadid) | 线程ID。 |
46 ### threadId subsection
49 uint32_t HiDebug_ThreadCpuUsage::threadId
/ohos5.0/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
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/
H A Devent_runner.cpp72 auto threadId = std::this_thread::get_id(); in ReclaimCurrentThread() local
73 HILOGD("Reclaim: Thread id: %{public}zu", CalculateHashCode(threadId)); in ReclaimCurrentThread()
83 reclaims_.emplace_back(threadId); in ReclaimCurrentThread()
106 auto threadId = thread->get_id(); in Deposit() local
107 HILOGD("Deposit: New thread id: %{public}zu", CalculateHashCode(threadId)); in Deposit()
115 depositMap_.emplace(threadId, in Deposit()
171 auto threadId = it->first; in DoReclaimLocked() local
178 size_t hashThreadId = CalculateHashCode(threadId); in DoReclaimLocked()
200 auto threadId = reclaims_.back(); in Run() local
202 DoReclaimLocked(lock, depositMap_.find(threadId), false); in Run()
/ohos5.0/docs/en/application-dev/reference/apis-performance-analysis-kit/
H A D_hi_debug___thread_cpu_usage.md20 | uint32_t [threadId](#threadid) | Thread ID. |
46 ### threadId subsection
49 uint32_t HiDebug_ThreadCpuUsage::threadId
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/
H A Dpan_network.cpp44 pthread_t threadId; in Open() local
84 threadId = CreateThread(PollEventThread, this); in Open()
85 if (threadId == static_cast<pthread_t>(-1)) { in Open()
89 pollThreadId_ = threadId; in Open()
337 pthread_t threadId = static_cast<pthread_t>(-1); in CreateThread() local
338 if (pthread_create(&threadId, &threadAttr, startRoutine, arg) != 0) { in CreateThread()
342 …DEBUG("[Pan Network]%{public}s():%{public}lu: threadcreated successfully", __FUNCTION__, threadId); in CreateThread()
343 return threadId; in CreateThread()
/ohos5.0/foundation/graphic/graphic_utils_lite/interfaces/innerkits/
H A Dgraphic_thread.h55 pthread_t threadId; in ThreadCreate()
56 int ret = pthread_create(&threadId, &threadAttr, entry, arg); in ThreadCreate()
60 return (ThreadId)threadId; in ThreadCreate()
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h138 bool DetachThreadLockInfo(const std::thread::id &threadId);
139 …ttachThreadLockInfo(std::shared_ptr<SocketThreadLockInfo> object, const std::thread::id &threadId);
140 std::shared_ptr<SocketThreadLockInfo> QueryThreadLockInfo(const std::thread::id &threadId);
148 int PopSocketIdFromThread(const std::thread::id &threadId);
183 bool AddDataThreadToIdle(const std::thread::id &threadId);
184 bool DeleteDataThreadFromIdle(const std::thread::id &threadId);
186 …void AddDataInfoToThread(const std::thread::id &threadId, std::shared_ptr<ThreadProcessInfo> proce…
187 std::shared_ptr<ThreadProcessInfo> PopDataInfoFromThread(const std::thread::id &threadId);
189 void AddDataThreadInWait(const std::thread::id &threadId);
/ohos5.0/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()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/
H A Dreactor_linux.c32 pthread_t threadId; member
56 void ReactorSetThreadId(Reactor *reactor, unsigned long threadId) in ReactorSetThreadId() argument
58 reactor->threadId = (pthread_t)threadId; in ReactorSetThreadId()
232 if (pthread_equal(item->reactor->threadId, pthread_self())) { in ReactorUnregister()
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dthread_adapter.c82 pthread_t threadId = 0; in THREAD_Create() local
83 int errno = pthread_create(&threadId, &threadAttr, run, argv); in THREAD_Create()
91 return (ThreadId)threadId; in THREAD_Create()
/ohos5.0/drivers/hdf_core/framework/support/posix/src/
H A Dosal_thread.c94 static int OsalCreatePthread(pthread_t *threadId, pthread_attr_t *attribute, struct ThreadWrapper *… in OsalCreatePthread() argument
96 …int resultCode = pthread_create(threadId, attribute, (PosixEntry)para->threadEntry, para->entryPar… in OsalCreatePthread()
105 pthread_setname_np(*threadId, threadName); in OsalCreatePthread()
108 resultCode = pthread_detach(*threadId); in OsalCreatePthread()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_uhid.cpp40 pthread_t threadId; in Open() local
53 threadId = CreateThread(PollEventThread, this); in Open()
54 if (threadId == static_cast<pthread_t>(-1)) { in Open()
58 pollThreadId_ = threadId; in Open()
294 pthread_t threadId = static_cast<pthread_t>(-1); in CreateThread() local
295 if (pthread_create(&threadId, &threadAttr, startRoutine, arg) != 0) { in CreateThread()
299 LOG_INFO("[UHID]%{public}s():%{public}lu: threadcreated successfully", __FUNCTION__, threadId); in CreateThread()
300 return threadId; in CreateThread()
/ohos5.0/foundation/communication/wifi/wifi/base/cRPC/src/
H A Dclient.c161 client->threadId = 0; in CreateRpcClient()
168 int ret = pthread_create(&client->threadId, NULL, RpcClientThreadDeal, client); in CreateRpcClient()
180 pthread_setname_np(client->threadId, "RpcClientThread"); in CreateRpcClient()
188 if (client->threadId != 0) { in ReleaseRpcClient()
190 pthread_join(client->threadId, NULL); in ReleaseRpcClient()
/ohos5.0/foundation/communication/ipc/ipc/native/c/manager/src/
H A Dipc_thread_pool.c44 current->threadId = pthread_self(); in GetCurrentThreadContext()
148 pthread_t threadId; in SpawnNewThread() local
167 int ret = pthread_create(&threadId, NULL, ThreadHandler, threadContext); in SpawnNewThread()
174 pthread_detach(threadId); in SpawnNewThread()
/ohos5.0/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), false); in Run()
/ohos5.0/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()

12345