Do not update batch variables when not in a batch
Former-commit-id: ad1e0286cf9b2d9de33c65e8e798a05ead3f7d5a
This commit is contained in:
parent
91c4c2b7f7
commit
0b220bddc7
@ -254,9 +254,11 @@ void resizeReplicationBacklog(long long newsize) {
|
||||
zfree(g_pserver->repl_backlog);
|
||||
g_pserver->repl_backlog = backlog;
|
||||
g_pserver->repl_backlog_idx = g_pserver->repl_backlog_histlen;
|
||||
g_pserver->repl_batch_idxStart -= earliest_idx;
|
||||
if (g_pserver->repl_batch_idxStart < 0)
|
||||
g_pserver->repl_batch_idxStart += g_pserver->repl_backlog_size;
|
||||
if (g_pserver->repl_batch_idxStart >= 0) {
|
||||
g_pserver->repl_batch_idxStart -= earliest_idx;
|
||||
if (g_pserver->repl_batch_idxStart < 0)
|
||||
g_pserver->repl_batch_idxStart += g_pserver->repl_backlog_size;
|
||||
}
|
||||
g_pserver->repl_backlog_start = earliest_off;
|
||||
} else {
|
||||
zfree(g_pserver->repl_backlog);
|
||||
|
Loading…
x
Reference in New Issue
Block a user