summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/move_primary_source_manager.cpp
diff options
context:
space:
mode:
authorSamy Lanka <samy.lanka@mongodb.com>2018-12-06 13:32:23 -0500
committerSamy Lanka <samy.lanka@mongodb.com>2018-12-13 16:43:06 -0500
commit12845bf8781348fb7cf261a8723f75906f481b0a (patch)
tree071e68d5ce85f7662cfb90e5d52be00788e970e3 /src/mongo/db/s/move_primary_source_manager.cpp
parenta98950ce0441b2a6ecfb6397c9dfef927c159826 (diff)
downloadmongo-12845bf8781348fb7cf261a8723f75906f481b0a.tar.gz
SERVER-38440 Remove unnecessary UninterruptibleLockGuards from sharding code
Diffstat (limited to 'src/mongo/db/s/move_primary_source_manager.cpp')
-rw-r--r--src/mongo/db/s/move_primary_source_manager.cpp5
1 files changed, 0 insertions, 5 deletions
diff --git a/src/mongo/db/s/move_primary_source_manager.cpp b/src/mongo/db/s/move_primary_source_manager.cpp
index 90f1cc50cce..c8c1cc00c90 100644
--- a/src/mongo/db/s/move_primary_source_manager.cpp
+++ b/src/mongo/db/s/move_primary_source_manager.cpp
@@ -86,9 +86,6 @@ Status MovePrimarySourceManager::clone(OperationContext* opCtx) {
ShardingCatalogClient::kMajorityWriteConcern));
{
- // Register for notifications from the replication subsystem
- UninterruptibleLockGuard noInterrupt(opCtx->lockState());
-
// We use AutoGetOrCreateDb the first time just in case movePrimary was called before any
// data was inserted into the database.
AutoGetOrCreateDb autoDb(opCtx, getNss().toString(), MODE_X);
@@ -141,7 +138,6 @@ Status MovePrimarySourceManager::enterCriticalSection(OperationContext* opCtx) {
// The critical section must be entered with the database X lock in order to ensure there
// are no writes which could have entered and passed the database version check just before
// we entered the critical section, but will potentially complete after we left it.
- UninterruptibleLockGuard noInterrupt(opCtx->lockState());
AutoGetDb autoDb(opCtx, getNss().toString(), MODE_X);
if (!autoDb.getDb()) {
@@ -191,7 +187,6 @@ Status MovePrimarySourceManager::commitOnConfig(OperationContext* opCtx) {
commitMovePrimaryRequest.setTo(_toShard.toString());
{
- UninterruptibleLockGuard noInterrupt(opCtx->lockState());
AutoGetDb autoDb(opCtx, getNss().toString(), MODE_X);
if (!autoDb.getDb()) {