| /foundation/communication/ipc/ipc/native/c/rpc/src/ |
| D | rpc_process_skeleton.c | 117 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
188 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(threadId); in WakeUpDataThread()
216 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId) in PopDataInfoFromThread() argument
222 if (pthread_equal(node->threadId, threadId) != 0) { in PopDataInfoFromThread()
[all …]
|
| D | dbinder_invoker.c | 254 messageInfo->threadId = pthread_self(); in MakeThreadMessageInfo()
519 pthread_t threadId = idleDataThread->threadId; in StartProcessLoop() local
520 processInfo->threadId = threadId; in StartProcessLoop()
522 WakeUpDataThread(threadId); in StartProcessLoop()
742 pthread_t threadId = pthread_self(); in RpcJoinThread() local
751 AddDataThreadInWait(threadId); in RpcJoinThread()
752 ThreadProcessInfo *processInfo = PopDataInfoFromThread(threadId); in RpcJoinThread()
|
| /foundation/communication/ipc/ipc/native/c/rpc/include/ |
| D | rpc_process_skeleton.h | 50 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);
|
| /foundation/communication/ipc/ipc/test/rpc/socket_trans/src/ |
| D | rpc_socket_trans.c | 176 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()
|
| D | rpc_mini_socket_trans.c | 183 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()
313 pthread_t threadId; in Connect() local
328 ret = pthread_create(&threadId, &threadAttr, HandleSendReply, (void *)sessionId); in Connect()
333 pthread_detach(threadId); in Connect()
|
| /foundation/graphic/graphic_utils_lite/interfaces/innerkits/ |
| D | graphic_thread.h | 55 pthread_t threadId; in ThreadCreate()
56 int ret = pthread_create(&threadId, &threadAttr, entry, arg); in ThreadCreate()
60 return (ThreadId)threadId; in ThreadCreate()
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| D | thread_adapter.c | 82 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()
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| D | ipc_workthread.cpp | 101 pthread_t threadId; in Start() local
102 int ret = pthread_create(&threadId, NULL, &IPCWorkThread::ThreadHandler, this); in Start()
107 if (pthread_detach(threadId) != 0) { in Start()
|
| D | ipc_process_skeleton.cpp | 528 bool IPCProcessSkeleton::DetachThreadLockInfo(const std::thread::id &threadId) in DetachThreadLockInfo() argument
532 return (threadLockInfo_.erase(threadId) > 0); in DetachThreadLockInfo()
536 const std::thread::id &threadId) in AttachThreadLockInfo() argument
540 …kInfo_.insert(std::pair<std::thread::id, std::shared_ptr<SocketThreadLockInfo>>(threadId, object)); in AttachThreadLockInfo()
544 …_ptr<SocketThreadLockInfo> IPCProcessSkeleton::QueryThreadLockInfo(const std::thread::id &threadId) in QueryThreadLockInfo() argument
548 auto it = threadLockInfo_.find(threadId); in QueryThreadLockInfo()
557 bool IPCProcessSkeleton::AddDataThreadToIdle(const std::thread::id &threadId) in AddDataThreadToIdle() argument
561 idleDataThreads_.push_front(threadId); in AddDataThreadToIdle()
565 bool IPCProcessSkeleton::DeleteDataThreadFromIdle(const std::thread::id &threadId) in DeleteDataThreadFromIdle() argument
569 if ((*it) == threadId) { in DeleteDataThreadFromIdle()
[all …]
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
| D | event_runner.cpp | 72 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()
|
| D | event_handler.cpp | 255 int64_t threadId = gettid(); in DeliveryTimeAction() local
256 std::string threadIdCharacter = std::to_string(threadId); in DeliveryTimeAction()
283 int64_t threadId = gettid(); in DistributeTimeAction() local
284 std::string threadIdCharacter = std::to_string(threadId); in DistributeTimeAction()
|
| /foundation/communication/ipc/ipc/native/src/core/include/ |
| D | ipc_process_skeleton.h | 120 bool DetachThreadLockInfo(const std::thread::id &threadId);
121 …ttachThreadLockInfo(std::shared_ptr<SocketThreadLockInfo> object, const std::thread::id &threadId);
122 std::shared_ptr<SocketThreadLockInfo> QueryThreadLockInfo(const std::thread::id &threadId);
130 int PopSocketIdFromThread(const std::thread::id &threadId);
156 bool AddDataThreadToIdle(const std::thread::id &threadId);
157 bool DeleteDataThreadFromIdle(const std::thread::id &threadId);
159 …void AddDataInfoToThread(const std::thread::id &threadId, std::shared_ptr<ThreadProcessInfo> proce…
160 std::shared_ptr<ThreadProcessInfo> PopDataInfoFromThread(const std::thread::id &threadId);
162 void AddDataThreadInWait(const std::thread::id &threadId);
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| D | reactor_linux.c | 32 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()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/ |
| D | pan_network.cpp | 44 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()
|
| /foundation/communication/wifi/wifi/services/wifi_standard/ipc_framework/cRPC/src/ |
| D | client.c | 159 client->threadId = 0; in CreateRpcClient()
166 int ret = pthread_create(&client->threadId, NULL, RpcClientThreadDeal, client); in CreateRpcClient()
178 pthread_setname_np(client->threadId, "RpcClientThread"); in CreateRpcClient()
186 if (client->threadId != 0) { in ReleaseRpcClient()
188 pthread_join(client->threadId, NULL); in ReleaseRpcClient()
|
| /foundation/communication/ipc/ipc/native/c/manager/src/ |
| D | ipc_thread_pool.c | 44 current->threadId = pthread_self(); in GetCurrentThreadContext()
147 pthread_t threadId; in SpawnNewThread() local
166 int ret = pthread_create(&threadId, NULL, ThreadHandler, threadContext); in SpawnNewThread()
173 pthread_detach(threadId); in SpawnNewThread()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/ |
| D | hid_host_uhid.cpp | 40 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()
|
| /foundation/multimedia/av_codec/test/moduletest/muxer/FFmpegAPI/ |
| D | FFmpegAVMuxerStablityTest.cpp | 368 void RunMuxer(string testcaseName, int threadId, OutputFormat format) in RunMuxer() argument
376 …cout << "thread id is: " << threadId << ", run time : " << difftime(curTime, startTime) << " secon… in RunMuxer()
377 string fileName = testcaseName + "_" + to_string(threadId); in RunMuxer()
379 cout << "thread id is: " << threadId << ", cur file name is: " << fileName << endl; in RunMuxer()
386 cout << "thread id is: " << threadId << ", fd is: " << fd << endl; in RunMuxer()
392 cout << "thread id is: " << threadId << ", format is: " << format << endl; in RunMuxer()
397 cout << "thread id is: " << threadId << ", format is: " << format << endl; in RunMuxer()
409 cout << "thread id is: " << threadId << ", audio track id is: " << audioTrackId in RunMuxer()
413 cout << "thread id is: " << threadId << ", Start ret is:" << (int)ret << endl; in RunMuxer()
418 cout << "thread id is: " << threadId << ", Stop ret is:" << (int)ret << endl; in RunMuxer()
[all …]
|
| /foundation/multimedia/media_lite/interfaces/kits/player_lite/js/builtin/src/ |
| D | audio_player.cpp | 99 pthread_t threadId; in OnPlaybackComplete() local
103 …int retCode = pthread_create(&threadId, &attr, AudioPlayerCallback::PlaybackCompleteHandler, audio… in OnPlaybackComplete()
108 MEDIA_DEBUG_LOG("fork thread success: %lu", threadId); in OnPlaybackComplete()
155 pthread_t threadId; in ForkUpdateTimeThread() local
171 retCode = pthread_create(&threadId, nullptr, AudioPlayer::UpdateTimeHandler, this); in ForkUpdateTimeThread()
178 MEDIA_DEBUG_LOG("fork thread success: %lu", threadId); in ForkUpdateTimeThread()
|
| /foundation/multimedia/av_codec/test/moduletest/muxer/InnerAPI/ |
| D | InnerAVMuxerStablityTest.cpp | 391 void RunMuxer(string testcaseName, int threadId, OutputFormat format) in RunMuxer() argument
399 …cout << "thread id is: " << threadId << ", run time : " << difftime(curTime, startTime) << " secon… in RunMuxer()
400 string fileName = testcaseName + "_" + to_string(threadId); in RunMuxer()
402 cout << "thread id is: " << threadId << ", cur file name is: " << fileName << endl; in RunMuxer()
409 cout << "thread id is: " << threadId << ", fd is: " << fd << endl; in RunMuxer()
415 cout << "thread id is: " << threadId << ", format is: " << format << endl; in RunMuxer()
420 cout << "thread id is: " << threadId << ", format is: " << format << endl; in RunMuxer()
432 cout << "thread id is: " << threadId << ", audio track id is: " << audioTrackId in RunMuxer()
436 cout << "thread id is: " << threadId << ", Start ret is:" << ret << endl; in RunMuxer()
441 cout << "thread id is: " << threadId << ", Stop ret is:" << ret << endl; in RunMuxer()
[all …]
|
| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | ipc_process_skeleton_unittest.cpp | 478 std::thread::id threadId; variable
479 skeleton->AttachThreadLockInfo(object, threadId);
481 auto ret = skeleton->QueryThreadLockInfo(threadId);
495 std::thread::id threadId; variable
496 skeleton->AddDataThreadToIdle(threadId);
498 bool ret = skeleton->DeleteDataThreadFromIdle(threadId);
512 std::thread::id threadId; variable
513 skeleton->AddDataThreadToIdle(threadId);
515 EXPECT_NE(threadId, ret);
562 std::thread::id threadId; variable
[all …]
|
| /foundation/communication/wifi/wifi/services/wifi_standard/ipc_framework/cRPC/include/ |
| D | client.h | 44 pthread_t threadId; member
|
| /foundation/multimedia/media_lite/services/recorder_lite/impl/src/ |
| D | recorder_sink.cpp | 48 if (threadId != 0) { in ~RecorderSink()
50 pthread_cancel(threadId); in ~RecorderSink()
343 sink->threadId = 0; in MessageThread()
359 int32_t ret = pthread_create(&threadId, nullptr, MessageThread, this); in Start()
408 if (threadId != 0) { in Stop()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/ |
| D | reactor.h | 73 void ReactorSetThreadId(Reactor *reactor, unsigned long threadId);
|
| /foundation/multimedia/camera_lite/services/impl/include/ |
| D | camera_device.h | 87 pthread_t threadId;
106 pthread_t threadId;
|