Uses of Interface
edu.rit.pj.cluster.JobBackendRef
Packages that use JobBackendRef
Package
Description
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 JobBackendRef in edu.rit.pj.cluster
Classes in edu.rit.pj.cluster that implement JobBackendRefModifier and TypeClassDescriptionclassClass JobBackend is the main program for a job backend process in the PJ cluster middleware.classClass JobBackendProxy provides a proxy object for sending messages to a PJ job backend process.Fields in edu.rit.pj.cluster declared as JobBackendRefMethods in edu.rit.pj.cluster with parameters of type JobBackendRefModifier and TypeMethodDescriptionvoidJobFrontend.backendFinished(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.static JobFrontendMessageJobFrontendMessage.backendFinished(JobBackendRef theJobBackend) Construct a new "backend finished" message.voidJobFrontendProxy.backendFinished(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.voidJobFrontendRef.backendFinished(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.voidNonPjJobFrontend.backendFinished(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.voidJobFrontend.backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.static JobFrontendMessageJobFrontendMessage.backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Construct a new "backend ready" message.voidJobFrontendProxy.backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.voidJobFrontendRef.backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.voidNonPjJobFrontend.backendReady(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.voidJobFrontend.cancelJob(JobBackendRef theJobBackend, String errmsg) Cancel the job.static JobFrontendMessageJobFrontendMessage.cancelJob(JobBackendRef theJobBackend, String errmsg) Construct a new "cancel job" message.voidJobFrontendProxy.cancelJob(JobBackendRef theJobBackend, String errmsg) Cancel the job.voidJobFrontendRef.cancelJob(JobBackendRef theJobBackend, String errmsg) Cancel the job.voidNonPjJobFrontend.cancelJob(JobBackendRef theJobBackend, String errmsg) Cancel the job.voidFrontendFileReader.inputFileClose(JobBackendRef theJobBackend, int ffd) Close the given input file.voidJobFrontend.inputFileClose(JobBackendRef theJobBackend, int ffd) Close the given input file.static JobFrontendMessageJobFrontendMessage.inputFileClose(JobBackendRef theJobBackend, int ffd) Construct a new "input file close" message.voidJobFrontendProxy.inputFileClose(JobBackendRef theJobBackend, int ffd) Close the given input file.voidJobFrontendRef.inputFileClose(JobBackendRef theJobBackend, int ffd) Close the given input file.voidNonPjJobFrontend.inputFileClose(JobBackendRef theJobBackend, int ffd) Close the given input file.voidFrontendFileReader.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.voidJobFrontend.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.static JobFrontendMessageJobFrontendMessage.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Construct a new "input file open" message.voidJobFrontendProxy.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.voidJobFrontendRef.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.voidNonPjJobFrontend.inputFileOpen(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.voidFrontendFileReader.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.voidJobFrontend.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.static JobFrontendMessageJobFrontendMessage.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Construct a new "input file read" message.voidJobFrontendProxy.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.voidJobFrontendRef.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.voidNonPjJobFrontend.inputFileRead(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.voidFrontendFileReader.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.voidJobFrontend.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.static JobFrontendMessageJobFrontendMessage.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Construct a new "input file skip" message.voidJobFrontendProxy.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.voidJobFrontendRef.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.voidNonPjJobFrontend.inputFileSkip(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.voidJobBackendMessage.invoke(JobBackendRef theJobBackend, JobFrontendRef theJobFrontend) Invoke the method corresponding to this job backend message on the given Job Backend object.voidJobFrontendMessage.invoke(JobFrontendRef theJobFrontend, JobBackendRef theJobBackend) Invoke the method corresponding to this job frontend message on the given Job Frontend object.voidFrontendFileWriter.outputFileClose(JobBackendRef theJobBackend, int ffd) Close the given output file.voidJobFrontend.outputFileClose(JobBackendRef theJobBackend, int ffd) Close the given output file.static JobFrontendMessageJobFrontendMessage.outputFileClose(JobBackendRef theJobBackend, int ffd) Construct a new "output file close" message.voidJobFrontendProxy.outputFileClose(JobBackendRef theJobBackend, int ffd) Close the given output file.voidJobFrontendRef.outputFileClose(JobBackendRef theJobBackend, int ffd) Close the given output file.voidNonPjJobFrontend.outputFileClose(JobBackendRef theJobBackend, int ffd) Close the given output file.voidFrontendFileWriter.outputFileFlush(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.voidJobFrontend.outputFileFlush(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.static JobFrontendMessageJobFrontendMessage.outputFileFlush(JobBackendRef theJobBackend, int ffd) Construct a new "output file flush" message.voidJobFrontendProxy.outputFileFlush(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.voidJobFrontendRef.outputFileFlush(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.voidNonPjJobFrontend.outputFileFlush(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.voidFrontendFileWriter.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.voidJobFrontend.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.static JobFrontendMessageJobFrontendMessage.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Construct a new "output file open" message.voidJobFrontendProxy.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.voidJobFrontendRef.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.voidNonPjJobFrontend.outputFileOpen(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.voidFrontendFileWriter.outputFileWrite(JobBackendRef theJobBackend, int ffd, int len) Write the given bytes to the given output file.voidJobFrontend.outputFileWrite(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.static JobFrontendMessageJobFrontendMessage.outputFileWrite(JobBackendRef theJobBackend, int ffd, int len) Construct a new "output file write" message.voidJobFrontendProxy.outputFileWrite(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.voidJobFrontendRef.outputFileWrite(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.voidNonPjJobFrontend.outputFileWrite(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.voidJobFrontend.renewLease(JobBackendRef theJobBackend) Renew the lease on the job.static JobFrontendMessageJobFrontendMessage.renewLease(JobBackendRef theJobBackend) Construct a new "renew lease" message.voidJobFrontendProxy.renewLease(JobBackendRef theJobBackend) Renew the lease on the job.voidJobFrontendRef.renewLease(JobBackendRef theJobBackend) Renew the lease on the job.voidNonPjJobFrontend.renewLease(JobBackendRef theJobBackend) Renew the lease on the job.voidJobFrontend.reportComment(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.static JobFrontendMessageJobFrontendMessage.reportComment(JobBackendRef theJobBackend, int rank, String comment) Construct a new "report comment" message.voidJobFrontendProxy.reportComment(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.voidJobFrontendRef.reportComment(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.voidNonPjJobFrontend.reportComment(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.voidJobFrontend.requestResource(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.static JobFrontendMessageJobFrontendMessage.requestResource(JobBackendRef theJobBackend, String resourceName) Construct a new "request resource" message.voidJobFrontendProxy.requestResource(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.voidJobFrontendRef.requestResource(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.voidNonPjJobFrontend.requestResource(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.Constructors in edu.rit.pj.cluster with parameters of type JobBackendRefModifierConstructorDescriptionBackendClassLoader(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.ProcessInfo(ProcessInfo.State state, String name, int rank, JobBackendRef backend, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress, Timer renewTimer, Timer expireTimer, int Nt) Construct a new job information record.