Uses of Interface
edu.rit.pj.cluster.JobFrontendRef

Packages that use JobFrontendRef

Package	Description
edu.rit.pj.cluster	The Cluster package contains the Parallel Java cluster middleware and the main program for the PJ Job Scheduler Daemon process for a parallel computer.

Uses of JobFrontendRef in edu.rit.pj.cluster

Classes in edu.rit.pj.cluster that implement JobFrontendRef

Modifier and Type	Class	Description
class	JobFrontend	Class JobFrontend provides the message handler for the PJ job frontend process.
class	JobFrontendProxy	Class JobFrontendProxy provides a proxy object for sending messages to a PJ job frontend process.
class	NonPjJobFrontend	Class NonPjJobFrontend provides the message handler for a job frontend process that communicates with the Job Scheduler to allocate backend nodes but does not run a PJ program.

Fields in edu.rit.pj.cluster declared as JobFrontendRef

Modifier and Type	Field	Description
JobFrontendRef	JobInfo.frontend	Reference to the job frontend process.

Methods in edu.rit.pj.cluster with parameters of type JobFrontendRef

Modifier and Type	Method	Description
void	JobScheduler.backendFailed(JobFrontendRef theJobFrontend, String name)	Report that a backend node failed.
static JobSchedulerMessage	JobSchedulerMessage.backendFailed(JobFrontendRef theJobFrontend, String name)	Construct a new "backend failed" message.
void	JobSchedulerProxy.backendFailed(JobFrontendRef theJobFrontend, String name)	Report that a backend node failed.
void	JobSchedulerRef.backendFailed(JobFrontendRef theJobFrontend, String name)	Report that a backend node failed.
void	JobBackend.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel the job.
static JobBackendMessage	JobBackendMessage.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Construct a new "cancel job" message.
void	JobBackendProxy.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel the job.
void	JobBackendRef.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel the job.
void	JobScheduler.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel a job.
static JobSchedulerMessage	JobSchedulerMessage.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Construct a new "cancel job" message.
void	JobSchedulerProxy.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel a job.
void	JobSchedulerRef.cancelJob(JobFrontendRef theJobFrontend, String errmsg)	Cancel a job.
void	JobBackend.commenceJob(JobFrontendRef theJobFrontend, InetSocketAddress[] middlewareAddress, InetSocketAddress[] worldAddress, InetSocketAddress[] frontendAddress, Properties properties, String mainClassName, String[] args)	Commence the job.
static JobBackendMessage	JobBackendMessage.commenceJob(JobFrontendRef theJobFrontend, InetSocketAddress[] middlewareAddress, InetSocketAddress[] worldAddress, InetSocketAddress[] frontendAddress, Properties properties, String mainClassName, String[] args)	Construct a new "commence job" message.
void	JobBackendProxy.commenceJob(JobFrontendRef theJobFrontend, InetSocketAddress[] middlewareAddress, InetSocketAddress[] worldAddress, InetSocketAddress[] frontendAddress, Properties properties, String mainClassName, String[] args)	Commence the job.
void	JobBackendRef.commenceJob(JobFrontendRef theJobFrontend, InetSocketAddress[] middlewareAddress, InetSocketAddress[] worldAddress, InetSocketAddress[] frontendAddress, Properties properties, String mainClassName, String[] args)	Commence the job.
void	BackendFileReader.inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given input file.
void	JobBackend.inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given input file.
static JobBackendMessage	JobBackendMessage.inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Construct a new "input file close result" message.
void	JobBackendProxy.inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given input file.
void	JobBackendRef.inputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given input file.
void	BackendFileReader.inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given input file.
void	JobBackend.inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given input file.
static JobBackendMessage	JobBackendMessage.inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Construct a new "input file open result" message.
void	JobBackendProxy.inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given input file.
void	JobBackendRef.inputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given input file.
void	BackendFileReader.inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, int len, IOException exc)	Report the result of reading the given input file.
void	JobBackend.inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, byte[] buf, int len, IOException exc)	Report the result of reading the given input file.
static JobBackendMessage	JobBackendMessage.inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, int len, IOException exc)	Construct a new "input file read result" message.
void	JobBackendProxy.inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, byte[] buf, int len, IOException exc)	Report the result of reading the given input file.
void	JobBackendRef.inputFileReadResult(JobFrontendRef theJobFrontend, int ffd, byte[] buf, int len, IOException exc)	Report the result of reading the given input file.
void	BackendFileReader.inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc)	Report the result of skipping the given input file.
void	JobBackend.inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc)	Report the result of skipping the given input file.
static JobBackendMessage	JobBackendMessage.inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc)	Construct a new "input file skip result" message.
void	JobBackendProxy.inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc)	Report the result of skipping the given input file.
void	JobBackendRef.inputFileSkipResult(JobFrontendRef theJobFrontend, int ffd, long len, IOException exc)	Report the result of skipping the given input file.
void	JobBackendMessage.invoke(JobBackendRef theJobBackend, JobFrontendRef theJobFrontend)	Invoke the method corresponding to this job backend message on the given Job Backend object.
void	JobFrontendMessage.invoke(JobFrontendRef theJobFrontend, JobBackendRef theJobBackend)	Invoke the method corresponding to this job frontend message on the given Job Frontend object.
void	JobFrontendMessage.invoke(JobFrontendRef theJobFrontend, JobSchedulerRef theJobScheduler)	Invoke the method corresponding to this job frontend message on the given Job Frontend object.
void	JobSchedulerMessage.invoke(JobSchedulerRef theJobScheduler, JobFrontendRef theJobFrontend)	Invoke the method corresponding to this job scheduler message on the given Job Scheduler object.
void	JobBackend.jobFinished(JobFrontendRef theJobFrontend)	Report that the job finished.
static JobBackendMessage	JobBackendMessage.jobFinished(JobFrontendRef theJobFrontend)	Construct a new "job finished" message.
void	JobBackendProxy.jobFinished(JobFrontendRef theJobFrontend)	Report that the job finished.
void	JobBackendRef.jobFinished(JobFrontendRef theJobFrontend)	Report that the job finished.
void	JobScheduler.jobFinished(JobFrontendRef theJobFrontend)	Report that a job finished.
static JobSchedulerMessage	JobSchedulerMessage.jobFinished(JobFrontendRef theJobFrontend)	Construct a new "job finished" message.
void	JobSchedulerProxy.jobFinished(JobFrontendRef theJobFrontend)	Report that a job finished.
void	JobSchedulerRef.jobFinished(JobFrontendRef theJobFrontend)	Report that a job finished.
void	BackendFileWriter.outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given output file.
void	JobBackend.outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given output file.
static JobBackendMessage	JobBackendMessage.outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Construct a new "output file close result" message.
void	JobBackendProxy.outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given output file.
void	JobBackendRef.outputFileCloseResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of closing the given output file.
void	BackendFileWriter.outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of flushing the given output file.
void	JobBackend.outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of flushing the given output file.
static JobBackendMessage	JobBackendMessage.outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Construct a new "output file flush result" message.
void	JobBackendProxy.outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of flushing the given output file.
void	JobBackendRef.outputFileFlushResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of flushing the given output file.
void	BackendFileWriter.outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given output file.
void	JobBackend.outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given output file.
static JobBackendMessage	JobBackendMessage.outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Construct a new "output file open result" message.
void	JobBackendProxy.outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given output file.
void	JobBackendRef.outputFileOpenResult(JobFrontendRef theJobFrontend, int bfd, int ffd, IOException exc)	Report the result of opening the given output file.
void	BackendFileWriter.outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of writing the given output file.
void	JobBackend.outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of writing the given output file.
static JobBackendMessage	JobBackendMessage.outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Construct a new "output file write result" message.
void	JobBackendProxy.outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of writing the given output file.
void	JobBackendRef.outputFileWriteResult(JobFrontendRef theJobFrontend, int ffd, IOException exc)	Report the result of writing the given output file.
void	JobBackend.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on the job.
static JobBackendMessage	JobBackendMessage.renewLease(JobFrontendRef theJobFrontend)	Construct a new "renew lease" message.
void	JobBackendProxy.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on the job.
void	JobBackendRef.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on the job.
void	JobScheduler.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on a job.
static JobSchedulerMessage	JobSchedulerMessage.renewLease(JobFrontendRef theJobFrontend)	Construct a new "renew lease" message.
void	JobSchedulerProxy.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on a job.
void	JobSchedulerRef.renewLease(JobFrontendRef theJobFrontend)	Renew the lease on a job.
void	JobScheduler.reportComment(JobFrontendRef theJobFrontend, int rank, String comment)	Report a comment for a process.
static JobSchedulerMessage	JobSchedulerMessage.reportComment(JobFrontendRef theJobFrontend, int rank, String comment)	Construct a new "report comment" message.
void	JobSchedulerProxy.reportComment(JobFrontendRef theJobFrontend, int rank, String comment)	Report a comment for a process.
void	JobSchedulerRef.reportComment(JobFrontendRef theJobFrontend, int rank, String comment)	Report a comment for a process.
void	JobBackend.reportResource(JobFrontendRef theJobFrontend, String resourceName, byte[] content)	Report the content for a previously-requested resource.
void	JobBackend.reportResource(JobFrontendRef theJobFrontend, String resourceName, ByteSequence content)	Report the content for a previously-requested resource.
static JobBackendMessage	JobBackendMessage.reportResource(JobFrontendRef theJobFrontend, String resourceName, byte[] content)	Construct a new "report resource" message.
static JobBackendMessage	JobBackendMessage.reportResource(JobFrontendRef theJobFrontend, String resourceName, ByteSequence content)	Construct a new "report resource" message.
void	JobBackendProxy.reportResource(JobFrontendRef theJobFrontend, String resourceName, byte[] content)	Report the content for a previously-requested resource.
void	JobBackendProxy.reportResource(JobFrontendRef theJobFrontend, String resourceName, ByteSequence content)	Report the content for a previously-requested resource.
void	JobBackendRef.reportResource(JobFrontendRef theJobFrontend, String resourceName, byte[] content)	Report the content for a previously-requested resource.
void	JobBackendRef.reportResource(JobFrontendRef theJobFrontend, String resourceName, ByteSequence content)	Report the content for a previously-requested resource.
void	JobScheduler.requestJob(JobFrontendRef theJobFrontend, String username, int Nn, int Np, int Nt)	Request that a job be scheduled.
static JobSchedulerMessage	JobSchedulerMessage.requestJob(JobFrontendRef theJobFrontend, String username, int Nn, int Np, int Nt)	Construct a new "request job" message.
void	JobSchedulerProxy.requestJob(JobFrontendRef theJobFrontend, String username, int Nn, int Np, int Nt)	Request that a job be scheduled.
void	JobSchedulerRef.requestJob(JobFrontendRef theJobFrontend, String username, int Nn, int Np, int Nt)	Request that a job be scheduled.

Constructors in edu.rit.pj.cluster with parameters of type JobFrontendRef

Modifier	Constructor	Description
	BackendClassLoader(JobBackendRef theJobBackend, JobFrontendRef theJobFrontend, ResourceCache theCache)	Construct a new backend class loader.
	BackendClassLoader(ClassLoader parent, JobBackendRef theJobBackend, JobFrontendRef theJobFrontend, ResourceCache theCache)	Construct a new backend class loader.
	BackendFileReader(JobFrontendRef theJobFrontend, JobBackendRef theJobBackend)	Construct a new backend file reader.
	BackendFileWriter(JobFrontendRef theJobFrontend, JobBackendRef theJobBackend)	Construct a new backend file writer.
	JobInfo(int jobnum, JobInfo.State state, long stateTime, String username, int Nn, int Np, int Nt, int count, BackendInfo[] backend, int[] cpus, int nodeCount, JobFrontendRef frontend, Timer renewTimer, Timer expireTimer, Timer jobTimer)	Construct a new job information record.