mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 17:10:48 +01:00
Code Issues Releases Activity

SERVER-19110 Ignore failed operations in mixed_storage_version_replication.js

Browse Source
This commit is contained in:
Charlie Swanson 2015-06-24 10:45:52 -04:00
parent 34549ae64a
commit 51cd740ce1
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
jstests/multiVersion/mixed_storage_version_replication.js
View File

@ -86,8 +86,12 @@ var RandomOps = {
},
getRandomDoc: function(collection) {
var randIndex = Random.randInt(0, collection.find().count());
return collection.find().sort({$natural: 1}).skip(randIndex).limit(1)[0];
try {
var randIndex = Random.randInt(0, collection.find().count());
return collection.find().sort({$natural: 1}).skip(randIndex).limit(1)[0];
} catch(e) {
return undefined;
}
},
/*
@ -151,13 +155,17 @@ var RandomOps = {
if (coll === null || coll.find().count() === 0) {
return null; // No data, can't delete anything.
}
// If multithreaded, doc might be undefined.
var doc = this.getRandomDoc(coll);
if (doc === undefined) {
// If multithreaded, there could have been issues finding a random doc.
// If so, just skip this operation.
return;
}
if (this.verbose) {
print("Deleting:");
printjson(doc);
}
// If multithreaded, doc might not exist anymore.
try {
coll.remove(doc);
} catch(e) {
@ -175,8 +183,13 @@ var RandomOps = {
if (coll === null || coll.find().count() === 0) {
return null; // No data, can't update anything.
}
// If multithreaded, doc might be undefined.
var doc = this.getRandomDoc(coll);
if (doc === undefined) {
// If multithreaded, there could have been issues finding a random doc.
// If so, just skip this operation.
return;
}
var field = this.randomChoice(this.fieldNames);
var updateDoc = {$set: {}};
updateDoc.$set[field] = this.randomChoice(this.fieldValues);