Package uk.ac.manchester.spinnaker.nmpi.jobmanager

Class JobManager

java.lang.Object

uk.ac.manchester.spinnaker.nmpi.jobmanager.JobManager

All Implemented Interfaces:

JobManagerInterface, NMPIQueueListener

@Service("service")
public class JobManager
extends Object
implements NMPIQueueListener, JobManagerInterface

The manager of jobs; synchronises and manages all the ongoing and future processes and machines.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	STATUS_UPDATE_PERIOD	Seconds between status updates.

Fields inherited from interface uk.ac.manchester.spinnaker.nmpi.model.job.JobManagerInterface

APPLICATION_JSON, APPLICATION_OCTET_STREAM, APPLICATION_ZIP, JOB_PROCESS_MANAGER, PATH, SETUP_SCRIPT, TEXT_PLAIN

Constructor Summary

Constructors

Constructor	Description
JobManager(URL baseUrl)	Create a job manager.

Method Summary

Modifier and Type	Method	Description
void	addJob(Job job)	Adds a job to the listener.
void	addOutput(String projectId, int id, String output, InputStream input)
void	addProvenance(int id, List<String> path, String value)
void	appendLog(int id, String logToAppend)
JobMachineAllocated	checkMachineLease(int id, int waitTime)
void	extendJobMachineLease(int id, double runTime)
ChipCoordinates	getChipCoordinates(int id, String machineName, int chipX, int chipY)
SpinnakerMachine	getJobMachine(int id, int nCores, int nChips, int nBoards, double runTime)
Response	getJobProcessManager()
SpinnakerMachine	getLargestJobMachine(int id, double runTime)
Job	getNextJob(String executerId)
Response	getSetupScript()
void	releaseMachine(int id, String machineName)
void	setExecutorExited(String executorId, String logToAppend)	Mark the executor as having exited.
void	setJobError(String projectId, int id, String error, String logToAppend, String baseDirectory, List<String> outputs, RemoteStackTrace stackTrace)
void	setJobFinished(String projectId, int id, String logToAppend, String baseDirectory, List<String> outputs)
void	setMachinePower(int id, String machineName, boolean powerOn)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

STATUS_UPDATE_PERIOD

public static final int STATUS_UPDATE_PERIOD

Seconds between status updates.

See Also:

• Constant Field Values

Constructor Details

JobManager

public JobManager(URL baseUrl)

Create a job manager.

Parameters:

baseUrl - The URL of the REST service of the manager.

Method Details

addJob

public void addJob(Job job)
            throws IOException

Description copied from interface: NMPIQueueListener

Adds a job to the listener.

Specified by:

addJob in interface NMPIQueueListener

Parameters:

job - The job to add.

Throws:

IOException - If anything goes wrong.

getNextJob

public Job getNextJob(String executerId)

Specified by:

getNextJob in interface JobManagerInterface

getLargestJobMachine

public SpinnakerMachine getLargestJobMachine(int id,
 double runTime)

Specified by:

getLargestJobMachine in interface JobManagerInterface

getJobMachine

public SpinnakerMachine getJobMachine(int id,
 int nCores,
 int nChips,
 int nBoards,
 double runTime)

Specified by:

getJobMachine in interface JobManagerInterface

releaseMachine

public void releaseMachine(int id,
 String machineName)

Specified by:

releaseMachine in interface JobManagerInterface

setMachinePower

public void setMachinePower(int id,
 String machineName,
 boolean powerOn)

Specified by:

setMachinePower in interface JobManagerInterface

getChipCoordinates

public ChipCoordinates getChipCoordinates(int id,
 String machineName,
 int chipX,
 int chipY)

Specified by:

getChipCoordinates in interface JobManagerInterface

extendJobMachineLease

public void extendJobMachineLease(int id,
 double runTime)

Specified by:

extendJobMachineLease in interface JobManagerInterface

checkMachineLease

public JobMachineAllocated checkMachineLease(int id,
 int waitTime)

Specified by:

checkMachineLease in interface JobManagerInterface

appendLog

public void appendLog(int id,
 String logToAppend)

Specified by:

appendLog in interface JobManagerInterface

addOutput

public void addOutput(String projectId,
 int id,
 String output,
 InputStream input)

Specified by:

addOutput in interface JobManagerInterface

addProvenance

public void addProvenance(int id,
 List<String> path,
 String value)

Specified by:

addProvenance in interface JobManagerInterface

setJobFinished

public void setJobFinished(String projectId,
 int id,
 String logToAppend,
 String baseDirectory,
 List<String> outputs)

Specified by:

setJobFinished in interface JobManagerInterface

setJobError

public void setJobError(String projectId,
 int id,
 String error,
 String logToAppend,
 String baseDirectory,
 List<String> outputs,
 RemoteStackTrace stackTrace)

Specified by:

setJobError in interface JobManagerInterface

setExecutorExited

public void setExecutorExited(String executorId,
 String logToAppend)

Mark the executor as having exited.

Parameters:

executorId - The ID of the executor in question

logToAppend - The log messages

getJobProcessManager

public Response getJobProcessManager()

Specified by:

getJobProcessManager in interface JobManagerInterface

getSetupScript

public Response getSetupScript()
                        throws IOException

Specified by:

getSetupScript in interface JobManagerInterface

Throws:

IOException