Home
last modified time | relevance | path

Searched refs:sessionOfPeer (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_object.h27 if (sessionOfPeer == nullptr) { in TranslateBinderType()
34 return FlattenSession(sessionOffset, sessionOfPeer, SUPPORT_TOKENID_VERSION_NUM); in TranslateBinderType()
52 std::shared_ptr<T> sessionOfPeer = nullptr; in TranslateHandleType() local
54 sessionOfPeer = QuerySessionOfBinderProxy(binderObject->handle, session); in TranslateHandleType()
56 sessionOfPeer = NewSessionOfBinderProxy(binderObject->handle, session); in TranslateHandleType()
58 if (sessionOfPeer == nullptr) { in TranslateHandleType()
77 std::shared_ptr<T> sessionOfPeer = nullptr; in TranslateRemoteHandleType() local
80 sessionOfPeer = UnFlattenSession(sessionOffset, binderVersion); in TranslateRemoteHandleType()
82 if (sessionOfPeer == nullptr) { in TranslateRemoteHandleType()
92 uint32_t handle = QueryHandleBySession(sessionOfPeer); in TranslateRemoteHandleType()
[all …]
H A Ddbinder_base_invoker_interface.h69 std::shared_ptr<T> sessionOfPeer, MessageParcel *reply) in SendOrWaitForCompletion() argument
75 if (sessionOfPeer == nullptr) { in SendOrWaitForCompletion()
79 int result = OnSendMessage(sessionOfPeer); in SendOrWaitForCompletion()
84 result = WaitForReply(seqNumber, reply, sessionOfPeer->GetSocketId(), userWaitTime); in SendOrWaitForCompletion()
H A Ddbinder_base_invoker_define.h74 …int SendOrWaitForCompletion(int userWaitTime, uint64_t seqNumber, std::shared_ptr<T> sessionOfPeer,
86 virtual int OnSendMessage(std::shared_ptr<T> sessionOfPeer) = 0;
H A Ddbinder_databus_invoker.h74 int OnSendMessage(std::shared_ptr<DBinderSessionObject> sessionOfPeer) override;
/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Ddbinder_invoker.c227 static int32_t OnSendMessage(HandleSessionList *sessionOfPeer) in OnSendMessage() argument
229 if (sessionOfPeer == NULL || sessionOfPeer->buffer == NULL) { in OnSendMessage()
239 int32_t ret = rpcSkeleton->rpcTrans->Send((int)sessionOfPeer->sessionId, in OnSendMessage()
240 (void *)sessionOfPeer->buffer, (uint32_t)sessionOfPeer->len); in OnSendMessage()
242 free(sessionOfPeer->buffer); in OnSendMessage()
316 HandleSessionList *sessionOfPeer, IpcIo *reply, uintptr_t *buffer) in SendOrWaitForCompletion() argument
322 if (sessionOfPeer == NULL) { in SendOrWaitForCompletion()
326 int32_t result = OnSendMessage(sessionOfPeer); in SendOrWaitForCompletion()
331 return WaitForReply(seqNumber, reply, sessionOfPeer->handle, userWaitTime, buffer); in SendOrWaitForCompletion()
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dmessage_parcel.cpp136 std::shared_ptr<DBinderSessionObject> sessionOfPeer = current->ProxyQueryDBinderSession(handle); in WriteDBinderProxy() local
137 if (sessionOfPeer == nullptr) { in WriteDBinderProxy()
141 std::string peerName = sessionOfPeer->GetServiceName(); in WriteDBinderProxy()
142 std::string peerId = sessionOfPeer->GetDeviceId(); in WriteDBinderProxy()
144 uint32_t tokenId = sessionOfPeer->GetTokenId(); in WriteDBinderProxy()
150 …fakeStub = new (std::nothrow) DBinderCallbackStub(peerName, peerId, localId, sessionOfPeer->GetStu… in WriteDBinderProxy()
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/source/
H A Ddbinder_databus_invoker.cpp186 …std::shared_ptr<DBinderSessionObject> sessionOfPeer = current->StubQueryDBinderSession(databusHand… in QueryClientSessionObject() local
187 if (sessionOfPeer == nullptr) { in QueryClientSessionObject()
191 ZLOGI(LOG_LABEL, "socketId:%{public}d", sessionOfPeer->GetSocketId()); in QueryClientSessionObject()
192 return sessionOfPeer; in QueryClientSessionObject()
203 std::shared_ptr<DBinderSessionObject> sessionOfPeer = current->ProxyQueryDBinderSession(handle); in QueryServerSessionObject() local
204 if (sessionOfPeer == nullptr) { in QueryServerSessionObject()
209 return sessionOfPeer; in QueryServerSessionObject()
331 int DBinderDatabusInvoker::OnSendMessage(std::shared_ptr<DBinderSessionObject> sessionOfPeer) in OnSendMessage() argument
333 if (sessionOfPeer == nullptr) { in OnSendMessage()
338 int32_t socketId = sessionOfPeer->GetSocketId(); in OnSendMessage()
[all …]
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_binder_databus_invoker_unittest.cpp756 std::shared_ptr<DBinderSessionObject> sessionOfPeer = nullptr; variable
757 int ret = testInvoker.OnSendMessage(sessionOfPeer);
770 std::shared_ptr<DBinderSessionObject> sessionOfPeer = variable
772 int ret = testInvoker.OnSendMessage(sessionOfPeer);
784 std::shared_ptr<DBinderSessionObject> sessionOfPeer = variable
794 sessionOfPeer->buff_ = sessionBuff;
795 int ret = testInvoker.OnSendMessage(sessionOfPeer);