summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_timestamp_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/storage_timestamp_test.cpp')
-rw-r--r--src/mongo/db/repl/storage_timestamp_test.cpp13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/mongo/db/repl/storage_timestamp_test.cpp b/src/mongo/db/repl/storage_timestamp_test.cpp
index 6431be37aed..7919675a946 100644
--- a/src/mongo/db/repl/storage_timestamp_test.cpp
+++ b/src/mongo/db/repl/storage_timestamp_test.cpp
@@ -46,7 +46,7 @@
#include "mongo/db/catalog/index_catalog.h"
#include "mongo/db/catalog/multi_index_block.h"
#include "mongo/db/client.h"
-#include "mongo/db/concurrency/exception_util.h"
+#include "mongo/db/concurrency/write_conflict_exception.h"
#include "mongo/db/db_raii.h"
#include "mongo/db/dbdirectclient.h"
#include "mongo/db/dbhelpers.h"
@@ -90,6 +90,7 @@
#include "mongo/db/transaction_participant_gen.h"
#include "mongo/db/vector_clock_mutable.h"
#include "mongo/dbtests/dbtests.h"
+#include "mongo/idl/server_parameter_test_util.h"
#include "mongo/logv2/log.h"
#include "mongo/rpc/get_status_from_command_result.h"
#include "mongo/stdx/future.h"
@@ -1473,7 +1474,7 @@ TEST_F(StorageTimestampTest, SecondarySetWildcardIndexMultikeyOnInsert) {
_coordinatorMock,
_consistencyMarkers,
storageInterface,
- repl::OplogApplier::Options(repl::OplogApplication::Mode::kStableRecovering),
+ repl::OplogApplier::Options(repl::OplogApplication::Mode::kRecovering),
writerPool.get());
uassertStatusOK(oplogApplier.applyOplogBatch(_opCtx, ops));
@@ -1571,7 +1572,7 @@ TEST_F(StorageTimestampTest, SecondarySetWildcardIndexMultikeyOnUpdate) {
_coordinatorMock,
_consistencyMarkers,
storageInterface,
- repl::OplogApplier::Options(repl::OplogApplication::Mode::kStableRecovering),
+ repl::OplogApplier::Options(repl::OplogApplication::Mode::kRecovering),
writerPool.get());
uassertStatusOK(oplogApplier.applyOplogBatch(_opCtx, ops));
@@ -2703,10 +2704,8 @@ TEST_F(StorageTimestampTest, IndexBuildsResolveErrorsDuringStateChangeToPrimary)
}
auto indexCatalog = collection->getIndexCatalog();
- buildingIndex = indexCatalog->getEntry(indexCatalog->findIndexByName(
- _opCtx,
- "a_1_b_1",
- IndexCatalog::InclusionPolicy::kReady | IndexCatalog::InclusionPolicy::kUnfinished));
+ buildingIndex = indexCatalog->getEntry(
+ indexCatalog->findIndexByName(_opCtx, "a_1_b_1", /* includeUnfinished */ true));
ASSERT(buildingIndex);
ASSERT_OK(indexer.insertAllDocumentsInCollection(_opCtx, collection.get()));