Lines Matching refs:replyMessage
528 static int32_t OnRemoteInvokerDataBusMessage(ProxyObject *proxy, DHandleEntryTxRx *replyMessage,
572 replyMessage->dBinderCode = MESSAGE_AS_REPLY;
573 replyMessage->stubIndex = stubIndex;
574 replyMessage->serviceNameLength = (uint16_t)sessionLen;
575 if (memcpy_s(replyMessage->serviceName, SERVICENAME_LENGTH, serverSessionName, sessionLen) != 0) {
576 RPC_LOG_ERROR("replyMessage serviceName memcpy failed");
580 replyMessage->serviceName[replyMessage->serviceNameLength] = '\0';
595 DHandleEntryTxRx replyMessage;
596 if (memcpy_s(&replyMessage, sizeof(DHandleEntryTxRx), message, sizeof(DHandleEntryTxRx)) != EOK) {
597 RPC_LOG_ERROR("OnRemoteInvokerMessage replyMessage memcpy failed");
600 char *fromDeviceID = replyMessage.deviceIdInfo.fromDeviceId;
602 switch (replyMessage.transType) {
604 if (OnRemoteInvokerDataBusMessage(saProxy, &replyMessage, fromDeviceID,
617 if (SendDataToRemote(fromDeviceID, &replyMessage) != ERR_NONE) {
666 static void MakeSessionByReplyMessage(const DHandleEntryTxRx *replyMessage)
668 if (replyMessage == NULL) {
669 RPC_LOG_ERROR("replyMessage is null");
672 if (!HasDBinderStub(replyMessage->binderObject)) {
676 if (QuerySessionObject(replyMessage->stub) != NULL) {
687 &replyMessage->deviceIdInfo, sizeof(struct DeviceIdInfo)) != 0) {
692 if (strcpy_s(session->serviceName, SERVICENAME_LENGTH + 1, replyMessage->serviceName) != EOK) {
697 session->serviceName[replyMessage->serviceNameLength] = '\0';
700 session->stubIndex = replyMessage->stubIndex;
701 session->toPort = replyMessage->toPort;
702 session->fromPort = replyMessage->fromPort;
703 session->type = replyMessage->transType;
704 session->stub = replyMessage->stub;
718 static int32_t OnRemoteReplyMessage(const DHandleEntryTxRx *replyMessage)
720 MakeSessionByReplyMessage(replyMessage);
721 WakeupThreadByStub(replyMessage->seqNumber);