Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Run logfile analysis in cluster case too.

This commit is contained in:
Willi Goesgens 2015-02-01 12:38:04 +01:00
parent 436ac1adfc
commit 1c0c259d03
1 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
js/server/modules/org/arangodb/testing.js
View File

@ -367,21 +367,26 @@ function startInstance (protocol, options, addArgs, testname) {
return instanceInfo;
}
function readImportantLogLines(logFilename) {
function readImportantLogLines(logPath) {
var i, j;
var importantLines = [];
var buf = fs.readBuffer(logFilename);
var i;
var lineStart = 0;
var maxBuffer = buf.length;
for (i = 0; i < maxBuffer; i++) {
if (buf[i] === 10) { // \n
var line = buf.asciiSlice(lineStart, i - 1);
// filter out regular INFO lines, and test related messages
if ((line.search(" INFO ") < 0) &&
(line.search("WARNING about to execute:") < 0)) {
importantLines.push(line);
var list=fs.list(logPath);
for (i = 0; i < list.length; i++) {
if (list[i].slice(0,3) === 'log') {
var buf = fs.readBuffer(fs.join(logPath,list[i]));
var lineStart = 0;
var maxBuffer = buf.length;
for (j = 0; j < maxBuffer; j++) {
if (buf[j] === 10) { // \n
var line = buf.asciiSlice(lineStart, j - 1);
// filter out regular INFO lines, and test related messages
if ((line.search(" INFO ") < 0) &&
(line.search("WARNING about to execute:") < 0)) {
importantLines.push(line);
}
lineStart = j + 1;
}
}
lineStart = i + 1;
}
}
return importantLines;
@ -454,10 +459,11 @@ function checkInstanceAlive(instanceInfo, options) {
function shutdownInstance (instanceInfo, options) {
if (!checkInstanceAlive(instanceInfo, options)) {
print("Server already dead, doing nothing. This shouldn't happen?");
print("Server already dead, doing nothing. This shouldn't happen?");
}
if (options.cluster) {
var rc = instanceInfo.kickstarter.shutdown();
instanceInfo.importantLogLines = readImportantLogLines(instanceInfo.tmpDataDir);
if (options.cleanup) {
instanceInfo.kickstarter.cleanup();
}
@ -500,7 +506,7 @@ function shutdownInstance (instanceInfo, options) {
else {
wait(1);
}
}
}
else if (instanceInfo.exitStatus.status !== "TERMINATED") {
if (instanceInfo.exitStatus.hasOwnProperty('signal')) {
print("Server shut down with : " + yaml.safeDump(instanceInfo.exitStatus) + " marking build as crashy.");
@ -520,8 +526,7 @@ function shutdownInstance (instanceInfo, options) {
else {
print("Server already dead, doing nothing.");
}
instanceInfo.importantLogLines = readImportantLogLines(fs.join(instanceInfo.tmpDataDir, "log"));
instanceInfo.importantLogLines = readImportantLogLines(instanceInfo.tmpDataDir);
}
cleanupDirectories = cleanupDirectories.concat([instanceInfo.tmpDataDir, instanceInfo.flatTmpDataDir]);