kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix IndexDataCapacityMonitor’s timer issue. maybe happened issue.

This commit is contained in:
wusheng 2016-11-15 10:23:08 +08:00
parent 3a7e331aa0
commit c567cfa0ba
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/IndexDataCapacityMonitor.java
View File

@ -38,20 +38,20 @@ public class IndexDataCapacityMonitor {
public Detector(long timestamp) {
this.timestamp = timestamp;
currentSize = new AtomicLong();
startTimer();
start();
}
public Detector(long timestamp, long currentSize) {
this.currentSize = new AtomicLong(currentSize);
this.timestamp = timestamp;
startTimer();
start();
}
public void startTimer() {
timer.scheduleAtFixedRate(this, 0, TimeUnit.SECONDS.toMillis(30));
public void start() {
timer.schedule(this, 0, TimeUnit.SECONDS.toMillis(30));
}
public void stopTimer() {
public void stop() {
timer.cancel();
}
@ -66,8 +66,8 @@ public class IndexDataCapacityMonitor {
@Override
public void run() {
if (currentSize.get() > SIZE * 0.8) {
stop();
notificationAddNewBlockIndexAndCreateNewIndexDB();
stopTimer();
HealthCollector.getCurrentHeathReading("Index Data Capacity Detector").updateData(HeathReading.INFO,
"Detector is detecting the index [%d]. and the capacity of {} is %d", timestamp,
currentSize.get());
@ -111,6 +111,6 @@ public class IndexDataCapacityMonitor {
public static void stop() {
detector.stopTimer();
detector.stop();
}
}