| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | schema_negotiate.cpp | 108 …Code = it.second.CompareWithTable(remoteSchema.GetTable(it.first), localSchema.GetSchemaVersion()); in MakeOpinionEachTable()
114 …ode = remoteSchema.GetTable(it.first).CompareWithTable(it.second, remoteSchema.GetSchemaVersion()); in MakeOpinionEachTable()
155 if (localSchema.GetSchemaVersion() != remoteSchemaObj.GetSchemaVersion()) { in MakeLocalSyncOpinion()
157 localSchema.GetSchemaVersion().c_str(), remoteSchemaObj.GetSchemaVersion().c_str()); in MakeLocalSyncOpinion()
161 if (localSchema.GetSchemaVersion() == SchemaConstant::SCHEMA_SUPPORT_VERSION_V2_1 && in MakeLocalSyncOpinion()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | ability_sync.h | 70 uint64_t GetSchemaVersion() const;
128 uint64_t GetSchemaVersion() const;
|
| H A D | ability_sync.cpp | 171 uint64_t AbilitySyncRequestPacket::GetSchemaVersion() const in GetSchemaVersion() function in DistributedDB::AbilitySyncRequestPacket
294 uint64_t AbilitySyncAckPacket::GetSchemaVersion() const in GetSchemaVersion() function in DistributedDB::AbilitySyncAckPacket
733 parcel.WriteUInt64(packet->GetSchemaVersion()); in RequestPacketSerialization()
766 parcel.WriteUInt64(packet->GetSchemaVersion()); in AckPacketSerialization()
1140 … ackCode = metadata_->SetRemoteSchemaVersion(context->GetDeviceId(), packet->GetSchemaVersion()); in HandleRequestRecv()
1255 RecordAbilitySyncFinish(recvPacket->GetSchemaVersion(), *context); in HandleKvAckSchemaParam()
1301 RecordAbilitySyncFinish(recvPacket->GetSchemaVersion(), *context); in HandleRelationAckSchemaParam()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/ |
| H A D | relational_schema_object.h | 52 std::string GetSchemaVersion() const;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_packet.h | 116 uint64_t GetSchemaVersion() const;
|
| H A D | single_ver_data_sync_utils.cpp | 572 if (remoteSchemaVersion != packet.GetSchemaVersion()) { in SchemaVersionMatchCheck()
574 packet.GetSchemaVersion(), remoteSchemaVersion); in SchemaVersionMatchCheck()
|
| H A D | single_ver_data_packet.cpp | 321 uint64_t DataRequestPacket::GetSchemaVersion() const in GetSchemaVersion() function in DistributedDB::DataRequestPacket
|
| H A D | single_ver_serialize_manager.cpp | 958 parcel.WriteUInt64(packet->GetSchemaVersion()); in DataPacketInnerSerialization()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 288 errCode = tableInfo.CompareWithTable(newTableInfo, localSchema_.GetSchemaVersion()); in CompareSchemaTableColumns()
316 errCode = tableInfo.CompareWithTable(newTableInfo, schema.GetSchemaVersion()); in UpgradeDistributedTable()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | relational_schema_object.cpp | 136 std::string RelationalSchemaObject::GetSchemaVersion() const in GetSchemaVersion() function in DistributedDB::RelationalSchemaObject
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 844 errCode = handle->CheckQueryObjectLegal(table, query, schema.GetSchemaVersion()); in CheckAndInitQueryCondition()
|