Home
last modified time | relevance | path

Searched refs:inMsg (Results 1 – 25 of 61) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.h38 static uint32_t CalculateLen(const Message *inMsg);
42 static bool IsPacketValid(const Message *inMsg);
50 static uint32_t CalculateDataLen(const Message *inMsg);
51 static uint32_t CalculateControlLen(const Message *inMsg);
57 static int DataPacketCalculateLen(const Message *inMsg, uint32_t &len);
68 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
75 static int ControlPacketCalculateLen(const Message *inMsg, uint32_t &len);
79 static int AckControlPacketCalculateLen(const Message *inMsg, uint32_t &len);
85 static int SubscribeCalculateLen(const Message *inMsg, uint32_t &len);
92 static uint32_t ISyncPacketCalculateLen(const Message *inMsg);
[all …]
H A Dsingle_ver_serialize_manager.cpp126 if (!(IsPacketValid(inMsg))) { in CalculateLen()
137 return computeFunc(inMsg); in CalculateLen()
142 return CalculateDataLen(inMsg); in CalculateLen()
316 if (inMsg == nullptr) { in IsPacketValid()
740 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterCommunicatorTransformFunc() argument
766 func.computeFunc = [](const Message *inMsg) { return ISyncPacketCalculateLen(inMsg); }; in RegisterInnerTransformFunc() argument
779 if (inMsg == nullptr) { in ISyncPacketCalculateLen()
791 const Message *inMsg) in ISyncPacketSerialization() argument
793 if (inMsg == nullptr) { in ISyncPacketSerialization()
806 Message *inMsg) in ISyncPacketDeSerialization() argument
[all …]
H A Dsingle_ver_sync_state_machine.cpp187 switch (inMsg->GetMessageId()) { in ReceiveMessageCallback()
448 if (IsNeedResetWatchdog(inMsg)) { in HandleControlAckRecv()
599 if (inMsg->GetMessageType() == TYPE_RESPONSE && AbilityMsgSessionIdCheck(inMsg)) { in AbilitySyncResponseRecv()
652 …bool isNeedStop = StartSaveDataNotify(inMsg->GetSessionId(), inMsg->GetSequenceId(), inMsg->GetMes… in HandleDataRequestRecv()
729 if (!IsPacketValid(inMsg)) { in HandleDataAckRecv()
743 …bool isNeedStop = StartSaveDataNotify(inMsg->GetSessionId(), inMsg->GetSequenceId(), inMsg->GetMes… in HandleDataAckRecv()
787 dataSync_->PutDataMsg(inMsg); in ScheduleMsgAndHandle()
923 if (inMsg == nullptr) { in IsPacketValid()
927 if ((inMsg->GetMessageId() < TIME_SYNC_MESSAGE) || (inMsg->GetMessageId() >= UNKNOW_MESSAGE)) { in IsPacketValid()
984 if (!IsPacketValid(inMsg)) { in MessageCallbackPre()
[all …]
H A Dsingle_ver_sync_state_machine.h85 int HandleDataRequestRecv(const Message *inMsg);
134 int TimeMarkSyncRecv(const Message *inMsg);
175 int HandleControlAckRecv(const Message *inMsg);
179 int AbilitySyncRecv(const Message *inMsg);
181 int DataPktRecv(Message *inMsg);
183 void ScheduleMsgAndHandle(Message *inMsg);
185 int ControlPktRecv(Message *inMsg);
189 int HandleDataAckRecv(const Message *inMsg);
195 bool IsPacketValid(const Message *inMsg) const;
201 int MessageCallbackPre(const Message *inMsg);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.cpp127 if (!IsPacketValid(inMsg)) { in MessageCallbackCheck()
130 … if ((inMsg->GetMessageType() == TYPE_RESPONSE) && (inMsg->GetMessageId() != TIME_SYNC_MESSAGE)) { in MessageCallbackCheck()
142 if (inMsg == nullptr) { in ReceiveMessageCallback()
145 if (inMsg->IsFeedbackError()) { in ReceiveMessageCallback()
157 switch (inMsg->GetMessageId()) { in ReceiveMessageCallback()
323 … if ((context == nullptr) || (inMsg == nullptr) || (inMsg->GetMessageId() != TIME_SYNC_MESSAGE)) { in TimeSyncPacketRecvCallback()
326 switch (inMsg->GetMessageType()) { in TimeSyncPacketRecvCallback()
348 switch (inMsg->GetMessageType()) { in CommitHistorySyncPktRecvCallback()
377 switch (inMsg->GetMessageType()) { in MultiVerDataPktRecvCallback()
501 if (inMsg == nullptr) { in IsPacketValid()
[all …]
H A Dmulti_ver_data_sync.cpp102 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
106 switch (inMsg->GetMessageType()) { in Serialization()
118 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
122 switch (inMsg->GetMessageType()) { in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
140 switch (inMsg->GetMessageType()) { in CalculateLen()
159 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc() argument
361 if ((inMsg == nullptr) || !IsPacketValid(inMsg, TYPE_REQUEST)) { in RequestPacketCalculateLen()
440 if (!IsPacketValid(inMsg, TYPE_RESPONSE)) { in AckPacketCalculateLen()
531 if ((inMsg == nullptr) || (inMsg->GetMessageId() != MULTI_VER_DATA_SYNC_MESSAGE)) { in IsPacketValid()
[all …]
H A Dvalue_slice_sync.cpp102 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
106 switch (inMsg->GetMessageType()) { in Serialization()
118 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
122 switch (inMsg->GetMessageType()) { in DeSerialization()
134 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
140 switch (inMsg->GetMessageType()) { in CalculateLen()
159 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc() argument
161 return Serialization(buffer, length, inMsg); in RegisterTransformFunc()
164 return DeSerialization(buffer, length, inMsg); in RegisterTransformFunc()
491 if ((inMsg == nullptr) || (inMsg->GetMessageId() != VALUE_SLICE_SYNC_MESSAGE)) { in IsPacketValid()
[all …]
H A Dvalue_slice_sync.h75 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
77 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
79 static uint32_t CalculateLen(const Message *inMsg);
90 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
92 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
94 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
96 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
98 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
100 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
102 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
[all …]
H A Dmulti_ver_data_sync.h76 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
78 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
80 static uint32_t CalculateLen(const Message *inMsg);
100 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
102 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
104 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
106 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
108 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
110 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
112 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
[all …]
H A Dmulti_ver_sync_state_machine.h47 int ReceiveMessageCallback(Message *inMsg) override;
77 bool IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) override;
92 int MessageCallbackCheck(const Message *inMsg);
100 int TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, const Message *inMsg);
102 int CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
104 int MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
106 int ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
112 bool IsPacketValid(const Message *inMsg) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.cpp143 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
147 switch (inMsg->GetMessageType()) { in Serialization()
159 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
163 switch (inMsg->GetMessageType()) { in DeSerialization()
175 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
181 switch (inMsg->GetMessageType()) { in CalculateLen()
202 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc() argument
324 if (inMsg == nullptr) { in RequestPacketCalculateLen()
332 …if ((inMsg->GetMessageId() != COMMIT_HISTORY_SYNC_MESSAGE) || (inMsg->GetMessageType() != TYPE_REQ… in RequestPacketCalculateLen()
438 if (inMsg == nullptr) { in AckPacketCalculateLen()
[all …]
H A Dsync_engine.cpp136 delete inMsg; in Close()
353 Message *inMsg) in MessageReciveCallbackTask() argument
371 delete inMsg; in MessageReciveCallbackTask()
372 inMsg = nullptr; in MessageReciveCallbackTask()
385 delete inMsg; in RemoteDataChangedTask()
386 inMsg = nullptr; in RemoteDataChangedTask()
429 delete inMsg; in DealMsgUtilQueueEmpty()
430 inMsg = nullptr; in DealMsgUtilQueueEmpty()
497 delete inMsg; in MessageReciveCallback()
498 inMsg = nullptr; in MessageReciveCallback()
[all …]
H A Dcommit_history_sync.h95 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
97 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
99 static uint32_t CalculateLen(const Message *inMsg);
110 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
112 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
114 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
116 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
118 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
120 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
122 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
[all …]
H A Dremote_executor.cpp99 if (inMsg == nullptr) { in ReceiveMessage()
104 delete inMsg; in ReceiveMessage()
105 inMsg = nullptr; in ReceiveMessage()
208 (void)ResponseFailed(errCode, inMsg->GetSessionId(), inMsg->GetSequenceId(), device); in ParseOneRequestMessage()
213 (void)ResponseFailed(errCode, inMsg->GetSessionId(), inMsg->GetSequenceId(), device); in ParseOneRequestMessage()
780 if (inMsg->IsFeedbackError() && IsPacketValid(inMsg->GetSessionId())) { in ReceiveMessageInner()
781 DoFinished(inMsg->GetSessionId(), -inMsg->GetErrorNo()); in ReceiveMessageInner()
782 delete inMsg; in ReceiveMessageInner()
783 inMsg = nullptr; in ReceiveMessageInner()
798 delete inMsg; in ReceiveMessageInner()
[all …]
H A Dability_sync.cpp617 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc() argument
619 return Serialization(buffer, length, inMsg); in RegisterTransformFunc()
629 if ((inMsg == nullptr) || (inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE)) { in CalculateLen()
634 switch (inMsg->GetMessageType()) { in CalculateLen()
662 if ((buffer == nullptr) || (inMsg == nullptr)) { in Serialization()
666 switch (inMsg->GetMessageType()) { in Serialization()
679 if ((buffer == nullptr) || (inMsg == nullptr)) { in DeSerialization()
683 switch (inMsg->GetMessageType()) { in DeSerialization()
812 errCode = inMsg->SetExternalObject<>(packet); in RequestPacketDeSerialization()
950 errCode = inMsg->SetExternalObject<>(packet); in AckPacketDeSerialization()
[all …]
H A Dtime_sync.cpp171 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc() argument
173 return Serialization(buffer, length, inMsg); in RegisterTransformFunc()
176 return DeSerialization(buffer, length, inMsg); in RegisterTransformFunc()
261 uint32_t TimeSync::CalculateLen(const Message *inMsg) in CalculateLen() argument
263 if (!(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in CalculateLen()
277 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in Serialization()
322 …if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQU… in DeSerialization()
339 return inMsg->SetCopiedObject<>(packet); in DeSerialization()
366 return inMsg->SetCopiedObject<>(packet); in DeSerialization()
470 if (inMsg == nullptr) { in IsPacketValid()
[all …]
H A Dability_sync.h178 static uint32_t CalculateLen(const Message *inMsg);
180 …static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg); // register to c…
182 …static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg); // register to…
185 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
187 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
189 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
191 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
193 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
195 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
245 int SendAck(const Message *inMsg, const AbilitySyncAckPacket &ackPacket, bool isAckNotify);
H A Dsync_engine.h166 …geReciveCallbackTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *inMsg);
168 …emoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *inMsg);
173 void MessageReciveCallback(const std::string &targetDev, Message *inMsg);
176 int MessageReciveCallbackInner(const std::string &targetDev, Message *inMsg);
182 void PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize);
185 int GetMsgSize(const Message *inMsg) const;
191 int ScheduleDealMsg(ISyncTaskContext *context, Message *inMsg);
201 bool IsSkipCalculateLen(const Message *inMsg);
219 int HandleRemoteExecutorMsg(const std::string &targetDev, Message *inMsg);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator.cpp50 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
65 delete inMsg; in SendMessage()
66 inMsg = nullptr; in SendMessage()
70 int errCode = TranslateMsg(inMsg, message); in SendMessage()
72 communicatorAggregator_->DispatchMessage(deviceId_, dstTarget, inMsg, onEnd); in SendMessage()
78 delete inMsg; in SendMessage()
79 inMsg = nullptr; in SendMessage()
100 onMessage_(srcTarget, inMsg); in CallbackOnMessage()
106 delete inMsg; in CallbackOnMessage()
107 inMsg = nullptr; in CallbackOnMessage()
[all …]
H A Dvirtual_time_sync_communicator.cpp85 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
88 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
98 …LOGD("VirtualTimeSyncCommunicator::sendMessage dev = %s, syncid = %d", dstTarget.c_str(), inMsg->G… in SendMessage()
109 errCode = srcTimeSync_->AckRecv(inMsg); in SendMessage()
115 Message *msgTmp = const_cast<Message *>(inMsg); in SendMessage()
118 if (inMsg != nullptr) { in SendMessage()
119 delete inMsg; in SendMessage()
120 inMsg = nullptr; in SendMessage()
H A Dgeneric_virtual_device.cpp135 int GenericVirtualDevice::MessageCallback(const std::string &deviceId, Message *inMsg) in MessageCallback() argument
137 if (inMsg->GetMessageId() == LOCAL_DATA_CHANGED) { in MessageCallback()
140 delete inMsg; in MessageCallback()
141 inMsg = nullptr; in MessageCallback()
144 delete inMsg; in MessageCallback()
145 inMsg = nullptr; in MessageCallback()
150 if (inMsg->GetMessageId() == REMOTE_EXECUTE_MESSAGE && executor_ != nullptr) { in MessageCallback()
152 executor_->ReceiveMessage(deviceId, inMsg); in MessageCallback()
161 std::thread thread([context, communicateHandle, inMsg]() { in MessageCallback()
162 int errCode = context->ReceiveMessageCallback(inMsg); in MessageCallback()
[all …]
H A Dvirtual_communicator_aggregator.cpp169 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessage() argument
178 delete inMsg; in DispatchMessage()
179 inMsg = nullptr; in DispatchMessage()
183 beforeDispatch_(dstTarget, inMsg); in DispatchMessage()
189 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessageInner() argument
198 delete inMsg; in DispatchMessageInner()
199 inMsg = nullptr; in DispatchMessageInner()
202 uint32_t messageId = inMsg->GetMessageId(); in DispatchMessageInner()
203 Message *msg = const_cast<Message *>(inMsg); in DispatchMessageInner()
225 delete inMsg; in DispatchMessageInner()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp76 funcForTinyMsg.computeFunc = [](const Message *inMsg)->uint32_t{return TINY_SIZE;}; in RegFuncForTinyMsg() argument
78 const RegedTinyObject *outObj = inMsg->GetObject<RegedTinyObject>(); in RegFuncForTinyMsg()
83 int errCode = inMsg->SetCopiedObject(RegedTinyObject()); in RegFuncForTinyMsg()
96 const RegedHugeObject *outObj = inMsg->GetObject<RegedHugeObject>(); in RegFuncForHugeMsg()
101 int errCode = inMsg->SetCopiedObject(RegedHugeObject()); in RegFuncForHugeMsg()
112 funcForGiantMsg.computeFunc = [](const Message *inMsg)->uint32_t{ in RegFuncForGiantMsg() argument
113 const RegedGiantObject *outObj = inMsg->GetObject<RegedGiantObject>(); in RegFuncForGiantMsg()
120 const RegedGiantObject *outObj = inMsg->GetObject<RegedGiantObject>(); in RegFuncForGiantMsg()
144 int errCode = inMsg->SetExternalObject(obj); in RegFuncForGiantMsg()
160 const RegedOverSizeObject *outObj = inMsg->GetObject<RegedOverSizeObject>(); in RegFuncForOverSizeMsg()
[all …]
H A Ddistributeddb_communicator_send_receive_test.cpp139 recvMsgForAA = inMsg; in __anon922778e00202()
143 recvMsgForBA = inMsg; in __anon922778e00302()
147 recvMsgForBB = inMsg; in __anon922778e00402()
461 if (inMsg != nullptr) { in __anon922778e00d02()
462 delete inMsg; in __anon922778e00d02()
463 inMsg = nullptr; in __anon922778e00d02()
522 if (inMsg != nullptr) { in __anon922778e00e02()
523 delete inMsg; in __anon922778e00e02()
524 inMsg = nullptr; in __anon922778e00e02()
719 recvMsgForAA = inMsg; in __anon922778e01002()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp100 if (inMsg == nullptr) { in ToSerialBuffer()
141 errCode = SerializeMessage(buffer, inMsg); in ToSerialBuffer()
602 uint32_t messageId = inMsg->GetMessageId(); in CalculateDataSerializeLength()
632 messageHdr->version = inMsg->GetVersion(); in SerializeMessage()
634 messageHdr->messageId = inMsg->GetMessageId(); in SerializeMessage()
637 messageHdr->errorNo = inMsg->GetErrorNo(); in SerializeMessage()
679 inMsg->SetVersion(version); in DeSerializeMessage()
681 inMsg->SetMessageId(messageHdr.messageId); in DeSerializeMessage()
682 inMsg->SetSessionId(messageHdr.sessionId); in DeSerializeMessage()
683 inMsg->SetSequenceId(messageHdr.sequenceId); in DeSerializeMessage()
[all …]

123