Home
last modified time | relevance | path

Searched refs:SocketThreadLockInfo (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Drpc_process_skeleton.c109 static int32_t AttachThreadLockInfo(SocketThreadLockInfo *threadLockInfo) in AttachThreadLockInfo()
117 static SocketThreadLockInfo *QueryThreadLockInfo(pthread_t threadId) in QueryThreadLockInfo()
119 SocketThreadLockInfo *node = NULL; in QueryThreadLockInfo()
121 …UTILS_DL_LIST_FOR_EACH_ENTRY(node, &g_socketLockInfoList.socketLockInfo, SocketThreadLockInfo, lis… in QueryThreadLockInfo()
149 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(threadId); in AddDataThreadInWait()
151 threadLockInfo = (SocketThreadLockInfo *)malloc(sizeof(SocketThreadLockInfo)); in AddDataThreadInWait()
188 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(threadId); in WakeUpDataThread()
365 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(messageInfo->threadId); in AddSendThreadInWait()
367 threadLockInfo = (SocketThreadLockInfo *)malloc(sizeof(SocketThreadLockInfo)); in AddSendThreadInWait()
443 SocketThreadLockInfo *threadLockInfo = QueryThreadLockInfo(messageInfo->threadId); in WakeUpThreadBySeqNumber()
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h45 struct SocketThreadLockInfo { struct
139 …bool AttachThreadLockInfo(std::shared_ptr<SocketThreadLockInfo> object, const std::thread::id &thr…
140 std::shared_ptr<SocketThreadLockInfo> QueryThreadLockInfo(const std::thread::id &threadId);
275 std::map<std::thread::id, std::shared_ptr<SocketThreadLockInfo>> threadLockInfo_;
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp470 std::shared_ptr<SocketThreadLockInfo> object =
471 std::make_shared<SocketThreadLockInfo>();
638 std::shared_ptr<SocketThreadLockInfo> object =
639 std::make_shared<SocketThreadLockInfo>();
705 std::shared_ptr<SocketThreadLockInfo> object =
706 std::make_shared<SocketThreadLockInfo>();
739 std::shared_ptr<SocketThreadLockInfo> object = nullptr;
789 std::shared_ptr<SocketThreadLockInfo> object =
790 std::make_shared<SocketThreadLockInfo>();
/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/include/
H A Drpc_process_skeleton.h66 } SocketThreadLockInfo; typedef
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp717 bool IPCProcessSkeleton::AttachThreadLockInfo(std::shared_ptr<SocketThreadLockInfo> object, in AttachThreadLockInfo()
723 …threadLockInfo_.insert(std::pair<std::thread::id, std::shared_ptr<SocketThreadLockInfo>>(threadId,… in AttachThreadLockInfo()
727 std::shared_ptr<SocketThreadLockInfo> IPCProcessSkeleton::QueryThreadLockInfo(const std::thread::id… in QueryThreadLockInfo()
825 std::shared_ptr<SocketThreadLockInfo> threadLockInfo = QueryThreadLockInfo(threadID); in WakeUpDataThread()
840 std::shared_ptr<SocketThreadLockInfo> threadLockInfo; in AddDataThreadInWait()
844 threadLockInfo = std::make_shared<struct SocketThreadLockInfo>(); in AddDataThreadInWait()
/ohos5.0/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp482 std::shared_ptr<SocketThreadLockInfo> object = std::make_shared<SocketThreadLockInfo>(); in AttachThreadLockInfoTest()