summaryrefslogtreecommitdiff
path: root/jstests/core/tailable_skip_limit.js
diff options
context:
space:
mode:
authorclang-format-7.0.1 <adam.martin@10gen.com>2019-07-26 18:42:24 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2019-07-26 18:42:24 -0400
commitc1a45ebbb0530e3d0201321d725527f1eb83ffce (patch)
treef523079dc5ded3052eefbdcaae424b7502df5b25 /jstests/core/tailable_skip_limit.js
parentc9599d8610c3da0b7c3da65667aff821063cf5b9 (diff)
downloadmongo-c1a45ebbb0530e3d0201321d725527f1eb83ffce.tar.gz
Apply formatting per `clang-format-7.0.1`
Diffstat (limited to 'jstests/core/tailable_skip_limit.js')
-rw-r--r--jstests/core/tailable_skip_limit.js150
1 files changed, 75 insertions, 75 deletions
diff --git a/jstests/core/tailable_skip_limit.js b/jstests/core/tailable_skip_limit.js
index 8669e29a836..672a52aeb3d 100644
--- a/jstests/core/tailable_skip_limit.js
+++ b/jstests/core/tailable_skip_limit.js
@@ -2,92 +2,92 @@
// Test that tailable cursors work correctly with skip and limit.
(function() {
- "use strict";
+"use strict";
- // Setup the capped collection.
- var collname = "jstests_tailable_skip_limit";
- var t = db[collname];
- t.drop();
- assert.commandWorked(db.createCollection(collname, {capped: true, size: 1024}));
+// Setup the capped collection.
+var collname = "jstests_tailable_skip_limit";
+var t = db[collname];
+t.drop();
+assert.commandWorked(db.createCollection(collname, {capped: true, size: 1024}));
- assert.writeOK(t.insert({_id: 1}));
- assert.writeOK(t.insert({_id: 2}));
+assert.writeOK(t.insert({_id: 1}));
+assert.writeOK(t.insert({_id: 2}));
- // Non-tailable with skip
- var cursor = t.find().skip(1);
- assert.eq(2, cursor.next()["_id"]);
- assert(!cursor.hasNext());
- assert.writeOK(t.insert({_id: 3}));
- assert(!cursor.hasNext());
+// Non-tailable with skip
+var cursor = t.find().skip(1);
+assert.eq(2, cursor.next()["_id"]);
+assert(!cursor.hasNext());
+assert.writeOK(t.insert({_id: 3}));
+assert(!cursor.hasNext());
- // Non-tailable with limit
- var cursor = t.find().limit(100);
- for (var i = 1; i <= 3; i++) {
- assert.eq(i, cursor.next()["_id"]);
- }
- assert(!cursor.hasNext());
- assert.writeOK(t.insert({_id: 4}));
- assert(!cursor.hasNext());
+// Non-tailable with limit
+var cursor = t.find().limit(100);
+for (var i = 1; i <= 3; i++) {
+ assert.eq(i, cursor.next()["_id"]);
+}
+assert(!cursor.hasNext());
+assert.writeOK(t.insert({_id: 4}));
+assert(!cursor.hasNext());
- // Non-tailable with negative limit
- var cursor = t.find().limit(-100);
- for (var i = 1; i <= 4; i++) {
- assert.eq(i, cursor.next()["_id"]);
- }
- assert(!cursor.hasNext());
- assert.writeOK(t.insert({_id: 5}));
- assert(!cursor.hasNext());
+// Non-tailable with negative limit
+var cursor = t.find().limit(-100);
+for (var i = 1; i <= 4; i++) {
+ assert.eq(i, cursor.next()["_id"]);
+}
+assert(!cursor.hasNext());
+assert.writeOK(t.insert({_id: 5}));
+assert(!cursor.hasNext());
- // Tailable with skip
- cursor = t.find().addOption(2).skip(4);
- assert.eq(5, cursor.next()["_id"]);
- assert(!cursor.hasNext());
- assert.writeOK(t.insert({_id: 6}));
- assert(cursor.hasNext());
- assert.eq(6, cursor.next()["_id"]);
+// Tailable with skip
+cursor = t.find().addOption(2).skip(4);
+assert.eq(5, cursor.next()["_id"]);
+assert(!cursor.hasNext());
+assert.writeOK(t.insert({_id: 6}));
+assert(cursor.hasNext());
+assert.eq(6, cursor.next()["_id"]);
- // Tailable with limit
- var cursor = t.find().addOption(2).limit(100);
- for (var i = 1; i <= 6; i++) {
- assert.eq(i, cursor.next()["_id"]);
- }
- assert(!cursor.hasNext());
- assert.writeOK(t.insert({_id: 7}));
- assert(cursor.hasNext());
- assert.eq(7, cursor.next()["_id"]);
+// Tailable with limit
+var cursor = t.find().addOption(2).limit(100);
+for (var i = 1; i <= 6; i++) {
+ assert.eq(i, cursor.next()["_id"]);
+}
+assert(!cursor.hasNext());
+assert.writeOK(t.insert({_id: 7}));
+assert(cursor.hasNext());
+assert.eq(7, cursor.next()["_id"]);
- // Tailable with negative limit is an error.
- assert.throws(function() {
- t.find().addOption(2).limit(-100).next();
- });
+// Tailable with negative limit is an error.
+assert.throws(function() {
+ t.find().addOption(2).limit(-100).next();
+});
+assert.throws(function() {
+ t.find().addOption(2).limit(-1).itcount();
+});
+
+// When using read commands, a limit of 1 with the tailable option is allowed. In legacy
+// readMode, an ntoreturn of 1 means the same thing as ntoreturn -1 and is disallowed with
+// tailable.
+if (db.getMongo().useReadCommands()) {
+ assert.eq(1, t.find().addOption(2).limit(1).itcount());
+} else {
assert.throws(function() {
- t.find().addOption(2).limit(-1).itcount();
+ t.find().addOption(2).limit(1).itcount();
});
+}
- // When using read commands, a limit of 1 with the tailable option is allowed. In legacy
- // readMode, an ntoreturn of 1 means the same thing as ntoreturn -1 and is disallowed with
- // tailable.
- if (db.getMongo().useReadCommands()) {
- assert.eq(1, t.find().addOption(2).limit(1).itcount());
- } else {
- assert.throws(function() {
- t.find().addOption(2).limit(1).itcount();
- });
- }
-
- // Tests that a tailable cursor over an empty capped collection produces a dead cursor, intended
- // to be run on both mongod and mongos. For SERVER-20720.
- t.drop();
- assert.commandWorked(db.createCollection(t.getName(), {capped: true, size: 1024}));
+// Tests that a tailable cursor over an empty capped collection produces a dead cursor, intended
+// to be run on both mongod and mongos. For SERVER-20720.
+t.drop();
+assert.commandWorked(db.createCollection(t.getName(), {capped: true, size: 1024}));
- var cmdRes = db.runCommand({find: t.getName(), tailable: true});
- assert.commandWorked(cmdRes);
- assert.eq(cmdRes.cursor.id, NumberLong(0));
- assert.eq(cmdRes.cursor.ns, t.getFullName());
- assert.eq(cmdRes.cursor.firstBatch.length, 0);
+var cmdRes = db.runCommand({find: t.getName(), tailable: true});
+assert.commandWorked(cmdRes);
+assert.eq(cmdRes.cursor.id, NumberLong(0));
+assert.eq(cmdRes.cursor.ns, t.getFullName());
+assert.eq(cmdRes.cursor.firstBatch.length, 0);
- // Test that the cursor works in the shell.
- assert.eq(t.find().addOption(2).itcount(), 0);
- assert.writeOK(t.insert({a: 1}));
- assert.eq(t.find().addOption(2).itcount(), 1);
+// Test that the cursor works in the shell.
+assert.eq(t.find().addOption(2).itcount(), 0);
+assert.writeOK(t.insert({a: 1}));
+assert.eq(t.find().addOption(2).itcount(), 1);
})();