From 6d1be2a3f5ee59ae1ceef0a5fb56b83a56d4eeb1 Mon Sep 17 00:00:00 2001
From: christianEQ <christian@eqalpha.com>
Date: Wed, 24 Mar 2021 20:33:26 +0000
Subject: [PATCH] counter for time thread sleeping threads

Former-commit-id: 6270939d6a2d7820fecac9c5aedf0ff985531f6b
---
 src/server.cpp | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/server.cpp b/src/server.cpp
index 0f503ece3..7827879a5 100644
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -100,7 +100,7 @@ thread_local struct redisServerThreadVars *serverTL = NULL;   // thread local se
 volatile unsigned long lru_clock; /* Server global current LRU time. */
 std::mutex time_thread_mutex;
 std::condition_variable time_thread_cv;
-bool time_thread_running = false;
+int sleeping_threads = cserver.cthreads;
 void wakeTimeThread();
 
 /* Our command table.
@@ -2514,7 +2514,9 @@ void beforeSleep(struct aeEventLoop *eventLoop) {
     serverAssert(g_pserver->repl_batch_offStart < 0);
     runAndPropogateToReplicas(processClients);
 
-    time_thread_running = false;
+    time_thread_mutex.lock();
+    sleeping_threads++;
+    time_thread_mutex.unlock();
 
     /* Handle precise timeouts of blocked clients. */
     handleBlockedClientsTimeout();
@@ -6086,7 +6088,9 @@ void OnTerminate()
 }
 
 void wakeTimeThread() {
-    time_thread_running = true;
+    time_thread_mutex.lock();
+    sleeping_threads--;
+    time_thread_mutex.unlock();
     time_thread_cv.notify_one();
 }
 
@@ -6096,7 +6100,7 @@ void *timeThreadMain(void*) {
     delay.tv_nsec = 100;
     while (true) {
         std::unique_lock<std::mutex> lock(time_thread_mutex);
-        if (!time_thread_running) {
+        if (sleeping_threads >= cserver.cthreads) {
             time_thread_cv.wait(lock);
         }
         updateCachedTime();