jstests/core/cursora.js


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
46
47
48
49
50
51
52
53
54
55
56
57

// @tags: [
//   requires_fastcount,
//   requires_getmore,
//   requires_non_retryable_writes,
//   # Uses $where operator
//   requires_scripting,
//   sbe_incompatible,
//   uses_multiple_connections,
//   uses_parallel_shell,
// ]

(function() {
"use strict";

const t = db.cursora;

function run(n) {
    if (!isNumber(n)) {
        assert(isNumber(n), "cursora.js isNumber");
    }
    t.drop();

    let bulk = t.initializeUnorderedBulkOp();
    for (let i = 0; i < n; i++)
        bulk.insert({_id: i});
    assert.commandWorked(bulk.execute());

    const join = startParallelShell("sleep(50);" +
                                    "db.cursora.remove({});");

    let num;
    try {
        let start = new Date();
        num = t.find(function() {
                   let num = 2;
                   for (let x = 0; x < 1000; x++)
                       num += 2;
                   return num > 0;
               })
                  .sort({_id: -1})
                  .itcount();
    } catch (e) {
        print("cursora.js FAIL " + e);
        join();
        throw e;
    }

    join();

    assert.eq(0, t.count());
    if (n == num)
        print("cursora.js warning: shouldn't have counted all  n: " + n + " num: " + num);
}

run(1500);
run(5000);
})();