diff options
Diffstat (limited to 'src/mongo/db/repl/oplog_fetcher.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog_fetcher.cpp | 4 |
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()); }); |