Uses of Interface
edu.rit.pj.cluster.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
Modifier and TypeClassDescriptionclass
Class JobBackend is the main program for a job backend process in the PJ cluster middleware.class
Class JobBackendProxy provides a proxy object for sending messages to a PJ job backend process.Modifier and TypeMethodDescriptionvoid
JobFrontend.backendFinished
(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.static JobFrontendMessage
JobFrontendMessage.backendFinished
(JobBackendRef theJobBackend) Construct a new "backend finished" message.void
JobFrontendProxy.backendFinished
(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.void
JobFrontendRef.backendFinished
(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.void
NonPjJobFrontend.backendFinished
(JobBackendRef theJobBackend) Report that a backend process has finished executing the job.void
JobFrontend.backendReady
(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.static JobFrontendMessage
JobFrontendMessage.backendReady
(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Construct a new "backend ready" message.void
JobFrontendProxy.backendReady
(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.void
JobFrontendRef.backendReady
(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.void
NonPjJobFrontend.backendReady
(JobBackendRef theJobBackend, int rank, InetSocketAddress middlewareAddress, InetSocketAddress worldAddress, InetSocketAddress frontendAddress) Report that a backend process is ready to commence executing the job.void
JobFrontend.cancelJob
(JobBackendRef theJobBackend, String errmsg) Cancel the job.static JobFrontendMessage
JobFrontendMessage.cancelJob
(JobBackendRef theJobBackend, String errmsg) Construct a new "cancel job" message.void
JobFrontendProxy.cancelJob
(JobBackendRef theJobBackend, String errmsg) Cancel the job.void
JobFrontendRef.cancelJob
(JobBackendRef theJobBackend, String errmsg) Cancel the job.void
NonPjJobFrontend.cancelJob
(JobBackendRef theJobBackend, String errmsg) Cancel the job.void
FrontendFileReader.inputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given input file.void
JobFrontend.inputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given input file.static JobFrontendMessage
JobFrontendMessage.inputFileClose
(JobBackendRef theJobBackend, int ffd) Construct a new "input file close" message.void
JobFrontendProxy.inputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given input file.void
JobFrontendRef.inputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given input file.void
NonPjJobFrontend.inputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given input file.void
FrontendFileReader.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.void
JobFrontend.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.static JobFrontendMessage
JobFrontendMessage.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Construct a new "input file open" message.void
JobFrontendProxy.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.void
JobFrontendRef.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.void
NonPjJobFrontend.inputFileOpen
(JobBackendRef theJobBackend, int bfd, File file) Open the given input file for reading.void
FrontendFileReader.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.void
JobFrontend.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.static JobFrontendMessage
JobFrontendMessage.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Construct a new "input file read" message.void
JobFrontendProxy.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.void
JobFrontendRef.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.void
NonPjJobFrontend.inputFileRead
(JobBackendRef theJobBackend, int ffd, int len) Read bytes from the given input file.void
FrontendFileReader.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.void
JobFrontend.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.static JobFrontendMessage
JobFrontendMessage.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Construct a new "input file skip" message.void
JobFrontendProxy.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.void
JobFrontendRef.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from the given input file.void
NonPjJobFrontend.inputFileSkip
(JobBackendRef theJobBackend, int ffd, long len) Skip bytes from 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
FrontendFileWriter.outputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given output file.void
JobFrontend.outputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given output file.static JobFrontendMessage
JobFrontendMessage.outputFileClose
(JobBackendRef theJobBackend, int ffd) Construct a new "output file close" message.void
JobFrontendProxy.outputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given output file.void
JobFrontendRef.outputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given output file.void
NonPjJobFrontend.outputFileClose
(JobBackendRef theJobBackend, int ffd) Close the given output file.void
FrontendFileWriter.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.void
JobFrontend.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.static JobFrontendMessage
JobFrontendMessage.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Construct a new "output file flush" message.void
JobFrontendProxy.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.void
JobFrontendRef.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.void
NonPjJobFrontend.outputFileFlush
(JobBackendRef theJobBackend, int ffd) Flush accumulated bytes to the given output file.void
FrontendFileWriter.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.void
JobFrontend.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.static JobFrontendMessage
JobFrontendMessage.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Construct a new "output file open" message.void
JobFrontendProxy.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.void
JobFrontendRef.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.void
NonPjJobFrontend.outputFileOpen
(JobBackendRef theJobBackend, int bfd, File file, boolean append) Open the given output file for writing or appending.void
FrontendFileWriter.outputFileWrite
(JobBackendRef theJobBackend, int ffd, int len) Write the given bytes to the given output file.void
JobFrontend.outputFileWrite
(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.static JobFrontendMessage
JobFrontendMessage.outputFileWrite
(JobBackendRef theJobBackend, int ffd, int len) Construct a new "output file write" message.void
JobFrontendProxy.outputFileWrite
(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.void
JobFrontendRef.outputFileWrite
(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.void
NonPjJobFrontend.outputFileWrite
(JobBackendRef theJobBackend, int ffd, byte[] buf, int off, int len) Write the given bytes to the given output file.void
JobFrontend.renewLease
(JobBackendRef theJobBackend) Renew the lease on the job.static JobFrontendMessage
JobFrontendMessage.renewLease
(JobBackendRef theJobBackend) Construct a new "renew lease" message.void
JobFrontendProxy.renewLease
(JobBackendRef theJobBackend) Renew the lease on the job.void
JobFrontendRef.renewLease
(JobBackendRef theJobBackend) Renew the lease on the job.void
NonPjJobFrontend.renewLease
(JobBackendRef theJobBackend) Renew the lease on the job.void
JobFrontend.reportComment
(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.static JobFrontendMessage
JobFrontendMessage.reportComment
(JobBackendRef theJobBackend, int rank, String comment) Construct a new "report comment" message.void
JobFrontendProxy.reportComment
(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.void
JobFrontendRef.reportComment
(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.void
NonPjJobFrontend.reportComment
(JobBackendRef theJobBackend, int rank, String comment) Report a comment for a process.void
JobFrontend.requestResource
(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.static JobFrontendMessage
JobFrontendMessage.requestResource
(JobBackendRef theJobBackend, String resourceName) Construct a new "request resource" message.void
JobFrontendProxy.requestResource
(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.void
JobFrontendRef.requestResource
(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.void
NonPjJobFrontend.requestResource
(JobBackendRef theJobBackend, String resourceName) Request the given resource from this job frontend's class loader.ModifierConstructorDescriptionBackendClassLoader
(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.