SERVER-33354 Add snapshot read support for additional commands

1 files changed, 9 insertions, 1 deletions

diff --git a/src/mongo/db/commands/parallel_collection_scan.cpp b/src/mongo/db/commands/parallel_collection_scan.cpp
index c040e9e0510..ae3818ab9ea 100644
--- a/src/mongo/db/commands/parallel_collection_scan.cpp
+++ b/src/mongo/db/commands/parallel_collection_scan.cpp
@@ -129,8 +129,15 @@ public:
                 make_unique<MultiIteratorStage>(opCtx, ws.get(), collection);
 
             // Takes ownership of 'ws' and 'mis'.
+            const auto& readConcernArgs = repl::ReadConcernArgs::get(opCtx);
             auto statusWithPlanExecutor = PlanExecutor::make(
-                opCtx, std::move(ws), std::move(mis), collection, PlanExecutor::YIELD_AUTO);
+                opCtx,
+                std::move(ws),
+                std::move(mis),
+                collection,
+                readConcernArgs.getLevel() == repl::ReadConcernLevel::kSnapshotReadConcern
+                    ? PlanExecutor::INTERRUPT_ONLY
+                    : PlanExecutor::YIELD_AUTO);
             invariant(statusWithPlanExecutor.isOK());
             execs.push_back(std::move(statusWithPlanExecutor.getValue()));
         }
@@ -167,6 +174,7 @@ public:
             bucketsBuilder.append(threadResult.obj());
         }
         result.appendArray("cursors", bucketsBuilder.obj());
+        opCtx->setStashedCursor();
 
         return true;
     }