diff options
Diffstat (limited to 'src/mongo/s/balancer_configuration.cpp')
-rw-r--r-- | src/mongo/s/balancer_configuration.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/s/balancer_configuration.cpp b/src/mongo/s/balancer_configuration.cpp index 9dacc96a258..ef7e27aa6a9 100644 --- a/src/mongo/s/balancer_configuration.cpp +++ b/src/mongo/s/balancer_configuration.cpp @@ -96,7 +96,7 @@ BalancerConfiguration::BalancerConfiguration() BalancerConfiguration::~BalancerConfiguration() = default; BalancerSettingsType::BalancerMode BalancerConfiguration::getBalancerMode() const { - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); return _balancerSettings.getMode(); } @@ -148,7 +148,7 @@ Status BalancerConfiguration::enableAutoSplit(OperationContext* opCtx, bool enab } bool BalancerConfiguration::shouldBalance() const { - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); if (_balancerSettings.getMode() == BalancerSettingsType::kOff || _balancerSettings.getMode() == BalancerSettingsType::kAutoSplitOnly) { return false; @@ -158,7 +158,7 @@ bool BalancerConfiguration::shouldBalance() const { } bool BalancerConfiguration::shouldBalanceForAutoSplit() const { - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); if (_balancerSettings.getMode() == BalancerSettingsType::kOff) { return false; } @@ -167,12 +167,12 @@ bool BalancerConfiguration::shouldBalanceForAutoSplit() const { } MigrationSecondaryThrottleOptions BalancerConfiguration::getSecondaryThrottle() const { - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); return _balancerSettings.getSecondaryThrottle(); } bool BalancerConfiguration::waitForDelete() const { - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); return _balancerSettings.waitForDelete(); } @@ -214,7 +214,7 @@ Status BalancerConfiguration::_refreshBalancerSettings(OperationContext* opCtx) return settingsObjStatus.getStatus(); } - stdx::lock_guard<stdx::mutex> lk(_balancerSettingsMutex); + stdx::lock_guard<Latch> lk(_balancerSettingsMutex); _balancerSettings = std::move(settings); return Status::OK(); |