/** * */ (function() { 'use strict' ; load( "jstests/libs/fail_point_util.js" ); load( 'jstests/replsets/rslib.js' ); const basename = 'initial_sync_rename_database_before_cloning' ; jsTestLog( 'Bring up a replica set' ); const rst = new ReplSetTest({name: basename, nodes: 1}); rst.startSet(); rst.initiate(); const dbName = "test" ; const primary = rst.getPrimary(); const primaryDb = primary.getDB(dbName); jsTestLog( "Create collections on primary" ); const collName = "coll" ; jsTestLog( 'Waiting for replication' ); rst.awaitReplication(); jsTestLog( 'Bring up a new node' ); const secondary = rst.add({setParameter: 'numInitialSyncAttempts=1' }); // Add a fail point that causes the secondary's initial sync to hang before // copying databases. const failPoint = configureFailPoint(secondary, 'initialSyncHangBeforeCopyingDatabases' ); jsTestLog( 'Begin initial sync on secondary' ); let conf = rst.getPrimary().getDB( 'admin' ).runCommand({replSetGetConfig: 1}).config; conf.members.push({_id: 1, host: secondary.host, priority: 0, votes: 0}); conf.version++; assert .commandWorked(rst.getPrimary().getDB( 'admin' ).runCommand({replSetReconfig: conf})); assert .eq(primary, rst.getPrimary(), 'Primary changed after reconfig' ); // Confirm that initial sync started on the secondary node. jsTestLog( 'Waiting for initial sync to start' ); failPoint.wait(); assert .commandWorked(primaryDb.getCollection(collName).insert({})); assert .commandWorked(primaryDb.runCommand({emptycapped: "coll" })) assert .commandWorked(primaryDb.getCollection(collName).insert({_id: 0, a: 1})); jsTestLog( 'Build index on the sync source' ); const fpIndexSrc = configureFailPoint(primary, 'hangAfterStartingIndexBuild' ); const awaitIndex = startParallelShell(() => { assert .commandWorked(db.getCollection( 'coll' ).createIndex({a: 1})); }, primary.port) jsTestLog( 'Pause index build on sync source' ) fpIndexSrc.wait(); const fpIndexInit = configureFailPoint(secondary, 'hangAfterStartingIndexBuild' ); jsTestLog( 'Resume the initial sync' ) failPoint.off(); jsTestLog( 'Pause index build on initial sync node' ); fpIndexInit.wait(); jsTestLog( 'Resume index build on sync source to finish' ); fpIndexSrc.off(); awaitIndex(); jsTestLog( 'Resume index build on initial sync node to finish' ); fpIndexInit.off(); jsTestLog( 'Wait for both nodes to be up-to-date' ); rst.awaitSecondaryNodes(); rst.awaitReplication(); rst.checkReplicatedDataHashes(); rst.checkOplogs(); rst.stopSet(); })();