| /foundation/communication/ipc/ipc/native/c/rpc/src/ |
| D | rpc_process_skeleton.c | 117 static SocketThreadLockInfo *QueryThreadLockInfo(pthread_t threadId) in QueryThreadLockInfo()
147 void AddDataThreadInWait(pthread_t threadId) in AddDataThreadInWait()
186 void WakeUpDataThread(pthread_t threadId) in WakeUpDataThread()
216 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId) in PopDataInfoFromThread()
|
| D | dbinder_invoker.c | 519 pthread_t threadId = idleDataThread->threadId; in StartProcessLoop() local
742 pthread_t threadId = pthread_self(); in RpcJoinThread() local
|
| /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
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
| D | event_runner.cpp | 72 auto threadId = std::this_thread::get_id(); in ReclaimCurrentThread() local
106 auto threadId = thread->get_id(); in Deposit() local
171 auto threadId = it->first; in DoReclaimLocked() local
200 auto threadId = reclaims_.back(); in Run() local
|
| D | event_handler.cpp | 255 int64_t threadId = gettid(); in DeliveryTimeAction() local
283 int64_t threadId = gettid(); in DistributeTimeAction() local
|
| /foundation/communication/ipc/ipc/test/rpc/socket_trans/src/ |
| D | rpc_mini_socket_trans.c | 183 pthread_t threadId; in OpenTcpServerSocket() local
217 pthread_t threadId; in StartListen() local
313 pthread_t threadId; in Connect() local
|
| D | rpc_socket_trans.c | 176 pthread_t threadId; in OpenTcpServerSocket() local
197 pthread_t threadId; in StartListen() local
279 pthread_t threadId; in Connect() local
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| D | ipc_workthread.cpp | 101 pthread_t threadId; in Start() local
|
| D | ipc_process_skeleton.cpp | 528 bool IPCProcessSkeleton::DetachThreadLockInfo(const std::thread::id &threadId) in DetachThreadLockInfo()
536 const std::thread::id &threadId) in AttachThreadLockInfo()
544 …_ptr<SocketThreadLockInfo> IPCProcessSkeleton::QueryThreadLockInfo(const std::thread::id &threadId) in QueryThreadLockInfo()
557 bool IPCProcessSkeleton::AddDataThreadToIdle(const std::thread::id &threadId) in AddDataThreadToIdle()
565 bool IPCProcessSkeleton::DeleteDataThreadFromIdle(const std::thread::id &threadId) in DeleteDataThreadFromIdle()
587 std::thread::id threadId = idleDataThreads_.back(); in GetIdleDataThread() local
608 void IPCProcessSkeleton::AddDataInfoToThread(const std::thread::id &threadId, in AddDataInfoToThread()
616 …d_ptr<ThreadProcessInfo> IPCProcessSkeleton::PopDataInfoFromThread(const std::thread::id &threadId) in PopDataInfoFromThread()
645 void IPCProcessSkeleton::AddDataThreadInWait(const std::thread::id &threadId) in AddDataThreadInWait()
|
| /foundation/communication/wifi/wifi/services/wifi_standard/ipc_framework/cRPC/include/ |
| D | client.h | 44 pthread_t threadId; member
|
| /foundation/arkui/ace_engine/frameworks/core/common/flutter/ |
| D | flutter_task_executor.h | 78 std::thread::id threadId; member
|
| /foundation/multimedia/media_lite/services/recorder_lite/impl/include/ |
| D | recorder_sink.h | 73 pthread_t threadId = 0; variable
|
| /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()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/ |
| D | pan_network.cpp | 44 pthread_t threadId; in Open() local
337 pthread_t threadId = static_cast<pthread_t>(-1); in CreateThread() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| D | distributeddb_nb_autolaunch_test.cpp | 606 for (unsigned int threadId = 0; threadId < threeThreads; ++threadId) { variable
614 for (unsigned int threadId = 0; threadId < threeThreads; ++threadId) { variable
620 for (unsigned int threadId = 0; threadId <= threeThreads; ++threadId) { variable
|
| D | distributeddb_nb_enable_sync_by_closed_db_test.cpp | 595 for (unsigned int threadId = 0; threadId < threeThreads; ++threadId) { variable
603 for (unsigned int threadId = 0; threadId < threeThreads; ++threadId) { variable
609 for (unsigned int threadId = 0; threadId <= threeThreads; ++threadId) { variable
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/ |
| D | hid_host_uhid.cpp | 40 pthread_t threadId; in Open() local
294 pthread_t threadId = static_cast<pthread_t>(-1); in CreateThread() local
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| D | thread_adapter.c | 82 pthread_t threadId = 0; in THREAD_Create() local
|
| /foundation/communication/ipc/ipc/native/c/manager/include/ |
| D | ipc_thread_pool.h | 38 pthread_t threadId; member
|
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| D | task_manager.c | 82 register ThreadId threadId = (ThreadId)THREAD_Create(TaskEntry, pool->queueId, &attr); in SAMGR_StartTaskPool() local
|
| /foundation/communication/ipc/ipc/native/c/manager/src/ |
| D | ipc_thread_pool.c | 147 pthread_t threadId; in SpawnNewThread() local
|
| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | ipc_process_skeleton_unittest.cpp | 478 std::thread::id threadId; variable
495 std::thread::id threadId; variable
512 std::thread::id threadId; variable
562 std::thread::id threadId; variable
1810 std::thread::id threadId; variable
1827 std::thread::id threadId; variable
1844 std::thread::id threadId; variable
1892 std::thread::id threadId; variable
|
| /foundation/multimedia/av_codec/test/moduletest/audio_encoder/NativeAPI/ |
| D | NativeStablityTest.cpp | 78 void RunEncode(string encoderName, string inputFile, string outputFile, int32_t threadId) in RunEncode()
90 void RunLongTimeFlush(string encoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeFlush()
119 void RunLongTimeReset(string encoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeReset()
148 void RunLongTimeStop(string encoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeStop()
|
| /foundation/multimedia/media_lite/interfaces/kits/player_lite/js/builtin/src/ |
| D | audio_player.cpp | 99 pthread_t threadId; in OnPlaybackComplete() local
155 pthread_t threadId; in ForkUpdateTimeThread() local
|
| /foundation/multimedia/av_codec/test/moduletest/audio_decoder/NativeAPI/ |
| D | NativeStablityTest.cpp | 176 void RunDecode(string decoderName, string inputFile, string outputFile, int32_t threadId) in RunDecode()
199 void RunLongTimeFlush(string decoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeFlush()
228 void RunLongTimeReset(string decoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeReset()
258 void RunLongTimeStop(string decoderName, string inputFile, string outputFile, int32_t threadId) in RunLongTimeStop()
|