[fix] fix the error that modify diskTrimCheckIntervalSec on the fly

Signed-off-by: caoxianfei1 <caoxianfei@corp.netease.com>
opencurve · Nov 17, 2023 · 4e457ee · 4e457ee
1 parent 095006a
commit 4e457ee
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/curvefs/src/client/s3/disk_cache_manager.cpp b/curvefs/src/client/s3/disk_cache_manager.cpp
@@ -418,6 +418,7 @@ void DiskCacheManager::TrimCache() {
     cacheWriteFullDir = GetCacheWriteFullDir();
     while (true) {
         UpdateDiskFsUsedRatio();
+        waitIntervalSec_.Init(FLAGS_diskTrimCheckIntervalSec * 1000);
         waitIntervalSec_.WaitForNextExcution();
         if (!isRunning_) {
             LOG(INFO) << "trim thread end.";