From 0928f6c6fbc857013fd5a45fa0d256b753870e78 Mon Sep 17 00:00:00 2001 From: Jin1K <1061208093@qq.com> Date: Tue, 13 May 2025 12:04:43 +0800 Subject: [PATCH] optimize dfx report Signed-off-by: Jin1K <1061208093@qq.com> --- .../service/data_share/data_share_service_impl.cpp | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/services/distributeddataservice/service/data_share/data_share_service_impl.cpp b/services/distributeddataservice/service/data_share/data_share_service_impl.cpp index 4029047ba..99bff919b 100644 --- a/services/distributeddataservice/service/data_share/data_share_service_impl.cpp +++ b/services/distributeddataservice/service/data_share/data_share_service_impl.cpp @@ -125,10 +125,10 @@ std::pair DataShareServiceImpl::InsertEx(const std::string &ur callingTokenId}, true); auto [errCode, ret] = dbDelegate->InsertEx(providerInfo.tableName, valuesBucket); if (errCode == E_OK && ret > 0) { - // only notify specific userId NotifyChange(uri, providerInfo.visitedUserId); RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData); - } else { + } + if (errCode != E_OK) { ReportExcuteFault(callingTokenId, providerInfo, errCode, func); } timeoutReport.Report(); @@ -175,7 +175,8 @@ std::pair DataShareServiceImpl::UpdateEx(const std::string &ur if (errCode == E_OK && ret > 0) { NotifyChange(uri, providerInfo.visitedUserId); RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData); - } else { + } + if (errCode != E_OK) { ReportExcuteFault(callingTokenId, providerInfo, errCode, func); } timeoutReport.Report(); @@ -203,7 +204,8 @@ std::pair DataShareServiceImpl::DeleteEx(const std::string &ur if (errCode == E_OK && ret > 0) { NotifyChange(uri, providerInfo.visitedUserId); RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData); - } else { + } + if (errCode != E_OK) { ReportExcuteFault(callingTokenId, providerInfo, errCode, func); } timeoutReport.Report(); -- Gitee