diff options
| author | Pavi Vetriselvan <pavithra.vetriselvan@mongodb.com> | 2021-03-02 10:35:42 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-03-10 01:00:54 +0000 |
| commit | a8a3bf12a9c056d26580623ff7a9c3401ac03fcf (patch) | |
| tree | a4ce63a99e6aba8fd434753d4be39f3c7c17b296 /src/mongo/db/repl/tenant_migration_recipient_service.h | |
| parent | b0da1daca18e915223154253df97d49fdb647934 (diff) | |
| download | mongo-a8a3bf12a9c056d26580623ff7a9c3401ac03fcf.tar.gz | |
SERVER-53508 Handle recipient failover while fetching retryable writes from donor
Diffstat (limited to 'src/mongo/db/repl/tenant_migration_recipient_service.h')
| -rw-r--r-- | src/mongo/db/repl/tenant_migration_recipient_service.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.h b/src/mongo/db/repl/tenant_migration_recipient_service.h index c8e5f8ce47b..bfff7af8af5 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.h +++ b/src/mongo/db/repl/tenant_migration_recipient_service.h @@ -368,10 +368,10 @@ public: /** * Runs an aggregation that gets the entire oplog chain for every retryable write entry in - * `config.transactions` with `lastWriteOpTime` < `startFetchingOpTime`. Adds these oplog - * entries to the oplog buffer. + * `config.transactions`. Only returns oplog entries in the chain where + * `ts` < `startFetchingOpTime.ts` and adds them to the oplog buffer. */ - void _fetchRetryableWritesOplogBeforeStartOpTime(); + SemiFuture<void> _fetchRetryableWritesOplogBeforeStartOpTime(); /** * Runs the aggregation from '_makeCommittedTransactionsAggregation()' and migrates the |