lima.distribution
Class TestWUPipe

java.lang.Object
  |
  +--java.rmi.server.RemoteObject
        |
        +--java.rmi.server.RemoteServer
              |
              +--java.rmi.server.UnicastRemoteObject
                    |
                    +--lima.distribution.TestWUPipe

All Implemented Interfaces:

java.rmi.Remote, java.io.Serializable, WorkUnitSink

public class TestWUPipe

extends java.rmi.server.UnicastRemoteObject

implements WorkUnitSink

A test harness for WUPipe. Written to help writing WUPipe.

See Also:

Serialized Form

Field Summary

java.util.HashSet

toRX

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

TestWUPipe()

Method Summary

void	allDone() Signals that all WorkUnits have been done.
void	flush(lima.distribution.WorkUnit u) Flush the WorkUnit w back to the distribution system.
static void	main(java.lang.String[] arrg) This provides testing of WUPipe.

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

toRX

public java.util.HashSet toRX

Constructor Detail

TestWUPipe

public TestWUPipe()
           throws java.rmi.RemoteException

Method Detail

flush

public void flush(lima.distribution.WorkUnit u)
           throws java.rmi.RemoteException

Description copied from interface: WorkUnitSink

Flush the WorkUnit w back to the distribution system. Note that order is not maintained.

Specified by:

flush in interface WorkUnitSink

Parameters:

u -

java.rmi.RemoteException

See Also:

WorkUnitSink.flush(lima.distribution.WorkUnit)

allDone

public void allDone()
             throws java.rmi.RemoteException

Description copied from interface: WorkUnitSink

Signals that all WorkUnits have been done.

Specified by:

allDone in interface WorkUnitSink

java.rmi.RemoteException

See Also:

WorkUnitSink.allDone()

main

public static void main(java.lang.String[] arrg)
                 throws java.rmi.RemoteException

This provides testing of WUPipe.

java.rmi.RemoteException