You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
116 lines
3.8 KiB
116 lines
3.8 KiB
'use strict';
|
|
|
|
function uuid() {
|
|
return (Math.random()*1e15).toString(32) + "-" + (Math.random()*1e15).toString(32);
|
|
}
|
|
|
|
/**
|
|
* This is a local assignment, this keeps track on how long an assignment takes THIS worker.
|
|
*
|
|
* @param id
|
|
* @param type
|
|
* @param timeStart
|
|
* @constructor
|
|
*/
|
|
function Job(id, type, timeStart, agentId, prerequisites) {
|
|
this.id = id;
|
|
this.type = type;
|
|
this.agentId = agentId;
|
|
|
|
this.timeStart = timeStart;
|
|
this.timeResumed = timeStart;
|
|
this.timePaused = 0;
|
|
this.elapsedTime = 0;
|
|
this.elapsedTimeWithPause = 0;
|
|
this.endOfDayPause = false;
|
|
|
|
this.paused = false;
|
|
this.finished = false;
|
|
|
|
this.duration = new DurationData();
|
|
this.prediction = new DurationStats();
|
|
this.startupTime = new DurationData();
|
|
this.predictedStartupTime = new DurationStats();
|
|
|
|
this.prerequisites = prerequisites;
|
|
}
|
|
|
|
Job.prototype.prerequisiteFinished = function(params) {
|
|
var uuid = params.uuid;
|
|
for (var i = 0; i < this.prerequisites.length; i++) {
|
|
var prereq = this.prerequisites[i];
|
|
if (prereq.uuid == uuid) {
|
|
prereq.times.setData(params.duration);
|
|
break;
|
|
}
|
|
}
|
|
};
|
|
|
|
Job.prototype.watchingPrerequisite = function(preliminaryStats, uuid) {
|
|
for (var i = 0; i < this.prerequisites.length; i++) {
|
|
var prereq = this.prerequisites[i];
|
|
if (prereq.uuid == uuid) {
|
|
prereq.stats.setData(preliminaryStats);
|
|
this.predictedStartupTime.useHighest(preliminaryStats);
|
|
break;
|
|
}
|
|
}
|
|
};
|
|
|
|
Job.prototype.finalizePrerequisites = function() {
|
|
for (var i = 0; i < this.prerequisites.length; i++) {
|
|
this.startupTime.useHighest(this.prerequisites[i].times);
|
|
}
|
|
};
|
|
|
|
Job.prototype.finish = function(time) {
|
|
this.finished = true;
|
|
this.elapsedTime += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.elapsedTimeWithPause += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.finalizePrerequisites();
|
|
|
|
this.duration.calculateDuration(time, this.timeStart, this.elapsedTime, this.elapsedTimeWithPause, this.startupTime);
|
|
};
|
|
|
|
Job.prototype.pause = function(time, endOfDay) {
|
|
// if this is the endOfDay AND the job is paused, count the pause time and set the endOfDay pause to true
|
|
if (endOfDay == true && this.paused == true) {
|
|
this.elapsedTimeWithPause += new Date(time).getTime() - new Date(this.timePaused).getTime();
|
|
this.endOfDayPause = true;
|
|
}
|
|
// if this is the endOfDay AND the job is NOT paused, pause the job, increment the timers
|
|
else if (endOfDay == true && this.paused == false) {
|
|
this.elapsedTimeWithPause += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.elapsedTime += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.endOfDayPause = true;
|
|
}
|
|
else if (this.paused == false) {
|
|
this.elapsedTimeWithPause += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.elapsedTime += new Date(time).getTime() - new Date(this.timeResumed).getTime();
|
|
this.timePaused = time;
|
|
this.paused = true;
|
|
}
|
|
};
|
|
|
|
Job.prototype.resume = function(time, startOfDay) {
|
|
// if the job was paused because of the endOfDay, resume it and set the timeResumed to now
|
|
if (this.endOfDayPause == true && startOfDay == true && this.paused == false) {
|
|
this.timeResumed = time;
|
|
this.endOfDayPause = false;
|
|
}
|
|
// if the job was paused before the endOfDay, keep it paused, but set the paused time to now.
|
|
else if (this.endOfDayPause == true && startOfDay == true && this.paused == true) {
|
|
this.timePaused = time;
|
|
this.endOfDayPause = false;
|
|
}
|
|
// if this is NOT the start of day and the job was paused, resume job, increment
|
|
else if (startOfDay == false && this.paused == true) {
|
|
this.elapsedTimeWithPause += new Date(time).getTime() - new Date(this.timePaused).getTime();
|
|
this.timeResumed = time;
|
|
this.paused = false;
|
|
}
|
|
|
|
|
|
};
|
|
|
|
|