| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_single_ver_state_machine.h | 35 int CallTimeMarkSyncRecv(const Message *inMsg) in CallTimeMarkSyncRecv() argument
|
| H A D | virtual_time_sync_communicator.cpp | 85 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
|
| H A D | virtual_communicator.cpp | 48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
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 D | generic_virtual_device.cpp | 135 int GenericVirtualDevice::MessageCallback(const std::string &deviceId, Message *inMsg) in MessageCallback() argument
[all...] |
| H A D | virtual_communicator_aggregator.cpp | 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...] |
| /foundation/ai/intelligent_voice_framework/utils/ |
| H A D | state_manager.h | 34 void *inMsg = nullptr; member
|
| /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 &config) in SendMessage() argument
103 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 198 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
203 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
|
| H A D | commit_history_sync.cpp | 141 int CommitHistorySync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
157 int CommitHistorySync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
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 D | time_sync.cpp | 261 uint32_t TimeSync::CalculateLen(const Message *inMsg) in CalculateLen() argument
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 D | remote_executor.cpp | 97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage() argument
167 int RemoteExecutor::ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorRequest() argument
200 void RemoteExecutor::ParseOneRequestMessage(const std::string &device, Message *inMsg) in ParseOneRequestMessage() argument
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 D | sync_task_context.cpp | 432 int SyncTaskContext::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback() argument
703 bool SyncTaskContext::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync() argument
|
| H A D | ability_sync.cpp | 627 uint32_t AbilitySync::CalculateLen(const Message *inMsg) in CalculateLen() argument
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 D | sync_engine.cpp | 132 Message *inMsg = msgQueue_.front(); in Close() local
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...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 121 int MultiVerSyncStateMachine::MessageCallbackCheck(const Message *inMsg) in MessageCallbackCheck() argument
140 int MultiVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback() argument
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 D | value_slice_sync.cpp | 100 int ValueSliceSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
116 int ValueSliceSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
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 D | multi_ver_data_sync.cpp | 100 int MultiVerDataSync::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
116 int MultiVerDataSync::DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg) in DeSerialization() argument
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...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_message_schedule.cpp | 35 void SingleVerDataMessageSchedule::PutMsg(Message *inMsg) in PutMsg() argument
80 ScheduleInfoHandle(bool isNeedHandleStatus, bool isNeedClearMap, const Message *inMsg) ScheduleInfoHandle() argument
|
| H A D | single_ver_serialize_manager.cpp | 32 int SingleVerSerializeManager::Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in Serialization() argument
54 int SingleVerSerializeManager::DataSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg) in DataSerialization() argument
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 D | single_ver_data_sync_utils.cpp | 343 bool SingleVerDataSyncUtils::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync() argument
|
| H A D | single_ver_sync_state_machine.cpp | 180 int SingleVerSyncStateMachine::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback() argument
445 int SingleVerSyncStateMachine::HandleControlAckRecv(const Message *inMsg) in HandleControlAckRecv() argument
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...] |
| /kernel/liteos_a/testsuites/unittest/extended/liteipc/ |
| H A D | liteipc.h | 106 IpcMsg *inMsg; /**< data reply by target */ member
|
| /foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/include/ |
| H A D | lite_ipc.h | 73 IpcMsg *inMsg; /**< data reply by target */ member
|
| /test/testfwk/arkxtest/uitest/test/ |
| H A D | extension_test.cpp | 269 const char *inMsg; member
|
| /kernel/liteos_a/kernel/extended/liteipc/ |
| H A D | hm_liteipc.h | 178 IpcMsg *inMsg; /**< data reply by target */ member
|