summaryrefslogtreecommitdiff
path: root/jstests/noPassthrough/query_yield2.js
diff options
context:
space:
mode:
authorJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:17:50 -0500
committerJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:18:14 -0500
commit4ae691e8edc87d0e3cfb633bb91c328426be007b (patch)
tree52079a593f54382ca13a2e741633eab1b6271893 /jstests/noPassthrough/query_yield2.js
parenta025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff)
downloadmongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/noPassthrough/query_yield2.js')
-rw-r--r--jstests/noPassthrough/query_yield2.js236
1 files changed, 124 insertions, 112 deletions
diff --git a/jstests/noPassthrough/query_yield2.js b/jstests/noPassthrough/query_yield2.js
index 5997fa15ec8..8e5dc8dc4ec 100644
--- a/jstests/noPassthrough/query_yield2.js
+++ b/jstests/noPassthrough/query_yield2.js
@@ -1,138 +1,150 @@
-if (0) { // Test disabled until SERVER-8579 is finished. Reminder ticket: SERVER-8342
+if (0) { // Test disabled until SERVER-8579 is finished. Reminder ticket: SERVER-8342
-var currentOp;
-var N;
-var i;
-var t;
-var q;
-var len;
-var num;
-var start;
-var insertTime;
+ var currentOp;
+ var N;
+ var i;
+ var t;
+ var q;
+ var len;
+ var num;
+ var start;
+ var insertTime;
-load( "jstests/libs/slow_weekly_util.js" );
-testServer = new SlowWeeklyMongod( "query_yield2" );
-db = testServer.getDB( "test" );
+ load("jstests/libs/slow_weekly_util.js");
+ testServer = new SlowWeeklyMongod("query_yield2");
+ db = testServer.getDB("test");
-t = db.query_yield2;
-t.drop();
+ t = db.query_yield2;
+ t.drop();
-N = 200;
-i = 0;
+ N = 200;
+ i = 0;
-q = function() { var x=this.n; for ( var i=0; i<25000; i++ ) { x = x * 2; } return false; };
-
-print( "Shell ==== Creating test.query_yield2 collection ..." );
-print( "Shell ==== Adding documents until a time-wasting query takes over 2 seconds to complete" );
-while ( true ){
- function fill() {
- var bulk = t.initializeUnorderedBulkOp();
- for ( ; i < N; ++i ) {
- bulk.insert({ _id: i , n: 1 });
+ q = function() {
+ var x = this.n;
+ for (var i = 0; i < 25000; i++) {
+ x = x * 2;
}
- assert.writeOK(bulk.execute());
- }
- function timeQuery() {
- return Date.timeFunc(
- function() {
- assert.eq( 0 , t.find( q ).itcount() );
+ return false;
+ };
+
+ print("Shell ==== Creating test.query_yield2 collection ...");
+ print(
+ "Shell ==== Adding documents until a time-wasting query takes over 2 seconds to complete");
+ while (true) {
+ function fill() {
+ var bulk = t.initializeUnorderedBulkOp();
+ for (; i < N; ++i) {
+ bulk.insert({_id: i, n: 1});
}
- );
- }
- print( "Shell ==== Adding document IDs from " + i + " to " + (N - 1) );
- fill();
- print( "Shell ==== Running warm-up query 1" );
- timeQuery();
- print( "Shell ==== Running warm-up query 2" );
- timeQuery();
- print( "Shell ==== Running timed query ..." );
- time = timeQuery();
- print( "Shell ==== Query across " + N + " documents took " + time + " ms" );
- if ( time > 2000 ) {
- print( "Shell ==== Reached desired 2000 ms mark (at " + time + " ms), proceding to next step" );
- break;
+ assert.writeOK(bulk.execute());
+ }
+ function timeQuery() {
+ return Date.timeFunc(function() {
+ assert.eq(0, t.find(q).itcount());
+ });
+ }
+ print("Shell ==== Adding document IDs from " + i + " to " + (N - 1));
+ fill();
+ print("Shell ==== Running warm-up query 1");
+ timeQuery();
+ print("Shell ==== Running warm-up query 2");
+ timeQuery();
+ print("Shell ==== Running timed query ...");
+ time = timeQuery();
+ print("Shell ==== Query across " + N + " documents took " + time + " ms");
+ if (time > 2000) {
+ print("Shell ==== Reached desired 2000 ms mark (at " + time +
+ " ms), proceding to next step");
+ break;
+ }
+ N *= 2;
+ print("Shell ==== Did not reach 2000 ms, increasing fill point to " + N + " documents");
}
- N *= 2;
- print( "Shell ==== Did not reach 2000 ms, increasing fill point to " + N + " documents" );
-}
-print( "Shell ==== Testing db.currentOp to make sure nothing is in progress" );
-print( "Shell ==== Dump of db.currentOp:" );
-currentOp = db.currentOp();
-print( tojson( currentOp ) );
-len = currentOp.inprog.length;
-if ( len ) {
- print( "Shell ==== This test is broken: db.currentOp().inprog.length is " + len );
- throw Error("query_yield2.js test is broken");
-}
-print( "Shell ==== The test is working so far: db.currentOp().inprog.length is " + len );
+ print("Shell ==== Testing db.currentOp to make sure nothing is in progress");
+ print("Shell ==== Dump of db.currentOp:");
+ currentOp = db.currentOp();
+ print(tojson(currentOp));
+ len = currentOp.inprog.length;
+ if (len) {
+ print("Shell ==== This test is broken: db.currentOp().inprog.length is " + len);
+ throw Error("query_yield2.js test is broken");
+ }
+ print("Shell ==== The test is working so far: db.currentOp().inprog.length is " + len);
-print( "Shell ==== Starting parallel shell to test if slow query will yield to write" );
-join = startParallelShell( "print( 0 == db.query_yield2.find( function(){ var x=this.n; for ( var i=0; i<50000; i++ ){ x = x * 2; } return false; } ).itcount() ); " );
+ print("Shell ==== Starting parallel shell to test if slow query will yield to write");
+ join = startParallelShell(
+ "print( 0 == db.query_yield2.find( function(){ var x=this.n; for ( var i=0; i<50000; i++ ){ x = x * 2; } return false; } ).itcount() ); ");
-print( "Shell ==== Waiting until db.currentOp().inprog becomes non-empty" );
-assert.soon(
- function(){
+ print("Shell ==== Waiting until db.currentOp().inprog becomes non-empty");
+ assert.soon(function() {
currentOp = db.currentOp();
len = currentOp.inprog.length;
- if ( len ) {
- print( "Shell ==== Wait satisfied: db.currentOp().inprog.length is " + len );
- print( "Shell ==== Dump of db.currentOp:" );
- print( tojson( currentOp ) );
- print( "Shell ==== Checking if this currentOp is the query we are waiting for" );
- if ( currentOp.inprog[0].ns == "test.query_yield2" && currentOp.inprog[0].query["$where"] ) {
- print( "Shell ==== Yes, we found the query we are waiting for" );
+ if (len) {
+ print("Shell ==== Wait satisfied: db.currentOp().inprog.length is " + len);
+ print("Shell ==== Dump of db.currentOp:");
+ print(tojson(currentOp));
+ print("Shell ==== Checking if this currentOp is the query we are waiting for");
+ if (currentOp.inprog[0].ns == "test.query_yield2" &&
+ currentOp.inprog[0].query["$where"]) {
+ print("Shell ==== Yes, we found the query we are waiting for");
return true;
}
- if ( currentOp.inprog[0].ns == "" && currentOp.inprog[0].query["whatsmyuri"] ) {
- print( "Shell ==== No, we found a \"whatsmyuri\" query, waiting some more" );
+ if (currentOp.inprog[0].ns == "" && currentOp.inprog[0].query["whatsmyuri"]) {
+ print("Shell ==== No, we found a \"whatsmyuri\" query, waiting some more");
return false;
}
- print( "Shell ==== No, we found something other than our query or a \"whatsmyuri\", waiting some more" );
+ print(
+ "Shell ==== No, we found something other than our query or a \"whatsmyuri\", waiting some more");
return false;
}
return len > 0;
- } , "Wait failed, db.currentOp().inprog never became non-empty" , 2000 , 1
-);
+ }, "Wait failed, db.currentOp().inprog never became non-empty", 2000, 1);
-print( "Shell ==== Now that we have seen db.currentOp().inprog show that our query is running, we start the real test" );
-num = 0;
-start = new Date();
-while ( ( (new Date()).getTime() - start ) < ( time * 2 ) ) {
- if ( num == 0 ) {
- print( "Shell ==== Starting loop " + num + ", inserting 1 document" );
- }
- insertTime = Date.timeFunc( function() { t.insert({ x: 1 } ); });
- currentOp = db.currentOp();
- len = currentOp.inprog.length;
- print( "Shell ==== Time to insert document " + num + " was " + insertTime + " ms, db.currentOp().inprog.length is " + len );
- if ( num++ == 0 ) {
- if ( len != 1 ) {
- print( "Shell ==== TEST FAILED! db.currentOp().inprog.length is " + len );
- print( "Shell ==== Dump of db.currentOp:" );
- print( tojson( currentOp ) );
- throw Error("TEST FAILED!");
+ print(
+ "Shell ==== Now that we have seen db.currentOp().inprog show that our query is running, we start the real test");
+ num = 0;
+ start = new Date();
+ while (((new Date()).getTime() - start) < (time * 2)) {
+ if (num == 0) {
+ print("Shell ==== Starting loop " + num + ", inserting 1 document");
+ }
+ insertTime = Date.timeFunc(function() {
+ t.insert({x: 1});
+ });
+ currentOp = db.currentOp();
+ len = currentOp.inprog.length;
+ print("Shell ==== Time to insert document " + num + " was " + insertTime +
+ " ms, db.currentOp().inprog.length is " + len);
+ if (num++ == 0) {
+ if (len != 1) {
+ print("Shell ==== TEST FAILED! db.currentOp().inprog.length is " + len);
+ print("Shell ==== Dump of db.currentOp:");
+ print(tojson(currentOp));
+ throw Error("TEST FAILED!");
+ }
+ }
+ assert.gt(200,
+ insertTime,
+ "Insert took too long (" + insertTime + " ms), should be less than 200 ms");
+ if (currentOp.inprog.length == 0) {
+ break;
}
}
- assert.gt( 200, insertTime, "Insert took too long (" + insertTime + " ms), should be less than 200 ms" );
- if ( currentOp.inprog.length == 0 ) {
- break;
- }
-}
-
-print( "Shell ==== Finished inserting documents, reader also finished" );
-print( "Shell ==== Waiting for parallel shell to exit" );
-join();
-currentOp = db.currentOp();
-len = currentOp.inprog.length;
-if ( len != 0 ) {
- print( "Shell ==== Final sanity check FAILED! db.currentOp().inprog.length is " + len );
- print( "Shell ==== Dump of db.currentOp:" );
- print( tojson( currentOp ) );
- throw Error("TEST FAILED!");
-}
-print( "Shell ==== Test completed successfully, shutting down server" );
-testServer.stop();
+ print("Shell ==== Finished inserting documents, reader also finished");
+ print("Shell ==== Waiting for parallel shell to exit");
+ join();
+ currentOp = db.currentOp();
+ len = currentOp.inprog.length;
+ if (len != 0) {
+ print("Shell ==== Final sanity check FAILED! db.currentOp().inprog.length is " + len);
+ print("Shell ==== Dump of db.currentOp:");
+ print(tojson(currentOp));
+ throw Error("TEST FAILED!");
+ }
+ print("Shell ==== Test completed successfully, shutting down server");
+ testServer.stop();
}