summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/collection_cloner_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/collection_cloner_test.cpp')
-rw-r--r--src/mongo/db/repl/collection_cloner_test.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/mongo/db/repl/collection_cloner_test.cpp b/src/mongo/db/repl/collection_cloner_test.cpp
index 8c0ac71ba70..440b8dee232 100644
--- a/src/mongo/db/repl/collection_cloner_test.cpp
+++ b/src/mongo/db/repl/collection_cloner_test.cpp
@@ -405,8 +405,8 @@ TEST_F(CollectionClonerTest, ListIndexesReturnedNamespaceNotFound) {
bool writesAreReplicatedOnOpCtx = false;
NamespaceString collNss;
storageInterface->createCollFn = [&collNss, &collectionCreated, &writesAreReplicatedOnOpCtx](
- OperationContext* txn, const NamespaceString& nss, const CollectionOptions& options) {
- writesAreReplicatedOnOpCtx = txn->writesAreReplicated();
+ OperationContext* opCtx, const NamespaceString& nss, const CollectionOptions& options) {
+ writesAreReplicatedOnOpCtx = opCtx->writesAreReplicated();
collectionCreated = true;
collNss = nss;
return Status::OK();
@@ -458,14 +458,14 @@ TEST_F(CollectionClonerTest,
// Replace scheduleDbWork function to schedule the create collection task with an injected error
// status.
auto exec = &getExecutor();
- collectionCloner->setScheduleDbWorkFn_forTest(
- [exec](const executor::TaskExecutor::CallbackFn& workFn) {
- auto wrappedTask = [workFn](const executor::TaskExecutor::CallbackArgs& cbd) {
- workFn(executor::TaskExecutor::CallbackArgs(
- cbd.executor, cbd.myHandle, Status(ErrorCodes::CallbackCanceled, ""), cbd.txn));
- };
- return exec->scheduleWork(wrappedTask);
- });
+ collectionCloner->setScheduleDbWorkFn_forTest([exec](
+ const executor::TaskExecutor::CallbackFn& workFn) {
+ auto wrappedTask = [workFn](const executor::TaskExecutor::CallbackArgs& cbd) {
+ workFn(executor::TaskExecutor::CallbackArgs(
+ cbd.executor, cbd.myHandle, Status(ErrorCodes::CallbackCanceled, ""), cbd.opCtx));
+ };
+ return exec->scheduleWork(wrappedTask);
+ });
bool collectionCreated = false;
storageInterface->createCollFn = [&collectionCreated](