blob: ac70861f8b272c3974c12a7486e08f0baea4ea77 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
// db = db.getSisterDB("concurrency")
// db.dropDatabase();
//
// NRECORDS=10*1024*1024 // this needs to be relatively big so that
// // the update() will take a while.
//
// print("loading data (will take a while; progress msg every 1024*1024 documents)")
// for (i=0; i<(10*1024*1024); i++) {
// db.conc.insert({x:i})
// if ((i%(1024*1024))==0)
// print("loaded " + i/(1024*1024) + " mibi-records")
// }
//
// print("making an index (will take a while)")
// db.conc.ensureIndex({x:1})
//
// var c1=db.conc.count({x:{$lt:NRECORDS}})
// // this is just a flag that the child will toggle when it's done.
// db.concflag.update({}, {inprog:true}, true)
//
// updater=startParallelShell("db=db.getSisterDB('concurrency');\
// db.conc.update({}, {$inc:{x: "+NRECORDS+"}}, false, true);\
// print(db.getLastError());\
// db.concflag.update({},{inprog:false})");
//
// querycount=0;
// decrements=0;
// misses=0
// while (1) {
// if (db.concflag.findOne().inprog) {
// c2=db.conc.count({x:{$lt:10*1024*1024}})
// print(c2)
// querycount++;
// if (c2<c1)
// decrements++;
// else
// misses++;
// c1 = c2;
// } else
// break;
// sleep(10);
// }
// print(querycount + " queries, " + decrements + " decrements, " + misses + " misses");
//
// updater() // wait()
|
