| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 287 std::function<void()> SyncManager::GetPostEventTask(const std::vector<SchemaMeta> &schemas, CloudInfo &cloud, in GetPostEventTask() argument
290 return [this, &cloud, &info, &schemas, retry, &traceIds]() { in GetPostEventTask()
292 for (auto &schema : schemas) { in GetPostEventTask()
361 auto schemas = GetSchemaMeta(cloud, info.bundleName_);
362 if (schemas.empty()) {
364 schemas = GetSchemaMeta(cloud, info.bundleName_);
365 if (schemas.empty()) {
377 auto task = GetPostEventTask(schemas, cloud, info, retry, traceIds);
806 std::vector<SchemaMeta> schemas;
808 MetaDataManager::GetInstance().LoadMeta(key, schemas, tru
[all...] |
| H A D | sync_manager.h | 144 std::function<void()> GetPostEventTask(const std::vector<SchemaMeta> &schemas, CloudInfo &cloud, SyncInfo &info,
|
| H A D | cloud_service_impl.cpp | 587 std::vector<SchemaMeta> schemas; in QueryLastSyncInfo() local
589 if (!MetaDataManager::GetInstance().LoadMeta(key, schemas, true) || schemas.empty()) { in QueryLastSyncInfo()
595 for (const auto &schema : schemas) { in QueryLastSyncInfo()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 374 std::map<std::string, DataBaseSchema> schemas; in GetKvStore() local
375 schemas[DistributedDBUnitTest::USER_ID] = GetDataBaseSchema(invalidSchema); in GetKvStore()
376 schemas[USER_ID_2] = GetDataBaseSchema(invalidSchema); in GetKvStore()
377 delegate->SetCloudDbSchema(schemas); in GetKvStore()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 582 auto schemas = GetDataBaseSchemas(); in CheckSyncOption() local
583 if (schemas.empty()) { in CheckSyncOption()
592 if (schemas.find(user) == schemas.end()) { in CheckSyncOption()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_kvstore_test.cpp | 237 std::map<std::string, DataBaseSchema> schemas; in GetKvStore() local
238 schemas[USER_ID] = GetDataBaseSchema(invalidSchema); in GetKvStore()
239 schemas[USER_ID_2] = GetDataBaseSchema(invalidSchema); in GetKvStore()
240 return delegate->SetCloudDbSchema(schemas); in GetKvStore()
446 std::map<std::string, DataBaseSchema> schemas; in HWTEST_F() local
447 schemas[USER_ID_2] = GetDataBaseSchema(false); in HWTEST_F()
448 kvDelegatePtrS1_->SetCloudDbSchema(schemas); in HWTEST_F()
1657 std::map<std::string, DataBaseSchema> schemas; in HWTEST_F() local
1658 schemas[USER_ID] = GetDataBaseSchema(true); in HWTEST_F()
1659 EXPECT_EQ(kvDelegatePtrS1_->SetCloudDbSchema(schemas), DB_ERRO in HWTEST_F()
[all...] |
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 263 std::map<std::string, DataBaseSchema> schemas; in GetKvStore() local
264 schemas[USER_ID] = GetDataBaseSchema(invalidSchema); in GetKvStore()
265 schemas[USER_ID_2] = GetDataBaseSchema(invalidSchema); in GetKvStore()
266 return delegate->SetCloudDbSchema(schemas); in GetKvStore()
|
| H A D | distributeddb_cloud_kv_test.cpp | 237 std::map<std::string, DataBaseSchema> schemas; in GetKvStore() local
238 schemas[USER_ID] = GetDataBaseSchema(invalidSchema); in GetKvStore()
239 schemas[USER_ID_2] = GetDataBaseSchema(invalidSchema); in GetKvStore()
240 return delegate->SetCloudDbSchema(schemas); in GetKvStore()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.cpp | 235 std::map<std::string, DataBaseSchema> schemas; in Bind() local
248 schemas.insert({ std::to_string(userId), dbSchema }); in Bind()
259 delegate_->SetCloudDbSchema(std::move(schemas)); in Bind()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 130 std::map<std::string, DataBaseSchema> schemas; in SetCloudDB() local
131 schemas[USER_ID] = GetDataBaseSchema(); in SetCloudDB()
132 return delegatePtr->SetCloudDbSchema(schemas); in SetCloudDB()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cloud_data_test.cpp | 1502 std::vector<SchemaMeta> schemas; in HWTEST_F() local
1504 schemas.push_back(schemaMeta_); in HWTEST_F()
1506 schemas.push_back(schemaMeta_); in HWTEST_F()
1515 auto task = sync.GetPostEventTask(schemas, cloudInfo_, info, true, traceIds); in HWTEST_F()
|