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
+}