Regular check and close rsync deamon

zmyer · Nov 14, 2016 · 9efa86b · 9efa86b
1 parent b1ee52f
commit 9efa86b
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 3 deletions.
diff --git a/include/pika_server.h b/include/pika_server.h
@@ -124,9 +124,7 @@ class PikaServer
   void Exit() {
     exit_ = true;
   }
-  void DoTimingTask() {
-    AutoPurge();
-  }
+  void DoTimingTask();
   void Cleanup();
 
   PikaSlavepingThread* ping_thread_;

diff --git a/src/pika_server.cc b/src/pika_server.cc
@@ -1142,3 +1142,16 @@ uint64_t PikaServer::ServerCurrentQps() {
   return server_current_qps;
 }
 
+void PikaServer::DoTimingTask() {
+  // Purge log
+  AutoPurge();
+
+  // Check rsync deamon
+ if (((role_ & PIKA_ROLE_SLAVE) ^ PIKA_ROLE_SLAVE) || // Not a slave
+   repl_state_ == PIKA_REPL_NO_CONNECT ||
+   repl_state_ == PIKA_REPL_CONNECTED ||
+   repl_state_ == PIKA_REPL_ERROR) {
+   slash::StopRsync(g_pika_conf->db_sync_path());
+ }
+}
+