edu.rit.pj.cluster

Class JobScheduler

java.lang.Object

edu.rit.pj.cluster.JobScheduler

All Implemented Interfaces:

JobSchedulerRef

public class JobScheduler
extends java.lang.Object
implements JobSchedulerRef

Class JobScheduler is the main program for the PJ Job Scheduler Daemon process for a parallel computer.

Run the Job Scheduler Daemon on the cluster's frontend processor by typing this command:

java edu.rit.pj.cluster.JobScheduler configfile
configfile = Configuration file name

For further information about the configuration file, see class Configuration.

Method Summary

Modifier and Type	Method and Description
void	backendFailed(JobFrontendRef theJobFrontend, java.lang.String name) Report that a backend node failed.
void	cancelJob(JobFrontendRef theJobFrontend, java.lang.String errmsg) Cancel a job.
void	close() Close communication with this Job Scheduler.
void	jobFinished(JobFrontendRef theJobFrontend) Report that a job finished.
static void	main(java.lang.String[] args) Job Scheduler main program.
void	renewLease(JobFrontendRef theJobFrontend) Renew the lease on a job.
void	requestJob(JobFrontendRef theJobFrontend, java.lang.String username, int Nn, int Np, int Nt) Request that a job be scheduled.

Methods inherited from class java.lang.Object

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

Method Detail

backendFailed

public void backendFailed(JobFrontendRef theJobFrontend,
                          java.lang.String name)
                   throws java.io.IOException

Report that a backend node failed.

Specified by:

backendFailed in interface JobSchedulerRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

name - Backend node name.

Throws:

java.io.IOException - Thrown if an I/O error occurred.

cancelJob

public void cancelJob(JobFrontendRef theJobFrontend,
                      java.lang.String errmsg)
               throws java.io.IOException

Cancel a job.

Specified by:

cancelJob in interface JobSchedulerRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

errmsg - Error message string.

Throws:

java.io.IOException - Thrown if an I/O error occurred.

jobFinished

public void jobFinished(JobFrontendRef theJobFrontend)
                 throws java.io.IOException

Report that a job finished.

Specified by:

jobFinished in interface JobSchedulerRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

Throws:

java.io.IOException - Thrown if an I/O error occurred.

renewLease

public void renewLease(JobFrontendRef theJobFrontend)
                throws java.io.IOException

Renew the lease on a job.

Specified by:

renewLease in interface JobSchedulerRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

Throws:

java.io.IOException - Thrown if an I/O error occurred.

requestJob

public void requestJob(JobFrontendRef theJobFrontend,
                       java.lang.String username,
                       int Nn,
                       int Np,
                       int Nt)
                throws java.io.IOException

Request that a job be scheduled.

Specified by:

requestJob in interface JobSchedulerRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

username - User name.

Nn - Number of backend nodes.

Np - Number of processes.

Nt - Number of CPUs per process. 0 means "all CPUs."

Throws:

java.io.IOException - Thrown if an I/O error occurred.

close

public void close()

Close communication with this Job Scheduler.

Specified by:

close in interface JobSchedulerRef

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Job Scheduler main program.

Throws:

java.lang.Exception