From 5a170aa3d71bd14f9f67f78e187fded33711af1c Mon Sep 17 00:00:00 2001 From: li-tiangang4 Date: Wed, 27 Nov 2024 15:27:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E8=AE=BE=E5=A4=87=E5=90=8C=E6=97=B6?= =?UTF-8?q?=E4=B8=8A=E7=BA=BF=E5=BC=95=E5=8F=91=E8=B5=84=E6=BA=90=E7=AB=9E?= =?UTF-8?q?=E4=BA=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: li-tiangang4 --- .../include/utils/dh_context.h | 2 +- .../src/utils/dh_context.cpp | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/services/distributedhardwarefwkservice/include/utils/dh_context.h b/services/distributedhardwarefwkservice/include/utils/dh_context.h index 149de60c..77ea053c 100644 --- a/services/distributedhardwarefwkservice/include/utils/dh_context.h +++ b/services/distributedhardwarefwkservice/include/utils/dh_context.h @@ -129,7 +129,7 @@ private: std::unordered_set connectedDevIds_; std::shared_mutex connectDevMutex_; - }; +}; } // namespace DistributedHardware } // namespace OHOS #endif diff --git a/services/distributedhardwarefwkservice/src/utils/dh_context.cpp b/services/distributedhardwarefwkservice/src/utils/dh_context.cpp index b02b2f9b..28726c78 100644 --- a/services/distributedhardwarefwkservice/src/utils/dh_context.cpp +++ b/services/distributedhardwarefwkservice/src/utils/dh_context.cpp @@ -281,14 +281,14 @@ std::string DHContext::GetDeviceIdByDBGetPrefix(const std::string &prefix) void DHContext::AddRealTimeOnlineDeviceNetworkId(const std::string &networkId) { DHLOGI("AddRealTimeOnlineDeviceNetworkId: %{public}s", GetAnonyString(networkId).c_str()); - std::shared_lock lock(realTimeNetworkIdMutex_); + std::unique_lock lock(realTimeNetworkIdMutex_); realTimeOnLineNetworkIdSet_.insert(networkId); } void DHContext::DeleteRealTimeOnlineDeviceNetworkId(const std::string &networkId) { DHLOGI("DeleteRealTimeOnlineDeviceNetworkId: %{public}s", GetAnonyString(networkId).c_str()); - std::shared_lock lock(realTimeNetworkIdMutex_); + std::unique_lock lock(realTimeNetworkIdMutex_); realTimeOnLineNetworkIdSet_.erase(networkId); } @@ -352,7 +352,7 @@ void DHContext::AddIsomerismConnectDev(const std::string &IsomerismDeviceId) return; } DHLOGI("AddIsomerismConnectDev id = %{public}s", GetAnonyString(IsomerismDeviceId).c_str()); - std::shared_lock lock(connectDevMutex_); + std::unique_lock lock(connectDevMutex_); connectedDevIds_.insert(IsomerismDeviceId); } @@ -362,7 +362,7 @@ void DHContext::DelIsomerismConnectDev(const std::string &IsomerismDeviceId) return; } DHLOGI("DelIsomerismConnectDev id = %{public}s", GetAnonyString(IsomerismDeviceId).c_str()); - std::shared_lock lock(connectDevMutex_); + std::unique_lock lock(connectDevMutex_); if (connectedDevIds_.find(IsomerismDeviceId) == connectedDevIds_.end()) { DHLOGI("DelIsomerismConnectDev is not exist."); return; -- Gitee