summaryrefslogtreecommitdiff
path: root/jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js')
-rw-r--r--jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js19
1 files changed, 9 insertions, 10 deletions
diff --git a/jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js b/jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js
index 877016bea2b..72661493d5d 100644
--- a/jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js
+++ b/jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_isolation_repeated_reads.js
@@ -11,7 +11,6 @@ load('jstests/concurrency/fsm_workloads/multi_statement_transaction_atomicity_is
// for $config
var $config = extendWorkload($config, function($config, $super) {
-
$config.data.numReads = 5;
$config.states.repeatedRead = function repeatedRead(db, collName) {
@@ -26,17 +25,17 @@ var $config = extendWorkload($config, function($config, $super) {
const collectionDocs = collection.find().batchSize(batchSize).toArray();
assertWhenOwnColl.eq(this.numDocs, collectionDocs.length, () => {
return "txnNumber: " + tojson(this.session.getTxnNumber_forTesting()) +
- ", session id: " + tojson(this.session.getSessionId()) + ", read number: " +
- i + ", collection docs: " + tojson(collectionDocs);
+ ", session id: " + tojson(this.session.getSessionId()) +
+ ", read number: " + i + ", collection docs: " + tojson(collectionDocs);
});
if (prevDocuments) {
- assertAlways.sameMembers(prevDocuments,
- collectionDocs,
- () => "Document mismatch - previous documents: " +
- tojsononeline(prevDocuments) +
- ", current documents: " +
- tojsononeline(collectionDocs),
- bsonBinaryEqual); // Exact document matches.
+ assertAlways.sameMembers(
+ prevDocuments,
+ collectionDocs,
+ () => "Document mismatch - previous documents: " +
+ tojsononeline(prevDocuments) +
+ ", current documents: " + tojsononeline(collectionDocs),
+ bsonBinaryEqual); // Exact document matches.
}
prevDocuments = collectionDocs;
}