From 0a25ecbba3d43bb3da1b492b84d8fa0045fe2cea Mon Sep 17 00:00:00 2001
From: wangkun <wangkun217@huawei.com>
Date: Wed, 8 Sep 2021 10:00:21 +0800
Subject: [PATCH] mutex usage fix.

Signed-off-by: wangkun <wangkun217@huawei.com>
---
 .../distributeddataservice/app/src/kvstore_resultset_impl.cpp   | 2 +-
 services/distributeddataservice/app/src/single_kvstore_impl.cpp | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/services/distributeddataservice/app/src/kvstore_resultset_impl.cpp b/services/distributeddataservice/app/src/kvstore_resultset_impl.cpp
index dac050779..36e0bb459 100755
--- a/services/distributeddataservice/app/src/kvstore_resultset_impl.cpp
+++ b/services/distributeddataservice/app/src/kvstore_resultset_impl.cpp
@@ -188,7 +188,7 @@ Status KvStoreResultSetImpl::CloseResultSet(DistributedDB::KvStoreNbDelegate *kv
         return Status::INVALID_ARGUMENT;
     }
     DdsTrace trace(std::string(LOG_TAG "::") + std::string(__FUNCTION__));
-    std::shared_lock<std::shared_mutex> lock(this->mutex_);
+    std::unique_lock<std::shared_mutex> lock(this->mutex_);
     DistributedDB::DBStatus status = kvStoreNbDelegate->CloseResultSet(kvStoreResultSet_);
     if (status != DistributedDB::DBStatus::OK) {
         return Status::DB_ERROR;
diff --git a/services/distributeddataservice/app/src/single_kvstore_impl.cpp b/services/distributeddataservice/app/src/single_kvstore_impl.cpp
index affe51662..c67beddd1 100755
--- a/services/distributeddataservice/app/src/single_kvstore_impl.cpp
+++ b/services/distributeddataservice/app/src/single_kvstore_impl.cpp
@@ -1448,6 +1448,7 @@ Status SingleKvStoreImpl::SetCapabilityRange(const std::vector<std::string> &loc
 
 Status SingleKvStoreImpl::GetSecurityLevel(SecurityLevel &securityLevel)
 {
+    std::shared_lock<std::shared_mutex> lock(storeNbDelegateMutex_);
     if (kvStoreNbDelegate_ == nullptr) {
         return Status::STORE_NOT_OPEN;
     }
-- 
Gitee