From 2a18091d73ade25ba305f02b828dab9b83848ad6 Mon Sep 17 00:00:00 2001
From: John Sully <john@csquare.ca>
Date: Thu, 10 Dec 2020 20:09:19 +0000
Subject: [PATCH] Fix test timeouts

Former-commit-id: 6f3feee67678b594fbe9fd592f9f823a7a07b770
---
 src/networking.cpp | 2 +-
 src/server.cpp     | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/networking.cpp b/src/networking.cpp
index d5a429dfe..9c968da32 100644
--- a/src/networking.cpp
+++ b/src/networking.cpp
@@ -3384,7 +3384,7 @@ void processEventsWhileBlocked(int iel) {
     locker.release();
 
     // Restore it so the calling code is not confused
-    if (fReplBacklog) {
+    if (fReplBacklog && !serverTL->el->stop) {
         g_pserver->repl_batch_idxStart = g_pserver->repl_backlog_idx;
         g_pserver->repl_batch_offStart = g_pserver->master_repl_offset;
     }
diff --git a/src/server.cpp b/src/server.cpp
index 15d8ca77e..181f9defc 100644
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -4416,6 +4416,12 @@ int prepareForShutdown(int flags) {
         unlink(cserver.pidfile);
     }
 
+    if (g_pserver->repl_batch_idxStart >= 0) {
+        flushReplBacklogToClients();
+        g_pserver->repl_batch_offStart = -1;
+        g_pserver->repl_batch_idxStart = -1;
+    }
+
     /* Best effort flush of replica output buffers, so that we hopefully
      * send them pending writes. */
     flushSlavesOutputBuffers();