Home
last modified time | relevance | path

Searched refs:MetaDataManager (Results 1 – 25 of 45) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Dmeta_data_test.cpp80 result = MetaDataManager::GetInstance().DelMeta(key, true);
90 result = MetaDataManager::GetInstance().DelMeta(key);
117 result = MetaDataManager::GetInstance().DelMeta(key, true);
128 result = MetaDataManager::GetInstance().DelMeta(key);
168 result = MetaDataManager::GetInstance().DelMeta(key);
208 result = MetaDataManager::GetInstance().DelMeta(prefix);
251 result = MetaDataManager::GetInstance().DelMeta(key);
372 result = MetaDataManager::GetInstance().DelMeta(key);
594 result = MetaDataManager::GetInstance().DelMeta(key);
635 result = MetaDataManager::GetInstance().DelMeta(key);
[all …]
H A Dmeta_data_manager_test.cpp47 MetaDataManager::Filter filter(pattern);
63 MetaDataManager::Filter filter(pattern);
83 MetaDataManager::OnComplete complete;
84 auto result = MetaDataManager::GetInstance().Sync(devices, complete);
99 MetaDataManager::OnComplete complete;
100 auto result = MetaDataManager::GetInstance().Sync(devices, complete);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/test/unittest/
H A Dkvstore_data_service_clear_test.cpp41 using MetaDataManager = OHOS::DistributedData::MetaDataManager; typedef
138 EXPECT_TRUE(MetaDataManager::GetInstance().SaveMeta(metaData_.GetKey(), metaData_));
139 EXPECT_TRUE(MetaDataManager::GetInstance().SaveMeta(metaData_.GetKey(), metaData_, true));
141 EXPECT_TRUE(MetaDataManager::GetInstance().SaveMeta(metaData_.GetStrategyKey(), metaData_));
142 EXPECT_TRUE(MetaDataManager::GetInstance().SaveMeta(metaData_.appId, metaData_, true));
145 EXPECT_TRUE(MetaDataManager::GetInstance().LoadMeta(metaData_.GetKey(), metaData_));
148 EXPECT_TRUE(MetaDataManager::GetInstance().LoadMeta(metaData_.appId, metaData_, true));
157 EXPECT_FALSE(MetaDataManager::GetInstance().LoadMeta(metaData_.GetKey(), metaData_));
160 EXPECT_FALSE(MetaDataManager::GetInstance().LoadMeta(metaData_.appId, metaData_, true));
163 MetaDataManager::GetInstance().DelMeta(metaData_.GetKey());
[all …]
H A Dmeta_data_manager_test.cpp52 MetaDataManager::GetInstance().DelMeta(testKey); in DeleteTestData()
95 MetaDataManager::GetInstance().Subscribe(
102 auto result = MetaDataManager::GetInstance().SaveMeta(student.name, student);
106 MetaDataManager::GetInstance().Unsubscribe(prefix);
109 result = MetaDataManager::GetInstance().LoadMeta(student.name, student1);
H A Dsession_manager_test.cpp86 …MetaDataManager::GetInstance().SaveMeta({ peerUserMetaKey.begin(), peerUserMetaKey.end() }, userMe… in SetUpTestCase()
92 …MetaDataManager::GetInstance().SaveMeta({ peerCapMetaKey.begin(), peerCapMetaKey.end() }, capMetaD… in SetUpTestCase()
103 MetaDataManager::GetInstance().SaveMeta(metaData.GetKey(), metaData); in SetUpTestCase()
109 …MetaDataManager::GetInstance().DelMeta(std::string(peerUserMetaKey.begin(), peerUserMetaKey.end())… in TearDownTestCase()
111 … MetaDataManager::GetInstance().DelMeta(std::string(peerCapMetaKey.begin(), peerCapMetaKey.end())); in TearDownTestCase()
121 MetaDataManager::GetInstance().DelMeta(metaData.GetKey()); in TearDownTestCase()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/
H A Dmeta_data_manager.cpp27 using Filter = MetaDataManager::Filter;
29 using Observer = MetaDataManager::Observer;
94 int32_t next = MetaDataManager::INSERT; in OnChange()
114 HandleChanges(MetaDataManager::INSERT, data.primaryData[MetaDataManager::INSERT]); in OnChange()
115 HandleChanges(MetaDataManager::UPDATE, data.primaryData[MetaDataManager::UPDATE]); in OnChange()
116 HandleChanges(MetaDataManager::DELETE, data.primaryData[MetaDataManager::DELETE]); in OnChange()
143 MetaDataManager &MetaDataManager::GetInstance() in GetInstance()
145 static MetaDataManager instance; in GetInstance()
149 MetaDataManager::MetaDataManager() = default;
151 MetaDataManager::~MetaDataManager() in ~MetaDataManager()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/installer/
H A Dinstaller_impl.cpp72 if (!MetaDataManager::GetInstance().LoadMeta(prefix, storeMetaData, true)) { in OnUninstall()
81 MetaDataManager::GetInstance().DelMeta(meta.GetKey()); in OnUninstall()
82 MetaDataManager::GetInstance().DelMeta(meta.GetKey(), true); in OnUninstall()
83 MetaDataManager::GetInstance().DelMeta(meta.GetKeyLocal(), true); in OnUninstall()
84 MetaDataManager::GetInstance().DelMeta(meta.GetSecretKey(), true); in OnUninstall()
85 MetaDataManager::GetInstance().DelMeta(meta.GetStrategyKey()); in OnUninstall()
86 MetaDataManager::GetInstance().DelMeta(meta.appId, true); in OnUninstall()
87 MetaDataManager::GetInstance().DelMeta(meta.GetBackupSecretKey(), true); in OnUninstall()
88 MetaDataManager::GetInstance().DelMeta(meta.GetAutoLaunchKey(), true); in OnUninstall()
89 MetaDataManager::GetInstance().DelMeta(meta.GetDebugInfoKey(), true); in OnUninstall()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Duser_delegate.cpp56 MetaDataManager::GetInstance().LoadMeta(UserMetaRow::GetKeyFor(key), userMetaData); in GetLocalUsers()
84 MetaDataManager::GetInstance().LoadMeta(UserMetaRow::GetKeyFor(key), userMetaData); in GetUsers()
141 …return MetaDataManager::GetInstance().SaveMeta(UserMetaRow::GetKeyFor(userMetaData.deviceId), user… in InitLocalUserMeta()
153 MetaDataManager::GetInstance().Subscribe( in Init()
157 MetaDataManager::GetInstance().LoadMeta(key, metaData); in Init()
166 if (flag == MetaDataManager::INSERT || flag == MetaDataManager::UPDATE) { in Init()
168 } else if (flag == MetaDataManager::DELETE) { in Init()
H A Dkvdb_service_impl.cpp170 MetaDataManager::GetInstance().LoadMeta(prefix, metaData, true); in GetStoreIds()
198 MetaDataManager::GetInstance().DelMeta(metaData.GetKey()); in Delete()
199 MetaDataManager::GetInstance().DelMeta(metaData.GetKey(), true); in Delete()
200 MetaDataManager::GetInstance().DelMeta(metaData.GetKeyLocal(), true); in Delete()
201 MetaDataManager::GetInstance().DelMeta(metaData.GetSecretKey(), true); in Delete()
202 MetaDataManager::GetInstance().DelMeta(metaData.GetStrategyKey()); in Delete()
249 MetaDataManager::GetInstance().LoadMeta(metaData.GetKey(), metaData); in Sync()
274 if (!MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta)) { in NotifyDataChange()
518 MetaDataManager::GetInstance().LoadMeta(strategy.GetKey(), strategy); in SetCapability()
788 if (!MetaDataManager::GetInstance().LoadMeta(prefix, metaData)) { in ResolveAutoLaunch()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/sync_strategies/
H A Dnetwork_sync_strategy.cpp29 MetaDataManager::GetInstance().Subscribe( in NetworkSyncStrategy()
37 if (flag == MetaDataManager::INSERT || flag == MetaDataManager::UPDATE) { in NetworkSyncStrategy()
39 } else if (flag == MetaDataManager::DELETE) { in NetworkSyncStrategy()
50 MetaDataManager::GetInstance().Unsubscribe(StrategyInfo::PREFIX); in ~NetworkSyncStrategy()
127 MetaDataManager::GetInstance().LoadMeta(GetKey(user, bundleName), info, true); in GetStrategy()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/src/
H A Ddevice_matrix.cpp40 MetaDataManager::GetInstance().Subscribe(MatrixMetaData::GetPrefix({}), in DeviceMatrix()
42 if (action != MetaDataManager::INSERT && action != MetaDataManager::UPDATE) { in DeviceMatrix()
59 MetaDataManager::GetInstance().Subscribe(MatrixMetaData::GetPrefix({}), in DeviceMatrix()
61 if (action != MetaDataManager::INSERT && action != MetaDataManager::UPDATE) { in DeviceMatrix()
66 MetaDataManager::GetInstance().LoadMeta(key, metaData); in DeviceMatrix()
80 MetaDataManager::GetInstance().Unsubscribe(MatrixMetaData::GetPrefix({})); in ~DeviceMatrix()
113 auto loaded = MetaDataManager::GetInstance().LoadMeta(key, oldMeta); in Initialize()
122 MetaDataManager::GetInstance().SaveMeta(newMeta.GetKey(), newMeta, true); in Initialize()
123 return MetaDataManager::GetInstance().SaveMeta(newMeta.GetKey(), newMeta); in Initialize()
510 MetaDataManager::GetInstance().SaveMeta(meta.GetKey(), meta, true); in UpdateConsistentMeta()
[all …]
H A Dauto_sync_matrix.cpp40 MetaDataManager::GetInstance().Subscribe(StoreMetaData::GetPrefix({ deviceId }), in AutoSyncMatrix()
44 MetaDataManager::GetInstance().LoadMeta(key, metaData); in AutoSyncMatrix()
53 auto act = static_cast<MetaDataManager::Action>(action); in AutoSyncMatrix()
55 case MetaDataManager::INSERT: in AutoSyncMatrix()
58 case MetaDataManager::DELETE: in AutoSyncMatrix()
61 case MetaDataManager::UPDATE: in AutoSyncMatrix()
79 if (!MetaDataManager::GetInstance().LoadMeta(StoreMetaData::GetPrefix({ deviceId }), metas)) { in Initialize()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Ddevice_matrix_test.cpp74 MetaDataManager::GetInstance().Initialize(dbStoreMock_, nullptr); in SetUpTestCase()
75 MetaDataManager::GetInstance().SetCloudSyncer([]() { in SetUpTestCase()
126 MetaDataManager::GetInstance().DelMeta(metaData.GetKey()); in InitRemoteMatrixMeta()
127 MetaDataManager::GetInstance().SaveMeta(metaData.GetKey(), metaData); in InitRemoteMatrixMeta()
303 MetaDataManager::GetInstance().Subscribe(MatrixMetaData::GetPrefix({ TEST_DEVICE }),
305 if (flag != MetaDataManager::INSERT && flag != MetaDataManager::UPDATE) { in __anonfb618eeb0202()
315 MetaDataManager::GetInstance().DelMeta(metaData.GetKey());
316 MetaDataManager::GetInstance().SaveMeta(metaData.GetKey(), metaData);
338 MetaDataManager::GetInstance().Unsubscribe(MatrixMetaData::GetPrefix({ TEST_DEVICE }));
H A Dwater_version_manager_test.cpp106 MetaDataManager::GetInstance().Initialize(dbStoreMock_, nullptr); in SetUpTestCase()
137 MetaDataManager::GetInstance().DelMeta(staticMeta_.GetKey(), true); in TearDown()
138 MetaDataManager::GetInstance().DelMeta(dynamicMeta_.GetKey(), true); in TearDown()
141 MetaDataManager::GetInstance().DelMeta(matrixMetaData.GetKey(), true); in TearDown()
146 MetaDataManager::GetInstance().SaveMeta(staticMeta_.GetKey(), staticMeta_, true); in InitMetaData()
147 MetaDataManager::GetInstance().SaveMeta(dynamicMeta_.GetKey(), dynamicMeta_, true); in InitMetaData()
179 …EXPECT_TRUE(MetaDataManager::GetInstance().LoadMeta(matrixMetaData.GetConsistentKey(), matrixMetaD…
215 …EXPECT_TRUE(MetaDataManager::GetInstance().LoadMeta(matrixMetaData.GetConsistentKey(), matrixMetaD…
255 …EXPECT_TRUE(MetaDataManager::GetInstance().LoadMeta(matrixMetaData.GetConsistentKey(), matrixMetaD…
363 ASSERT_TRUE(MetaDataManager::GetInstance().LoadMeta(key, matrixMetaData, true));
[all …]
H A Dcloud_data_test.cpp242 MetaDataManager::GetInstance().Initialize(dbStoreMock_, nullptr); in SetUpTestCase()
243 MetaDataManager::GetInstance().SetSyncer( in SetUpTestCase()
289 MetaDataManager::GetInstance().DelMeta(cloudInfo_.GetKey(), true); in TearDown()
290 MetaDataManager::GetInstance().DelMeta(metaData_.GetKey(), true); in TearDown()
327 MetaDataManager::GetInstance().DelMeta(cloudInfo_.GetKey(), true);
512 MetaDataManager::GetInstance().SaveMeta(info.GetKey(), info, true);
722 MetaDataManager::GetInstance().DelMeta(metaData_.GetKey(), true);
740 MetaDataManager::GetInstance().DelMeta(metaData_.GetKey(), true);
1571 MetaDataManager::GetInstance().DelMeta(cloudInfo_.GetKey(), true);
1627 MetaDataManager::GetInstance().DelMeta(cloudInfo_.GetKey(), true);
[all …]
H A Dmeta_data_test.cpp121 MetaDataManager::GetInstance().DelMeta(metaData_.GetKey()); in SetUp()
140 ASSERT_TRUE(MetaDataManager::GetInstance().LoadMeta(metaData_.GetKey(), metaData));
159 ASSERT_TRUE(MetaDataManager::GetInstance().LoadMeta(metaData_.GetKey(), metaData));
161 ASSERT_TRUE(MetaDataManager::GetInstance().DelMeta(metaData_.GetKey()));
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_data_service.cpp136 MetaDataManager::GetInstance().LoadMeta(info.appId, appIdMeta, true); in Initialize()
141 MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta, true); in Initialize()
521 MetaDataManager::GetInstance().DelMeta(meta.GetKey()); in AccountEventChanged()
522 MetaDataManager::GetInstance().DelMeta(meta.GetKey(), true); in AccountEventChanged()
528 MetaDataManager::GetInstance().DelMeta(meta.appId, true); in AccountEventChanged()
684 if (!MetaDataManager::GetInstance().LoadMeta(prefix, metaData, true)) { in ClearAppStorage()
694 MetaDataManager::GetInstance().DelMeta(meta.GetKey()); in ClearAppStorage()
695 MetaDataManager::GetInstance().DelMeta(meta.GetKey(), true); in ClearAppStorage()
696 MetaDataManager::GetInstance().DelMeta(meta.GetKeyLocal(), true); in ClearAppStorage()
698 MetaDataManager::GetInstance().DelMeta(meta.GetStrategyKey()); in ClearAppStorage()
[all …]
H A Dkvstore_meta_manager.cpp169 if (!(MetaDataManager::GetInstance().SaveMeta(data.GetKey(), data) && in InitMetaData()
170 MetaDataManager::GetInstance().SaveMeta(data.GetKey(), data, true) && in InitMetaData()
171 MetaDataManager::GetInstance().SaveMeta(data.GetKeyLocal(), localData, true))) { in InitMetaData()
182 if (!MetaDataManager::GetInstance().LoadMeta(versionMeta.GetKey(), versionMeta, true) in UpdateMetaData()
186 MetaDataManager::GetInstance().LoadMeta(prefix, metaDataList); in UpdateMetaData()
188 MetaDataManager::GetInstance().SaveMeta(metaData.GetKey(), metaData, true); in UpdateMetaData()
192 MetaDataManager::GetInstance().DelMeta(metaData.GetKey()); in UpdateMetaData()
198 MetaDataManager::GetInstance().SaveMeta(versionMeta.GetKey(), versionMeta, true); in UpdateMetaData()
255 MetaDataManager::GetInstance().Initialize(metaDelegate_, backup); in GetMetaKvStore()
344 MetaDataManager::GetInstance().SetCloudSyncer(cloudSyncer); in SetCloudSyncer()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dcloud_service_impl.cpp90 MetaDataManager::GetInstance().Subscribe( in CloudServiceImpl()
93 if (flag != MetaDataManager::INSERT && flag != MetaDataManager::UPDATE) { in CloudServiceImpl()
237 if (!MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta, true)) { in GetStoreMetaData()
444 MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta, true); in ExecuteStatistics()
784 MetaDataManager::GetInstance().DelMeta(cloudInfo.GetKey(), true); in UpdateSchema()
791 if (MetaDataManager::GetInstance().LoadMeta(key, oldMeta, true)) { in UpdateSchema()
794 MetaDataManager::GetInstance().SaveMeta(key, schemaMeta, true); in UpdateSchema()
897 MetaDataManager::GetInstance().SaveMeta(schemaKey, schemaMeta, true); in GetSchemaMeta()
1030 MetaDataManager::GetInstance().LoadMeta(sub.GetKey(), sub, true); in DoSubscribe()
1085 MetaDataManager::GetInstance().DelMeta(sub.GetKey(), true); in CleanSubscription()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/backup/src/
H A Dbackup_manager.cpp56 MetaDataManager::GetInstance().LoadMeta( in Init()
110 MetaDataManager::GetInstance().LoadMeta( in BackSchedule()
137 if (MetaDataManager::GetInstance().LoadMeta(key, secretKey, true)) { in DoBackup()
181 MetaDataManager::GetInstance().SaveMeta(key, secretKey, true); in SaveData()
257 if (MetaDataManager::GetInstance().LoadMeta(dbKey, dbPassword, true)) { in GetClearType()
259 MetaDataManager::GetInstance().LoadMeta(backupKey, backupPassword, true); in GetClearType()
303 MetaDataManager::GetInstance().LoadMeta(key, secretKey, true); in GetPassWord()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_service_impl.cpp56 using OHOS::DistributedData::MetaDataManager;
306 MetaDataManager::GetInstance().SaveMeta(meta.GetKey(), localMeta); in SetDistributedTables()
456 auto result = MetaDataManager::GetInstance().Sync(devices, complete); in DoSync()
679 MetaDataManager::GetInstance().DelMeta(storeMeta.GetKey()); in Delete()
680 MetaDataManager::GetInstance().DelMeta(storeMeta.GetKey(), true); in Delete()
681 MetaDataManager::GetInstance().DelMeta(storeMeta.GetKeyLocal(), true); in Delete()
682 MetaDataManager::GetInstance().DelMeta(storeMeta.GetSecretKey(), true); in Delete()
683 MetaDataManager::GetInstance().DelMeta(storeMeta.GetStrategyKey()); in Delete()
739 MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta, true); in BeforeOpen()
778 MetaDataManager::GetInstance().SaveMeta(meta.GetKey(), meta, true); in AfterOpen()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/
H A Dmeta_data_manager.h29 class MetaDataManager {
54 API_EXPORT static MetaDataManager &GetInstance();
84 MetaDataManager();
85 ~MetaDataManager();
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/permission/src/
H A Dpermit_delegate.cpp98 MetaDataManager::GetInstance().LoadMeta(key, appIDMeta, true); in VerifyPermission()
107 if (!MetaDataManager::GetInstance().LoadMeta(key, data)) { in VerifyPermission()
140 MetaDataManager::GetInstance().LoadMeta(local.GetKey(), local); in VerifyStrategy()
142 MetaDataManager::GetInstance().LoadMeta(remote.GetKey(), remote); in VerifyStrategy()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/
H A Dwater_version_manager.cpp59 MetaDataManager::GetInstance().LoadMeta(WaterVersionMetaData::GetPrefix(), metas, true); in Init()
192 if (!MetaDataManager::GetInstance().LoadMeta(storeMetaData.GetKey(), storeMetaData, true)) { in InitMeta()
410 … if (!status && !MetaDataManager::GetInstance().LoadMeta(metaData.GetKey(), metaData, true)) { in GenerateWaterVersion()
424 if (MetaDataManager::GetInstance().SaveMeta(metaData.GetKey(), metaData, true) && in GenerateWaterVersion()
442 if (MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), meta, true)) { in GetWaterVersion()
461 !MetaDataManager::GetInstance().LoadMeta(metaData.GetKey(), oldMeta, true)) { in SetWaterVersion()
490 return MetaDataManager::GetInstance().SaveMeta(oldMeta.GetKey(), oldMeta, true) && in SetWaterVersion()
498 … return versions_.Delete(deviceId) && MetaDataManager::GetInstance().DelMeta(meta.GetKey(), true); in DelWaterVersion()
507 return MetaDataManager::GetInstance().SaveMeta(meta.GetKey(), meta, true) && in InitWaterVersion()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/
H A Dupgrade_manager.cpp68 …status = MetaDataManager::GetInstance().LoadMeta(std::string(dbKey.begin(), dbKey.end()), capMetaD… in GetCapability()
83 …bool status = MetaDataManager::GetInstance().SaveMeta({ dbKey.begin(), dbKey.end() }, capMetaData); in InitLocalCapability()

12