Home
last modified time | relevance | path

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

123

/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);
/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 PopDataInfoFromThread(pthread_t threadId) PopDataInfoFromThread() argument
[all...]
/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()
/foundation/communication/ipc/ipc/test/rpc/socket_trans/src/
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()
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()
/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()
/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), fals in Run()
[all...]
/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()
/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()
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h138 bool DetachThreadLockInfo(const std::thread::id &threadId);
139 bool AttachThreadLockInfo(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> processInfo);
187 std::shared_ptr<ThreadProcessInfo> PopDataInfoFromThread(const std::thread::id &threadId);
189 void AddDataThreadInWait(const std::thread::id &threadId);
278 std::map<std::thread::id, std::vector<std::shared_ptr<ThreadProcessInfo>>> dataInfoQueue_; // key is threadId
[all...]
/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 LOG_DEBUG("[Pan Network]%{public}s():%{public}lu: threadcreated successfully", __FUNCTION__, threadId); in CreateThread()
343 return threadId; in CreateThread()
/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()
/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()
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/idl_client/unittest/
H A Dmock_client.c65 if (client->threadId != 0) { in ReleaseRpcClient()
67 pthread_join(client->threadId, NULL); in ReleaseRpcClient()
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_workthread.cpp172 pthread_t threadId; in Start() local
174 int ret = pthread_create(&threadId, NULL, &IPCWorkThread::ThreadHandler, param); in Start()
181 if (pthread_detach(threadId) != 0) { in Start()
H A Dipc_process_skeleton.cpp703 bool IPCProcessSkeleton::DetachThreadLockInfo(const std::thread::id &threadId) in DetachThreadLockInfo() argument
708 return (threadLockInfo_.erase(threadId) > 0); in DetachThreadLockInfo()
712 const std::thread::id &threadId) in AttachThreadLockInfo()
717 threadLockInfo_.insert(std::pair<std::thread::id, std::shared_ptr<SocketThreadLockInfo>>(threadId, object)); in AttachThreadLockInfo()
721 std::shared_ptr<SocketThreadLockInfo> IPCProcessSkeleton::QueryThreadLockInfo(const std::thread::id &threadId) in QueryThreadLockInfo() argument
726 auto it = threadLockInfo_.find(threadId); in QueryThreadLockInfo()
735 bool IPCProcessSkeleton::AddDataThreadToIdle(const std::thread::id &threadId) in AddDataThreadToIdle() argument
740 idleDataThreads_.push_front(threadId); in AddDataThreadToIdle()
744 bool IPCProcessSkeleton::DeleteDataThreadFromIdle(const std::thread::id &threadId) in DeleteDataThreadFromIdle() argument
749 if ((*it) == threadId) { in DeleteDataThreadFromIdle()
711 AttachThreadLockInfo(std::shared_ptr<SocketThreadLockInfo> object, const std::thread::id &threadId) AttachThreadLockInfo() argument
768 std::thread::id threadId = idleDataThreads_.back(); GetIdleDataThread() local
791 AddDataInfoToThread(const std::thread::id &threadId, std::shared_ptr<ThreadProcessInfo> processInfo) AddDataInfoToThread() argument
800 PopDataInfoFromThread(const std::thread::id &threadId) PopDataInfoFromThread() argument
831 AddDataThreadInWait(const std::thread::id &threadId) AddDataThreadInWait() argument
[all...]
/foundation/multimedia/av_codec/test/moduletest/muxer/InnerAPI/
H A DInnerAVMuxerStablityTest.cpp358 void RunMuxer(string testcaseName, int threadId, Plugins::OutputFormat format) in RunMuxer() argument
366 cout << "thread id is: " << threadId << ", run time : " << difftime(curTime, startTime) << " seconds" << endl; in RunMuxer()
367 string fileName = testcaseName + "_" + to_string(threadId); in RunMuxer()
369 cout << "thread id is: " << threadId << ", cur file name is: " << fileName << endl; in RunMuxer()
376 cout << "thread id is: " << threadId << ", fd is: " << fd << endl; in RunMuxer()
382 cout << "thread id is: " << threadId << ", format is: " << static_cast<int32_t>(format) << endl; in RunMuxer()
387 cout << "thread id is: " << threadId << ", format is: " << static_cast<int32_t>(format) << endl; in RunMuxer()
399 cout << "thread id is: " << threadId << ", audio track id is: " << audioTrackId in RunMuxer()
403 cout << "thread id is: " << threadId << ", Start ret is:" << ret << endl; in RunMuxer()
408 cout << "thread id is: " << threadId << ", Sto in RunMuxer()
[all...]
/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp483 std::thread::id threadId = std::this_thread::get_id(); in AttachThreadLockInfoTest() local
484 current->AttachThreadLockInfo(object, threadId); in AttachThreadLockInfoTest()
485 current->QueryThreadLockInfo(threadId); in AttachThreadLockInfoTest()
486 current->DetachThreadLockInfo(threadId); in AttachThreadLockInfoTest()
892 std::thread::id threadId = std::this_thread::get_id(); in AddToDeleteDataThreadToIdleTest() local
894 current->DeleteDataThreadFromIdle(threadId); in AddToDeleteDataThreadToIdleTest()
895 current->AddDataThreadToIdle(threadId); in AddToDeleteDataThreadToIdleTest()
897 current->DeleteDataThreadFromIdle(threadId); in AddToDeleteDataThreadToIdleTest()
907 std::thread::id threadId = std::this_thread::get_id(); in AddToPopDataInfoToThreadTest() local
909 current->PopDataInfoFromThread(threadId); in AddToPopDataInfoToThreadTest()
[all...]
/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp472 std::thread::id threadId; in HWTEST_F() local
473 skeleton->AttachThreadLockInfo(object, threadId); in HWTEST_F()
475 auto ret = skeleton->QueryThreadLockInfo(threadId); in HWTEST_F()
489 std::thread::id threadId; in HWTEST_F() local
490 skeleton->AddDataThreadToIdle(threadId); in HWTEST_F()
492 bool ret = skeleton->DeleteDataThreadFromIdle(threadId); in HWTEST_F()
506 std::thread::id threadId; in HWTEST_F() local
507 skeleton->AddDataThreadToIdle(threadId); in HWTEST_F()
556 std::thread::id threadId; in HWTEST_F() local
559 skeleton->AddDataInfoToThread(threadId, processInf in HWTEST_F()
1769 std::thread::id threadId; HWTEST_F() local
1786 std::thread::id threadId; HWTEST_F() local
1803 std::thread::id threadId; HWTEST_F() local
1851 std::thread::id threadId; HWTEST_F() local
[all...]
/foundation/multimedia/media_lite/interfaces/kits/player_lite/js/builtin/src/
H A Daudio_player.cpp99 pthread_t threadId; in OnPlaybackComplete() local
103 int retCode = pthread_create(&threadId, &attr, AudioPlayerCallback::PlaybackCompleteHandler, audioPlayer_); 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/graphic/graphic_2d/rosen/test/render/render/unittest/cmd/
H A Drs_canvas_node_cmd_test.cpp157 std::thread::id threadId = std::this_thread::get_id(); in HWTEST_F() local
158 RSSingleFrameComposer::SetSingleFrameFlag(threadId); in HWTEST_F()
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/pipeline/
H A Drs_canvas_drawing_render_node.h61 void SetSurfaceClearFunc(ThreadInfo threadInfo, pid_t threadId = 0) in SetSurfaceClearFunc()
64 threadId_ = threadId; in SetSurfaceClearFunc()
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/command/
H A Drs_canvas_node_command_test.cpp116 std::thread::id threadId = std::this_thread::get_id(); in HWTEST_F() local
117 RSSingleFrameComposer::SetSingleFrameFlag(threadId); in HWTEST_F()
/foundation/multimedia/camera_lite/services/impl/include/
H A Dcamera_device.h87 pthread_t threadId; member in OHOS::Media::PreviewAssistant
106 pthread_t threadId; member in OHOS::Media::CallbackAssistant
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/include/
H A Dthumbnail_generate_worker.h72 ThumbnailGenerateThreadStatus(int threadId) : threadId_(threadId) {} in ThumbnailGenerateThreadStatus() argument

Completed in 17 milliseconds

123