Home
last modified time | relevance | path

Searched refs:seqNumber (Results 1 - 21 of 21) sorted by relevance

/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_interface.h26 uint32_t code, MessageParcel &data, uint64_t &seqNumber, int status) in WriteTransaction()
42 seqNumber = seqNum; in WriteTransaction()
68 int DBinderBaseInvoker<T>::SendOrWaitForCompletion(int userWaitTime, uint64_t seqNumber, in SendOrWaitForCompletion() argument
71 if (seqNumber == 0) { in SendOrWaitForCompletion()
72 ZLOGE(LOG_LABEL, "seqNumber can not be zero"); in SendOrWaitForCompletion()
76 ZLOGE(LOG_LABEL, "current session is invalid, seq:%{public}" PRIu64, seqNumber); in SendOrWaitForCompletion()
81 ZLOGE(LOG_LABEL, "fail to send to remote session, error:%{public}d seq:%{public}" PRIu64, result, seqNumber); in SendOrWaitForCompletion()
84 result = WaitForReply(seqNumber, reply, sessionOfPeer->GetSocketId(), userWaitTime); in SendOrWaitForCompletion()
86 ZLOGE(LOG_LABEL, "dbinder wait for reply error:%{public}d seq:%{public}" PRIu64, result, seqNumber); in SendOrWaitForCompletion()
95 uint64_t seqNumber in SendRequest() local
25 WriteTransaction(int cmd, uint32_t flags, int32_t handle, int32_t socketId, uint32_t code, MessageParcel &data, uint64_t &seqNumber, int status) WriteTransaction() argument
130 uint64_t seqNumber = 0; SendReply() local
[all...]
H A Ddbinder_base_invoker_object.h255 transData.seqNumber = seqNum; in ConstructTransData()
335 int DBinderBaseInvoker<T>::HandleReply(uint64_t seqNumber, MessageParcel *reply, in HandleReply() argument
397 int DBinderBaseInvoker<T>::WaitForReply(uint64_t seqNumber, MessageParcel *reply, uint32_t handle, int userWaitTime) in WaitForReply() argument
407 handle, seqNumber); in WaitForReply()
414 handle, seqNumber); in WaitForReply()
418 if (!current->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime)) { in WaitForReply()
419 current->EraseThreadBySeqNumber(seqNumber); in WaitForReply()
421 "waitTime:%{public}d handle:%{public}u seq:%{public}" PRIu64, userWaitTime, handle, seqNumber); in WaitForReply()
425 int32_t err = HandleReply(seqNumber, reply, messageInfo); in WaitForReply()
426 current->EraseThreadBySeqNumber(seqNumber); in WaitForReply()
[all...]
H A Ddbinder_base_invoker_process.h68 uint64_t senderSeqNumber = tr->seqNumber; in ProcessTransaction()
129 std::shared_ptr<ThreadMessageInfo> messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply()
133 tr->seqNumber, listenFd, retryCount++); in ProcessReply()
140 messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber); in ProcessReply()
147 ", seqNumber:%{public}llu listenFd:%{public}d", tr->seqNumber, listenFd); in ProcessReply()
150 current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd); in ProcessReply()
157 ZLOGE(LOG_LABEL, "memcpy_s failed, error:%{public}d seqNumber:%{public}llu listenFd:%{public}d", in ProcessReply()
158 memcpyResult, tr->seqNumber, listenFd); in ProcessReply()
163 current->WakeUpThreadBySeqNumber(tr->seqNumber, listenF in ProcessReply()
[all...]
H A Ddbinder_base_invoker_define.h73 uint32_t code, MessageParcel &data, uint64_t &seqNumber, int status);
74 virtual int SendOrWaitForCompletion(int userWaitTime, uint64_t seqNumber, std::shared_ptr<T> sessionOfPeer,
110 int HandleReply(uint64_t seqNumber, MessageParcel *reply, std::shared_ptr<ThreadMessageInfo> messageInfo);
111 int WaitForReply(uint64_t seqNumber, MessageParcel *reply, uint32_t handle, int userWaitTime);
H A Dsys_binder.h299 __u64 seqNumber; member
/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Ddbinder_invoker.c72 return threadContext->seqNumber; in GetUniqueSeqNumber()
181 int32_t sessionId, uint32_t code, IpcIo *data, uint64_t *seqNumber, int status) in WriteTransaction()
197 *seqNumber = seqNum; in WriteTransaction()
205 .seqNumber = *seqNumber, in WriteTransaction()
246 static ThreadMessageInfo *MakeThreadMessageInfo(uint64_t seqNumber, uint32_t handle) in MakeThreadMessageInfo() argument
255 messageInfo->seqNumber = seqNumber; in MakeThreadMessageInfo()
262 static int32_t HandleReply(uint64_t seqNumber, IpcIo *reply, uintptr_t *buffer) in HandleReply() argument
269 ThreadMessageInfo *messageInfo = QueryThreadBySeqNumber(seqNumber); in HandleReply()
180 WriteTransaction(int32_t cmd, MessageOption option, int32_t handle, int32_t sessionId, uint32_t code, IpcIo *data, uint64_t *seqNumber, int status) WriteTransaction() argument
292 WaitForReply(uint64_t seqNumber, IpcIo *reply, uint32_t handle, uint32_t userWaitTime, uintptr_t *buffer) WaitForReply() argument
315 SendOrWaitForCompletion(uint32_t userWaitTime, uint64_t seqNumber, HandleSessionList *sessionOfPeer, IpcIo *reply, uintptr_t *buffer) SendOrWaitForCompletion() argument
342 uint64_t seqNumber = 0; SendReply() local
704 uint64_t seqNumber = 0; RpcInvokerSendRequest() local
[all...]
H A Drpc_process_skeleton.c65 g_rpcSkeleton.seqNumber = 0; in RpcProcessSkeleton()
311 ++g_rpcSkeleton.seqNumber; // can be overflow, and seqNumber do not use 0 in ProcessGetSeqNumber()
312 if (g_rpcSkeleton.seqNumber == 0) { in ProcessGetSeqNumber()
313 ++g_rpcSkeleton.seqNumber; in ProcessGetSeqNumber()
317 return g_rpcSkeleton.seqNumber; in ProcessGetSeqNumber()
358 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTime) in AddSendThreadInWait() argument
361 RPC_LOG_ERROR("add seqNumber = %llu failed", seqNumber); in AddSendThreadInWait()
414 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber() argument
429 WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle) WakeUpThreadBySeqNumber() argument
[all...]
/foundation/communication/ipc/ipc/native/c/rpc/include/
H A Drpc_process_skeleton.h32 uint64_t seqNumber; member
100 uint64_t seqNumber; member
128 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTime);
130 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber);
131 void WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle);
/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp496 uint64_t seqNumber; in EraseThreadBySeqNumberTest() local
497 if (!GenerateUint64(seqNumber)) { in EraseThreadBySeqNumberTest()
501 current->AddThreadBySeqNumber(seqNumber, messageInfo); in EraseThreadBySeqNumberTest()
502 current->QueryThreadBySeqNumber(seqNumber); in EraseThreadBySeqNumberTest()
503 current->EraseThreadBySeqNumber(seqNumber); in EraseThreadBySeqNumberTest()
513 uint64_t seqNumber; in QueryThreadBySeqNumberTest001() local
514 if (!GenerateUint64(seqNumber)) { in QueryThreadBySeqNumberTest001()
517 current->QueryThreadBySeqNumber(seqNumber); in QueryThreadBySeqNumberTest001()
527 uint64_t seqNumber; in AddSendThreadInWaitTest001() local
528 if (!GenerateUint64(seqNumber)) { in AddSendThreadInWaitTest001()
546 uint64_t seqNumber; AddSendThreadInWaitTest002() local
584 uint64_t seqNumber; WakeUpThreadBySeqNumberTest002() local
599 uint64_t seqNumber; WakeUpThreadBySeqNumberTest003() local
[all...]
/foundation/communication/ipc/services/dbinder/c/src/
H A Ddbinder_service.c58 uint32_t seqNumber; member
222 static int32_t SendEntryToRemote(DBinderServiceStub *stub, const uint32_t seqNumber) in SendEntryToRemote() argument
250 .seqNumber = seqNumber, in SendEntryToRemote()
321 static int32_t InvokerRemoteDBinder(DBinderServiceStub *dBinderServiceStub, uint32_t seqNumber) in InvokerRemoteDBinder() argument
333 threadLockInfo->seqNumber = seqNumber; in InvokerRemoteDBinder()
342 ret = SendEntryToRemote(dBinderServiceStub, seqNumber); in InvokerRemoteDBinder()
381 static uint32_t seqNumber = 0; in GetSeqNumber() local
383 seqNumber in GetSeqNumber()
624 QueryThreadLockInfo(uint32_t seqNumber) QueryThreadLockInfo() argument
639 WakeupThreadByStub(uint32_t seqNumber) WakeupThreadByStub() argument
[all...]
/foundation/communication/ipc/services/dbinder/dbinder_service/src/
H A Ddbinder_service.cpp383 message->stubIndex, message->seqNumber); in CopyDeviceIDsToMessage()
392 uint32_t seqNumber, uint32_t pid, uint32_t uid) in CreateMessage()
407 message->seqNumber = seqNumber; in CreateMessage()
417 bool DBinderService::SendEntryToRemote(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, uint32_t pid, in SendEntryToRemote() argument
427 auto message = CreateMessage(stub, seqNumber, pid, uid); in SendEntryToRemote()
438 " tokenId:%{public}u", message->pid, message->uid, message->seqNumber, in SendEntryToRemote()
443 message->stubIndex, message->seqNumber); in SendEntryToRemote()
450 message->stubIndex, message->seqNumber); in SendEntryToRemote()
457 int32_t DBinderService::InvokerRemoteDBinder(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, in InvokerRemoteDBinder() argument
391 CreateMessage(const sptr<DBinderServiceStub> &stub, uint32_t seqNumber, uint32_t pid, uint32_t uid) CreateMessage() argument
1038 WakeupThreadByStub(uint32_t seqNumber) WakeupThreadByStub() argument
1051 DetachThreadLockInfo(uint32_t seqNumber) DetachThreadLockInfo() argument
1057 AttachThreadLockInfo(uint32_t seqNumber, const std::string &networkId, std::shared_ptr<struct ThreadLockInfo> object) AttachThreadLockInfo() argument
1067 QueryThreadLockInfo(uint32_t seqNumber) QueryThreadLockInfo() argument
[all...]
/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp605 uint64_t seqNumber = 1; in HWTEST_F() local
608 skeleton->AddThreadBySeqNumber(seqNumber, messageInfo); in HWTEST_F()
609 auto ret = skeleton->QueryThreadBySeqNumber(seqNumber); in HWTEST_F()
620 uint64_t seqNumber = 1; in HWTEST_F() local
636 skeleton->AddThreadBySeqNumber(seqNumber, messageInfo); in HWTEST_F()
643 skeleton->WakeUpThreadBySeqNumber(seqNumber, handler); in HWTEST_F()
657 uint64_t seqNumber = 1; in HWTEST_F() local
660 skeleton->WakeUpThreadBySeqNumber(seqNumber, handler); in HWTEST_F()
661 ASSERT_TRUE(skeleton->QueryThreadBySeqNumber(seqNumber) == nullptr); in HWTEST_F()
675 uint64_t seqNumber in HWTEST_F() local
698 uint64_t seqNumber = 1; HWTEST_F() local
720 uint64_t seqNumber = 1; HWTEST_F() local
753 uint64_t seqNumber = 1; HWTEST_F() local
774 uint64_t seqNumber = 1; HWTEST_F() local
807 uint64_t seqNumber = 1; HWTEST_F() local
838 uint64_t seqNumber = 1; HWTEST_F() local
1873 uint64_t seqNumber = 1; HWTEST_F() local
[all...]
/foundation/communication/ipc/interfaces/innerkits/libdbinder/include/
H A Ddbinder_service.h66 uint32_t seqNumber; member
78 uint32_t seqNumber; member
309 int32_t InvokerRemoteDBinder(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, uint32_t pid, uint32_t uid);
315 void WakeupThreadByStub(uint32_t seqNumber);
316 void DetachThreadLockInfo(uint32_t seqNumber);
317 bool AttachThreadLockInfo(uint32_t seqNumber, const std::string &networkId,
319 std::shared_ptr<struct ThreadLockInfo> QueryThreadLockInfo(uint32_t seqNumber);
328 std::shared_ptr<struct DHandleEntryTxRx> CreateMessage(const sptr<DBinderServiceStub> &stub, uint32_t seqNumber,
330 bool SendEntryToRemote(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, uint32_t pid, uint32_t uid);
/foundation/communication/ipc/services/dbinder/c/include/
H A Ddbinder_types.h95 uint64_t seqNumber; member
109 uint32_t seqNumber; member
/foundation/communication/ipc/ipc/native/c/manager/include/
H A Dipc_thread_pool.h46 uint64_t seqNumber; member
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h141 void EraseThreadBySeqNumber(uint64_t seqNumber);
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 userWaitTime);
150 void WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle);
/foundation/communication/ipc/services/dbinder/test/unittest/
H A Ddbinder_service_unittest.cpp581 uint32_t seqNumber = 0; in HWTEST_F() local
584 bool res = dBinderService->SendEntryToRemote(stub, seqNumber, pid, uid); in HWTEST_F()
718 uint32_t seqNumber = 123456; in HWTEST_F() local
721 int32_t ret = dBinderService->InvokerRemoteDBinder(stub, seqNumber, pid, uid); in HWTEST_F()
728 ret = dBinderService->InvokerRemoteDBinder(stub, seqNumber, pid, uid); in HWTEST_F()
1002 uint32_t seqNumber = 10; in HWTEST_F() local
1007 dBinderService->AttachThreadLockInfo(seqNumber, "networkId", threadLockInfo); in HWTEST_F()
1008 dBinderService->WakeupThreadByStub(seqNumber); in HWTEST_F()
1009 EXPECT_TRUE(dBinderService->QueryThreadLockInfo(seqNumber) != nullptr); in HWTEST_F()
1010 EXPECT_EQ(dBinderService->QueryThreadLockInfo(seqNumber), threadLockInf in HWTEST_F()
1188 uint32_t seqNumber = 10; HWTEST_F() local
1286 uint32_t seqNumber = 0; HWTEST_F() local
[all...]
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp864 std::shared_ptr<ThreadMessageInfo> IPCProcessSkeleton::QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber() argument
869 auto it = seqNumberToThread_.find(seqNumber); in QueryThreadBySeqNumber()
877 void IPCProcessSkeleton::EraseThreadBySeqNumber(uint64_t seqNumber) in EraseThreadBySeqNumber() argument
881 seqNumberToThread_.erase(seqNumber); in EraseThreadBySeqNumber()
885 bool IPCProcessSkeleton::AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo) in AddThreadBySeqNumber() argument
891 seqNumberToThread_.insert(std::pair<uint64_t, std::shared_ptr<ThreadMessageInfo>>(seqNumber, messageInfo)); in AddThreadBySeqNumber()
896 void IPCProcessSkeleton::WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle) in WakeUpThreadBySeqNumber() argument
901 messageInfo = QueryThreadBySeqNumber(seqNumber); in WakeUpThreadBySeqNumber()
917 bool IPCProcessSkeleton::AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo> messageInfo, in AddSendThreadInWait() argument
925 if (!AddThreadBySeqNumber(seqNumber, messageInf in AddSendThreadInWait()
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/rtsp/src/
H A Drtsp_package.cpp549 int seqNumber = INVALID_VALUE; in EncapCommonResponse() local
552 seqNumber = RtspParse::ParseIntSafe(Utils::Trim(cseq)); in EncapCommonResponse()
555 return AddResponseHeaders(statusCode, seqNumber) + MSG_SEPARATOR; in EncapCommonResponse()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/rtsp/src/
H A Drtsp_package.cpp549 int seqNumber = INVALID_VALUE; in EncapCommonResponse() local
552 seqNumber = RtspParse::ParseIntSafe(Utils::Trim(cseq)); in EncapCommonResponse()
555 return AddResponseHeaders(statusCode, seqNumber) + MSG_SEPARATOR; in EncapCommonResponse()
/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/
H A Ddbinder_remote_listener.cpp125 message->seqNumber, message->stubIndex, message->dBinderCode); in OnBytesReceived()

Completed in 27 milliseconds