This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new f465f06  Use readLock in `getActiveRatio`
f465f06 is described below

commit f465f069b0eb40e09b275f6e2f3581ebfc22148a
Author: dwq <[email protected]>
AuthorDate: Mon Aug 3 13:43:28 2020 +0800

    Use readLock in `getActiveRatio`
---
 .../org/apache/iotdb/db/conf/adapter/ActiveTimeSeriesCounter.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/conf/adapter/ActiveTimeSeriesCounter.java
 
b/server/src/main/java/org/apache/iotdb/db/conf/adapter/ActiveTimeSeriesCounter.java
index 7251924..0934605 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/conf/adapter/ActiveTimeSeriesCounter.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/conf/adapter/ActiveTimeSeriesCounter.java
@@ -120,7 +120,7 @@ public class ActiveTimeSeriesCounter implements 
IActiveTimeSeriesCounter {
 
   @Override
   public double getActiveRatio(String storageGroup) {
-    lock.writeLock().lock();
+    lock.readLock().lock();
     double ratio;
     try {
       ratio = activeRatioMap.get(storageGroup);
@@ -128,7 +128,7 @@ public class ActiveTimeSeriesCounter implements 
IActiveTimeSeriesCounter {
       ratio = 0;
       LOGGER.error("Get active ratio failed", e);
     } finally {
-      lock.writeLock().unlock();
+      lock.readLock().unlock();
     }
     return ratio;
   }
@@ -156,4 +156,4 @@ public class ActiveTimeSeriesCounter implements 
IActiveTimeSeriesCounter {
     activeRatioMap = new ConcurrentHashMap<>();
     activeTimeSeriesNumMap = new ConcurrentHashMap<>();
   }
-}
\ No newline at end of file
+}

Reply via email to