ping replicas during key load

Former-commit-id: 2747d1a1a99d3415d5486a472fe0e39135b79bc5
This commit is contained in:
christianEQ 2021-01-11 21:18:25 +00:00 committed by John Sully
parent 28a0cdc572
commit 327c44f8eb

View File

@ -2188,6 +2188,12 @@ void rdbLoadProgressCallback(rio *r, const void *buf, size_t len) {
processEventsWhileBlocked(serverTL - g_pserver->rgthreadvar); processEventsWhileBlocked(serverTL - g_pserver->rgthreadvar);
processModuleLoadingProgressEvent(0); processModuleLoadingProgressEvent(0);
robj *ping_argv[1];
ping_argv[0] = createStringObject("PING",4);
replicationFeedSlaves(g_pserver->slaves, g_pserver->replicaseldb, ping_argv, 1);
decrRefCount(ping_argv[0]);
r->loaded_keys = 0; r->loaded_keys = 0;
} }
} }