summaryrefslogtreecommitdiff
path: root/jstests/noPassthrough/balancer_window.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthrough/balancer_window.js')
-rw-r--r--jstests/noPassthrough/balancer_window.js234
1 files changed, 119 insertions, 115 deletions
diff --git a/jstests/noPassthrough/balancer_window.js b/jstests/noPassthrough/balancer_window.js
index 15df48c634f..9f100846f1e 100644
--- a/jstests/noPassthrough/balancer_window.js
+++ b/jstests/noPassthrough/balancer_window.js
@@ -11,124 +11,128 @@
* sure that some chunks are moved.
*/
(function() {
-/**
- * Simple representation for wall clock time. Hour and minutes should be integers.
- */
-var HourAndMinute = function(hour, minutes) {
- return {
- /**
- * Returns a new HourAndMinute object with the amount of hours added.
- * Amount can be negative.
- */
- addHour: function(amount) {
- var newHour = (hour + amount) % 24;
- if (newHour < 0) {
- newHour += 24;
+ /**
+ * Simple representation for wall clock time. Hour and minutes should be integers.
+ */
+ var HourAndMinute = function(hour, minutes) {
+ return {
+ /**
+ * Returns a new HourAndMinute object with the amount of hours added.
+ * Amount can be negative.
+ */
+ addHour: function(amount) {
+ var newHour = (hour + amount) % 24;
+ if (newHour < 0) {
+ newHour += 24;
+ }
+
+ return new HourAndMinute(newHour, minutes);
+ },
+
+ /**
+ * Returns a string representation that is compatible with the format for the balancer
+ * window settings.
+ */
+ toString: function() {
+ var minStr = (minutes < 10) ? ('0' + minutes) : ('' + minutes);
+ var hourStr = (hour < 10) ? ('0' + hour) : ('' + hour);
+ return hourStr + ':' + minStr;
}
+ };
+ };
+
+ /**
+ * Waits until at least one balancing round has passed.
+ *
+ * Note: This relies on the fact that the balancer pings the config.mongos document every round.
+ */
+ var waitForAtLeastOneBalanceRound = function(mongosHost, timeoutMS) {
+ var mongos = new Mongo(mongosHost);
+ var configDB = mongos.getDB('config');
+
+ // Wait for ts to change twice because:
+ // 1st: for start of the balancing round.
+ // 2nd: for the start of the next round, which implies that the previous one has ended.
+ var waitForTSChangeNTimes = 2;
+ var lastPing = new Date(0);
+
+ assert.soon(
+ function() {
+ // Note: The balancer pings twice, once with { waiting: false } at the beginning
+ // and another { waiting: true } at the end. Poll for the negative edge since
+ // the smallest granurality should be a second, if for some reason the interval
+ // became less than a second, it can cause this to miss the negative edge and
+ // wake it wait longer than it should.
+ var currentPing = configDB.mongos.findOne({_id: mongosHost, waiting: true});
+ if (currentPing == null) {
+ return false;
+ }
+
+ if (currentPing.ping.valueOf() != lastPing.valueOf()) {
+ waitForTSChangeNTimes--;
+ lastPing = currentPing.ping;
+ }
+
+ return waitForTSChangeNTimes <= 0;
+ },
+ 'Timed out waiting for mongos ping to change ' + waitForTSChangeNTimes + ' more times',
+ timeoutMS,
+ 500);
+ };
- return new HourAndMinute(newHour, minutes);
+ var st = new ShardingTest({shards: 2});
+ var configDB = st.s.getDB('config');
+ assert.commandWorked(configDB.adminCommand({
+ configureFailPoint: 'balancerRoundIntervalSetting',
+ mode: 'alwaysOn',
+ data: {sleepSecs: 1}
+ }));
+
+ configDB.adminCommand({enableSharding: 'test'});
+ configDB.adminCommand({shardCollection: 'test.user', key: {_id: 1}});
+
+ // Disable balancer so it will not interfere with the chunk distribution setup.
+ st.stopBalancer();
+
+ for (var x = 0; x < 150; x += 10) {
+ configDB.adminCommand({split: 'test.user', middle: {_id: x}});
+ }
+
+ var shard0Chunks = configDB.chunks.find({ns: 'test.user', shard: 'shard0000'}).count();
+
+ var startDate = new Date();
+ var hourMinStart = new HourAndMinute(startDate.getHours(), startDate.getMinutes());
+ configDB.settings.update({_id: 'balancer'},
+ {
+ $set: {
+ activeWindow: {
+ start: hourMinStart.addHour(-2).toString(),
+ stop: hourMinStart.addHour(-1).toString()
+ },
+ stopped: false
+ }
+ },
+ true);
+
+ waitForAtLeastOneBalanceRound(st.s.host, 60 * 1000);
+
+ var shard0ChunksAfter = configDB.chunks.find({ns: 'test.user', shard: 'shard0000'}).count();
+ assert.eq(shard0Chunks, shard0ChunksAfter);
+
+ configDB.settings.update(
+ {_id: 'balancer'},
+ {
+ $set: {
+ activeWindow:
+ {start: hourMinStart.toString(), stop: hourMinStart.addHour(2).toString()}
+ }
},
+ true);
- /**
- * Returns a string representation that is compatible with the format for the balancer
- * window settings.
- */
- toString: function() {
- var minStr = (minutes < 10) ? ('0' + minutes) : ('' + minutes);
- var hourStr = (hour < 10) ? ('0' + hour) : ('' + hour);
- return hourStr + ':' + minStr;
- }
- };
-};
+ waitForAtLeastOneBalanceRound(st.s.host, 60 * 1000);
-/**
- * Waits until at least one balancing round has passed.
- *
- * Note: This relies on the fact that the balancer pings the config.mongos document every round.
- */
-var waitForAtLeastOneBalanceRound = function(mongosHost, timeoutMS) {
- var mongos = new Mongo(mongosHost);
- var configDB = mongos.getDB('config');
-
- // Wait for ts to change twice because:
- // 1st: for start of the balancing round.
- // 2nd: for the start of the next round, which implies that the previous one has ended.
- var waitForTSChangeNTimes = 2;
- var lastPing = new Date(0);
-
- assert.soon(function() {
- // Note: The balancer pings twice, once with { waiting: false } at the beginning
- // and another { waiting: true } at the end. Poll for the negative edge since
- // the smallest granurality should be a second, if for some reason the interval
- // became less than a second, it can cause this to miss the negative edge and
- // wake it wait longer than it should.
- var currentPing = configDB.mongos.findOne({ _id: mongosHost, waiting: true });
- if (currentPing == null) {
- return false;
- }
-
- if (currentPing.ping.valueOf() != lastPing.valueOf()) {
- waitForTSChangeNTimes--;
- lastPing = currentPing.ping;
- }
-
- return waitForTSChangeNTimes <= 0;
- }, 'Timed out waiting for mongos ping to change ' + waitForTSChangeNTimes + ' more times',
- timeoutMS, 500);
-};
-
-var st = new ShardingTest({ shards: 2 });
-var configDB = st.s.getDB('config');
-assert.commandWorked(configDB.adminCommand({ configureFailPoint: 'balancerRoundIntervalSetting',
- mode: 'alwaysOn',
- data: { sleepSecs: 1 }}));
-
-configDB.adminCommand({ enableSharding: 'test' });
-configDB.adminCommand({ shardCollection: 'test.user', key: { _id: 1 }});
-
-// Disable balancer so it will not interfere with the chunk distribution setup.
-st.stopBalancer();
-
-for (var x = 0; x < 150; x += 10) {
- configDB.adminCommand({ split: 'test.user', middle: { _id: x }});
-}
-
-var shard0Chunks = configDB.chunks.find({ ns: 'test.user', shard: 'shard0000' }).count();
-
-var startDate = new Date();
-var hourMinStart = new HourAndMinute(startDate.getHours(), startDate.getMinutes());
-configDB.settings.update({ _id: 'balancer' },
- {
- $set: {
- activeWindow: {
- start: hourMinStart.addHour(-2).toString(),
- stop: hourMinStart.addHour(-1).toString()
- },
- stopped: false
- }
- },
- true);
-
-waitForAtLeastOneBalanceRound(st.s.host, 60 * 1000);
-
-var shard0ChunksAfter = configDB.chunks.find({ ns: 'test.user', shard: 'shard0000' }).count();
-assert.eq(shard0Chunks, shard0ChunksAfter);
-
-configDB.settings.update({ _id: 'balancer' },
- {
- $set: {
- activeWindow: {
- start: hourMinStart.toString(),
- stop: hourMinStart.addHour(2).toString()
- }
- }
- },
- true);
-
-waitForAtLeastOneBalanceRound(st.s.host, 60 * 1000);
-
-shard0ChunksAfter = configDB.chunks.find({ ns: 'test.user', shard: 'shard0000' }).count();
-assert.neq(shard0Chunks, shard0ChunksAfter);
-
-st.stop();
+ shard0ChunksAfter = configDB.chunks.find({ns: 'test.user', shard: 'shard0000'}).count();
+ assert.neq(shard0Chunks, shard0ChunksAfter);
+
+ st.stop();
})();
View Lorry Controller Status