diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-01-11 14:00:27 -0500 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-01-19 09:55:59 -0500 |
| commit | 87c9442cc30d4101693bb8ccb6fd4509aa048558 (patch) | |
| tree | 99ab7b36d89776693c09f271e4de4fd4f64846e3 /jstests/change_streams | |
| parent | 71ae3ed5b7e99ddb629ec64b85f4bd75b73aff17 (diff) | |
| download | mongo-87c9442cc30d4101693bb8ccb6fd4509aa048558.tar.gz | |
SERVER-31785 Use 2 shards in sharded jscore passthrough.
Diffstat (limited to 'jstests/change_streams')
| -rw-r--r-- | jstests/change_streams/lookup_post_image.js | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/jstests/change_streams/lookup_post_image.js b/jstests/change_streams/lookup_post_image.js index bbf2b8027c7..46f5bfd93bf 100644 --- a/jstests/change_streams/lookup_post_image.js +++ b/jstests/change_streams/lookup_post_image.js @@ -7,7 +7,7 @@ load("jstests/libs/change_stream_util.js"); load("jstests/libs/collection_drop_recreate.js"); // For assert[Drop|Create]Collection. - load("jstests/libs/fixture_helpers.js"); // For awaitLastOpCommitted(). + load("jstests/libs/fixture_helpers.js"); // For FixtureHelpers. load("jstests/replsets/libs/two_phase_drops.js"); // For 'TwoPhaseDropCollectionTest'. let cst = new ChangeStreamTest(db); @@ -110,7 +110,7 @@ // If this test is running with secondary read preference, it's necessary for the remove // to propagate to all secondary nodes and be available for majority reads before we can // assume looking up the document will fail. - FixtureHelpers.awaitLastOpCommitted(); + FixtureHelpers.awaitLastOpCommitted(db); latestChange = cst.getOneChange(cursor); assert.eq(latestChange.operationType, "update"); @@ -162,7 +162,7 @@ // If this test is running with secondary read preference, it's necessary for the drop // to propagate to all secondary nodes and be available for majority reads before we can // assume looking up the document will fail. - FixtureHelpers.awaitLastOpCommitted(); + FixtureHelpers.awaitLastOpCommitted(db); // Check the next $changeStream entry; this is the test document inserted above. latestChange = cst.getOneChange(cursor); |