diff options
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_donor_service.h')
-rw-r--r-- | src/mongo/db/s/resharding/resharding_donor_service.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/mongo/db/s/resharding/resharding_donor_service.h b/src/mongo/db/s/resharding/resharding_donor_service.h index d08e254abe5..9f50173f29b 100644 --- a/src/mongo/db/s/resharding/resharding_donor_service.h +++ b/src/mongo/db/s/resharding/resharding_donor_service.h @@ -96,6 +96,10 @@ public: void onReshardingFieldsChanges(OperationContext* opCtx, const TypeCollectionReshardingFields& reshardingFields); + SharedSemiFuture<void> awaitCriticalSectionAcquired(); + + SharedSemiFuture<void> awaitCriticalSectionPromoted(); + SharedSemiFuture<void> awaitFinalOplogEntriesWritten(); /** @@ -154,7 +158,7 @@ private: const std::shared_ptr<executor::ScopedTaskExecutor>& executor, const CancellationToken& abortToken); - ExecutorFuture<void> _awaitAllRecipientsDoneApplying( + ExecutorFuture<void> _awaitAllRecipientsDoneApplyingThenTransitionToPreparingToBlockWrites( const std::shared_ptr<executor::ScopedTaskExecutor>& executor, const CancellationToken& abortToken); |