Home
last modified time | relevance | path

Searched refs:ThreadMessageInfo (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/include/
H A Drpc_process_skeleton.h107 } ThreadMessageInfo; typedef
128 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTi…
129 void EraseThreadBySeqNumber(ThreadMessageInfo *messageInfo);
130 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber);
/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Drpc_process_skeleton.c48 static ThreadMessageInfo g_seqNumberToThread;
350 static int32_t AddThreadBySeqNumber(ThreadMessageInfo *messageInfo) in AddThreadBySeqNumber()
358 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTi… in AddSendThreadInWait()
407 void EraseThreadBySeqNumber(ThreadMessageInfo *messageInfo) in EraseThreadBySeqNumber()
414 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber()
416 ThreadMessageInfo *node = NULL; in QueryThreadBySeqNumber()
418 UTILS_DL_LIST_FOR_EACH_ENTRY(node, &g_seqNumberToThread.list, ThreadMessageInfo, list) in QueryThreadBySeqNumber()
431 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(seqNumber); in WakeUpThreadBySeqNumber()
H A Ddbinder_invoker.c246 static ThreadMessageInfo *MakeThreadMessageInfo(uint64_t seqNumber, uint32_t handle) in MakeThreadMessageInfo()
248 ThreadMessageInfo *messageInfo = (ThreadMessageInfo *)malloc(sizeof(ThreadMessageInfo)); in MakeThreadMessageInfo()
269 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(seqNumber); in HandleReply()
298 ThreadMessageInfo *messageInfo = MakeThreadMessageInfo(seqNumber, handle); in WaitForReply()
410 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply()
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h51 struct ThreadMessageInfo { struct
142 bool AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo);
143 std::shared_ptr<ThreadMessageInfo> QueryThreadBySeqNumber(uint64_t seqNumber);
144 …bool AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo, int u…
273 std::map<uint64_t, std::shared_ptr<ThreadMessageInfo>> seqNumberToThread_;
/ohos5.0/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp500 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in EraseThreadBySeqNumberTest()
531 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in AddSendThreadInWaitTest001()
542 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in AddSendThreadInWaitTest002()
604 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<ThreadMessageInfo>(); in WakeUpThreadBySeqNumberTest003()
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_object.h338 std::shared_ptr<ThreadMessageInfo> messageInfo) in HandleReply()
406 std::shared_ptr<ThreadMessageInfo> messageInfo = MakeThreadMessageInfo(handle); in WaitForReply()
476 template <class T> std::shared_ptr<ThreadMessageInfo> DBinderBaseInvoker<T>::MakeThreadMessageInfo(… in MakeThreadMessageInfo()
478 std::shared_ptr<ThreadMessageInfo> messageInfo = std::make_shared<struct ThreadMessageInfo>(); in MakeThreadMessageInfo()
H A Ddbinder_base_invoker_define.h110 …int HandleReply(uint64_t seqNumber, MessageParcel *reply, std::shared_ptr<ThreadMessageInfo> messa…
132 std::shared_ptr<ThreadMessageInfo> MakeThreadMessageInfo(int32_t socketId);
H A Ddbinder_base_invoker_process.h129 std::shared_ptr<ThreadMessageInfo> messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply()
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp606 std::shared_ptr<ThreadMessageInfo> messageInfo =
607 std::make_shared<ThreadMessageInfo>();
634 auto messageInfo = std::make_shared<ThreadMessageInfo>();
677 auto messageInfo = std::make_shared<ThreadMessageInfo>();
700 auto messageInfo = std::make_shared<ThreadMessageInfo>();
734 auto messageInfo = std::make_shared<ThreadMessageInfo>();
759 auto messageInfo = std::make_shared<ThreadMessageInfo>();
784 auto messageInfo = std::make_shared<ThreadMessageInfo>();
816 auto messageInfo = std::make_shared<ThreadMessageInfo>();
845 auto messageInfo = std::make_shared<ThreadMessageInfo>();
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp870 std::shared_ptr<ThreadMessageInfo> IPCProcessSkeleton::QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber()
891 bool IPCProcessSkeleton::AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo… in AddThreadBySeqNumber()
897 …seqNumberToThread_.insert(std::pair<uint64_t, std::shared_ptr<ThreadMessageInfo>>(seqNumber, messa… in AddThreadBySeqNumber()
905 std::shared_ptr<ThreadMessageInfo> messageInfo; in WakeUpThreadBySeqNumber()
923 bool IPCProcessSkeleton::AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo>… in AddSendThreadInWait()