diff options
Diffstat (limited to 'jstests/free_mon/free_mon_rs_halt.js')
-rw-r--r-- | jstests/free_mon/free_mon_rs_halt.js | 76 |
1 files changed, 38 insertions, 38 deletions
diff --git a/jstests/free_mon/free_mon_rs_halt.js b/jstests/free_mon/free_mon_rs_halt.js index 5a5b94accc2..3962391826b 100644 --- a/jstests/free_mon/free_mon_rs_halt.js +++ b/jstests/free_mon/free_mon_rs_halt.js @@ -2,61 +2,61 @@ load("jstests/free_mon/libs/free_mon.js"); (function() { - 'use strict'; +'use strict'; - let mock_web = new FreeMonWebServer(FAULT_HALT_METRICS_5, true); +let mock_web = new FreeMonWebServer(FAULT_HALT_METRICS_5, true); - mock_web.start(); +mock_web.start(); - let options = { - setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web.getURL(), - enableFreeMonitoring: "on", - verbose: 1, - }; +let options = { + setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web.getURL(), + enableFreeMonitoring: "on", + verbose: 1, +}; - const rst = new ReplSetTest({nodes: 2, nodeOptions: options}); - rst.startSet(); - rst.initiate(); - rst.awaitReplication(); +const rst = new ReplSetTest({nodes: 2, nodeOptions: options}); +rst.startSet(); +rst.initiate(); +rst.awaitReplication(); - WaitForRegistration(rst.getPrimary()); +WaitForRegistration(rst.getPrimary()); - mock_web.waitRegisters(2); +mock_web.waitRegisters(2); - assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'enabled'); - assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'enabled'); +assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'enabled'); +assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'enabled'); - mock_web.enableFaults(); - mock_web.waitFaults(1); +mock_web.enableFaults(); +mock_web.waitFaults(1); - const qs1 = mock_web.queryStats(); +const qs1 = mock_web.queryStats(); - sleep(20 * 1000); +sleep(20 * 1000); - const qs2 = mock_web.queryStats(); +const qs2 = mock_web.queryStats(); - // Verify free monitoring stops but tolerate one additional collection - assert.gte(qs1.metrics + 1, qs2.metrics); - assert.eq(qs1.registers, qs2.registers); +// Verify free monitoring stops but tolerate one additional collection +assert.gte(qs1.metrics + 1, qs2.metrics); +assert.eq(qs1.registers, qs2.registers); - // Halt causes us to disable free monitoring, not return it to initial state. - assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'disabled'); - assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'disabled'); +// Halt causes us to disable free monitoring, not return it to initial state. +assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'disabled'); +assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'disabled'); - // Disable the fault so we can re-enable again - mock_web.disableFaults(); +// Disable the fault so we can re-enable again +mock_web.disableFaults(); - // Enable it again to be sure we can resume - assert.commandWorked(rst.getPrimary().adminCommand({setFreeMonitoring: 1, action: "enable"})); - WaitForRegistration(rst.getPrimary()); - WaitForRegistration(rst.getSecondary()); +// Enable it again to be sure we can resume +assert.commandWorked(rst.getPrimary().adminCommand({setFreeMonitoring: 1, action: "enable"})); +WaitForRegistration(rst.getPrimary()); +WaitForRegistration(rst.getSecondary()); - sleep(20 * 1000); +sleep(20 * 1000); - assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'enabled'); - assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'enabled'); +assert.eq(FreeMonGetServerStatus(rst.getPrimary()).state, 'enabled'); +assert.eq(FreeMonGetServerStatus(rst.getSecondary()).state, 'enabled'); - rst.stopSet(); +rst.stopSet(); - mock_web.stop(); +mock_web.stop(); })(); |