SERVER-30679 Integrate causallyConsistentReads into SessionOptions.

4 files changed, 12 insertions, 12 deletions

diff --git a/jstests/change_streams/change_stream.js b/jstests/change_streams/change_stream.js
index c545456ef33..5e06eae5b52 100644
--- a/jstests/change_streams/change_stream.js
+++ b/jstests/change_streams/change_stream.js
@@ -33,7 +33,7 @@
         // these synchronization points from this test.
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
 
         // Waiting for replication assures no previous operations will be included.
@@ -49,7 +49,7 @@
         // TODO: SERVER-29126
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
         FixtureHelpers.awaitReplication();
         if (expectedBatch.length == 0)
@@ -293,7 +293,7 @@
         // TODO: SERVER-29126
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
         FixtureHelpers.awaitReplication();
         FixtureHelpers.runCommandOnEachPrimary({
@@ -322,7 +322,7 @@
         // TODO: SERVER-29126
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
         FixtureHelpers.awaitReplication();
         assert.commandWorked(db.adminCommand(
diff --git a/jstests/change_streams/change_stream_invalidation.js b/jstests/change_streams/change_stream_invalidation.js
index 4d1122eeac3..8fcb5e9e527 100644
--- a/jstests/change_streams/change_stream_invalidation.js
+++ b/jstests/change_streams/change_stream_invalidation.js
@@ -19,7 +19,7 @@
         // these synchronization points from this test.
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
 
         let res = assert.commandWorked(
@@ -70,7 +70,7 @@
     // these synchronization points from this test.
     assert.commandWorked(db.runCommand({
         find: "foo",
-        readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+        readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
     }));
 
     res =
diff --git a/jstests/change_streams/lookup_post_image.js b/jstests/change_streams/lookup_post_image.js
index 44c1e8de956..fa9301fa142 100644
--- a/jstests/change_streams/lookup_post_image.js
+++ b/jstests/change_streams/lookup_post_image.js
@@ -21,7 +21,7 @@
         // these synchronization points from this test.
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
 
         const cmdResponse = assert.commandWorked(
@@ -44,7 +44,7 @@
         // TODO: SERVER-29126
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
         FixtureHelpers.awaitReplication();
         // TODO: SERVER-29126
@@ -54,7 +54,7 @@
         // these synchronization points from this test.
         assert.commandWorked(db.runCommand({
             find: "foo",
-            readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+            readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
         }));
         FixtureHelpers.runCommandOnEachPrimary({
             dbName: "admin",
@@ -285,7 +285,7 @@
     // these synchronization points from this test.
     assert.commandWorked(db.runCommand({
         find: "foo",
-        readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+        readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
     }));
 
     res = assert.commandWorked(db.runCommand({
@@ -302,7 +302,7 @@
     // these synchronization points from this test.
     assert.commandWorked(db.runCommand({
         find: "foo",
-        readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+        readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
     }));
 
     res = assert.commandWorked(db.runCommand({
diff --git a/jstests/change_streams/report_latest_observed_oplog_timestamp.js b/jstests/change_streams/report_latest_observed_oplog_timestamp.js
index 7345cfc4667..4598bc6ce9a 100644
--- a/jstests/change_streams/report_latest_observed_oplog_timestamp.js
+++ b/jstests/change_streams/report_latest_observed_oplog_timestamp.js
@@ -51,7 +51,7 @@
     // synchronization point from this test.
     assert.commandWorked(db.runCommand({
         find: "foo",
-        readConcern: {level: "local", afterClusterTime: db.getMongo().getOperationTime()}
+        readConcern: {level: "local", afterClusterTime: db.getSession().getOperationTime()}
     }));
 
     // Look at one batch's worth.