| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_meta_data.h | 36 int GetLocalWaterMark(const TableName &tableName, Timestamp &localMark);
38 int GetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
40 int SetLocalWaterMark(const TableName &tableName, Timestamp localMark);
41 … int SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark);
42 int SetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
44 int CleanWaterMark(const TableName &tableName);
48 void CleanWaterMarkInMemory(const TableName &tableName);
59 int ReadMarkFromMeta(const TableName &tableName);
60 int WriteMarkToMeta(const TableName &tableName, Timestamp localmark, std::string &cloudMark);
61 int WriteTypeMarkToMeta(const TableName &tableName, CloudMetaValue &cloudMetaValue);
[all …]
|
| H A D | schema_mgr.h | 34 int GetCloudTableSchema(const TableName &tableName, TableSchema &retSchema);
35 int ChkSchema(const TableName &tableName, RelationalSchemaObject &localSchema);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_meta_data.cpp | 29 int CloudMetaData::GetLocalWaterMark(const TableName &tableName, Timestamp &localMark) in GetLocalWaterMark()
43 int CloudMetaData::GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timesta… in GetLocalWaterMarkByType()
64 int CloudMetaData::GetCloudWaterMark(const TableName &tableName, std::string &cloudMark) in GetCloudWaterMark()
78 int CloudMetaData::SetLocalWaterMark(const TableName &tableName, Timestamp localMark) in SetLocalWaterMark()
101 int CloudMetaData::SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timesta… in SetLocalWaterMarkByType()
132 int CloudMetaData::SetCloudWaterMark(const TableName &tableName, std::string &cloudMark) in SetCloudWaterMark()
156 int CloudMetaData::ReadMarkFromMeta(const TableName &tableName) in ReadMarkFromMeta()
175 int CloudMetaData::WriteMarkToMeta(const TableName &tableName, Timestamp localmark, std::string &cl… in WriteMarkToMeta()
188 int CloudMetaData::WriteTypeMarkToMeta(const TableName &tableName, CloudMetaValue &cloudMetaValue) in WriteTypeMarkToMeta()
254 int CloudMetaData::CleanWaterMark(const TableName &tableName) in CleanWaterMark()
[all …]
|
| H A D | schema_mgr.cpp | 30 int SchemaMgr::ChkSchema(const TableName &tableName, RelationalSchemaObject &localSchema) in ChkSchema()
204 int SchemaMgr::GetCloudTableSchema(const TableName &tableName, TableSchema &retSchema) in GetCloudTableSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 88 int CheckSchema(const TableName &tableName) const;
92 …int GetPrimaryColNamesWithAssetsFields(const TableName &tableName, std::vector<std::string> &colNa…
108 int CleanWaterMark(const TableName &tableName);
110 int CleanWaterMarkInMemory(const TableName &tableName);
|
| H A D | icloud_sync_storage_interface.h | 98 virtual int ChkSchema(const TableName &tableName) = 0;
104 virtual int GetCloudTableSchema(const TableName &tableName, TableSchema &tableSchema) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | mock_icloud_sync_storage_interface.h | 26 MOCK_METHOD1(ChkSchema, int(const TableName &));
29 MOCK_METHOD2(GetCloudTableSchema, int(const TableName &, TableSchema &));
|
| H A D | cloud_syncer_test.h | 236 void SetAssetFields(const TableName &tableName, const std::vector<Field> &assetFields) in SetAssetFields()
254 void SetCloudWaterMarks(const TableName &tableName, const std::string &mark) in SetCloudWaterMarks()
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 615 .WillRepeatedly([](const TableName &, TableSchema &tableSchema) { in __anonb65cf8ae1502() argument
737 .WillRepeatedly([](const TableName &, TableSchema &tableSchema) { in __anonb65cf8ae2a02() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.h | 97 std::map<TableName, std::vector<Field>> assetFields;
101 std::map<TableName, std::map<std::string, std::map<std::string, Assets>>> assetsInfo;
103 std::map<int, std::map<TableName, std::string>> cloudWaterMarks;
168 int PreCheckUpload(TaskId &taskId, const TableName &tableName, Timestamp &localMark);
170 int PreCheck(TaskId &taskId, const TableName &tableName);
285 int SaveCloudWaterMark(const TableName &tableName, const TaskId taskId);
|
| H A D | cloud_syncer.cpp | 910 int CloudSyncer::PreCheck(CloudSyncer::TaskId &taskId, const TableName &tableName) in PreCheck()
1172 int CloudSyncer::PreCheckUpload(CloudSyncer::TaskId &taskId, const TableName &tableName, Timestamp … in PreCheckUpload()
1335 int CloudSyncer::SaveCloudWaterMark(const TableName &tableName, const TaskId taskId) in SaveCloudWaterMark()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.h | 32 int ChkSchema(const TableName &tableName) override;
38 int GetCloudTableSchema(const TableName &tableName, TableSchema &tableSchema) override;
|
| H A D | sqlite_cloud_kv_store.cpp | 42 int SqliteCloudKvStore::ChkSchema(const TableName &tableName) in ChkSchema()
69 int SqliteCloudKvStore::GetCloudTableSchema(const TableName &tableName, in GetCloudTableSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/ |
| H A D | storage_fuzzer.cpp | 45 TableName TABLE_NAME_1 = "tableName1";
163 bool SetAndGetLocalWaterMark(TableName &tableName, Timestamp mark) in SetAndGetLocalWaterMark()
181 bool SetAndGetCloudWaterMark(TableName &tableName, std::string &mark) in SetAndGetCloudWaterMark()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 342 int StorageProxy::CheckSchema(const TableName &tableName) const in CheckSchema()
369 int StorageProxy::GetPrimaryColNamesWithAssetsFields(const TableName &tableName, std::vector<std::s… in GetPrimaryColNamesWithAssetsFields()
465 int StorageProxy::CleanWaterMark(const DistributedDB::TableName &tableName) in CleanWaterMark()
475 int StorageProxy::CleanWaterMarkInMemory(const DistributedDB::TableName &tableName) in CleanWaterMarkInMemory()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_types.h | 30 using TableName = std::string; variable
|
| H A D | db_common.h | 112 static Key GetPrefixTableName(const TableName &tableName);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 161 int ChkSchema(const TableName &tableName) override;
167 int GetCloudTableSchema(const TableName &tableName, TableSchema &tableSchema) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 92 void SetAndGetWaterMark(TableName tableName, Timestamp mark) in SetAndGetWaterMark()
100 void SetAndGetWaterMark(TableName tableName, std::string mark) in SetAndGetWaterMark()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store.h | 92 int ChkSchema(const TableName &tableName);
|
| H A D | sqlite_relational_store.cpp | 1087 int SQLiteRelationalStore::ChkSchema(const TableName &tableName) in ChkSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 557 Key DBCommon::GetPrefixTableName(const TableName &tableName) in GetPrefixTableName()
559 TableName newName = CloudDbConstant::CLOUD_META_TABLE_PREFIX + tableName; in GetPrefixTableName()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1216 int RelationalSyncAbleStorage::ChkSchema(const TableName &tableName) in ChkSchema()
1335 int RelationalSyncAbleStorage::GetCloudTableSchema(const TableName &tableName, TableSchema &tableSc… in GetCloudTableSchema()
|