summaryrefslogtreecommitdiff
path: root/jstests/noPassthroughWithMongod/index_retry.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthroughWithMongod/index_retry.js')
-rw-r--r--jstests/noPassthroughWithMongod/index_retry.js103
1 files changed, 0 insertions, 103 deletions
diff --git a/jstests/noPassthroughWithMongod/index_retry.js b/jstests/noPassthroughWithMongod/index_retry.js
deleted file mode 100644
index 1fbb645c418..00000000000
--- a/jstests/noPassthroughWithMongod/index_retry.js
+++ /dev/null
@@ -1,103 +0,0 @@
-// Check index rebuild when MongoDB is killed
-(function() {
- 'use strict';
- var baseName = 'index_retry';
- var dbpath = MongoRunner.dataPath + baseName;
- var ports = allocatePorts(1);
- var conn = MongoRunner.runMongod({
- dbpath: dbpath,
- port: ports[0],
- journal: ''});
-
- var test = conn.getDB("test");
-
- var name = 'jstests_slownightly_' + baseName;
- var t = test.getCollection(name);
- t.drop();
-
- // Insert a large number of documents, enough to ensure that an index build on these documents
- // can be interrupted before complete.
- var bulk = t.initializeUnorderedBulkOp();
- for (var i = 0; i < 5e5; ++i) {
- bulk.insert({ a: i });
- if (i % 10000 == 0) {
- print("i: " + i);
- }
- }
- assert.writeOK(bulk.execute());
-
- function debug(x) {
- printjson(x);
- }
-
- /**
- * @return if there's a current running index build
- */
- function indexBuildInProgress() {
- var inprog = test.currentOp().inprog;
- debug(inprog);
- var indexBuildOpId = -1;
- inprog.forEach(
- function( op ) {
- // Identify the index build as a createIndexes command.
- // It is assumed that no other clients are concurrently
- // accessing the 'test' database.
- if ( op.op == 'query' && 'createIndexes' in op.query ) {
- debug(op.opid);
- var idxSpec = op.query.indexes[0];
- // SERVER-4295 Make sure the index details are there
- // we can't assert these things, since there is a race in reporting
- // but we won't count if they aren't
- if ( "a_1" == idxSpec.name &&
- 1 == idxSpec.key.a &&
- idxSpec.background &&
- op.progress &&
- (op.progress.done / op.progress.total) > 0.20) {
- indexBuildOpId = op.opid;
- }
- }
- }
- );
- return indexBuildOpId != -1;
- }
-
- function abortDuringIndexBuild(options) {
- var createIdx = startParallelShell(
- 'db.' + name + '.createIndex({ a: 1 }, { background: true });',
- ports[0]);
-
- // Wait for the index build to start.
- var times = 0;
- assert.soon(
- function() {
- return indexBuildInProgress() && times++ >= 2;
- }
- );
-
- print("killing the mongod");
- MongoRunner.stopMongod(ports[0], /* signal */ 9);
- createIdx();
- }
-
- abortDuringIndexBuild();
-
- conn = MongoRunner.runMongod({
- dbpath: dbpath,
- port: ports[0],
- journal: '',
- restart: true});
- test = conn.getDB("test");
- t = test.getCollection(name);
-
- assert.eq({a: 42}, t.find({a: 42}, {_id: 0}).hint({a: 1}).next(),
- 'index {a: 1} was rebuilt on startup');
-
- var indexes = t.getIndexes();
- assert.eq(2, indexes.length,
- 'unexpected number of indexes in listIndexes result: ' + tojson(indexes));
-
- print("Index built");
-
- MongoRunner.stopMongod(ports[0]);
- print("SUCCESS!");
-}());