SERVER-17132: Added SnapshotId and Snapshotted and use them in query to make sure we use correct versions of docs

1 files changed, 2 insertions, 2 deletions

diff --git a/src/mongo/db/exec/pipeline_proxy.cpp b/src/mongo/db/exec/pipeline_proxy.cpp
index 5369429cd07..2bcad44d998 100644
--- a/src/mongo/db/exec/pipeline_proxy.cpp
+++ b/src/mongo/db/exec/pipeline_proxy.cpp
@@ -58,7 +58,7 @@ namespace mongo {
         if (!_stash.empty()) {
             *out = _ws->allocate();
             WorkingSetMember* member = _ws->get(*out);
-            member->obj = _stash.back();
+            member->obj = Snapshotted<BSONObj>(SnapshotId(), _stash.back());
             _stash.pop_back();
             member->state = WorkingSetMember::OWNED_OBJ;
             return PlanStage::ADVANCED;
@@ -67,7 +67,7 @@ namespace mongo {
         if (boost::optional<BSONObj> next = getNextBson()) {
             *out = _ws->allocate();
             WorkingSetMember* member = _ws->get(*out);
-            member->obj = *next;
+            member->obj = Snapshotted<BSONObj>(SnapshotId(), *next);
             member->state = WorkingSetMember::OWNED_OBJ;
             return PlanStage::ADVANCED;
         }