curvefs/client: fix timer bug

src/common/interruptible_sleeper.h

@@ -57,6 +57,11 @@ class InterruptibleSleeper {
         cv.notify_all();
     }
 
+    void init() {
+        UniqueLock lock(m);
+        terminate = false;
+    }
+
  private:
     ConditionVariable cv;
     Mutex m;

src/common/wait_interval.cpp

@@ -43,7 +43,7 @@ void WaitInterval::WaitForNextExcution() {
     rest = (rest < 0) ? 0 : rest;
 
     sleeper_.wait_for(std::chrono::milliseconds(rest));
-
+    sleeper_.init();
     lastSend_ = TimeUtility::GetTimeofDayMs();
 }
 

test/common/wait_interval_test.cpp

@@ -43,6 +43,29 @@ TEST(WaitIntervalTest, test) {
     ASSERT_EQ(5, count);
 }
 
+TEST(IntervalTest, signalTest) {
+    WaitInterval waitInterval;
+    waitInterval.Init(1000);
+
+    uint64_t start = TimeUtility::GetTimeofDayMs();
+    bool isSignal = true;
+    int count = 0;
+    while (true) {
+        waitInterval.WaitForNextExcution();
+        if (isSignal) {
+           sleep(1);
+           waitInterval.StopWait();
+           isSignal = false;
+        }
+        if (++count > 10) {
+            break;
+        }
+    }
+    uint64_t end = TimeUtility::GetTimeofDayMs();
+    uint64_t dur = end - start;
+    ASSERT_GT(dur, 5000);
+}
+
 }  // namespace common
 }  // namespace curve