summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/tenant_migration_recipient_service.h
diff options
context:
space:
mode:
authorA. Jesse Jiryu Davis <jesse@mongodb.com>2022-02-16 03:02:49 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-02-16 03:30:27 +0000
commit9adc8c129a972b7e098bd8c50c9b222f98dd2edb (patch)
treeac16353d517626da96d92cd305eb69d61462439d /src/mongo/db/repl/tenant_migration_recipient_service.h
parent33199fcbda79a5ec0ec686896583deb460c56028 (diff)
downloadmongo-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.h11
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.