edu.rit.pj.cluster
Interface JobFrontendRef

All Known Implementing Classes:
JobFrontend, JobFrontendProxy, JobFrontendStub, NonPjJobFrontend

public interface JobFrontendRef

Interface JobFrontendRef specifies the interface for the PJ job frontend process.


Method Summary
 void assignBackend(JobSchedulerRef theJobScheduler, String name, String host, String jvm, String classpath, String[] jvmflags, String shellCommand, int Nt)
          Assign a backend process to the job.
 void assignJobNumber(JobSchedulerRef theJobScheduler, int jobnum, String pjhost)
          Assign a job number to the job.
 void backendFinished(JobBackendRef theJobBackend)
          Report that a backend process has finished executing the job.
 void backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress)
          Report that a backend process is ready to commence executing the job.
 void cancelJob(JobBackendRef theJobBackend, String errmsg)
          Cancel the job.
 void cancelJob(JobSchedulerRef theJobScheduler, String errmsg)
          Cancel the job.
 void close()
          Close communication with this Job Frontend.
 void inputFileClose(JobBackendRef theJobBackend, int ffd)
          Close the given input file.
 void inputFileOpen(JobBackendRef theJobBackend, int bfd, File file)
          Open the given input file for reading.
 void inputFileRead(JobBackendRef theJobBackend, int ffd, int len)
          Read bytes from the given input file.
 void inputFileSkip(JobBackendRef theJobBackend, int ffd, long len)
          Skip bytes from the given input file.
 void outputFileClose(JobBackendRef theJobBackend, int ffd)
          Close the given output file.
 void outputFileFlush(JobBackendRef theJobBackend, int ffd)
          Flush accumulated bytes to the given output file.
 void outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append)
          Open the given output file for writing or appending.
 void outputFileWrite(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len)
          Write the given bytes to the given output file.
 void renewLease(JobBackendRef theJobBackend)
          Renew the lease on the job.
 void renewLease(JobSchedulerRef theJobScheduler)
          Renew the lease on the job.
 void reportComment(JobBackendRef theJobBackend, int rank, String comment)
          Report a comment for a process.
 void requestResource(JobBackendRef theJobBackend, String resourceName)
          Request the given resource from this job frontend's class loader.
 

Method Detail

assignBackend

void assignBackend(JobSchedulerRef theJobScheduler,
                   String name,
                   String host,
                   String jvm,
                   String classpath,
                   String[] jvmflags,
                   String shellCommand,
                   int Nt)
                   throws IOException
Assign a backend process to the job.

Parameters:
theJobScheduler - Job Scheduler that is calling this method.
name - Backend node name.
host - Host name for SSH remote login.
jvm - Full pathname of Java Virtual Machine.
classpath - Java class path for PJ Library.
jvmflags - Array of JVM command line flags.
shellCommand - Shell command string.
Nt - Number of CPUs assigned to the process.
Throws:
IOException - Thrown if an I/O error occurred.

assignJobNumber

void assignJobNumber(JobSchedulerRef theJobScheduler,
                     int jobnum,
                     String pjhost)
                     throws IOException
Assign a job number to the job. The host name for the job frontend's middleware channel group is also specified.

Parameters:
theJobScheduler - Job Scheduler that is calling this method.
jobnum - Job number.
pjhost - Host name for middleware channel group.
Throws:
IOException - Thrown if an I/O error occurred.

cancelJob

void cancelJob(JobSchedulerRef theJobScheduler,
               String errmsg)
               throws IOException
Cancel the job.

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

renewLease

void renewLease(JobSchedulerRef theJobScheduler)
                throws IOException
Renew the lease on the job.

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

backendFinished

void backendFinished(JobBackendRef theJobBackend)
                     throws IOException
Report that a backend process has finished executing the job.

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

backendReady

void backendReady(JobBackendRef theJobBackend,
                  int rank,
                  InetSocketAddress middlewareAddress,
                  InetSocketAddress worldAddress,
                  InetSocketAddress frontendAddress)
                  throws IOException
Report that a backend process is ready to commence executing the job.

Parameters:
theJobBackend - Job Backend that is calling this method.
rank - Rank of the job backend process.
middlewareAddress - Host/port to which the job backend process is listening for middleware messages.
worldAddress - Host/port to which the job backend process is listening for the world communicator.
frontendAddress - Host/port to which the job backend process is listening for the frontend communicator, or null if the frontend communicator does not exist.
Throws:
IOException - Thrown if an I/O error occurred.

cancelJob

void cancelJob(JobBackendRef theJobBackend,
               String errmsg)
               throws IOException
Cancel the job.

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

renewLease

void renewLease(JobBackendRef theJobBackend)
                throws IOException
Renew the lease on the job.

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

requestResource

void requestResource(JobBackendRef theJobBackend,
                     String resourceName)
                     throws IOException
Request the given resource from this job frontend's class loader.

Parameters:
theJobBackend - Job Backend that is calling this method.
resourceName - Resource name.
Throws:
IOException - Thrown if an I/O error occurred.

outputFileOpen

void outputFileOpen(JobBackendRef theJobBackend,
                    int bfd,
                    File file,
                    boolean append)
                    throws IOException
Open the given output file for writing or appending.

Parameters:
theJobBackend - Job Backend that is calling this method.
bfd - Backend file descriptor.
file - File.
append - True to append, false to overwrite.
Throws:
IOException - Thrown if an I/O error occurred.

outputFileWrite

void outputFileWrite(JobBackendRef theJobBackend,
                     int ffd,
                     byte[] buf,
                     int off,
                     int len)
                     throws IOException
Write the given bytes to the given output file. ffd = 1 refers to the job's standard output stream; ffd = 2 refers to the job's standard error stream; other values refer to a previously opened file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
buf - Array of bytes to write.
off - Index of first byte to write.
len - Number of bytes to write.
Throws:
IOException - Thrown if an I/O error occurred.

outputFileFlush

void outputFileFlush(JobBackendRef theJobBackend,
                     int ffd)
                     throws IOException
Flush accumulated bytes to the given output file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
Throws:
IOException - Thrown if an I/O error occurred.

outputFileClose

void outputFileClose(JobBackendRef theJobBackend,
                     int ffd)
                     throws IOException
Close the given output file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
Throws:
IOException - Thrown if an I/O error occurred.

inputFileOpen

void inputFileOpen(JobBackendRef theJobBackend,
                   int bfd,
                   File file)
                   throws IOException
Open the given input file for reading.

Parameters:
theJobBackend - Job Backend that is calling this method.
bfd - Backend file descriptor.
file - File.
Throws:
IOException - Thrown if an I/O error occurred.

inputFileRead

void inputFileRead(JobBackendRef theJobBackend,
                   int ffd,
                   int len)
                   throws IOException
Read bytes from the given input file. ffd = 1 refers to the job's standard input stream; other values refer to a previously opened file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
len - Number of bytes to read.
Throws:
IOException - Thrown if an I/O error occurred.

inputFileSkip

void inputFileSkip(JobBackendRef theJobBackend,
                   int ffd,
                   long len)
                   throws IOException
Skip bytes from the given input file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
len - Number of bytes to skip.
Throws:
IOException - Thrown if an I/O error occurred.

inputFileClose

void inputFileClose(JobBackendRef theJobBackend,
                    int ffd)
                    throws IOException
Close the given input file.

Parameters:
theJobBackend - Job Backend that is calling this method.
ffd - Frontend file descriptor.
Throws:
IOException - Thrown if an I/O error occurred.

reportComment

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

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

close

void close()
Close communication with this Job Frontend.



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