Searched refs:ackMessage (Results 1 – 6 of 6) sorted by relevance
590 if (ackMessage == nullptr) { in SendAckPacket()599 int errCode = ackMessage->SetExternalObject<>(packet); in SendAckPacket()603 delete ackMessage; in SendAckPacket()604 ackMessage = nullptr; in SendAckPacket()608 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()609 ackMessage->SetTarget(context->GetDeviceId()); in SendAckPacket()610 ackMessage->SetSequenceId(message->GetSequenceId()); in SendAckPacket()611 ackMessage->SetSessionId(message->GetSessionId()); in SendAckPacket()612 errCode = Send(ackMessage->GetTarget(), ackMessage); in SendAckPacket()614 delete ackMessage; in SendAckPacket()[all …]
645 if (ackMessage == nullptr) { in SendAckPacket()661 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()662 ackMessage->SetTarget(context->GetDeviceId()); in SendAckPacket()663 int errCode = ackMessage->SetExternalObject(packet); in SendAckPacket()667 delete ackMessage; in SendAckPacket()668 ackMessage = nullptr; in SendAckPacket()672 ackMessage->SetSequenceId(message->GetSequenceId()); in SendAckPacket()673 ackMessage->SetSessionId(message->GetSessionId()); in SendAckPacket()674 errCode = Send(ackMessage->GetTarget(), ackMessage); in SendAckPacket()676 delete ackMessage; in SendAckPacket()[all …]
673 if (ackMessage == nullptr) { in SendAckPacket()683 ackMessage->SetMessageType(TYPE_RESPONSE); in SendAckPacket()684 ackMessage->SetTarget(context->GetDeviceId()); in SendAckPacket()685 int errCode = ackMessage->SetExternalObject(packet); in SendAckPacket()689 delete ackMessage; in SendAckPacket()690 ackMessage = nullptr; in SendAckPacket()694 ackMessage->SetSequenceId(message->GetSequenceId()); in SendAckPacket()695 ackMessage->SetSessionId(message->GetSessionId()); in SendAckPacket()696 errCode = Send(ackMessage->GetTarget(), ackMessage); in SendAckPacket()699 delete ackMessage; in SendAckPacket()[all …]
427 if (ackMessage == nullptr) { in RequestRecv()430 ackMessage->SetSessionId(message->GetSessionId()); in RequestRecv()431 ackMessage->SetPriority(Priority::NORMAL); in RequestRecv()432 ackMessage->SetMessageType(TYPE_RESPONSE); in RequestRecv()433 ackMessage->SetTarget(deviceId_); in RequestRecv()434 int errCode = ackMessage->SetCopiedObject<>(ackPacket); in RequestRecv()436 delete ackMessage; in RequestRecv()437 ackMessage = nullptr; in RequestRecv()441 errCode = SendPacket(deviceId_, ackMessage); in RequestRecv()443 delete ackMessage; in RequestRecv()[all …]
1186 if (ackMessage == nullptr) { in SendAck()1190 int errCode = ackMessage->SetCopiedObject<>(ackPacket); in SendAck()1193 delete ackMessage; in SendAck()1194 ackMessage = nullptr; in SendAck()1197 …(!isAckNotify) ? ackMessage->SetMessageType(TYPE_RESPONSE) : ackMessage->SetMessageType(TYPE_NOTIF… in SendAck()1198 ackMessage->SetTarget(deviceId_); in SendAck()1199 ackMessage->SetSessionId(inMsg->GetSessionId()); in SendAck()1200 ackMessage->SetSequenceId(inMsg->GetSequenceId()); in SendAck()1203 errCode = communicator_->SendMessage(deviceId_, ackMessage, conf); in SendAck()1206 delete ackMessage; in SendAck()[all …]
1137 delete ackMessage; in SendDataAck()1138 ackMessage = nullptr; in SendDataAck()1147 delete ackMessage; in SendDataAck()1148 ackMessage = nullptr; in SendDataAck()1253 delete ackMessage; in SendSaveDataNotifyPacket()1254 ackMessage = nullptr; in SendSaveDataNotifyPacket()1262 delete ackMessage; in SendSaveDataNotifyPacket()1372 delete ackMessage; in SendResetWatchDogPacket()1382 delete ackMessage; in SendResetWatchDogPacket()1941 delete ackMessage; in SendControlAck()[all …]