diff options
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_coordinator_service.h')
| -rw-r--r-- | src/mongo/db/s/resharding/resharding_coordinator_service.h | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_service.h b/src/mongo/db/s/resharding/resharding_coordinator_service.h index df5c0aa4fd0..0f1a6ba316d 100644 --- a/src/mongo/db/s/resharding/resharding_coordinator_service.h +++ b/src/mongo/db/s/resharding/resharding_coordinator_service.h @@ -206,15 +206,16 @@ private: boost::optional<Timestamp> fetchTimestamp = boost::none); /** - * Sends 'flushRoutingTableCacheUpdates' for the temporary namespace to all recipient - * shards. + * Sends 'flushRoutingTableCacheUpdatesWithWriteConcern' for the temporary namespace to all + * recipient shards. */ - void _tellAllRecipientsToRefresh(); + void _tellAllRecipientsToRefresh(const std::shared_ptr<executor::ScopedTaskExecutor>& executor); /** - * Sends 'flushRoutingTableCacheUpdates' for the original namespace to all donor shards. + * Sends 'flushRoutingTableCacheUpdatesWithWriteConcern' for the original namespace to all donor + * shards. */ - void _tellAllDonorsToRefresh(); + void _tellAllDonorsToRefresh(const std::shared_ptr<executor::ScopedTaskExecutor>& executor); // The unique key for a given resharding operation. InstanceID is an alias for BSONObj. The // value of this is the UUID that will be used as the collection UUID for the new sharded |