summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/pipeline_proxy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/pipeline_proxy.cpp')
-rw-r--r--src/mongo/db/exec/pipeline_proxy.cpp4
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;
}