diff --git a/shiroha-server/src/main/java/io/nanachiyo0721/shiroha/data/BufferedLinearRegionFileFlusher.java b/shiroha-server/src/main/java/io/nanachiyo0721/shiroha/data/BufferedLinearRegionFileFlusher.java index 3f50ca8..9dd7c7c 100644 --- a/shiroha-server/src/main/java/io/nanachiyo0721/shiroha/data/BufferedLinearRegionFileFlusher.java +++ b/shiroha-server/src/main/java/io/nanachiyo0721/shiroha/data/BufferedLinearRegionFileFlusher.java @@ -20,9 +20,9 @@ public class BufferedLinearRegionFileFlusher implements Runnable { private final Executor ioWorkerPool; private final long flushOfWriteTimeoutMs; - public BufferedLinearRegionFileFlusher(int nIoThreads, long checkIntervalMs, long flushOfWriteTimeoutMs) { + public BufferedLinearRegionFileFlusher(int nIoThreads, long scanInterval, long flushOfWriteTimeoutMs) { Validate.isTrue(nIoThreads > 0, "Number of I/O threads must > 0!"); - Validate.isTrue(checkIntervalMs > 0, "Check interval must > 0"); + Validate.isTrue(scanInterval > 0, "Scan interval must > 0"); Validate.isTrue(flushOfWriteTimeoutMs > 0, "Flush of write timeout must > 0"); this.ioWorkerPool = Executors.newFixedThreadPool(nIoThreads, new ThreadFactoryBuilder() @@ -34,7 +34,7 @@ public class BufferedLinearRegionFileFlusher implements Runnable { .setNameFormat("BufferedLinearRegionFile Flusher Checker") .setDaemon(true) .build()) - .scheduleWithFixedDelay(this, checkIntervalMs, checkIntervalMs, TimeUnit.MILLISECONDS); + .scheduleWithFixedDelay(this, scanInterval, scanInterval, TimeUnit.MILLISECONDS); this.flushOfWriteTimeoutMs = flushOfWriteTimeoutMs; }