From 4717e6cfe555c5b601a3c25a4ea101c44230a05b Mon Sep 17 00:00:00 2001 From: ZhaoJinghui Date: Mon, 17 Feb 2025 11:22:43 +0800 Subject: [PATCH] update meta sync Change-Id: I25fcf7b644066178abcf6c45b3e89269399d675a Signed-off-by: ZhaoJinghui --- .../service/kvdb/kvdb_service_impl.cpp | 5 +++++ .../distributeddataservice/service/rdb/rdb_service_impl.cpp | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/services/distributeddataservice/service/kvdb/kvdb_service_impl.cpp b/services/distributeddataservice/service/kvdb/kvdb_service_impl.cpp index e0ef9cc8e..09525d466 100644 --- a/services/distributeddataservice/service/kvdb/kvdb_service_impl.cpp +++ b/services/distributeddataservice/service/kvdb/kvdb_service_impl.cpp @@ -1067,6 +1067,11 @@ bool KVDBServiceImpl::IsNeedMetaSync(const StoreMetaData &meta, const std::vecto isAfterMeta = true; break; } + auto [existLocal, localMask] = DeviceMatrix::GetInstance().GetMask(uuid); + if ((localMask & DeviceMatrix::META_STORE_MASK) == DeviceMatrix::META_STORE_MASK) { + isAfterMeta = true; + break; + } } return isAfterMeta; } diff --git a/services/distributeddataservice/service/rdb/rdb_service_impl.cpp b/services/distributeddataservice/service/rdb/rdb_service_impl.cpp index b50d97cb3..f2d4df36c 100644 --- a/services/distributeddataservice/service/rdb/rdb_service_impl.cpp +++ b/services/distributeddataservice/service/rdb/rdb_service_impl.cpp @@ -482,6 +482,11 @@ bool RdbServiceImpl::IsNeedMetaSync(const StoreMetaData &meta, const std::vector isAfterMeta = true; break; } + auto [existLocal, localMask] = DeviceMatrix::GetInstance().GetMask(uuid); + if ((localMask & DeviceMatrix::META_STORE_MASK) == DeviceMatrix::META_STORE_MASK) { + isAfterMeta = true; + break; + } } return isAfterMeta; } -- Gitee