edu.rit.pj.cluster
Class JobBackendProxy

java.lang.Object
  edu.rit.pj.cluster.Proxy
      edu.rit.pj.cluster.JobBackendProxy

All Implemented Interfaces:

JobBackendRef

public class JobBackendProxy
extends Proxy
implements JobBackendRef

Class JobBackendProxy provides a proxy object for sending messages to a PJ job backend process.

Constructor Summary

JobBackendProxy(ChannelGroup theChannelGroup, Channel theChannel)
Construct a new job backend proxy.

Method Summary

void	cancelJob(JobFrontendRef theJobFrontend, String errmsg) Cancel the job.
void	commenceJob(JobFrontendRef theJobFrontend, InetSocketAddress[] middlewareAddress, InetSocketAddress[] worldAddress, InetSocketAddress[] frontendAddress, Properties properties, String mainClassName, String[] args) Commence the job.
void	inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc) Report the result of closing the given input file.
void	inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc) Report the result of opening the given input file.
void	inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, byte[] buf, int len, IOException exc) Report the result of reading the given input file.
void	inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc) Report the result of skipping the given input file.
void	jobFinished(JobFrontendRef theJobFrontend) Report that the job finished.
void	outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc) Report the result of closing the given output file.
void	outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc) Report the result of flushing the given output file.
void	outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc) Report the result of opening the given output file.
void	outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc) Report the result of writing the given output file.
void	renewLease(JobFrontendRef theJobFrontend) Renew the lease on the job.
void	reportResource(JobFrontendRef theJobFrontend, String resourceName, byte[] content) Report the content for a previously-requested resource.
void	reportResource(JobFrontendRef theJobFrontend, String resourceName, ByteSequence content) Report the content for a previously-requested resource.

Methods inherited from class edu.rit.pj.cluster.Proxy

close, receive, receive, send, send

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.rit.pj.cluster.JobBackendRef

close

Constructor Detail

JobBackendProxy

public JobBackendProxy(ChannelGroup theChannelGroup,
                       Channel theChannel)

Construct a new job backend proxy. The proxy will use the given channel in the given channel group to send messages to the job backend process.

Parameters:

theChannelGroup - Channel group.

theChannel - Channel.

Method Detail

cancelJob

public void cancelJob(JobFrontendRef theJobFrontend,
                      String errmsg)
               throws IOException

Cancel the job.

Specified by:

cancelJob in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

errmsg - Error message string.

Throws:

IOException - Thrown if an I/O error occurred.

commenceJob

public void commenceJob(JobFrontendRef theJobFrontend,
                        InetSocketAddress[] middlewareAddress,
                        InetSocketAddress[] worldAddress,
                        InetSocketAddress[] frontendAddress,
                        Properties properties,
                        String mainClassName,
                        String[] args)
                 throws IOException

Commence the job.

Specified by:

commenceJob in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

middlewareAddress - Array of hosts/ports for middleware messages. The first K elements are for the job backend processes in rank order, the K+1st element is for the job frontend process. If the

worldAddress - Array of hosts/ports for the world communicator. The K elements are for the job backend processes in rank order.

frontendAddress - Array of hosts/ports for the frontend communicator. The first K elements are for the job backend processes in rank order, the K+1st element is for the job frontend process. If the frontend communicator does not exist, frontendAddress is null.

properties - Java system properties.

mainClassName - Fully qualified class name of the Java main program class to execute.

args - Array of 0 or more Java command line arguments.

Throws:

IOException - Thrown if an I/O error occurred.

jobFinished

public void jobFinished(JobFrontendRef theJobFrontend)
                 throws IOException

Report that the job finished.

Specified by:

jobFinished in interface JobBackendRef

Parameters:

theJobFrontend - Job frontend that is calling this method.

Throws:

IOException - Thrown if an I/O error occurred.

renewLease

public void renewLease(JobFrontendRef theJobFrontend)
                throws IOException

Renew the lease on the job.

Specified by:

renewLease in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

Throws:

IOException - Thrown if an I/O error occurred.

reportResource

public void reportResource(JobFrontendRef theJobFrontend,
                           String resourceName,
                           byte[] content)
                    throws IOException

Report the content for a previously-requested resource.

Specified by:

reportResource in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

resourceName - Resource name.

content - Resource content, or null if resource not found.

Throws:

IOException - Thrown if an I/O error occurred.

reportResource

public void reportResource(JobFrontendRef theJobFrontend,
                           String resourceName,
                           ByteSequence content)
                    throws IOException

Report the content for a previously-requested resource.

Specified by:

reportResource in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

resourceName - Resource name.

content - Resource content, or null if resource not found.

Throws:

IOException - Thrown if an I/O error occurred.

outputFileOpenResult

public void outputFileOpenResult(JobFrontendRef theJobFrontend,
                                 int bfd,
                                 int ffd,
                                 IOException exc)
                          throws IOException

Report the result of opening the given output file.

Specified by:

outputFileOpenResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

bfd - Backend file descriptor.

ffd - Frontend file descriptor if success.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

outputFileWriteResult

public void outputFileWriteResult(JobFrontendRef theJobFrontend,
                                  int ffd,
                                  IOException exc)
                           throws IOException

Report the result of writing the given output file.

Specified by:

outputFileWriteResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

outputFileFlushResult

public void outputFileFlushResult(JobFrontendRef theJobFrontend,
                                  int ffd,
                                  IOException exc)
                           throws IOException

Report the result of flushing the given output file.

Specified by:

outputFileFlushResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

outputFileCloseResult

public void outputFileCloseResult(JobFrontendRef theJobFrontend,
                                  int ffd,
                                  IOException exc)
                           throws IOException

Report the result of closing the given output file.

Specified by:

outputFileCloseResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

inputFileOpenResult

public void inputFileOpenResult(JobFrontendRef theJobFrontend,
                                int bfd,
                                int ffd,
                                IOException exc)
                         throws IOException

Report the result of opening the given input file.

Specified by:

inputFileOpenResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

bfd - Backend file descriptor.

ffd - Frontend file descriptor if success.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

inputFileReadResult

public void inputFileReadResult(JobFrontendRef theJobFrontend,
                                int ffd,
                                byte[] buf,
                                int len,
                                IOException exc)
                         throws IOException

Report the result of reading the given input file.

Specified by:

inputFileReadResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

buf - Bytes read.

len - Number of bytes read, or -1 if EOF.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

inputFileSkipResult

public void inputFileSkipResult(JobFrontendRef theJobFrontend,
                                int ffd,
                                long len,
                                IOException exc)
                         throws IOException

Report the result of skipping the given input file.

Specified by:

inputFileSkipResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

len - Number of bytes skipped.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.

inputFileCloseResult

public void inputFileCloseResult(JobFrontendRef theJobFrontend,
                                 int ffd,
                                 IOException exc)
                          throws IOException

Report the result of closing the given input file.

Specified by:

inputFileCloseResult in interface JobBackendRef

Parameters:

theJobFrontend - Job Frontend that is calling this method.

ffd - Frontend file descriptor.

exc - Null if success, exception if failure.

Throws:

IOException - Thrown if an I/O error occurred.