summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/resharding
diff options
context:
space:
mode:
authorJack Mulrow <jack.mulrow@mongodb.com>2022-05-25 15:43:58 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-05-25 16:18:08 +0000
commit80e519f931ee0339b34e2546d274e21499e437b6 (patch)
tree4faab13bb94c6d37ff84467cbf81ce5050d7ec0c /src/mongo/db/s/resharding
parent982ba2296ba7e5a9f53e8f36d14310f0f45b7b70 (diff)
downloadmongo-80e519f931ee0339b34e2546d274e21499e437b6.tar.gz
SERVER-66565 Use hint with config.transactions partial index and allow creating it
Diffstat (limited to 'src/mongo/db/s/resharding')
-rw-r--r--src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp3
-rw-r--r--src/mongo/db/s/resharding/resharding_coordinator_test.cpp2
-rw-r--r--src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp2
-rw-r--r--src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp3
4 files changed, 10 insertions, 0 deletions
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp
index f890ca53ca2..7f57851d8e2 100644
--- a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp
+++ b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp
@@ -48,6 +48,7 @@
#include "mongo/db/s/resharding/resharding_service_test_helpers.h"
#include "mongo/db/s/resharding/resharding_util.h"
#include "mongo/db/s/transaction_coordinator_service.h"
+#include "mongo/db/session_catalog_mongod.h"
#include "mongo/idl/server_parameter_test_util.h"
#include "mongo/logv2/log.h"
#include "mongo/s/catalog/type_collection.h"
@@ -147,6 +148,8 @@ public:
auto opCtx = operationContext();
DBDirectClient client(opCtx);
client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns());
+ client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(),
+ {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()});
client.createCollection(NamespaceString::kConfigReshardingOperationsNamespace.ns());
client.createCollection(CollectionType::ConfigNS.ns());
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_test.cpp b/src/mongo/db/s/resharding/resharding_coordinator_test.cpp
index 6d69dd99f28..1fcb1fe7dd1 100644
--- a/src/mongo/db/s/resharding/resharding_coordinator_test.cpp
+++ b/src/mongo/db/s/resharding/resharding_coordinator_test.cpp
@@ -75,6 +75,8 @@ protected:
auto opCtx = operationContext();
DBDirectClient client(opCtx);
client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns());
+ client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(),
+ {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()});
client.createCollection(NamespaceString::kConfigReshardingOperationsNamespace.ns());
client.createCollection(CollectionType::ConfigNS.ns());
client.createIndex(TagsType::ConfigNS.ns(), BSON("ns" << 1 << "min" << 1));
diff --git a/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp b/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp
index ed5d6b1cf42..d95f0fdc23e 100644
--- a/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp
+++ b/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp
@@ -186,6 +186,8 @@ protected:
ReshardingEnv setupReshardingEnv(OperationContext* opCtx, bool refreshTempNss) {
DBDirectClient client(opCtx);
ASSERT(client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns()));
+ client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(),
+ {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()});
OperationShardingState::ScopedAllowImplicitCollectionCreate_UNSAFE unsafeCreateCollection(
opCtx);
diff --git a/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp b/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp
index e6e80179440..c6772c93d0b 100644
--- a/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp
+++ b/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp
@@ -142,6 +142,9 @@ public:
operationContext(),
NamespaceString::kSessionTransactionsTableNamespace.db().toString(),
BSON("create" << NamespaceString::kSessionTransactionsTableNamespace.coll())));
+ DBDirectClient client(operationContext());
+ client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(),
+ {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()});
OperationShardingState::ScopedAllowImplicitCollectionCreate_UNSAFE unsafeCreateCollection(
operationContext());