edu.rit.pj.cluster

Interface JobSchedulerRef

All Known Implementing Classes:

JobScheduler, JobSchedulerProxy

public interface JobSchedulerRef

Interface JobSchedulerRef specifies the interface for the PJ Job Scheduler Daemon process.

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.
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.

Method Detail

backendFailed

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

Report that a backend node failed.

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

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

Cancel a job.

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

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

Report that a job finished.

Parameters:

theJobFrontend - Job frontend that is calling this method.

Throws:

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

renewLease

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

Renew the lease on a job.

Parameters:

theJobFrontend - Job frontend that is calling this method.

Throws:

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

requestJob

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

Request that a job be scheduled.

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

void close()

Close communication with this Job Scheduler.