SERVER-40209 Implement $$NOW and $$CLUSTER_TIME

1 files changed, 8 insertions, 0 deletions

diff --git a/src/mongo/db/pipeline/expression_context.cpp b/src/mongo/db/pipeline/expression_context.cpp
index 508f51788c2..21651f6f2b8 100644
--- a/src/mongo/db/pipeline/expression_context.cpp
+++ b/src/mongo/db/pipeline/expression_context.cpp
@@ -62,6 +62,11 @@ ExpressionContext::ExpressionContext(OperationContext* opCtx,
     _ownedCollator = std::move(collator);
     _resolvedNamespaces = std::move(resolvedNamespaces);
     uuid = std::move(collUUID);
+    if (request.getRuntimeConstants()) {
+        variables.setRuntimeConstants(request.getRuntimeConstants().get());
+    } else {
+        variables.generateRuntimeConstants(opCtx);
+    }
 }
 
 ExpressionContext::ExpressionContext(OperationContext* opCtx, const CollatorInterface* collator)
@@ -170,6 +175,9 @@ intrusive_ptr<ExpressionContext> ExpressionContext::copyWith(
 
     expCtx->_resolvedNamespaces = _resolvedNamespaces;
 
+    expCtx->variables = variables;
+    expCtx->variablesParseState = variablesParseState.copyWith(expCtx->variables.useIdGenerator());
+
     // Note that we intentionally skip copying the value of '_interruptCounter' because 'expCtx' is
     // intended to be used for executing a separate aggregation pipeline.