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
 void backendFailed(JobFrontendRef theJobFrontend, String name)
          Report that a backend node failed.
 void cancelJob(JobFrontendRef theJobFrontend, 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 reportComment(JobFrontendRef theJobFrontend, int rank, String comment)
          Report a comment for a process.
 void requestJob(JobFrontendRef theJobFrontend, String username, int Nn, int Np, int Nt)
          Request that a job be scheduled.
 

Method Detail

backendFailed

void backendFailed(JobFrontendRef theJobFrontend,
                   String name)
                   throws IOException
Report that a backend node failed.

Parameters:
theJobFrontend - Job frontend that is calling this method.
name - Backend node name.
Throws:
IOException - Thrown if an I/O error occurred.

cancelJob

void cancelJob(JobFrontendRef theJobFrontend,
               String errmsg)
               throws IOException
Cancel a job.

Parameters:
theJobFrontend - Job frontend that is calling this method.
errmsg - Error message string.
Throws:
IOException - Thrown if an I/O error occurred.

jobFinished

void jobFinished(JobFrontendRef theJobFrontend)
                 throws IOException
Report that a job finished.

Parameters:
theJobFrontend - Job frontend that is calling this method.
Throws:
IOException - Thrown if an I/O error occurred.

renewLease

void renewLease(JobFrontendRef theJobFrontend)
                throws IOException
Renew the lease on a job.

Parameters:
theJobFrontend - Job frontend that is calling this method.
Throws:
IOException - Thrown if an I/O error occurred.

reportComment

void reportComment(JobFrontendRef theJobFrontend,
                   int rank,
                   String comment)
                   throws IOException
Report a comment for a process.

Parameters:
theJobFrontend - Job frontend that is calling this method.
rank - Process rank.
comment - Comment string.
Throws:
IOException - Thrown if an I/O error occurred.

requestJob

void requestJob(JobFrontendRef theJobFrontend,
                String username,
                int Nn,
                int Np,
                int Nt)
                throws 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:
IOException - Thrown if an I/O error occurred.

close

void close()
Close communication with this Job Scheduler.



Copyright © 2005-2012 by Alan Kaminsky. All rights reserved. Send comments to ark­@­cs.rit.edu.