summaryrefslogtreecommitdiff
path: root/jstests/replsets/oplog_term.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/oplog_term.js')
-rw-r--r--jstests/replsets/oplog_term.js51
1 files changed, 25 insertions, 26 deletions
diff --git a/jstests/replsets/oplog_term.js b/jstests/replsets/oplog_term.js
index 93b650ab637..f21e01f4a98 100644
--- a/jstests/replsets/oplog_term.js
+++ b/jstests/replsets/oplog_term.js
@@ -1,34 +1,33 @@
// Term counter should be present in oplog entries under protocol version 1.
(function() {
- 'use strict';
- load('jstests/replsets/rslib.js');
+'use strict';
+load('jstests/replsets/rslib.js');
- var name = 'oplog_term';
- var replSet = new ReplSetTest({name: name, nodes: 1});
- replSet.startSet();
- replSet.initiate();
- replSet.waitForState(replSet.nodes[0], ReplSetTest.State.PRIMARY, 5 * 1000);
+var name = 'oplog_term';
+var replSet = new ReplSetTest({name: name, nodes: 1});
+replSet.startSet();
+replSet.initiate();
+replSet.waitForState(replSet.nodes[0], ReplSetTest.State.PRIMARY, 5 * 1000);
- // Default protocol version is 1 - 'term' field should present in oplog entry.
- var primary = replSet.getPrimary();
- var collection = primary.getDB('test').getCollection(name);
- assert.writeOK(collection.save({_id: 1}));
+// Default protocol version is 1 - 'term' field should present in oplog entry.
+var primary = replSet.getPrimary();
+var collection = primary.getDB('test').getCollection(name);
+assert.writeOK(collection.save({_id: 1}));
- var oplogEntry = getLatestOp(primary);
- assert(oplogEntry, 'unexpected empty oplog');
- assert.eq(collection.getFullName(),
- oplogEntry.ns,
- 'unexpected namespace in oplog entry: ' + tojson(oplogEntry));
- assert.eq(
- 1,
- oplogEntry.o._id,
- 'oplog entry does not refer to most recently inserted document: ' + tojson(oplogEntry));
- assert(oplogEntry.hasOwnProperty('t'), 'oplog entry must contain term: ' + tojson(oplogEntry));
+var oplogEntry = getLatestOp(primary);
+assert(oplogEntry, 'unexpected empty oplog');
+assert.eq(collection.getFullName(),
+ oplogEntry.ns,
+ 'unexpected namespace in oplog entry: ' + tojson(oplogEntry));
+assert.eq(1,
+ oplogEntry.o._id,
+ 'oplog entry does not refer to most recently inserted document: ' + tojson(oplogEntry));
+assert(oplogEntry.hasOwnProperty('t'), 'oplog entry must contain term: ' + tojson(oplogEntry));
- var status = assert.commandWorked(primary.adminCommand({replSetGetStatus: 1}));
- assert.eq(status.term,
- oplogEntry.t,
- 'term in oplog entry does not match term in status: ' + tojson(oplogEntry));
+var status = assert.commandWorked(primary.adminCommand({replSetGetStatus: 1}));
+assert.eq(status.term,
+ oplogEntry.t,
+ 'term in oplog entry does not match term in status: ' + tojson(oplogEntry));
- replSet.stopSet();
+replSet.stopSet();
})();