diff options
author | A. Jesse Jiryu Davis <jesse@mongodb.com> | 2022-02-16 03:02:49 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-02-16 03:30:27 +0000 |
commit | 9adc8c129a972b7e098bd8c50c9b222f98dd2edb (patch) | |
tree | ac16353d517626da96d92cd305eb69d61462439d /src/mongo/db/repl/tenant_migration_recipient_service.h | |
parent | 33199fcbda79a5ec0ec686896583deb460c56028 (diff) | |
download | mongo-9adc8c129a972b7e098bd8c50c9b222f98dd2edb.tar.gz |
SERVER-61134 Recipient nodes tell primary they copied files
Diffstat (limited to 'src/mongo/db/repl/tenant_migration_recipient_service.h')
-rw-r--r-- | src/mongo/db/repl/tenant_migration_recipient_service.h | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/mongo/db/repl/tenant_migration_recipient_service.h b/src/mongo/db/repl/tenant_migration_recipient_service.h index 8284514cf71..5f3898e8b0b 100644 --- a/src/mongo/db/repl/tenant_migration_recipient_service.h +++ b/src/mongo/db/repl/tenant_migration_recipient_service.h @@ -509,13 +509,6 @@ public: */ SemiFuture<void> _updateStateDocForMajority(WithLock lk) const; - /** - * Updates the state doc in the database and waits for that to be propagated to all nodes in - * the replica set. - */ - SemiFuture<void> _updateStateDocForAllVotingNodes( - WithLock lk, const CancellationToken& abortToken) const; - /* * Returns the majority OpTime on the donor node that 'client' is connected to. */ @@ -602,6 +595,10 @@ public: // Promise that is resolved Signaled when the instance has started tenant database cloner // and tenant oplog fetcher. SharedPromise<void> _dataSyncStartedPromise; // (W) + // Future that is resolved when all recipient nodes have copied all donor files. + SharedSemiFuture<void> _copiedFilesFuture; // (W) + // Future that is resolved when all recipient nodes have imported all donor files. + SharedSemiFuture<void> _importedFilesFuture; // (W) // Promise that is resolved Signaled when the tenant data sync has reached consistent point. SharedPromise<OpTime> _dataConsistentPromise; // (W) // Promise that is resolved when the data sync has completed. |