com.nukernel.jdcf
Class CommunicatorImpl

java.lang.Object
  |
  +--java.rmi.server.RemoteObject
        |
        +--java.rmi.server.RemoteServer
              |
              +--java.rmi.server.UnicastRemoteObject
                    |
                    +--com.nukernel.jdcf.CommunicatorImpl

public class CommunicatorImpl

extends java.rmi.server.UnicastRemoteObject

implements Communicator

A default Communicator implementation; extending this class is recommended instead of implementing the Communicator interface directly.

See Also:

Serialized Form

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

CommunicatorImpl()

CommunicatorImpl(Cluster cluster)

Method Summary

RemoteThreadInterface	createThread(RemoteRunnable target, java.lang.String name) Called to create a remote thread on the target node.
void	kill() Called when the job should abort execution.
void	resume() Called on a previously suspended job when it should begin executing again.
java.lang.Object	status() Return an object representing the status of the computation.
void	suspend() Called when the job should stop executing temporarily.

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

Constructor Detail

CommunicatorImpl

public CommunicatorImpl()
                 throws java.rmi.RemoteException

CommunicatorImpl

public CommunicatorImpl(Cluster cluster)
                 throws java.rmi.RemoteException

Method Detail

status

public java.lang.Object status()
                        throws java.rmi.RemoteException

Description copied from interface: Communicator

Return an object representing the status of the computation.

Specified by:

status in interface Communicator

Tags copied from interface: Communicator

Returns:

status object

Throws:

java.rmi.RemoteException - if a communication error occurs

suspend

public void suspend()
             throws java.rmi.RemoteException

Description copied from interface: Communicator

Called when the job should stop executing temporarily.

Specified by:

suspend in interface Communicator

Tags copied from interface: Communicator

Throws:

java.rmi.RemoteException - if a communication error occurs

resume

public void resume()
            throws java.rmi.RemoteException

Description copied from interface: Communicator

Called on a previously suspended job when it should begin executing again.

Specified by:

resume in interface Communicator

Tags copied from interface: Communicator

Throws:

java.rmi.RemoteException - if a communication error occurs

kill

public void kill()
          throws java.rmi.RemoteException

Description copied from interface: Communicator

Called when the job should abort execution.

Specified by:

kill in interface Communicator

Tags copied from interface: Communicator

Throws:

java.rmi.RemoteException - if a communication error occurs

createThread

public RemoteThreadInterface createThread(RemoteRunnable target,
                                          java.lang.String name)
                                   throws java.rmi.RemoteException

Description copied from interface: Communicator

Called to create a remote thread on the target node.

Specified by:

createThread in interface Communicator

Tags copied from interface: Communicator

Parameters:

target - the run method to invoke

name - desired name for the thread

Returns:

a remote object similar to java.lang.Thread

Throws:

java.rmi.RemoteException - if a communication error occurs