Package 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.
Version:
24-Jan-2012
Author:
Alan Kaminsky

  • Method Details

    • 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.
      IOException - if any.

    • 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.
      IOException - if any.

    • 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.
      IOException - if any.

    • 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.
      IOException - if any.

    • 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.
      IOException - if any.

    • 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.
      IOException - if any.

    • close

      void close()
      Close communication with this Job Scheduler.