| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 124 uint32_t SingleVerSerializeManager::CalculateLen(const Message *inMsg) in CalculateLen()
145 uint32_t SingleVerSerializeManager::CalculateDataLen(const Message *inMsg) in CalculateDataLen()
170 uint32_t SingleVerSerializeManager::CalculateControlLen(const Message *inMsg) in CalculateControlLen()
314 bool SingleVerSerializeManager::IsPacketValid(const Message *inMsg) in IsPacketValid()
740 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterCommunicatorTransformFunc()
741 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterCommunicatorTransformFunc()
767 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterInnerTransformFunc()
777 uint32_t SingleVerSerializeManager::ISyncPacketCalculateLen(const Message *inMsg) in ISyncPacketCalculateLen()
791 const Message *inMsg) in ISyncPacketSerialization()
806 Message *inMsg) in ISyncPacketDeSerialization()
[all …]
|
| H A D | single_ver_sync_state_machine.cpp | 180 int SingleVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback()
445 int SingleVerSyncStateMachine::HandleControlAckRecv(const Message *inMsg) in HandleControlAckRecv()
583 int SingleVerSyncStateMachine::AbilitySyncRecv(const Message *inMsg) in AbilitySyncRecv()
627 int SingleVerSyncStateMachine::HandleDataRequestRecv(const Message *inMsg) in HandleDataRequestRecv()
719 int SingleVerSyncStateMachine::HandleDataAckRecv(const Message *inMsg) in HandleDataAckRecv()
761 int SingleVerSyncStateMachine::DataPktRecv(Message *inMsg) in DataPktRecv()
785 void SingleVerSyncStateMachine::ScheduleMsgAndHandle(Message *inMsg) in ScheduleMsgAndHandle()
823 int SingleVerSyncStateMachine::ControlPktRecv(Message *inMsg) in ControlPktRecv()
884 int SingleVerSyncStateMachine::TimeMarkSyncRecv(const Message *inMsg) in TimeMarkSyncRecv()
977 int SingleVerSyncStateMachine::MessageCallbackPre(const Message *inMsg) in MessageCallbackPre()
[all …]
|
| H A D | single_ver_data_message_schedule.cpp | 35 void SingleVerDataMessageSchedule::PutMsg(Message *inMsg) in PutMsg()
81 const Message *inMsg) in ScheduleInfoHandle()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.cpp | 76 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()
82 … funcForTinyMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ 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()
100 … funcForHugeMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForHugeMsg()
112 funcForGiantMsg.computeFunc = [](const Message *inMsg)->uint32_t{ in RegFuncForGiantMsg()
119 funcForGiantMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForGiantMsg()
133 … funcForGiantMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForGiantMsg()
158 funcForOverSizeMsg.computeFunc = [](const Message *inMsg)->uint32_t{return OVER_SIZE;}; in RegFuncForOverSizeMsg()
[all …]
|
| H A D | distributeddb_communicator_send_receive_test.cpp | 137 …gOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Message *inMsg) { in __anon922778e00202()
141 …gOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in __anon922778e00302()
145 …gOnMessageCallback([&srcTargetForBB, &recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in __anon922778e00402()
459 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in __anon922778e00d02()
520 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in __anon922778e00e02()
717 …gOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Message *inMsg) { in __anon922778e01002()
721 …gOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in __anon922778e01102()
|
| H A D | distributeddb_communicator_deep_test.cpp | 146 g_commBB->RegOnMessageCallback([&msgForBB](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20302()
150 g_commCA->RegOnMessageCallback([&msgForCA](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20402()
332 g_commBB->RegOnMessageCallback([&recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20502()
387 g_commCC->RegOnMessageCallback([&recvMsgForCC](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20602()
453 OnMessageCallback callback = [&count](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20702()
519 g_commBB->RegOnMessageCallback([&recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in __anonb9037cf20802()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.cpp | 100 int ValueSliceSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization()
116 int ValueSliceSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization()
132 uint32_t ValueSliceSync::CalculateLen(const Message *inMsg) in CalculateLen()
159 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
160 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
163 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
341 int ValueSliceSync::RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) in RequestPacketCalculateLen()
412 int ValueSliceSync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
422 int ValueSliceSync::AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in AckPacketSerialization()
489 bool ValueSliceSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
[all …]
|
| H A D | multi_ver_data_sync.cpp | 100 int MultiVerDataSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization()
116 int MultiVerDataSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization()
132 uint32_t MultiVerDataSync::CalculateLen(const Message *inMsg) in CalculateLen()
159 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
160 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
163 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
359 int MultiVerDataSync::RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) in RequestPacketCalculateLen()
438 int MultiVerDataSync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
452 int MultiVerDataSync::AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in AckPacketSerialization()
529 bool MultiVerDataSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
[all …]
|
| H A D | multi_ver_sync_state_machine.cpp | 121 int MultiVerSyncStateMachine::MessageCallbackCheck(const Message *inMsg) in MessageCallbackCheck()
140 int MultiVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback()
320 …teMachine::TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, const Message *inMsg) in TimeSyncPacketRecvCallback()
341 …teMachine::CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) in CommitHistorySyncPktRecvCallback()
370 …ncStateMachine::MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) in MultiVerDataPktRecvCallback()
397 …SyncStateMachine::ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg) in ValueSlicePktRecvCallback()
607 bool MultiVerSyncStateMachine::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 141 int CommitHistorySync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization()
157 int CommitHistorySync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization()
173 uint32_t CommitHistorySync::CalculateLen(const Message *inMsg) in CalculateLen()
202 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
203 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
206 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
322 int CommitHistorySync::RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) in RequestPacketCalculateLen()
436 int CommitHistorySync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
453 …t CommitHistorySync::AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in AckPacketSerialization()
535 bool CommitHistorySync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
[all …]
|
| H A D | sync_engine.cpp | 132 Message *inMsg = msgQueue_.front(); in Close() local
299 …[this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); },… in InitComunicator()
353 Message *inMsg) in MessageReciveCallbackTask()
377 …RemoteDataChangedTask(ISyncTaskContext *context, const ICommunicator *communicator, Message *inMsg) in RemoteDataChangedTask()
404 Message *inMsg = nullptr; in DealMsgUtilQueueEmpty() local
463 int SyncEngine::ScheduleDealMsg(ISyncTaskContext *context, Message *inMsg) in ScheduleDealMsg()
492 void SyncEngine::MessageReciveCallback(const std::string &targetDev, Message *inMsg) in MessageReciveCallback()
504 int SyncEngine::MessageReciveCallbackInner(const std::string &targetDev, Message *inMsg) in MessageReciveCallbackInner()
552 void SyncEngine::PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize) in PutMsgIntoQueue()
965 bool SyncEngine::IsSkipCalculateLen(const Message *inMsg) in IsSkipCalculateLen()
[all …]
|
| H A D | device_manager.cpp | 54 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
60 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
|
| H A D | ability_sync.cpp | 617 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
618 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
621 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
627 uint32_t AbilitySync::CalculateLen(const Message *inMsg) in CalculateLen()
660 int AbilitySync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization()
677 int AbilitySync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization()
694 int AbilitySync::RequestPacketCalculateLen(const Message *inMsg, uint32_t &len) in RequestPacketCalculateLen()
705 int AbilitySync::AckPacketCalculateLen(const Message *inMsg, uint32_t &len) in AckPacketCalculateLen()
716 int AbilitySync::RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in RequestPacketSerialization()
740 int AbilitySync::AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in AckPacketSerialization()
[all …]
|
| H A D | time_sync.cpp | 171 func.computeFunc = [](const Message *inMsg) { return CalculateLen(inMsg); }; in RegisterTransformFunc()
172 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
175 func.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg) { in RegisterTransformFunc()
261 uint32_t TimeSync::CalculateLen(const Message *inMsg) in CalculateLen()
275 int TimeSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization()
320 int TimeSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization()
468 bool TimeSync::IsPacketValid(const Message *inMsg, uint16_t messageType) in IsPacketValid()
|
| H A D | remote_executor.cpp | 97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage()
167 int RemoteExecutor::ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorRequest()
200 void RemoteExecutor::ParseOneRequestMessage(const std::string &device, Message *inMsg) in ParseOneRequestMessage()
217 int RemoteExecutor::CheckPermissions(const std::string &device, Message *inMsg) in CheckPermissions()
248 int RemoteExecutor::SendRemoteExecutorData(const std::string &device, const Message *inMsg) in SendRemoteExecutorData()
274 int RemoteExecutor::ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorAck()
777 void RemoteExecutor::ReceiveMessageInner(const std::string &targetDev, Message *inMsg) in ReceiveMessageInner()
|
| H A D | communicator_proxy.cpp | 198 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendCo… in SendMessage()
203 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendCo… in SendMessage()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator.cpp | 48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const Send… in SendMessage()
53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const Send… in SendMessage()
95 void VirtualCommunicator::CallbackOnMessage(const std::string &srcTarget, Message *inMsg) in CallbackOnMessage()
216 int VirtualCommunicator::TranslateMsg(const Message *inMsg, Message *&outMsg) in TranslateMsg()
|
| H A D | virtual_time_sync_communicator.cpp | 85 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage()
91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage()
|
| H A D | mock_single_ver_state_machine.h | 35 int CallTimeMarkSyncRecv(const Message *inMsg) in CallTimeMarkSyncRecv()
|
| H A D | virtual_communicator_aggregator.cpp | 169 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessage()
189 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessageInner()
|
| H A D | generic_virtual_device.cpp | 135 int GenericVirtualDevice::MessageCallback(const std::string &deviceId, Message *inMsg) in MessageCallback()
|
| H A D | distributeddb_single_ver_p2p_sync_check_test.cpp | 756 …atorAggregator->RegOnDispatch([&errCodeAck, &afterErrAck](const std::string &dev, Message *inMsg) { in RegOnDispatchWithDelayAck()
776 const std::string &dev, Message *inMsg) { in RegOnDispatchWithOffline()
797 const std::string &dev, Message *inMsg) { in RegOnDispatchWithInvalidMsg()
1090 const std::string &dev, Message *inMsg) { in RegOnDispatchToGetSyncCount()
1300 const std::string &dev, Message *inMsg) { in RegOnDispatchWithInvalidMsgAndCnt()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator.cpp | 98 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig … in SendMessage()
103 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig … in SendMessage()
|
| H A D | protocol_proto.cpp | 97 SerialBuffer *ProtocolProto::ToSerialBuffer(const Message *inMsg, in ToSerialBuffer()
200 SerialBuffer *ProtocolProto::BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLab… in BuildFeedbackMessageFrame()
600 int ProtocolProto::CalculateDataSerializeLength(const Message *inMsg, uint32_t &outLength) in CalculateDataSerializeLength()
622 int ProtocolProto::SerializeMessage(SerialBuffer *inBuff, const Message *inMsg) in SerializeMessage()
659 int ProtocolProto::DeSerializeMessage(const SerialBuffer *inBuff, Message *inMsg, bool onlyMsgHeade… in DeSerializeMessage()
|
| /ohos5.0/foundation/ai/intelligent_voice_framework/utils/ |
| H A D | state_manager.h | 34 void *inMsg = nullptr; member
|