Fix pulledVersion of backup worker

Not sure why, the cursor's version can be smaller than before.
This commit is contained in:
Jingyu Zhou 2020-02-28 16:05:34 -08:00
parent 672ad7a8ea
commit 00350dd3d8
1 changed files with 3 additions and 1 deletions

View File

@ -607,7 +607,9 @@ ACTOR Future<Void> pullAsyncData(BackupData* self) {
}
tagAt = r->version().version;
self->pulledVersion = tagAt;
if (tagAt > self->pulledVersion.get()) {
self->pulledVersion.set(tagAt);
}
TraceEvent("BackupWorkerGot", self->myId).suppressFor(1.0).detail("V", tagAt);
if (self->endVersion.present() && tagAt > self->endVersion.get()) {
self->eraseMessagesAfterEndVersion();