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
|
/*
* Helper functions which connect to a server, and check its logs for particular strings.
*/
var checkLog;
(function() {
"use strict";
if (checkLog) {
return; // Protect against this file being double-loaded.
}
checkLog = (function() {
var getGlobalLog = function(conn) {
var cmdRes;
try {
cmdRes = conn.adminCommand({getLog: 'global'});
} catch (e) {
// Retry with network errors.
print("checkLog ignoring failure: " + e);
return null;
}
return assert.commandWorked(cmdRes).log;
};
/*
* Calls the 'getLog' function at regular intervals on the provided connection 'conn' until
* the provided 'msg' is found in the logs, or 5 minutes have elapsed. Throws an exception
* on timeout.
*/
var contains = function(conn, msg) {
assert.soon(
function() {
var logMessages = getGlobalLog(conn);
if (logMessages === null) {
return false;
}
for (var i = 0; i < logMessages.length; i++) {
if (logMessages[i].indexOf(msg) != -1) {
return true;
}
}
return false;
},
'Could not find log entries containing the following message: ' + msg,
5 * 60 * 1000,
300);
};
/*
* Calls the 'getLog' function at regular intervals on the provided connection 'conn' until
* the provided 'msg' is found in the logs exactly 'expectedCount' times, or 5 minutes have
* elapsed.
* Throws an exception on timeout.
*/
var containsWithCount = function(conn, msg, expectedCount) {
var count = 0;
assert.soon(
function() {
var logMessages = getGlobalLog(conn);
if (logMessages === null) {
return false;
}
for (var i = 0; i < logMessages.length; i++) {
if (logMessages[i].indexOf(msg) != -1) {
count++;
}
}
return expectedCount === count;
},
'Expected ' + expectedCount + ', but instead saw ' + count +
' log entries containing the following message: ' + msg,
5 * 60 * 1000,
300);
};
return {contains: contains, containsWithCount: containsWithCount};
})();
})();
|
