diff --git a/src/replication.cpp b/src/replication.cpp
index 0ef43485b..3b8b6f9e1 100644
--- a/src/replication.cpp
+++ b/src/replication.cpp
@@ -2980,7 +2980,7 @@ void readSyncBulkPayload(connection *conn) {
     rdbSaveInfo rsi;
     redisMaster *mi = (redisMaster*)connGetPrivateData(conn);
     static int usemark = 0;
-    if (mi == nullptr) {
+    if (mi == nullptr || conn != mi->repl_transfer_s) {
         // We're about to be free'd so bail out
         return;
     }