| /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()
|
| /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_socket_trans.c | 176 pthread_t threadId; in OpenTcpServerSocket() local
197 pthread_t threadId; in StartListen() local
279 pthread_t threadId; in Connect() local
|
| D | rpc_mini_socket_trans.c | 183 pthread_t threadId; in OpenTcpServerSocket() local
217 pthread_t threadId; in StartListen() local
284 pthread_t threadId; in HandleConnect() local
|
| /foundation/communication/wifi/wifi/base/cRPC/include/ |
| D | client.h | 44 pthread_t threadId; member
|
| /foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/idl_client/unittest/ |
| D | mock_client.h | 44 pthread_t threadId; member
|
| /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/multimedia/media_lite/services/recorder_lite/impl/include/ |
| D | recorder_sink.h | 73 pthread_t threadId = 0; variable
|
| /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/arkui/ace_engine/frameworks/core/common/ |
| D | task_executor_impl.h | 87 std::thread::id threadId; member
|
| /foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/command/ |
| D | rs_canvas_node_command_test.cpp | 117 std::thread::id threadId = std::this_thread::get_id(); variable
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| D | thread_adapter.c | 82 pthread_t threadId = 0; in THREAD_Create() local
|
| /foundation/multimedia/camera_framework/frameworks/native/camera/src/input/ |
| D | camera_manager.cpp | 252 std::shared_ptr<CameraManagerCallback> cameraManagerCallback) { in OnCameraStatusChanged()
279 …listenerMap.Iterate([&](std::thread::id threadId, std::shared_ptr<CameraManagerCallback> cameraMan… in OnFlashlightStatusChanged()
969 std::shared_ptr<CameraManagerCallback> cameraManagerCallback) { in CameraServerDied()
1027 std::thread::id threadId = std::this_thread::get_id(); in SetCallback() local
1034 std::thread::id threadId = std::this_thread::get_id(); in GetApplicationCallback() local
1042 std::thread::id threadId = std::this_thread::get_id(); in RegisterCameraMuteListener() local
1049 std::thread::id threadId = std::this_thread::get_id(); in GetCameraMuteListener() local
1057 std::thread::id threadId = std::this_thread::get_id(); in RegisterTorchListener() local
1064 std::thread::id threadId = std::this_thread::get_id(); in GetTorchListener() local
1072 std::thread::id threadId = std::this_thread::get_id(); in RegisterFoldListener() local
[all …]
|
| /foundation/communication/ipc/ipc/native/c/manager/include/ |
| D | ipc_thread_pool.h | 38 pthread_t threadId; member
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| D | ipc_workthread.cpp | 171 pthread_t threadId; in Start() local
|
| D | ipc_process_skeleton.cpp | 709 bool IPCProcessSkeleton::DetachThreadLockInfo(const std::thread::id &threadId) in DetachThreadLockInfo()
718 const std::thread::id &threadId) in AttachThreadLockInfo()
727 …_ptr<SocketThreadLockInfo> IPCProcessSkeleton::QueryThreadLockInfo(const std::thread::id &threadId) in QueryThreadLockInfo()
741 bool IPCProcessSkeleton::AddDataThreadToIdle(const std::thread::id &threadId) in AddDataThreadToIdle()
750 bool IPCProcessSkeleton::DeleteDataThreadFromIdle(const std::thread::id &threadId) in DeleteDataThreadFromIdle()
774 std::thread::id threadId = idleDataThreads_.back(); in GetIdleDataThread() local
797 void IPCProcessSkeleton::AddDataInfoToThread(const std::thread::id &threadId, in AddDataInfoToThread()
806 …d_ptr<ThreadProcessInfo> IPCProcessSkeleton::PopDataInfoFromThread(const std::thread::id &threadId) in PopDataInfoFromThread()
837 void IPCProcessSkeleton::AddDataThreadInWait(const std::thread::id &threadId) in AddDataThreadInWait()
|
| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | ipc_process_skeleton_unittest.cpp | 472 std::thread::id threadId; variable
489 std::thread::id threadId; variable
506 std::thread::id threadId; variable
556 std::thread::id threadId; variable
1769 std::thread::id threadId; variable
1786 std::thread::id threadId; variable
1803 std::thread::id threadId; variable
1851 std::thread::id threadId; variable
|
| /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/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/communication/ipc/ipc/native/c/manager/src/ |
| D | ipc_thread_pool.c | 148 pthread_t threadId; in SpawnNewThread() local
|