Home
last modified time | relevance | path

Searched refs:DataRequestPacket (Results 1 – 14 of 14) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_packet.cpp26 DataRequestPacket::~DataRequestPacket() in ~DataRequestPacket()
89 int32_t DataRequestPacket::GetSendCode() const in GetSendCode()
94 void DataRequestPacket::SetMode(int32_t mode) in SetMode()
99 int32_t DataRequestPacket::GetMode() const in GetMode()
119 uint32_t DataRequestPacket::GetVersion() const in GetVersion()
139 uint64_t DataRequestPacket::GetPacketId() const in GetPacketId()
206 void DataRequestPacket::SetFlag(uint32_t flag) in SetFlag()
211 uint32_t DataRequestPacket::GetFlag() const in GetFlag()
221 void DataRequestPacket::SetLastSequence() in SetLastSequence()
231 void DataRequestPacket::SetUpdateWaterMark() in SetUpdateWaterMark()
[all …]
H A Dsingle_ver_serialize_manager.h54 static int DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet);
55 static int DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet);
56 …static int DataPacketExtraConditionsSerialization(Parcel &parcel, const DataRequestPacket *packet);
58 static int DataPacketInnerSerialization(const DataRequestPacket *packet, Parcel &parcel);
60 static int DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet);
61 static int DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet);
63 …static int DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t…
65 static int DataPacketExtraConditionsDeserialization(Parcel &parcel, DataRequestPacket *packet);
66 static int DataPacketInnerDeSerialization(DataRequestPacket *packet, Parcel &parcel);
H A Dsingle_ver_data_sync_utils.h28 static int RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface *storage);
46 const std::string &label, const DataRequestPacket *packet);
54 …static void SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t ver…
101 …const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadat…
103 …t SchemaVersionMatchCheck(const SingleVerSyncTaskContext &context, const DataRequestPacket &packet,
107 const std::string &label, const DataRequestPacket *packet, int mode);
H A Dsingle_ver_data_sync.h141 void FillDataRequestPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *context,
186 …int SendDataPacket(SyncType syncType, DataRequestPacket *packet, SingleVerSyncTaskContext *context…
200 … void GetPullEndWatermark(const SingleVerSyncTaskContext *context, const DataRequestPacket *packet,
207 const DataRequestPacket *packet);
211 int SendReSendPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *context,
220 …acket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, const DataRequestPacket *packet,
230 void FillRequestReSendPacket(const SingleVerSyncTaskContext *context, DataRequestPacket *packet,
H A Dsingle_ver_serialize_manager.cpp201 …erializeManager::DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketSyncerPartSerialization()
225 auto packet = inMsg->GetObject<DataRequestPacket>(); in DataPacketSerialization()
269 …SerializeManager::DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketQuerySyncSerialization()
294 const DataRequestPacket *packet = inMsg->GetObject<DataRequestPacket>(); in DataPacketCalculateLen()
375 auto packet = new (std::nothrow) DataRequestPacket(); in DataPacketDeSerialization()
407 int SingleVerSerializeManager::DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket… in DataPacketQuerySyncDeSerialization()
436 …rSerializeManager::DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet) in DataPacketCompressDataDeSerialization()
448 …VerSerializeManager::DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, in DataPacketSyncerPartDeSerialization()
876 …rializeManager::DataPacketExtraConditionsDeserialization(Parcel &parcel, DataRequestPacket *packet) in DataPacketExtraConditionsDeserialization()
906 int SingleVerSerializeManager::DataPacketInnerDeSerialization(DataRequestPacket *packet, Parcel &pa… in DataPacketInnerDeSerialization()
[all …]
H A Dsingle_ver_data_sync_utils.cpp93 int SingleVerDataSyncUtils::RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface… in RequestQueryCheck()
201 const std::string &label, const DataRequestPacket *packet) in RunPermissionCheck()
267 void SingleVerDataSyncUtils::SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *conte… in SetPacketId()
490 …const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet, in… in RunPermissionCheckInner()
511 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in GetTimeOffsetFromRequestMsg()
540 …const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadat… in SetDataRequestCommonInfo()
566 const DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata) in SchemaVersionMatchCheck()
H A Dsingle_ver_data_sync.cpp555 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in RemoveDeviceDataHandle()
733 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in RequestStart()
797 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in PullRequestStart()
946 auto *packet = message->GetObject<DataRequestPacket>(); in DataRequestRecvPre()
993 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in DataRequestRecv()
1081 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in SendPullResponseDataPkt()
1124 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in SendDataAck()
1319 const DataRequestPacket *packet) in RunPermissionCheck()
1408 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in ReSend()
1519 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in WaterMarkErrHandle()
[all …]
H A Dsingle_ver_data_packet.h29 class DataRequestPacket {
31 DataRequestPacket() {}; in DataRequestPacket() function
32 virtual ~DataRequestPacket();
H A Dsingle_ver_data_message_schedule.cpp321 const auto *cachePacket = messageMap_[sequenceId]->GetObject<DataRequestPacket>(); in UpdateMsgMapIfNeed()
342 const DataRequestPacket *packet = msg->GetObject<DataRequestPacket>(); in GetPacketId()
H A Dsingle_ver_sync_state_machine.cpp1002 const DataRequestPacket *packet = inMsg->GetObject<DataRequestPacket>(); in AddPullResponseTarget()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_msg_schedule_test.cpp263 const DataRequestPacket *packet = msg->GetObject<DataRequestPacket>();
320 const DataRequestPacket *packet = msg->GetObject<DataRequestPacket>();
386 const DataRequestPacket *packet = msg->GetObject<DataRequestPacket>();
430 const DataRequestPacket *packet = msg->GetObject<DataRequestPacket>();
H A Ddistributeddb_anti_dos_sync_test.cpp174 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket;
225 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket;
289 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket;
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp616 auto packet = new (std::nothrow) DataRequestPacket;
664 auto outPacket = outMsg.GetObject<DataRequestPacket>();
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.cpp1055 auto packet = new (std::nothrow) DataRequestPacket; in BuildMessage()