summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/snapshot_management.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/commands/snapshot_management.cpp')
-rw-r--r--src/mongo/db/commands/snapshot_management.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/mongo/db/commands/snapshot_management.cpp b/src/mongo/db/commands/snapshot_management.cpp
index 8ab963eb71e..1eb6e2c2126 100644
--- a/src/mongo/db/commands/snapshot_management.cpp
+++ b/src/mongo/db/commands/snapshot_management.cpp
@@ -32,6 +32,7 @@
#include "mongo/base/init.h"
#include "mongo/db/commands.h"
+#include "mongo/db/concurrency/d_concurrency.h"
#include "mongo/db/operation_context.h"
#include "mongo/db/repl/replication_coordinator.h"
#include "mongo/db/service_context.h"
@@ -75,8 +76,7 @@ public:
return appendCommandStatus(result, {ErrorCodes::CommandNotSupported, ""});
}
- ScopedTransaction st(opCtx, MODE_IX);
- Lock::GlobalLock lk(opCtx->lockState(), MODE_IX, UINT_MAX);
+ Lock::GlobalLock lk(opCtx, MODE_IX, UINT_MAX);
auto status = snapshotManager->prepareForCreateSnapshot(opCtx);
if (status.isOK()) {
@@ -126,8 +126,7 @@ public:
return appendCommandStatus(result, {ErrorCodes::CommandNotSupported, ""});
}
- ScopedTransaction st(opCtx, MODE_IX);
- Lock::GlobalLock lk(opCtx->lockState(), MODE_IX, UINT_MAX);
+ Lock::GlobalLock lk(opCtx, MODE_IX, UINT_MAX);
auto name = SnapshotName(cmdObj.firstElement().Long());
snapshotManager->setCommittedSnapshot(name);
return true;