diff --git a/src/replication.c b/src/replication.c
index 35a38e2e32a5334d81d05542efb38269c056d35a..050abfd03ddcca8a13de5bed779dffa41b80f5ba 100644
--- a/src/replication.c
+++ b/src/replication.c
@@ -881,10 +881,10 @@ void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) {
 
     /* Read bulk data */
     if (usemark) {
+        readlen = sizeof(buf);
+    } else {
         left = server.repl_transfer_size - server.repl_transfer_read;
         readlen = (left < (signed)sizeof(buf)) ? left : (signed)sizeof(buf);
-    } else {
-        readlen = sizeof(buf);
     }
 
     nread = read(fd,buf,readlen);