diff options
Diffstat (limited to 'jstests/noPassthrough/timeseries_ttl.js')
| -rw-r--r-- | jstests/noPassthrough/timeseries_ttl.js | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/jstests/noPassthrough/timeseries_ttl.js b/jstests/noPassthrough/timeseries_ttl.js index 087bcd15c21..ebc2cb272f6 100644 --- a/jstests/noPassthrough/timeseries_ttl.js +++ b/jstests/noPassthrough/timeseries_ttl.js @@ -11,7 +11,6 @@ (function() { "use strict"; load("jstests/libs/clustered_collections/clustered_collection_util.js"); -load("jstests/libs/ttl_util.js"); // Run TTL monitor constantly to speed up this test. const conn = MongoRunner.runMongod({setParameter: 'ttlMonitorSleepSecs=1'}); @@ -51,7 +50,7 @@ testCase((coll, bucketsColl) => { assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); }); @@ -68,7 +67,7 @@ testCase((coll, bucketsColl) => { assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); }); @@ -82,7 +81,7 @@ testCase((coll, bucketsColl) => { assert.commandWorked(coll.insert({[timeFieldName]: minTime, [metaFieldName]: "localhost"})); assert.commandWorked(coll.insert({[timeFieldName]: maxTime, [metaFieldName]: "localhost"})); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(0, coll.find().itcount()); assert.eq(0, bucketsColl.find().itcount()); }); @@ -101,7 +100,7 @@ testCase((coll, bucketsColl) => { assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(2, coll.find().itcount()); assert.eq(1, bucketsColl.find().itcount()); }); @@ -117,7 +116,7 @@ testCase((coll, bucketsColl) => { {[timeFieldName]: maxTime, [metaFieldName]: "localhost"} ])); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(0, coll.find().itcount()); assert.eq(0, bucketsColl.find().itcount()); }); @@ -150,7 +149,7 @@ testCase((coll, bucketsColl) => { expireAfterSeconds: expireAfterSeconds, })); - TTLUtil.waitForPass(coll.getDB("test")); + ClusteredCollectionUtil.waitForTTL(coll.getDB("test")); assert.eq(0, coll.find().itcount()); assert.eq(0, bucketsColl.find().itcount()); })(); |