mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

SERVER-46922 Verify minimum number of reads for mirrored_reads.js

Browse Source
This commit is contained in:
Amirsaman Memaripour 2020-03-30 12:02:04 -04:00 committed by Evergreen Agent
parent 1f7a2d26e6
commit 73d13ccc6e
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
jstests/noPassthrough/mirror_reads.js
View File

@ -15,9 +15,12 @@ const kBurstCount = 1000;
const kDbName = "mirrored_reads_test";
const kCollName = "test";
function getMirroredReadsStats(rst) {
return rst.getPrimary().getDB(kDbName).serverStatus({mirroredReads: 1}).mirroredReads;
}
function sendAndCheckReads({rst, cmd, minRate, maxRate}) {
let startMirroredReads =
rst.getPrimary().getDB(kDbName).serverStatus({mirroredReads: 1}).mirroredReads;
let startMirroredReads = getMirroredReadsStats(rst);
jsTestLog(`Sending ${kBurstCount} request burst of ${tojson(cmd)} to primary`);
@ -30,15 +33,13 @@ function sendAndCheckReads({rst, cmd, minRate, maxRate}) {
// Verify that the reads have been observed on the primary
{
let currentMirroredReads =
rst.getPrimary().getDB(kDbName).serverStatus({mirroredReads: 1}).mirroredReads;
assert.eq(startMirroredReads.seen + kBurstCount, currentMirroredReads.seen);
let currentMirroredReads = getMirroredReadsStats(rst);
assert.lte(startMirroredReads.seen + kBurstCount, currentMirroredReads.seen);
}
// Verify that the reads mirrored to the secondaries have responded
assert.soon(() => {
let currentMirroredReads =
rst.getPrimary().getDB(kDbName).serverStatus({mirroredReads: 1}).mirroredReads;
let currentMirroredReads = getMirroredReadsStats(rst);
let readsSeen = currentMirroredReads.seen - startMirroredReads.seen;
let readsMirrored = currentMirroredReads.resolved - startMirroredReads.resolved;