/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_query_sync_test.cpp | 609 EXPECT_NE(querySync.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 659 EXPECT_EQ(querySync.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 753 EXPECT_EQ(querySync.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 785 EXPECT_NE(querySync.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 855 EXPECT_EQ(querySync.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 1172 uint32_t buffLen = obj1.CalculateParcelLen(SOFTWARE_VERSION_CURRENT); 1175 EXPECT_EQ(obj1.SerializeData(writeParcel, SOFTWARE_VERSION_CURRENT), E_OK); 1225 auto len = obj1.CalculateParcelLen(SOFTWARE_VERSION_CURRENT); 1228 obj1.SerializeData(parcel1, SOFTWARE_VERSION_CURRENT); 1348 uint32_t buffLen = obj1.CalculateParcelLen(SOFTWARE_VERSION_CURRENT); [all …]
|
H A D | distributeddb_query_object_helper_test.cpp | 295 bytes.resize(object.CalculateParcelLen(SOFTWARE_VERSION_CURRENT)); 297 EXPECT_EQ(object.SerializeData(parcel, SOFTWARE_VERSION_CURRENT), E_OK);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_ability_sync_test.cpp | 130 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 161 EXPECT_TRUE(packet2->GetSoftwareVersion() == SOFTWARE_VERSION_CURRENT); 183 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 229 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 263 EXPECT_TRUE(packet2->GetSoftwareVersion() == SOFTWARE_VERSION_CURRENT); 347 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 378 EXPECT_TRUE(packet2->GetSoftwareVersion() == SOFTWARE_VERSION_CURRENT); 455 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 466 EXPECT_TRUE(context->GetRemoteSoftwareVersion() == SOFTWARE_VERSION_CURRENT); 527 packet1.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); [all …]
|
H A D | distributeddb_meta_data_test.cpp | 210 EXPECT_EQ(metadata_->SetRemoteSchemaVersion(DEVICE_A, SOFTWARE_VERSION_CURRENT), E_OK); 211 EXPECT_EQ(metadata_->GetRemoteSchemaVersion(DEVICE_A), SOFTWARE_VERSION_CURRENT); 274 EXPECT_EQ(metadata_->SetLocalSchemaVersion(SOFTWARE_VERSION_CURRENT), E_OK); 277 EXPECT_EQ(res.second, SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_single_ver_msg_schedule_test.cpp | 70 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 163 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 230 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 289 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 346 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 412 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_anti_dos_sync_test.cpp | 184 packet->SetVersion(SOFTWARE_VERSION_CURRENT); 235 packet->SetVersion(SOFTWARE_VERSION_CURRENT); 300 packet->SetVersion(SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_communicator_proxy_test.cpp | 290 .WillOnce(DoAll(SetArgReferee<1>(SOFTWARE_VERSION_CURRENT), Return(E_OK))); 297 EXPECT_EQ(version, SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 624 {CompressAlgorithm::ZLIB, SOFTWARE_VERSION_CURRENT}) == E_OK); 628 packet->SetBasicInfo(-E_NOT_SUPPORT, SOFTWARE_VERSION_CURRENT, SyncModeType::QUERY_PUSH_PULL); 665 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT); 725 packet.SetVersion(SOFTWARE_VERSION_CURRENT); 763 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 275 packet->SetPacketHead(100, SOFTWARE_VERSION_CURRENT, SUBSCRIBE_QUERY_CMD, 1); 310 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT); 331 packet.SetPacketHead(-E_NOT_SUPPORT, SOFTWARE_VERSION_CURRENT, SUBSCRIBE_QUERY_CMD, 1); 365 EXPECT_EQ(outPacket->GetVersion(), SOFTWARE_VERSION_CURRENT);
|
H A D | distributeddb_mock_sync_module_test.cpp | 692 packet.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); 911 syncTaskContext.SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 1168 context->SetRemoteSoftwareVersion(SOFTWARE_VERSION_CURRENT); 1541 len += entryPtr->CalculateLen(SOFTWARE_VERSION_CURRENT); 1546 …EXPECT_EQ(GenericSingleVerKvEntry::SerializeDatas(kvEntries, parcel, SOFTWARE_VERSION_CURRENT), E_…
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_data_packet.h | 134 uint32_t version_ = SOFTWARE_VERSION_CURRENT; 188 uint32_t version_ = SOFTWARE_VERSION_CURRENT; 205 uint32_t version_ = SOFTWARE_VERSION_CURRENT; 236 uint32_t version_ = SOFTWARE_VERSION_CURRENT;
|
H A D | single_ver_data_sync.cpp | 309 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in GetMatchData() 665 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in FillDataRequestPacket() 810 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in PullRequestStart() 1192 SOFTWARE_VERSION_CURRENT, label_.c_str(), STR_MASK(GetDeviceId())); in AckRecv() 1331 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in RunPermissionCheck() 1369 ack.SetVersion(std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT)); in SendResetWatchDogPacket() 1471 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in CheckPermitSendData() 1602 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in SetAckPacket() 1628 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in GetReSendData() 1717 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in FillRequestReSendPacket() [all …]
|
H A D | single_ver_serialize_manager.cpp | 287 errCode = queryObj.SerializeData(parcel, SOFTWARE_VERSION_CURRENT); in DataPacketQuerySyncSerialization() 366 if (version > SOFTWARE_VERSION_CURRENT) { in DataPacketDeSerialization() 504 if (version > SOFTWARE_VERSION_CURRENT) { in AckPacketDeSerialization() 666 if (version > SOFTWARE_VERSION_CURRENT) { in ControlRequestDeSerialization() 703 errCode = queryObj.SerializeData(parcel, SOFTWARE_VERSION_CURRENT); in SubscribeSerialization()
|
H A D | single_ver_data_packet.cpp | 179 totalLen += query_.CalculateParcelLen(SOFTWARE_VERSION_CURRENT); in CalculateLen() 495 totalLen += query_.CalculateParcelLen(SOFTWARE_VERSION_CURRENT); in CalculateLen()
|
H A D | single_ver_data_sync_utils.cpp | 57 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in QuerySyncCheck() 314 uint32_t version = std::min(context->GetRemoteSoftwareVersion(), SOFTWARE_VERSION_CURRENT); in FillControlRequestPacket()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | commit_history_sync.h | 51 uint32_t version_ = SOFTWARE_VERSION_CURRENT; 80 uint32_t version_ = SOFTWARE_VERSION_CURRENT;
|
H A D | commit_history_sync.cpp | 284 … ", myversion = %" PRIu32, errCode, context->GetDeviceId().c_str(), ver, SOFTWARE_VERSION_CURRENT); in RequestRecvCallback() 318 commits.size(), context->GetDeviceId().c_str(), ver, SOFTWARE_VERSION_CURRENT); in AckRecvCallback() 625 packet->SetVersion(SOFTWARE_VERSION_CURRENT); in SendRequestPacket() 682 packet->SetVersion(SOFTWARE_VERSION_CURRENT); in SendAckPacket()
|
H A D | ability_sync.cpp | 36 softwareVersion_(SOFTWARE_VERSION_CURRENT), in AbilitySyncRequestPacket() 178 softwareVersion_(SOFTWARE_VERSION_CURRENT), in AbilitySyncAckPacket() 749 parcel.WriteUInt32(SOFTWARE_VERSION_CURRENT); in AckPacketSerialization() 1004 packet.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); in SetAbilityRequestBodyInfo() 1011 …SOFTWARE_VERSION_CURRENT, option.securityLabel, option.securityFlag, dbCreateTime, localSchemaVer); in SetAbilityRequestBodyInfo() 1019 ackPacket.SetSoftwareVersion(SOFTWARE_VERSION_CURRENT); in SetAbilityAckBodyInfo()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
H A D | version.h | 50 constexpr uint32_t SOFTWARE_VERSION_CURRENT = SOFTWARE_VERSION_RELEASE_9_0; variable
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
H A D | intercepted_data_impl.cpp | 75 totalLength_ = GenericSingleVerKvEntry::CalculateLens(dataItems, SOFTWARE_VERSION_CURRENT); in InterceptedDataImpl()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | generic_single_ver_kv_entry.cpp | 232 if (targetVersion < SOFTWARE_VERSION_EARLIEST || targetVersion > SOFTWARE_VERSION_CURRENT) { in AdaptToVersion() 252 if (targetVersion < SOFTWARE_VERSION_EARLIEST || targetVersion > SOFTWARE_VERSION_CURRENT) { in AdaptToVersion()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | distributeddb_cloud_kv_syncer_test.cpp | 507 bytes.resize(syncObject.CalculateParcelLen(SOFTWARE_VERSION_CURRENT)); 509 ASSERT_EQ(syncObject.SerializeData(parcel, SOFTWARE_VERSION_CURRENT), E_OK);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | query_sync_object.cpp | 198 if (softWareVersion == SOFTWARE_VERSION_CURRENT) { in CalculateParcelLen()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | cloud_syncer_extend.cpp | 89 bytes.resize(obj.CalculateParcelLen(SOFTWARE_VERSION_CURRENT)); in FillDownloadExtend() 91 errCode = obj.SerializeData(parcel, SOFTWARE_VERSION_CURRENT); in FillDownloadExtend()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
H A D | protocol_proto.cpp | 34 const uint16_t DB_GLOBAL_VERSION = SOFTWARE_VERSION_CURRENT - SOFTWARE_VERSION_EARLIEST;
|