summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_fetcher.cpp
diff options
context:
space:
mode:
authorEric Cox <eric.cox@mongodb.com>2020-01-21 20:31:02 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-02-13 14:58:45 +0000
commite289b78c61033674f6440d9ddc402b50903717ac (patch)
treef468a4ea2a6c68e3bbf3e23522926e05e4f92aa4 /src/mongo/db/repl/oplog_fetcher.cpp
parent173e12f195cf456c6f08d82131256d625c1f583f (diff)
downloadmongo-e289b78c61033674f6440d9ddc402b50903717ac.tar.gz
SERVER-45454 Desugar where to expr + function
Diffstat (limited to 'src/mongo/db/repl/oplog_fetcher.cpp')
-rw-r--r--src/mongo/db/repl/oplog_fetcher.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/repl/oplog_fetcher.cpp b/src/mongo/db/repl/oplog_fetcher.cpp
index 5cd9e5c967c..afff88413c3 100644
--- a/src/mongo/db/repl/oplog_fetcher.cpp
+++ b/src/mongo/db/repl/oplog_fetcher.cpp
@@ -472,7 +472,7 @@ StatusWith<BSONObj> OplogFetcher::_onSuccessfulBatch(const Fetcher::QueryRespons
[&](const BSONObj& data) {
auto opCtx = cc().makeOperationContext();
boost::intrusive_ptr<ExpressionContext> expCtx(
- new ExpressionContext(opCtx.get(), nullptr));
+ new ExpressionContext(opCtx.get(), nullptr, _getNamespace()));
Matcher m(data["document"].Obj(), expCtx);
return !queryResponse.documents.empty() &&
m.matches(queryResponse.documents.front()["o"].Obj());
@@ -1079,7 +1079,7 @@ Status NewOplogFetcher::_onSuccessfulBatch(const Documents& documents) {
[&](const BSONObj& data) {
auto opCtx = cc().makeOperationContext();
boost::intrusive_ptr<ExpressionContext> expCtx(
- new ExpressionContext(opCtx.get(), nullptr));
+ new ExpressionContext(opCtx.get(), nullptr, _nss));
Matcher m(data["document"].Obj(), expCtx);
return !documents.empty() && m.matches(documents.front()["o"].Obj());
});