diff options
Diffstat (limited to 'jstests/replsets/oplog_term.js')
-rw-r--r-- | jstests/replsets/oplog_term.js | 51 |
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(); })(); |