summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/resharding/resharding_donor_service.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_donor_service.h')
-rw-r--r--src/mongo/db/s/resharding/resharding_donor_service.h6
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);