| /ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/ |
| H A D | dbinder_base_invoker_interface.h | 26 uint32_t code, MessageParcel &data, uint64_t &seqNumber, int status) in WriteTransaction() argument
42 seqNumber = seqNum; in WriteTransaction()
68 int DBinderBaseInvoker<T>::SendOrWaitForCompletion(int userWaitTime, uint64_t seqNumber, in SendOrWaitForCompletion() argument
71 if (seqNumber == 0) { in SendOrWaitForCompletion()
95 uint64_t seqNumber = 0; in SendRequest() local
113 ret = SendOrWaitForCompletion(userWaitTime, seqNumber, session, nullptr); in SendRequest()
115 ret = SendOrWaitForCompletion(userWaitTime, seqNumber, session, &reply); in SendRequest()
130 uint64_t seqNumber = 0; in SendReply() local
132 GetClientFd(), 0, reply, seqNumber, result); in SendReply()
133 if (seqNumber == 0) { in SendReply()
[all …]
|
| H A D | dbinder_base_invoker_object.h | 257 transData.seqNumber = seqNum; in ConstructTransData()
337 int DBinderBaseInvoker<T>::HandleReply(uint64_t seqNumber, MessageParcel *reply, in HandleReply() argument
399 int DBinderBaseInvoker<T>::WaitForReply(uint64_t seqNumber, MessageParcel *reply, uint32_t handle, … in WaitForReply() argument
409 handle, seqNumber); in WaitForReply()
416 handle, seqNumber); in WaitForReply()
420 if (!current->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime)) { in WaitForReply()
421 current->EraseThreadBySeqNumber(seqNumber); in WaitForReply()
423 … "waitTime:%{public}d handle:%{public}u seq:%{public}" PRIu64, userWaitTime, handle, seqNumber); in WaitForReply()
427 int32_t err = HandleReply(seqNumber, reply, messageInfo); in WaitForReply()
428 current->EraseThreadBySeqNumber(seqNumber); in WaitForReply()
|
| H A D | dbinder_base_invoker_process.h | 68 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()
158 memcpyResult, tr->seqNumber, listenFd); in ProcessReply()
163 current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd); in ProcessReply()
174 current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd); in ProcessReply()
338 … tr->seqNumber, tr->buffer_size, tr->offsets_size, tr->offsets, sizeof(dbinder_transaction_data)); in PrintDBinderTransaction()
|
| H A D | dbinder_base_invoker_define.h | 73 uint32_t code, MessageParcel &data, uint64_t &seqNumber, int status);
74 …virtual int SendOrWaitForCompletion(int userWaitTime, uint64_t seqNumber, std::shared_ptr<T> sessi…
110 …int HandleReply(uint64_t seqNumber, MessageParcel *reply, std::shared_ptr<ThreadMessageInfo> messa…
111 int WaitForReply(uint64_t seqNumber, MessageParcel *reply, uint32_t handle, int userWaitTime);
|
| H A D | sys_binder.h | 300 __u64 seqNumber; member
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/ |
| H A D | dbinder_invoker.c | 72 return threadContext->seqNumber; in GetUniqueSeqNumber()
197 *seqNumber = seqNum; in WriteTransaction()
205 .seqNumber = *seqNumber, in WriteTransaction()
255 messageInfo->seqNumber = seqNumber; in MakeThreadMessageInfo()
318 if (seqNumber == 0) { in SendOrWaitForCompletion()
342 uint64_t seqNumber = 0; in SendReply() local
347 0, reply, &seqNumber, result); in SendReply()
349 if (seqNumber == 0) { in SendReply()
398 threadContext->seqNumber = 0; in ProcessTransaction()
704 uint64_t seqNumber = 0; in RpcInvokerSendRequest() local
[all …]
|
| H A D | rpc_process_skeleton.c | 65 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 userWaitTi… in AddSendThreadInWait() argument
361 RPC_LOG_ERROR("add seqNumber = %llu failed", seqNumber); in AddSendThreadInWait()
414 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber() argument
420 if (node->seqNumber == seqNumber) { in QueryThreadBySeqNumber()
429 void WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle) in WakeUpThreadBySeqNumber() argument
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/ |
| H A D | ipcprocessskeleton_fuzzer.cpp | 496 uint64_t seqNumber; in EraseThreadBySeqNumberTest() local
497 if (!GenerateUint64(seqNumber)) { 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()
527 uint64_t seqNumber; in AddSendThreadInWaitTest001() local
528 if (!GenerateUint64(seqNumber)) { in AddSendThreadInWaitTest001()
546 uint64_t seqNumber; in AddSendThreadInWaitTest002() local
584 uint64_t seqNumber; in WakeUpThreadBySeqNumberTest002() local
[all …]
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/dbinder_service/src/ |
| H A D | dbinder_service.cpp | 392 uint32_t seqNumber, uint32_t pid, uint32_t uid) in CreateMessage() argument
407 message->seqNumber = seqNumber; in CreateMessage()
487 DetachThreadLockInfo(seqNumber); in InvokerRemoteDBinder()
916 WakeupThreadByStub(replyMessage->seqNumber); in OnRemoteErrorMessage()
917 DetachThreadLockInfo(replyMessage->seqNumber); in OnRemoteErrorMessage()
928 WakeupThreadByStub(replyMessage->seqNumber); in OnRemoteReplyMessage()
929 DetachThreadLockInfo(replyMessage->seqNumber); in OnRemoteReplyMessage()
972 session->seqNumber = replyMessage->seqNumber; in InitializeSession()
1019 if (oldSession->seqNumber < session->seqNumber) { in MakeSessionByReplyMessage()
1054 threadLockInfo_.erase(seqNumber); in DetachThreadLockInfo()
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/include/ |
| H A D | rpc_process_skeleton.h | 32 uint64_t seqNumber; member
100 uint64_t seqNumber; member
128 int32_t AddSendThreadInWait(uint64_t seqNumber, ThreadMessageInfo *messageInfo, uint32_t userWaitTi…
130 ThreadMessageInfo *QueryThreadBySeqNumber(uint64_t seqNumber);
131 void WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle);
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/c/src/ |
| H A D | dbinder_service.c | 58 uint32_t seqNumber; member
250 .seqNumber = seqNumber, in SendEntryToRemote()
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()
385 return seqNumber; in GetSeqNumber()
624 static ThreadLockInfo *QueryThreadLockInfo(uint32_t seqNumber) in QueryThreadLockInfo() argument
630 if (node->seqNumber == seqNumber) { in QueryThreadLockInfo()
639 static void WakeupThreadByStub(uint32_t seqNumber) in WakeupThreadByStub() argument
[all …]
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/libdbinder/include/ |
| H A D | dbinder_service.h | 66 uint32_t seqNumber; member
78 uint32_t seqNumber; member
309 …int32_t InvokerRemoteDBinder(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, uint32_t pid…
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 …tr<struct DHandleEntryTxRx> CreateMessage(const sptr<DBinderServiceStub> &stub, uint32_t seqNumber,
330 …bool SendEntryToRemote(const sptr<DBinderServiceStub> stub, uint32_t seqNumber, uint32_t pid, uint…
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/ |
| H A D | ipc_process_skeleton_unittest.cpp | 605 uint64_t seqNumber = 1; variable
620 uint64_t seqNumber = 1; variable
657 uint64_t seqNumber = 1; variable
675 uint64_t seqNumber = 1; variable
698 uint64_t seqNumber = 1; variable
720 uint64_t seqNumber = 1; variable
753 uint64_t seqNumber = 1; variable
774 uint64_t seqNumber = 1; variable
807 uint64_t seqNumber = 1; variable
838 uint64_t seqNumber = 1; variable
[all …]
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/test/unittest/ |
| H A D | dbinder_service_unittest.cpp | 581 uint32_t seqNumber = 0; variable
584 bool res = dBinderService->SendEntryToRemote(stub, seqNumber, pid, uid);
718 uint32_t seqNumber = 123456; variable
728 ret = dBinderService->InvokerRemoteDBinder(stub, seqNumber, pid, uid);
1002 uint32_t seqNumber = 10; variable
1008 dBinderService->WakeupThreadByStub(seqNumber);
1011 dBinderService->DetachThreadLockInfo(seqNumber);
1012 dBinderService->WakeupThreadByStub(seqNumber);
1113 message->seqNumber = 1;
1188 uint32_t seqNumber = 10; variable
[all …]
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/c/include/ |
| H A D | dbinder_types.h | 95 uint64_t seqNumber; member
109 uint32_t seqNumber; member
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/ |
| H A D | ipc_process_skeleton.h | 141 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 u…
150 void WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle);
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/include/ |
| H A D | ipc_thread_pool.h | 46 uint64_t seqNumber; member
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/ |
| H A D | ipc_process_skeleton.cpp | 870 std::shared_ptr<ThreadMessageInfo> IPCProcessSkeleton::QueryThreadBySeqNumber(uint64_t seqNumber) in QueryThreadBySeqNumber() argument
875 auto it = seqNumberToThread_.find(seqNumber); in QueryThreadBySeqNumber()
883 void IPCProcessSkeleton::EraseThreadBySeqNumber(uint64_t seqNumber) in EraseThreadBySeqNumber() argument
887 seqNumberToThread_.erase(seqNumber); in EraseThreadBySeqNumber()
891 bool IPCProcessSkeleton::AddThreadBySeqNumber(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo… in AddThreadBySeqNumber() argument
897 …seqNumberToThread_.insert(std::pair<uint64_t, std::shared_ptr<ThreadMessageInfo>>(seqNumber, messa… in AddThreadBySeqNumber()
902 void IPCProcessSkeleton::WakeUpThreadBySeqNumber(uint64_t seqNumber, uint32_t handle) in WakeUpThreadBySeqNumber() argument
907 messageInfo = QueryThreadBySeqNumber(seqNumber); in WakeUpThreadBySeqNumber()
923 bool IPCProcessSkeleton::AddSendThreadInWait(uint64_t seqNumber, std::shared_ptr<ThreadMessageInfo>… in AddSendThreadInWait() argument
931 if (!AddThreadBySeqNumber(seqNumber, messageInfo)) { in AddSendThreadInWait()
[all …]
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/ |
| H A D | dbinder_remote_listener.cpp | 125 message->seqNumber, message->stubIndex, message->dBinderCode); in OnBytesReceived()
|