summaryrefslogtreecommitdiff
path: root/jstests/gle/gle_after_split_failure_during_migration.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/gle/gle_after_split_failure_during_migration.js')
-rw-r--r--jstests/gle/gle_after_split_failure_during_migration.js136
1 files changed, 0 insertions, 136 deletions
diff --git a/jstests/gle/gle_after_split_failure_during_migration.js b/jstests/gle/gle_after_split_failure_during_migration.js
deleted file mode 100644
index 9d0a6a9ca2a..00000000000
--- a/jstests/gle/gle_after_split_failure_during_migration.js
+++ /dev/null
@@ -1,136 +0,0 @@
-/**
- * SERVER-4987 This test tries to check the getLastError call will still use
- * the same connection even if a split chunk triggered while doing inserts
- * failed (cause by StaleConfigException).
- *
- * TODO: SERVER-5175
- * This test relies on the corresponding delays inside (1) WriteBackListener::run
- * and (2) ShardStrategy::_insert and (3) receivedInsert from instance.cpp
- * to make the bug easier to manifest.
- *
- * The purpose of (1) is to make the writebacks slower so the failed inserts won't
- * be reapplied on time.
- *
- * The purpose of (2) is to make it easier for the moveChunk command from the other
- * mongos to interleave in between the moment the insert has set its shard version and
- * when in tries to autosplit (Note: it should be long enough to allow the moveChunk
- * to actually complete before it tries to proceed to autosplit).
- *
- * The purpose of (3) is to make sure that the insert won't get applied to the
- * shard right away so when a different connection is used to do the getLastError,
- * the write will still not be applied.
- */
-function testGleAfterSplitDuringMigration(){
- var st = new ShardingTest({ shards: 2, verbose: 2, mongos: 2,
- other: { chunksize: 1 }});
-
- // Stop the balancer to prevent it from contending with the distributed lock.
- st.stopBalancer();
-
- var DB_NAME = jsTest.name();
- var COLL_NAME = "coll";
-
- var mongos = st.s0;
- var confDB = mongos.getDB( "config" );
- var coll = mongos.getCollection( DB_NAME + "." + COLL_NAME );
-
- var shardConn = st.d0;
- var shardColl = shardConn.getCollection( coll.getFullName() );
-
- var data = "x";
- var dataSize = 1024 * 256; // bytes, must be power of 2
- while( data.length < dataSize ) data += data;
-
- // Shard collection
- st.shardColl( coll, { _id : 1 }, false );
-
- var docID = 0;
-
- /**
- * @return {Mongo} the connection object given the name of the shard.
- */
- var getShardConn = function( shardName ) {
- var shardLoc = confDB.shards.findOne({ _id: shardName }).host;
- return new Mongo( shardLoc );
- };
-
- /**
- * Inserts documents using a direct shard connection to the max key chunk
- * enough to make sure that it will trigger the auto split.
- *
- * variables from outer scope: docID, coll, confDB, data
- */
- var primeForSplitting = function() {
- var topChunk = confDB.chunks.find().sort({ max: -1 }).limit( 1 ).next();
- var shardLoc = getShardConn( topChunk.shard );
- var testColl = shardLoc.getCollection( coll.getFullName() );
-
- var superSaturatedChunkSize = 1024 * 1024 * 10; // 10MB
- var docsToSaturateChunkSize = superSaturatedChunkSize / dataSize;
-
- for ( var i = 0; i < docsToSaturateChunkSize; i++ ) {
- testColl.insert({ _id: docID++, val: data });
- }
-
- assert.eq( null, testColl.getDB().getLastError() );
- };
-
- /**
- * Moves a random chunk to a new shard using a different mongos.
- *
- * @param tries {Number} number of retry attempts when the moveChunk command
- * fails.
- *
- * variables from outer scope: coll, st
- */
- var moveRandomChunk = function( tries ) {
- var otherConfDB = st.s1.getDB( "config" );
- var chunksCursor = otherConfDB.chunks.find().sort({ max: 1 });
- var chunkCount = chunksCursor.count();
-
- var randIdx = Math.floor( Math.random() * chunkCount );
- // Don't get the chunk with max/min key
- randIdx = ( randIdx == chunkCount )? randIdx - 1 : randIdx;
- randIdx = ( randIdx == 0 )? randIdx + 1 : randIdx;
-
- var chunk = chunksCursor.arrayAccess( randIdx );
- var chunkOwner = chunk.shard;
- var newOwner = otherConfDB.shards.findOne({ _id: { $ne: chunkOwner }})._id;
-
- var result = otherConfDB.adminCommand({ moveChunk: coll.getFullName(),
- find: { _id: chunk.min._id },
- to: newOwner });
-
- jsTest.log( "moveChunk result: " + tojson( result ));
- if( !result.ok && tries > 1 ) {
- moveRandomChunk( tries - 1 );
- }
- };
-
- var chunks = 0;
- do {
- coll.insert({ _id: docID++, val: data });
- chunks = mongos.getDB( "config" ).chunks.find().count();
- } while ( chunks < 5 );
-
- primeForSplitting();
-
- jsTest.log( "Starting the insert that should trigger auto-split." );
-
- // TODO: SERVER-5175 Trigger delays here
- coll.insert({ _id: docID++, val: data });
- moveRandomChunk( 3 );
-
- // getLastError should wait for all writes to this connection.
- var errObj = coll.getDB().getLastErrorObj();
- jsTest.log( "Last Error Object: " + tojson( errObj ));
-
- assert.eq( docID, coll.find().itcount(), "Count does not match!" );
-
- jsTest.log( "Finished counting." );
-
- st.stop();
-}
-
-testGleAfterSplitDuringMigration();
-