summaryrefslogtreecommitdiff
path: root/src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp')
-rw-r--r--src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp b/src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp
index 97c923524a3..f30ad593951 100644
--- a/src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp
+++ b/src/mongo/db/serverless/shard_split_donor_op_observer_test.cpp
@@ -34,6 +34,7 @@
#include "mongo/db/repl/replication_coordinator_mock.h"
#include "mongo/db/repl/storage_interface_mock.h"
#include "mongo/db/repl/tenant_migration_access_blocker_util.h"
+#include "mongo/db/serverless/serverless_operation_lock_registry.h"
#include "mongo/db/serverless/shard_split_donor_op_observer.h"
#include "mongo/db/serverless/shard_split_state_machine_gen.h"
#include "mongo/db/serverless/shard_split_test_utils.h"
@@ -446,7 +447,13 @@ TEST_F(ShardSplitDonorOpObserverTest, SetExpireAtForAbortedRemoveBlockers) {
ASSERT_FALSE(mtab);
};
+ ServerlessOperationLockRegistry::get(_opCtx->getServiceContext())
+ .acquireLock(ServerlessOperationLockRegistry::LockType::kShardSplit, _uuid);
+
runUpdateTestCase(stateDocument, _tenantIds, mtabVerifier);
+
+ ASSERT_FALSE(ServerlessOperationLockRegistry::get(_opCtx->getServiceContext())
+ .getActiveOperationType_forTest());
}
TEST_F(ShardSplitDonorOpObserverTest, DeleteAbortedDocumentDoesNotRemoveBlockers) {