1 function newTaskState() {
2 return {"complete_count": 0,
9 function addToLogViewer(logViewer, lines, taskState) {
10 var re = /((\d\d\d\d)-(\d\d)-(\d\d))_((\d\d):(\d\d):(\d\d)) ([a-z0-9]{5}-[a-z0-9]{5}-[a-z0-9]{15}) (\d+) (\d+)? (.*)/;
13 for (var a in lines) {
14 var v = lines[a].match(re);
17 var ts = new Date(Date.UTC(v[2], v[3], v[4], v[6], v[7], v[8]));
20 if (typeof v[11] === 'undefined') {
31 if (!taskState.hasOwnProperty(v11)) {
33 taskState.task_count += 1;
36 if (/^stderr /.test(message)) {
37 message = message.substr(7);
38 if (/^crunchstat: /.test(message)) {
40 message = message.substr(12);
41 } else if (/^srun: /.test(message) || /^slurmd/.test(message)) {
42 type = "task-dispatch";
48 if (m = /^success in (\d+) second/.exec(message)) {
49 taskState[v11].outcome = "success";
50 taskState[v11].runtime = Number(m[1]);
51 taskState.complete_count += 1;
53 else if (m = /^failure \(\#\d+, (temporary|permanent)\) after (\d+) second/.exec(message)) {
54 taskState[v11].outcome = "failure";
55 taskState[v11].runtime = Number(m[2]);
56 taskState.failure_count += 1;
57 if (m[1] == "permanent") {
58 taskState.incomplete_count += 1;
61 else if (m = /^child \d+ started on ([^.]*)\.(\d+)/.exec(message)) {
62 taskState[v11].node = m[1];
63 taskState[v11].slot = m[2];
64 if (taskState.nodes.indexOf(m[1], 0) == -1) {
65 taskState.nodes.push(m[1]);
67 for (var i in items) {
69 if (items[i].taskid === v11) {
76 type = "task-dispatch";
78 node = taskState[v11].node;
79 slot = taskState[v11].slot;
85 id: logViewer.items.length,
87 timestamp: ts.toLocaleDateString() + " " + ts.toLocaleTimeString(),
95 console.log("Did not parse: " + lines[a]);
101 function sortById(a, b, opt) {
105 if (a["id"] > b["id"]) {
108 if (a["id"] < b["id"]) {
114 function sortByTask(a, b, opt) {
118 if (aa["taskid"] === "" && bb["taskid"] !== "") {
121 if (aa["taskid"] !== "" && bb["taskid"] === "") {
125 if (aa["taskid"] !== "" && bb["taskid"] !== "") {
126 if (aa["taskid"] > bb["taskid"]) {
129 if (aa["taskid"] < bb["taskid"]) {
134 return sortById(a, b, opt);
137 function sortByNode(a, b, opt) {
141 if (aa["node"] === "" && bb["node"] !== "") {
144 if (aa["node"] !== "" && bb["node"] === "") {
148 if (aa["node"] !== "" && bb["node"] !== "") {
149 if (aa["node"] > bb["node"]) {
152 if (aa["node"] < bb["node"]) {
157 if (aa["slot"] !== "" && bb["slot"] !== "") {
158 if (aa["slot"] > bb["slot"]) {
161 if (aa["slot"] < bb["slot"]) {
166 return sortById(a, b, opt);
170 function dumbPluralize(n, s, p) {
171 if (typeof p === 'undefined') {
174 if (n == 0 || n > 1) {
175 return n + " " + (s + p);
181 function generateJobOverview(id, logViewer, taskState) {
184 var first = logViewer.items[1];
185 var last = logViewer.items[logViewer.items.length-1];
189 html += "Started at " + first.values().timestamp;
191 var duration = (last.values().ts.getTime() - first.values().ts.getTime()) / 1000;
197 if (duration >= 3600) {
198 hours = Math.floor(duration / 3600);
199 duration -= (hours * 3600);
201 if (duration >= 60) {
202 minutes = Math.floor(duration / 60);
203 duration -= (minutes * 60);
207 var tcount = taskState.task_count;
209 html += ". Ran " + dumbPluralize(tcount, " task") + " over ";
211 html += dumbPluralize(hours, " hour");
214 html += " " + dumbPluralize(minutes, " minute");
217 html += " " + dumbPluralize(seconds, " second");
220 html += " using " + dumbPluralize(taskState.nodes.length, " node");
222 html += ". " + dumbPluralize(taskState.complete_count, "task") + " completed";
223 html += ", " + dumbPluralize(taskState.incomplete_count, "task") + " incomplete";
224 html += " (" + dumbPluralize(taskState.failure_count, " failure") + ")";
226 html += ". Finished at " + last.values().timestamp + ".";
233 function gotoPage(n, logViewer, page, id) {
234 if (n < 0) { return; }
235 if (n*page > logViewer.matchingItems.length) { return; }
236 logViewer.page_offset = n;
237 logViewer.show(n*page, page);
240 function updatePaging(id, logViewer, page) {
242 var i = logViewer.matchingItems.length;
244 for (n = 0; (n*page) < i; n += 1) {
245 if (n == logViewer.page_offset) {
246 p += "<span class='log-viewer-page-num'>" + (n+1) + "</span> ";
248 p += "<a href=\"#\" class='log-viewer-page-num log-viewer-page-" + n + "'>" + (n+1) + "</a> ";
252 for (n = 0; (n*page) < i; n += 1) {
254 $(".log-viewer-page-" + n).on("click", function() {
255 gotoPage(n, logViewer, page, id);
261 if (logViewer.page_offset == 0) {
262 $(".log-viewer-page-up").addClass("text-muted");
264 $(".log-viewer-page-up").removeClass("text-muted");
267 if (logViewer.page_offset == (n-1)) {
268 $(".log-viewer-page-down").addClass("text-muted");
270 $(".log-viewer-page-down").removeClass("text-muted");
274 function nextPage(logViewer, page, id) {
275 gotoPage(logViewer.page_offset+1, logViewer, page, id);
278 function prevPage(logViewer, page, id) {
279 gotoPage(logViewer.page_offset-1, logViewer, page, id);