| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | device_matrix_test.cpp | 45 uint16_t mask_ = DeviceMatrix::INVALID_LEVEL;
76 DeviceMatrix::GetInstance().OnChanged(DeviceMatrix::META_STORE_MASK); in SetUpTestCase()
104 DeviceMatrix::GetInstance().Clear(); in SetUp()
207 DeviceMatrix::DataLevel level = {
208 .dynamic = DeviceMatrix::META_STORE_MASK,
228 DeviceMatrix::DataLevel level = {
246 DeviceMatrix::DataLevel level = {
262 DeviceMatrix::DataLevel level = {
277 DeviceMatrix::GetInstance().OnExchanged(TEST_DEVICE, DeviceMatrix::META_STORE_MASK);
321 DeviceMatrix::DataLevel level = {
[all …]
|
| H A D | kvdb_service_impl_test.cpp | 40 using ChangeType = OHOS::DistributedData::DeviceMatrix::ChangeType;
628 switchData.value = DeviceMatrix::INVALID_VALUE;
629 switchData.length = DeviceMatrix::INVALID_LEVEL;
632 switchData.value = DeviceMatrix::INVALID_MASK;
633 switchData.length = DeviceMatrix::INVALID_LENGTH;
636 switchData.value = DeviceMatrix::INVALID_VALUE;
637 switchData.length = DeviceMatrix::INVALID_LENGTH;
640 switchData.value = DeviceMatrix::INVALID_MASK;
641 switchData.length = DeviceMatrix::INVALID_LEVEL;
|
| H A D | cloud_data_test.cpp | 244 … [](const auto &, auto) { DeviceMatrix::GetInstance().OnChanged(DeviceMatrix::META_STORE_MASK); }); in SetUpTestCase()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/src/ |
| H A D | device_matrix.cpp | 32 DeviceMatrix &DeviceMatrix::GetInstance() in GetInstance()
34 static DeviceMatrix instance; in GetInstance()
38 DeviceMatrix::DeviceMatrix() in DeviceMatrix() function in OHOS::DistributedData::DeviceMatrix
78 DeviceMatrix::~DeviceMatrix() in ~DeviceMatrix()
174 void DeviceMatrix::UpdateMask(Mask &mask) in UpdateMask()
641 void DeviceMatrix::Clear() in Clear()
674 void DeviceMatrix::UpdateLevel(const std::string &device, uint16_t level, DeviceMatrix::LevelType t… in UpdateLevel()
740 DeviceMatrix::Task DeviceMatrix::GenResetTask() in GenResetTask()
755 bool DeviceMatrix::DataLevel::IsValid() const in IsValid()
761 bool DeviceMatrix::IsSupportMatrix() in IsSupportMatrix()
[all …]
|
| H A D | auto_sync_matrix.cpp | 96 if (meta.dataType != DataType::DYNAMICAL || DeviceMatrix::GetInstance().IsDynamic(meta)) { in IsAutoSync()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/include/ |
| H A D | device_matrix.h | 30 class API_EXPORT DeviceMatrix {
65 static DeviceMatrix &GetInstance();
100 DeviceMatrix();
101 ~DeviceMatrix();
102 DeviceMatrix(const DeviceMatrix &) = delete;
103 DeviceMatrix(DeviceMatrix &&) noexcept = delete;
104 DeviceMatrix &operator=(const DeviceMatrix &) = delete;
105 DeviceMatrix &operator=(DeviceMatrix &&) noexcept = delete;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.cpp | 107 DistributedData::DeviceMatrix::DataLevel level; in InitBroadcast()
112 DeviceMatrix::GetInstance().OnBroadcast(device, std::move(level)); in InitBroadcast()
115 … EventCenter::GetInstance().Subscribe(DeviceMatrix::MATRIX_BROADCAST, [pipe](const Event &event) { in InitBroadcast()
301 DeviceMatrix::GetInstance().OnExchanged(info.deviceId, DeviceMatrix::META_STORE_MASK, in CreateMetaKvStore()
302 DeviceMatrix::LevelType::DYNAMIC, DeviceMatrix::ChangeType::CHANGE_REMOTE); in CreateMetaKvStore()
354 DeviceMatrix::GetInstance().OnChanged(DeviceMatrix::META_STORE_MASK); in CloudSyncTask()
411 DeviceMatrix::GetInstance().Offline(info.uuid); in OnDeviceChanged()
414 DeviceMatrix::GetInstance().Online(info.uuid, RefCount([deviceId = info.uuid]() { in OnDeviceChanged()
|
| H A D | kvstore_data_service.cpp | 355 …DeviceMatrix::GetInstance().Initialize(IPCSkeleton::GetCallingTokenID(), Bootstrap::GetInstance().… in StartService()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 252 DeviceMatrix::GetInstance().OnChanged(metaData); in Sync()
279 if (DeviceMatrix::GetInstance().IsSupportMatrix() && in NotifyDataChange()
280 … (DeviceMatrix::GetInstance().IsStatics(meta) || DeviceMatrix::GetInstance().IsDynamic(meta))) { in NotifyDataChange()
282 DeviceMatrix::GetInstance().OnChanged(meta); in NotifyDataChange()
297 if (data.value == DeviceMatrix::INVALID_VALUE || data.length == DeviceMatrix::INVALID_LENGTH) { in PutSwitch()
312 DeviceMatrix::DataLevel level = { in PutSwitch()
318 DeviceMatrix::GetInstance().Broadcast(level); in PutSwitch()
833 auto code = DeviceMatrix::GetInstance().GetCode(metaData); in IsRemoteChange()
834 if (code == DeviceMatrix::INVALID_MASK) { in IsRemoteChange()
1066 if ((mask & DeviceMatrix::META_STORE_MASK) == DeviceMatrix::META_STORE_MASK) { in IsNeedMetaSync()
[all …]
|
| H A D | kvdb_general_store.cpp | 185 … if (DeviceMatrix::GetInstance().IsDynamic(meta) || DeviceMatrix::GetInstance().IsStatics(meta)) { in KVDBGeneralStore()
187 …DeviceMatrix::GetInstance().OnExchanged(info.deviceId, meta, DeviceMatrix::ChangeType::CHANGE_REMO… in KVDBGeneralStore()
|
| H A D | kvdb_service_impl.h | 83 using ChangeType = OHOS::DistributedData::DeviceMatrix::ChangeType;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
| H A D | water_version_manager.cpp | 307 DeviceMatrix::GetInstance().UpdateLevel(metaData.deviceId, metaData.GetLevel(), in SaveMatrix()
308 …metaData.type == STATIC ? DeviceMatrix::STATICS : DeviceMatrix::DYNAMIC, metaData.deviceId != loca… in SaveMatrix()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 480 auto [exist, mask] = DeviceMatrix::GetInstance().GetRemoteMask(uuid); in IsNeedMetaSync()
481 if ((mask & DeviceMatrix::META_STORE_MASK) == DeviceMatrix::META_STORE_MASK) { in IsNeedMetaSync()
498 DeviceMatrix::GetInstance().OnExchanged(uuid, DeviceMatrix::META_STORE_MASK); in ProcessResult()
|