diff options
| author | Pavi Vetriselvan <pavithra.vetriselvan@mongodb.com> | 2021-02-02 10:58:22 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-02-03 19:29:12 +0000 |
| commit | ee992b9f2c1319df706a62062f20dd2bc2685a2b (patch) | |
| tree | b0f1261bca6bfb02516e0046111eac78b9a1d3ba /src/mongo/db/repl/tenant_migration_recipient_service.h | |
| parent | 753529749c452d1a62f875039ac7a7b4f282b808 (diff) | |
| download | mongo-ee992b9f2c1319df706a62062f20dd2bc2685a2b.tar.gz | |
SERVER-53319 Create stub _retrieveRetryableWrites function in TenantMigrationRecipientService
Diffstat (limited to 'src/mongo/db/repl/tenant_migration_recipient_service.h')
| -rw-r--r-- | src/mongo/db/repl/tenant_migration_recipient_service.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.h b/src/mongo/db/repl/tenant_migration_recipient_service.h index 58d0197b6d9..db33d95fde1 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.h +++ b/src/mongo/db/repl/tenant_migration_recipient_service.h @@ -325,6 +325,13 @@ public: const OplogFetcher::DocumentsInfo& info); /** + * 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. + */ + void _fetchRetryableWritesOplogBeforeStartOpTime(); + + /** * Starts the tenant oplog fetcher. */ void _startOplogFetcher(); |