jist.runtime
Class RemoteJist.JobQueueServer

java.lang.Object
  java.rmi.server.RemoteObject
      java.rmi.server.RemoteServer
          java.rmi.server.UnicastRemoteObject
              jist.runtime.RemoteJist.JobQueueServer

All Implemented Interfaces:

java.io.Serializable, java.rmi.Remote, RemoteJist.JobQueueServerRemote

Enclosing class:

RemoteJist

public static class RemoteJist.JobQueueServer
extends java.rmi.server.UnicastRemoteObject
implements RemoteJist.JobQueueServerRemote

Job queue server.

See Also:

Serialized Form

Field Summary

static java.lang.String

JIST_JOBSERVER_RMI_NAME RMI name of job queue server.

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

RemoteJist.JobQueueServer(int port, java.io.PrintStream out)
Start new job queue server.

Method Summary

void	addJob(RemoteJist.Job job, boolean front) Add job to queue.
RemoteJist.Job	getJob(long maxMem) Return next job from queue, or null if queue is empty.
static RemoteJist.JobQueueServerRemote	getRemote(Node n) Return stub of remote job queue server.
RemoteIO.RemoteOutputStreamRemote	getStdOut() Return RMI handle to queue standard output stream.
void	waitForJob(long maxMem) Wait for job.

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

JIST_JOBSERVER_RMI_NAME

public static final java.lang.String JIST_JOBSERVER_RMI_NAME

RMI name of job queue server.

See Also:

Constant Field Values

Constructor Detail

RemoteJist.JobQueueServer

public RemoteJist.JobQueueServer(int port,
                                 java.io.PrintStream out)
                          throws java.rmi.RemoteException

Start new job queue server.

Parameters:

port - rmi listen port

out - local server output stream

Throws:

java.rmi.RemoteException - rpc failure

Method Detail

getRemote

public static RemoteJist.JobQueueServerRemote getRemote(Node n)
                                                 throws java.rmi.NotBoundException,
                                                        java.net.MalformedURLException,
                                                        java.rmi.RemoteException

Return stub of remote job queue server.

Parameters:

n - node (host:port) of remote job queue server

Returns:

stub of remote job queue server

Throws:

java.rmi.NotBoundException - when jist not bound (started) on remote server

java.net.MalformedURLException - never

java.rmi.RemoteException - rpc failure

addJob

public void addJob(RemoteJist.Job job,
                   boolean front)
            throws java.rmi.RemoteException

Add job to queue.

Specified by:

addJob in interface RemoteJist.JobQueueServerRemote

Parameters:

job - job to enqueue

front - whether job should be added to the front of the queue

Throws:

java.rmi.RemoteException - rpc failure

waitForJob

public void waitForJob(long maxMem)
                throws java.rmi.RemoteException

Wait for job. Returns when there might be a job available.

Specified by:

waitForJob in interface RemoteJist.JobQueueServerRemote

Parameters:

maxMem - maximum available server memory

Throws:

java.rmi.RemoteException - rpc failure

getJob

public RemoteJist.Job getJob(long maxMem)
                      throws java.rmi.RemoteException

Return next job from queue, or null if queue is empty.

Specified by:

getJob in interface RemoteJist.JobQueueServerRemote

Parameters:

maxMem - maximum available server memory

Returns:

next job from queue; null if none exists

Throws:

java.rmi.RemoteException - rpc failure

getStdOut

public RemoteIO.RemoteOutputStreamRemote getStdOut()
                                            throws java.rmi.RemoteException

Return RMI handle to queue standard output stream.

Specified by:

getStdOut in interface RemoteJist.JobQueueServerRemote

Returns:

remote output stream RMI handle

Throws:

java.rmi.RemoteException - rpc failure