diff options
Diffstat (limited to 'jstests/free_mon/free_mon_rs_resend.js')
-rw-r--r-- | jstests/free_mon/free_mon_rs_resend.js | 91 |
1 files changed, 45 insertions, 46 deletions
diff --git a/jstests/free_mon/free_mon_rs_resend.js b/jstests/free_mon/free_mon_rs_resend.js index 464caf396e5..2241524f37f 100644 --- a/jstests/free_mon/free_mon_rs_resend.js +++ b/jstests/free_mon/free_mon_rs_resend.js @@ -3,64 +3,63 @@ load("jstests/free_mon/libs/free_mon.js"); (function() { - 'use strict'; +'use strict'; - let mock_web = new FreeMonWebServer(FAULT_RESEND_REGISTRATION_AT_3); - let mock_web_sec = new FreeMonWebServer(FAULT_RESEND_REGISTRATION_ONCE, true); +let mock_web = new FreeMonWebServer(FAULT_RESEND_REGISTRATION_AT_3); +let mock_web_sec = new FreeMonWebServer(FAULT_RESEND_REGISTRATION_ONCE, true); - mock_web.start(); - mock_web_sec.start(); +mock_web.start(); +mock_web_sec.start(); - const rst = new ReplSetTest({ - name: "free_mon_rs_register", - nodes: [ - { - setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web.getURL(), - verbose: 1, - }, - { - setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web_sec.getURL(), - verbose: 1, - } - ] - }); +const rst = new ReplSetTest({ + name: "free_mon_rs_register", + nodes: [ + { + setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web.getURL(), + verbose: 1, + }, + { + setParameter: "cloudFreeMonitoringEndpointURL=" + mock_web_sec.getURL(), + verbose: 1, + } + ] +}); - rst.startSet(); - rst.initiate(); - rst.awaitReplication(); +rst.startSet(); +rst.initiate(); +rst.awaitReplication(); - sleep(10 * 1000); - assert.eq(0, mock_web.queryStats().registers, "mongod registered without enabling free_mod"); - assert.eq( - 0, mock_web_sec.queryStats().registers, "mongod registered without enabling free_mod"); +sleep(10 * 1000); +assert.eq(0, mock_web.queryStats().registers, "mongod registered without enabling free_mod"); +assert.eq(0, mock_web_sec.queryStats().registers, "mongod registered without enabling free_mod"); - assert.commandWorked(rst.getPrimary().adminCommand({setFreeMonitoring: 1, action: "enable"})); - WaitForRegistration(rst.getPrimary()); +assert.commandWorked(rst.getPrimary().adminCommand({setFreeMonitoring: 1, action: "enable"})); +WaitForRegistration(rst.getPrimary()); - mock_web.waitRegisters(1); - mock_web_sec.waitRegisters(1); +mock_web.waitRegisters(1); +mock_web_sec.waitRegisters(1); - 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.waitRegisters(2); - mock_web_sec.waitRegisters(2); - mock_web_sec.disableFaults(); +mock_web.waitRegisters(2); +mock_web_sec.waitRegisters(2); +mock_web_sec.disableFaults(); - // Trigger resend on the secondary only - mock_web_sec.enableFaults(); - mock_web_sec.waitFaults(1); - mock_web_sec.waitRegisters(3); +// Trigger resend on the secondary only +mock_web_sec.enableFaults(); +mock_web_sec.waitFaults(1); +mock_web_sec.waitRegisters(3); - // Double check registers were as expected - const stats = mock_web.queryStats(); - assert.eq(stats.registers, 2); +// Double check registers were as expected +const stats = mock_web.queryStats(); +assert.eq(stats.registers, 2); - const stats_sec = mock_web_sec.queryStats(); - assert.gte(stats_sec.registers, 3); +const stats_sec = mock_web_sec.queryStats(); +assert.gte(stats_sec.registers, 3); - rst.stopSet(); +rst.stopSet(); - mock_web.stop(); - mock_web_sec.stop(); +mock_web.stop(); +mock_web_sec.stop(); })(); |