edu.rit.pj.cluster

Class ProcessInfo

java.lang.Object

edu.rit.pj.cluster.ProcessInfo

public class ProcessInfo
extends java.lang.Object

Class ProcessInfo provides a record of information about one job backend process in the PJ cluster middleware.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProcessInfo.State The state of a job backend process.

Field Summary

Fields

Modifier and Type	Field and Description
JobBackendRef	backend Reference to the job backend process.
Timer	expireTimer Lease expiration timer.
java.net.InetSocketAddress	frontendAddress Host/port to which the job backend process is listening for the frontend communicator, or null if the frontend communicator does not exist.
java.net.InetSocketAddress	middlewareAddress Host/port to which the job backend process is listening for middleware messages.
java.lang.String	name The job backend node's name.
int	Nt Number of CPUs assigned to the job backend process.
int	rank The job backend process's rank.
Timer	renewTimer Lease renewal timer.
ProcessInfo.State	state The job backend process's state.
java.net.InetSocketAddress	worldAddress Host/port to which the job backend process is listening for the world communicator.

Constructor Summary

Constructors

Constructor and Description
ProcessInfo(ProcessInfo.State state, java.lang.String name, int rank, JobBackendRef backend, java.net.InetSocketAddress middlewareAddress, java.net.InetSocketAddress worldAddress, java.net.InetSocketAddress frontendAddress, Timer renewTimer, Timer expireTimer, int Nt) Construct a new job information record.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

state

public ProcessInfo.State state

The job backend process's state.

name

public java.lang.String name

The job backend node's name.

rank

public int rank

The job backend process's rank.

backend

public JobBackendRef backend

Reference to the job backend process.

middlewareAddress

public java.net.InetSocketAddress middlewareAddress

Host/port to which the job backend process is listening for middleware messages.

worldAddress

public java.net.InetSocketAddress worldAddress

Host/port to which the job backend process is listening for the world communicator.

frontendAddress

public java.net.InetSocketAddress frontendAddress

Host/port to which the job backend process is listening for the frontend communicator, or null if the frontend communicator does not exist.

renewTimer

public Timer renewTimer

Lease renewal timer.

expireTimer

public Timer expireTimer

Lease expiration timer.

Nt

public int Nt

Number of CPUs assigned to the job backend process.

Constructor Detail

ProcessInfo

public ProcessInfo(ProcessInfo.State state,
                   java.lang.String name,
                   int rank,
                   JobBackendRef backend,
                   java.net.InetSocketAddress middlewareAddress,
                   java.net.InetSocketAddress worldAddress,
                   java.net.InetSocketAddress frontendAddress,
                   Timer renewTimer,
                   Timer expireTimer,
                   int Nt)

Construct a new job information record.

Parameters:

state - The job backend process's state.

name - The job backend processor's name.

rank - The job backend process's rank.

backend - Reference to 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.

renewTimer - Lease renewal timer.

expireTimer - Lease expiration timer.

Nt - Number of CPUs assigned to the job backend process.