summaryrefslogtreecommitdiff
path: root/jstests/sharding/multi_mongos2.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/multi_mongos2.js')
-rw-r--r--jstests/sharding/multi_mongos2.js11
1 files changed, 8 insertions, 3 deletions
diff --git a/jstests/sharding/multi_mongos2.js b/jstests/sharding/multi_mongos2.js
index 41458c3b223..43be2ecd9da 100644
--- a/jstests/sharding/multi_mongos2.js
+++ b/jstests/sharding/multi_mongos2.js
@@ -21,14 +21,17 @@ assert.eq(1, s2.getDB('test').existing.count({_id:1}));
s2.adminCommand( { shardcollection : "test.existing" , key : { _id : 1 } } );
assert.commandWorked(s2.adminCommand({ split: "test.existing", middle: { _id: 5 }}));
-res = s2.getDB( "admin" ).runCommand( { moveChunk: "test.existing" , find : { _id : 1 } , to : s1.getOther( s1.getServer( "test" ) ).name } );
+res = s2.getDB( "admin" ).runCommand( { moveChunk: "test.existing" ,
+ find : { _id : 1 } ,
+ to : s1.getOther( s1.getPrimaryShard( "test" ) ).name } );
assert.eq(1 , res.ok, tojson(res));
s1.startBalancer();
printjson( s2.adminCommand( {"getShardVersion" : "test.existing" } ) );
-printjson( new Mongo(s1.getServer( "test" ).name).getDB( "admin" ).adminCommand( {"getShardVersion" : "test.existing" } ) );
+printjson( new Mongo(s1.getPrimaryShard( "test" ).name).getDB( "admin" )
+ .adminCommand( {"getShardVersion" : "test.existing" } ) );
assert.eq(1, s1.getDB('test').existing.count({_id:1})); // SERVER-2828
assert.eq(1, s2.getDB('test').existing.count({_id:1}));
@@ -58,7 +61,9 @@ s1.stopBalancer();
s2.adminCommand( { shardcollection : "test.existing3" , key : { _id : 1 } } );
assert.commandWorked(s2.adminCommand({ split: "test.existing3", middle: { _id: 5 }}));
-res = s1.getDB( "admin" ).runCommand( { moveChunk: "test.existing3" , find : { _id : 1 } , to : s1.getOther( s1.getServer( "test" ) ).name } );
+res = s1.getDB( "admin" ).runCommand( { moveChunk: "test.existing3",
+ find : { _id : 1 },
+ to : s1.getOther( s1.getPrimaryShard( "test" ) ).name } );
assert.eq(1 , res.ok, tojson(res));
s1.startBalancer();