/
reaper_test.js
124 lines (109 loc) · 4.32 KB
/
reaper_test.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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
var mongodb = process.env['TEST_NATIVE'] != null ? require('../lib/mongodb').native() : require('../lib/mongodb').pure();
var useSSL = process.env['USE_SSL'] != null ? true : false;
var testCase = require('nodeunit').testCase,
debug = require('util').debug,
inspect = require('util').inspect,
nodeunit = require('nodeunit'),
gleak = require('../dev/tools/gleak'),
Db = mongodb.Db,
Cursor = mongodb.Cursor,
Collection = mongodb.Collection,
Server = mongodb.Server;
var MONGODB = 'integration_tests';
var client = null;
/**
* Retrieve the server information for the current
* instance of the db client
*
* @ignore
*/
exports.setUp = function(callback) {
var self = exports;
client = new Db(MONGODB, new Server("127.0.0.1", 27017, {auto_reconnect: true, poolSize: 4, ssl:useSSL}), {safe:false, native_parser: (process.env['TEST_NATIVE'] != null)});
client.open(function(err, db_p) {
if(numberOfTestsRun == (Object.keys(self).length)) {
// If first test drop the db
client.dropDatabase(function(err, done) {
callback();
});
} else {
return callback();
}
});
}
/**
* Retrieve the server information for the current
* instance of the db client
*
* @ignore
*/
exports.tearDown = function(callback) {
var self = this;
numberOfTestsRun = numberOfTestsRun - 1;
// Close connection
client.close();
callback();
}
exports.shouldCorrectlyAssertCorrectReaperBehavior = function(test) {
var reaperClient = new Db(MONGODB, new Server("127.0.0.1", 27017, {auto_reconnect: false, ssl:useSSL}), {safe:false, reaper:true, native_parser: (process.env['TEST_NATIVE'] != null)});
reaperClient.open(function(err, reaperClient) {
reaperClient._lastReaperTimestamp = (new Date().getTime() - 1000000);
var con = reaperClient.serverConfig.checkoutReader();
// Prime the reaper with a bogus call
reaperClient._callBackStore._notReplied["3"] = {start: (new Date().getTime() - 50000), 'raw': false, chained:null, connection:con};
reaperClient._callBackStore.once("3", function(err, result) {
reaperClient.close();
test.done();
})
reaperClient.collection("test", {safe:true}, function(err, col) {
// Does not matter
});
})
}
// // * - **reaperInterval** {Number, default:10000}, number of miliseconds between reaper wakups.
// // * - **reaperTimeout** {Number, default:30000}, the amount of time before a callback times out.
// exports.shouldHandleReaperKills = function(test) {
// var reaperClient = new Db(MONGODB, new Server("127.0.0.1", 27017, {auto_reconnect: false, ssl:useSSL}), {reaper:true, reaperInterval:0, reaperTimeout:0, native_parser: (process.env['TEST_NATIVE'] != null)});
// reaperClient.open(function(err, db) {
// db.collection("shouldHandleReaperKills").insert({a:1}, {safe:true}, function(err, result) {
// console.log("============================================")
// db.collection("shouldHandleReaperKills").insert({a:1}, {safe:true}, function(err, result) {
// // Prime the reaper with a bogus call
// db._callBackStore._notReplied["3"] = {start: (new Date().getTime() - 50000), 'raw': false, chained:null, connection:null};
// db.collection("shouldHandleReaperKills").findOne(function(err, item) {
// db.close();
// test.done();
// })
// });
// });
// // reaperClient._lastReaperTimestamp = (new Date().getTime() - 1000000);
// // var con = reaperClient.serverConfig.checkoutReader();
// // // Prime the reaper with a bogus call
// // reaperClient._callBackStore._notReplied["3"] = {start: (new Date().getTime() - 50000), 'raw': false, chained:null, connection:con};
// // reaperClient._callBackStore.once("3", function(err, result) {
// // reaperClient.close();
// // test.done();
// // })
// // reaperClient.collection("test", {safe:true}, function(err, col) {
// // // Does not matter
// // });
// })
// }
/**
* Retrieve the server information for the current
* instance of the db client
*
* @ignore
*/
exports.noGlobalsLeaked = function(test) {
var leaks = gleak.detectNew();
test.equal(0, leaks.length, "global var leak detected: " + leaks.join(', '));
test.done();
}
/**
* Retrieve the server information for the current
* instance of the db client
*
* @ignore
*/
var numberOfTestsRun = Object.keys(this).length - 2;