| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | schema_negotiate.cpp | 28 …maNegotiate::MakeLocalSyncOpinion(const SchemaObject &localSchema, const std::string &remoteSchema, in MakeLocalSyncOpinion() argument
57 int errCode = remoteSchemaObj.ParseFromSchemaString(remoteSchema); in MakeLocalSyncOpinion()
99 const RelationalSchemaObject &remoteSchema) in MakeOpinionEachTable() argument
103 … if (!DBCommon::CaseInsensitiveCompare(remoteSchema.GetTable(it.first).GetTableName(), it.first)) { in MakeOpinionEachTable()
108 …int errCode = it.second.CompareWithTable(remoteSchema.GetTable(it.first), localSchema.GetSchemaVer… in MakeOpinionEachTable()
114 …errCode = remoteSchema.GetTable(it.first).CompareWithTable(it.second, remoteSchema.GetSchemaVersio… in MakeOpinionEachTable()
127 const std::string &remoteSchema, uint8_t remoteSchemaType) in MakeLocalSyncOpinion() argument
148 int errCode = remoteSchemaObj.ParseFromSchemaString(remoteSchema); in MakeLocalSyncOpinion()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | schema_negotiate.h | 42 … SyncOpinion MakeLocalSyncOpinion(const SchemaObject &localSchema, const std::string &remoteSchema,
49 const std::string &remoteSchema, uint8_t remoteSchemaType);
63 const RelationalSchemaObject &remoteSchema);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | ability_sync.cpp | 1213 const std::string &remoteSchema, ISyncTaskContext *context) in MakeKvSyncOpinion() argument
1217 …SyncOpinion localSyncOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, re… in MakeKvSyncOpinion()
1230 const std::string &remoteSchema) const in MakeRelationSyncOpinion()
1234 return SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteSchemaType); in MakeRelationSyncOpinion()
1240 std::string remoteSchema = recvPacket->GetSchema(); in HandleKvAckSchemaParam() local
1246 …SyncOpinion syncOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteS… in HandleKvAckSchemaParam()
1267 std::string remoteSchema = recvPacket->GetSchema(); in HandleRelationAckSchemaParam() local
1270 …auto localOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteSchemaT… in HandleRelationAckSchemaParam()
1280 deviceId_, remoteSchema, remoteSchemaType)); in HandleRelationAckSchemaParam()
|
| H A D | ability_sync.h | 249 …cOpinion MakeKvSyncOpinion(const AbilitySyncRequestPacket *packet, const std::string &remoteSchema,
253 const std::string &remoteSchema) const;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 542 RelationalSchemaObject remoteSchema; in SaveSyncDataItems() local
543 errCode = GetRemoteDeviceSchema(deviceName, remoteSchema); in SaveSyncDataItems()
551 remoteSchema.GetTable(query.GetTableName()).GetFieldInfos(), info); in SaveSyncDataItems()
937 int errCode = schemaObj.ParseFromSchemaString(remoteSchema); in SaveRemoteDeviceSchema()
945 Value remoteSchemaBuff(remoteSchema.begin(), remoteSchema.end()); in SaveRemoteDeviceSchema()
952 return remoteDeviceSchema_.Put(deviceId, remoteSchema); in SaveRemoteDeviceSchema()
961 std::string remoteSchema; in GetRemoteDeviceSchema() local
962 int errCode = remoteDeviceSchema_.Get(deviceId, remoteSchema); in GetRemoteDeviceSchema()
973 remoteSchema = std::string(remoteSchemaBuff.begin(), remoteSchemaBuff.end()); in GetRemoteDeviceSchema()
974 errCode = remoteDeviceSchema_.Put(deviceId, remoteSchema); in GetRemoteDeviceSchema()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | relational_db_sync_interface.h | 52 …virtual int SaveRemoteDeviceSchema(const std::string &deviceId, const std::string &remoteSchema, u…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_relational_ver_sync_db_interface.h | 114 …int SaveRemoteDeviceSchema(const std::string &deviceId, const std::string &remoteSchema, uint8_t t…
|
| H A D | virtual_relational_ver_sync_db_interface.cpp | 339 const std::string &remoteSchema, uint8_t type) in SaveRemoteDeviceSchema() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store.cpp | 1577 SchemaObject remoteSchema; in CheckCompatible() local
1578 int errCode = remoteSchema.ParseFromSchemaString(schema); in CheckCompatible()
1585 errCode = localSchema.CompareAgainstSchemaObject(remoteSchema); in CheckCompatible()
1591 errCode = remoteSchema.CompareAgainstSchemaObject(localSchema); in CheckCompatible()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 128 …int SaveRemoteDeviceSchema(const std::string &deviceId, const std::string &remoteSchema, uint8_t t…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_get_data_test.cpp | 260 std::string remoteSchema = store->GetSchemaInfo().ToSchemaString(); in SetRemoteSchema() local
262 …const_cast<RelationalSyncAbleStorage *>(store)->SaveRemoteDeviceSchema(deviceID, remoteSchema, rem… in SetRemoteSchema()
|