Home
last modified time | relevance | path

Searched refs:inMsg (Results 1 - 25 of 60) sorted by relevance

123

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.h34 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
36 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
38 static uint32_t CalculateLen(const Message *inMsg);
42 static bool IsPacketValid(const Message *inMsg);
44 static int DataSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
45 static int ControlSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
47 static int DataDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
48 static int ControlDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
50 static uint32_t CalculateDataLen(const Message *inMsg);
51 static uint32_t CalculateControlLen(const Message *inMsg);
[all...]
H A Dsingle_ver_serialize_manager.cpp32 int SingleVerSerializeManager::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
34 if ((buffer == nullptr) || !(IsPacketValid(inMsg))) { in Serialization()
40 if (messageHandles_.find(inMsg->GetMessageId()) != messageHandles_.end()) { in Serialization()
41 serializeFunc = messageHandles_.at(inMsg->GetMessageId()).serializeFunc; in Serialization()
45 return serializeFunc(buffer, length, inMsg); in Serialization()
48 if (inMsg->GetMessageId() == CONTROL_SYNC_MESSAGE) { in Serialization()
49 return ControlSerialization(buffer, length, inMsg); in Serialization()
51 return DataSerialization(buffer, length, inMsg); in Serialization()
54 int SingleVerSerializeManager::DataSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in DataSerialization() argument
56 switch (inMsg in DataSerialization()
67 ControlSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) ControlSerialization() argument
79 DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) DeSerialization() argument
100 DataDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) DataDeSerialization() argument
113 ControlDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) ControlDeSerialization() argument
125 CalculateLen(const Message *inMsg) CalculateLen() argument
146 CalculateDataLen(const Message *inMsg) CalculateDataLen() argument
171 CalculateControlLen(const Message *inMsg) CalculateControlLen() argument
224 DataPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) DataPacketSerialization() argument
293 DataPacketCalculateLen(const Message *inMsg, uint32_t &len) DataPacketCalculateLen() argument
304 AckPacketCalculateLen(const Message *inMsg, uint32_t &len) AckPacketCalculateLen() argument
315 IsPacketValid(const Message *inMsg) IsPacketValid() argument
329 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
357 DataPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) DataPacketDeSerialization() argument
495 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
539 ControlPacketCalculateLen(const Message *inMsg, uint32_t &len) ControlPacketCalculateLen() argument
552 ControlPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) ControlPacketSerialization() argument
565 ControlPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) ControlPacketDeSerialization() argument
579 AckControlPacketCalculateLen(const Message *inMsg, uint32_t &len) AckControlPacketCalculateLen() argument
590 AckControlPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckControlPacketSerialization() argument
609 AckControlPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckControlPacketDeSerialization() argument
642 ControlRequestSerialization(Parcel &parcel, const Message *inMsg) ControlRequestSerialization() argument
681 SubscribeCalculateLen(const Message *inMsg, uint32_t &len) SubscribeCalculateLen() argument
691 SubscribeSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) SubscribeSerialization() argument
712 SubscribeDeSerialization(Parcel &parcel, Message *inMsg, ControlRequestPacket &controlPacket) SubscribeDeSerialization() argument
778 ISyncPacketCalculateLen(const Message *inMsg) ISyncPacketCalculateLen() argument
791 ISyncPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) ISyncPacketSerialization() argument
806 ISyncPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) ISyncPacketDeSerialization() argument
832 BuildISyncPacket(Message *inMsg, ISyncPacket *&packet) BuildISyncPacket() argument
[all...]
H A Dsingle_ver_sync_state_machine.h80 int ReceiveMessageCallback(Message *inMsg) override;
85 int HandleDataRequestRecv(const Message *inMsg);
93 bool IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) override;
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);
[all...]
H A Dsingle_ver_sync_state_machine.cpp180 int SingleVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback() argument
182 int errCode = MessageCallbackPre(inMsg); in ReceiveMessageCallback()
187 switch (inMsg->GetMessageId()) { in ReceiveMessageCallback()
189 errCode = TimeMarkSyncRecv(inMsg); in ReceiveMessageCallback()
192 errCode = AbilitySyncRecv(inMsg); in ReceiveMessageCallback()
196 errCode = DataPktRecv(inMsg); in ReceiveMessageCallback()
199 errCode = ControlPktRecv(inMsg); in ReceiveMessageCallback()
445 int SingleVerSyncStateMachine::HandleControlAckRecv(const Message *inMsg) in HandleControlAckRecv() argument
448 if (IsNeedResetWatchdog(inMsg)) { in HandleControlAckRecv()
451 int errCode = dataSync_->ControlCmdAckRecv(context_, inMsg); in HandleControlAckRecv()
582 AbilitySyncRecv(const Message *inMsg) AbilitySyncRecv() argument
596 AbilitySyncResponseRecv(const Message *inMsg) AbilitySyncResponseRecv() argument
626 HandleDataRequestRecv(const Message *inMsg) HandleDataRequestRecv() argument
685 HandleDataAckRecvWithSlidingWindow(int errCode, const Message *inMsg, bool ignoreInnerErr) HandleDataAckRecvWithSlidingWindow() argument
718 HandleDataAckRecv(const Message *inMsg) HandleDataAckRecv() argument
760 DataPktRecv(Message *inMsg) DataPktRecv() argument
784 ScheduleMsgAndHandle(Message *inMsg) ScheduleMsgAndHandle() argument
822 ControlPktRecv(Message *inMsg) ControlPktRecv() argument
883 TimeMarkSyncRecv(const Message *inMsg) TimeMarkSyncRecv() argument
976 MessageCallbackPre(const Message *inMsg) MessageCallbackPre() argument
989 AddPullResponseTarget(const Message *inMsg, WaterMark pullEndWatermark) AddPullResponseTarget() argument
1150 AbilityMsgSessionIdCheck(const Message *inMsg) AbilityMsgSessionIdCheck() argument
1204 IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) IsNeedTriggerQueryAutoSync() argument
1281 AbilitySyncNotifyRecv(const Message *inMsg) AbilitySyncNotifyRecv() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.cpp121 int MultiVerSyncStateMachine::MessageCallbackCheck(const Message *inMsg) in MessageCallbackCheck() argument
127 if (!IsPacketValid(inMsg)) { in MessageCallbackCheck()
130 if ((inMsg->GetMessageType() == TYPE_RESPONSE) && (inMsg->GetMessageId() != TIME_SYNC_MESSAGE)) { in MessageCallbackCheck()
140 int MultiVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback() argument
142 if (inMsg == nullptr) { in ReceiveMessageCallback()
145 if (inMsg->IsFeedbackError()) { in ReceiveMessageCallback()
146 LOGE("[MultiVerSyncStateMachine] Feedback Message with errorNo=%u.", inMsg->GetErrorNo()); in ReceiveMessageCallback()
147 return -static_cast<int>(inMsg->GetErrorNo()); in ReceiveMessageCallback()
149 if (inMsg in ReceiveMessageCallback()
320 TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, const Message *inMsg) TimeSyncPacketRecvCallback() argument
341 CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) CommitHistorySyncPktRecvCallback() argument
370 MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) MultiVerDataPktRecvCallback() argument
397 ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) ValueSlicePktRecvCallback() argument
607 IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) IsNeedTriggerQueryAutoSync() argument
[all...]
H A Dmulti_ver_data_sync.cpp100 int MultiVerDataSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
102 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
106 switch (inMsg->GetMessageType()) { in Serialization()
108 return RequestPacketSerialization(buffer, length, inMsg); in Serialization()
110 return AckPacketSerialization(buffer, length, inMsg); in Serialization()
116 int MultiVerDataSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
118 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
122 switch (inMsg in DeSerialization()
132 CalculateLen(const Message *inMsg) CalculateLen() argument
359 RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) RequestPacketCalculateLen() argument
373 RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) RequestPacketSerialization() argument
403 RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) RequestPacketDeSerialization() argument
438 AckPacketCalculateLen(const Message *inMsg, uint32_t &len) AckPacketCalculateLen() argument
452 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
486 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
529 IsPacketValid(const Message *inMsg, uint16_t messageType) IsPacketValid() argument
579 Send(const DeviceID &deviceId, const Message *inMsg) Send() argument
[all...]
H A Dvalue_slice_sync.cpp100 int ValueSliceSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
102 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
106 switch (inMsg->GetMessageType()) { in Serialization()
108 return RequestPacketSerialization(buffer, length, inMsg); in Serialization()
110 return AckPacketSerialization(buffer, length, inMsg); in Serialization()
116 int ValueSliceSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
118 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
122 switch (inMsg in DeSerialization()
132 CalculateLen(const Message *inMsg) CalculateLen() argument
341 RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) RequestPacketCalculateLen() argument
352 RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) RequestPacketSerialization() argument
378 RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) RequestPacketDeSerialization() argument
412 AckPacketCalculateLen(const Message *inMsg, uint32_t &len) AckPacketCalculateLen() argument
422 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
453 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
489 IsPacketValid(const Message *inMsg, uint16_t messageType) IsPacketValid() argument
528 Send(const DeviceID &deviceId, const Message *inMsg) Send() argument
[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_
[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_
[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;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator.cpp48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
50 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
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()
95 void VirtualCommunicator::CallbackOnMessage(const std::string &srcTarget, Message *inMsg) in CallbackOnMessage() argument
216 TranslateMsg(const Message *inMsg, Message *&outMsg) TranslateMsg() argument
[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->GetSequenceId()); 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 Dvirtual_communicator_aggregator.cpp169 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessage()
178 delete inMsg; in DispatchMessage()
179 inMsg = nullptr; in DispatchMessage()
183 beforeDispatch_(dstTarget, inMsg); in DispatchMessage()
185 DispatchMessageInner(srcTarget, dstTarget, inMsg, onEnd); in DispatchMessage()
189 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessageInner()
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()
168 DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg, const OnSendEnd &onEnd) DispatchMessage() argument
188 DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg, const OnSendEnd &onEnd) DispatchMessageInner() argument
[all...]
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()
149 LOGD("[GenericVirtualDevice] onMessage, src %s id %u", deviceId.c_str(), inMsg->GetMessageId()); 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()
[all...]
/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()
77 funcForTinyMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForTinyMsg()
78 const RegedTinyObject *outObj = inMsg->GetObject<RegedTinyObject>(); in RegFuncForTinyMsg()
82 funcForTinyMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForTinyMsg()
83 int errCode = inMsg->SetCopiedObject(RegedTinyObject()); in RegFuncForTinyMsg()
94 funcForHugeMsg.computeFunc = [](const Message *inMsg)->uint32_t{return HUGE_SIZE;}; in RegFuncForHugeMsg()
95 funcForHugeMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForHugeMsg()
96 const RegedHugeObject *outObj = inMsg->GetObject<RegedHugeObject>(); in RegFuncForHugeMsg()
100 funcForHugeMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForHugeMsg()
101 int errCode = inMsg in RegFuncForHugeMsg()
[all...]
H A Ddistributeddb_communicator_send_receive_test.cpp137 g_commAA->RegOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
139 recvMsgForAA = inMsg; in HWTEST_F()
141 g_commBA->RegOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
143 recvMsgForBA = inMsg; in HWTEST_F()
145 g_commBB->RegOnMessageCallback([&srcTargetForBB, &recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
147 recvMsgForBB = inMsg; in HWTEST_F()
459 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
461 if (inMsg != nullptr) { in HWTEST_F()
462 delete inMsg; in HWTEST_F()
463 inMsg in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.cpp141 int CommitHistorySync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
143 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in Serialization()
147 switch (inMsg->GetMessageType()) { in Serialization()
149 return RequestPacketSerialization(buffer, length, inMsg); in Serialization()
151 return AckPacketSerialization(buffer, length, inMsg); in Serialization()
157 int CommitHistorySync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
159 if ((buffer == nullptr) || !(IsPacketValid(inMsg, TYPE_RESPONSE) || IsPacketValid(inMsg, TYPE_REQUEST))) { in DeSerialization()
163 switch (inMsg in DeSerialization()
173 CalculateLen(const Message *inMsg) CalculateLen() argument
322 RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) RequestPacketCalculateLen() argument
339 RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) RequestPacketSerialization() argument
383 RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) RequestPacketDeSerialization() argument
436 AckPacketCalculateLen(const Message *inMsg, uint32_t &len) AckPacketCalculateLen() argument
453 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
492 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
535 IsPacketValid(const Message *inMsg, uint16_t messageType) IsPacketValid() argument
546 Send(const DeviceID &deviceId, const Message *inMsg) Send() argument
[all...]
H A Dcommit_history_sync.h97 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
99 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
101 static uint32_t CalculateLen(const Message *inMsg);
112 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
114 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
116 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
118 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
120 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
122 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
124 static bool IsPacketValid(const Message *inMsg, uint16_
[all...]
H A Dsync_engine.cpp132 Message *inMsg = msgQueue_.front(); in Close() local
134 if (inMsg != nullptr) { // LCOV_EXCL_BR_LINE in Close()
135 queueCacheSize_ -= GetMsgSize(inMsg); in Close()
136 delete inMsg; in Close()
137 inMsg = nullptr; in Close()
299 [this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); }, []() {}); in InitComunicator()
353 Message *inMsg) in MessageReciveCallbackTask()
357 if (inMsg->GetMessageId() != LOCAL_DATA_CHANGED) { in MessageReciveCallbackTask()
358 int errCode = context->ReceiveMessageCallback(inMsg); in MessageReciveCallbackTask()
352 MessageReciveCallbackTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *inMsg) MessageReciveCallbackTask() argument
377 RemoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *inMsg) RemoteDataChangedTask() argument
404 Message *inMsg = nullptr; DealMsgUtilQueueEmpty() local
463 ScheduleDealMsg(ISyncTaskContext *context, Message *inMsg) ScheduleDealMsg() argument
492 MessageReciveCallback(const std::string &targetDev, Message *inMsg) MessageReciveCallback() argument
504 MessageReciveCallbackInner(const std::string &targetDev, Message *inMsg) MessageReciveCallbackInner() argument
552 PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize) PutMsgIntoQueue() argument
975 IsSkipCalculateLen(const Message *inMsg) IsSkipCalculateLen() argument
1208 HandleRemoteExecutorMsg(const std::string &targetDev, Message *inMsg) HandleRemoteExecutorMsg() argument
[all...]
H A Dability_sync.cpp617 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
618 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
619 return Serialization(buffer, length, inMsg); in RegisterTransformFunc()
621 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
622 return DeSerialization(buffer, length, inMsg); in RegisterTransformFunc()
627 uint32_t AbilitySync::CalculateLen(const Message *inMsg) in CalculateLen() argument
629 if ((inMsg == nullptr) || (inMsg->GetMessageId() != ABILITY_SYNC_MESSAGE)) { in CalculateLen()
634 switch (inMsg in CalculateLen()
660 Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) Serialization() argument
677 DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) DeSerialization() argument
694 RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) RequestPacketCalculateLen() argument
705 AckPacketCalculateLen(const Message *inMsg, uint32_t &len) AckPacketCalculateLen() argument
716 RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) RequestPacketSerialization() argument
740 AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) AckPacketSerialization() argument
774 RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) RequestPacketDeSerialization() argument
910 AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) AckPacketDeSerialization() argument
1183 SendAck(const Message *inMsg, const AbilitySyncAckPacket &ackPacket, bool isAckNotify) SendAck() argument
[all...]
H A Dtime_sync.cpp171 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
172 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
173 return Serialization(buffer, length, inMsg); in RegisterTransformFunc()
175 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *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()
267 const TimeSyncPacket *packet = const_cast<TimeSyncPacket *>(inMsg in CalculateLen()
275 Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) Serialization() argument
320 DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) DeSerialization() argument
468 IsPacketValid(const Message *inMsg, uint16_t messageType) IsPacketValid() argument
[all...]
H A Dremote_executor.cpp97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage() argument
99 if (inMsg == nullptr) { in ReceiveMessage()
104 delete inMsg; in ReceiveMessage()
105 inMsg = nullptr; in ReceiveMessage()
109 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, targetDev, inMsg]() { in ReceiveMessage()
110 ReceiveMessageInner(targetDev, inMsg); in ReceiveMessage()
167 int RemoteExecutor::ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorRequest() argument
172 searchMessageQueue_.push(std::make_pair(targetDev, inMsg)); in ReceiveRemoteExecutorRequest()
200 void RemoteExecutor::ParseOneRequestMessage(const std::string &device, Message *inMsg) in ParseOneRequestMessage() argument
206 int errCode = CheckPermissions(device, inMsg); in ParseOneRequestMessage()
217 CheckPermissions(const std::string &device, Message *inMsg) CheckPermissions() argument
248 SendRemoteExecutorData(const std::string &device, const Message *inMsg) SendRemoteExecutorData() argument
274 ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg) ReceiveRemoteExecutorAck() argument
776 ReceiveMessageInner(const std::string &targetDev, Message *inMsg) ReceiveMessageInner() argument
[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 communicator
182 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg); // register to communicator
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, cons
[all...]
H A Dremote_executor.h65 int ReceiveMessage(const std::string &targetDev, Message *inMsg);
76 virtual void ParseOneRequestMessage(const std::string &device, Message *inMsg);
90 void ReceiveMessageInner(const std::string &targetDev, Message *inMsg);
92 int ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg);
94 int ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg);
96 int CheckPermissions(const std::string &device, Message *inMsg);
98 int SendRemoteExecutorData(const std::string &device, const Message *inMsg);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage_transform.h25 using ComputeLengthFunc = std::function<uint32_t(const Message *inMsg)>;
26 using SerializeFunc = std::function<int(uint8_t *buffer, uint32_t length, const Message *inMsg)>;
27 using DeserializeFunc = std::function<int(const uint8_t *buffer, uint32_t length, Message *inMsg)>;

Completed in 16 milliseconds

123