diff --git a/services/distributedhardwarefwkservice/include/utils/dh_context.h b/services/distributedhardwarefwkservice/include/utils/dh_context.h index e2108c507e8d3e3532ce2049024e234ddeb227e0..f408e04fb29026281d2de916153a764ffe2e2106 100644 --- a/services/distributedhardwarefwkservice/include/utils/dh_context.h +++ b/services/distributedhardwarefwkservice/include/utils/dh_context.h @@ -146,7 +146,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 1cb0d94febc2228c38370b243f4adcdc720fa2c6..f7e00ecab16b915bdd115951cbd02a5c87939561 100644 --- a/services/distributedhardwarefwkservice/src/utils/dh_context.cpp +++ b/services/distributedhardwarefwkservice/src/utils/dh_context.cpp @@ -322,14 +322,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); } @@ -393,7 +393,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); } @@ -403,7 +403,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;