jgroup.test.gm
Class RemoteTestLayer

java.lang.Object
  jgroup.test.gm.RemoteTestLayer

All Implemented Interfaces:

jgroup.core.InternalGMIListener, jgroup.core.Layer, jgroup.core.multicast.MulticastListener, InternalRemoteTest, RemoteTestService

public class RemoteTestLayer
extends java.lang.Object
implements RemoteTestService, jgroup.core.multicast.MulticastListener, InternalRemoteTest

Test layer for remote interaction styles; for the purpose of testing the IGMI and Mcast layer performance.

Author:

Hein Meling

Nested Class Summary

Nested classes/interfaces inherited from interface jgroup.core.Layer

jgroup.core.Layer.FinalizeLayer

Method Summary

void	activate()
void	addListener(java.lang.Object listener) Add a server or layer that is listening for remote test layer events.
java.lang.Object	deliverObject(java.lang.Object msg, jgroup.core.MemberId sender, int seqNo)
java.lang.Object	deliverStream(java.io.InputStream msg, jgroup.core.MemberId sender, int seqNo)
static RemoteTestLayer	getLayer(jgroup.core.GroupManager gm, jgroup.relacs.gm.DispatcherService dispatcher, jgroup.core.InternalGMIService igmis, jgroup.core.multicast.MulticastService mcast) Get an instance of this layer; note that this layer needs the group manager object and this must be passed to the layer as the first argument to the getLayer method.
java.lang.String	getProtocolName()
void	halt()
java.lang.Object	rtest(byte[] var)
java.lang.Object	rtest(int var)
void	rtest(int[] array)
java.lang.Object	rtest(java.lang.Object obj)

Methods inherited from class java.lang.Object

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

Method Detail

getLayer

public static RemoteTestLayer getLayer(jgroup.core.GroupManager gm,
                                       jgroup.relacs.gm.DispatcherService dispatcher,
                                       jgroup.core.InternalGMIService igmis,
                                       jgroup.core.multicast.MulticastService mcast)
                                throws jgroup.core.JgroupException,
                                       java.rmi.RemoteException

Get an instance of this layer; note that this layer needs the group manager object and this must be passed to the layer as the first argument to the getLayer method.

Throws:

jgroup.core.JgroupException

java.rmi.RemoteException

addListener

public void addListener(java.lang.Object listener)

Add a server or layer that is listening for remote test layer events. Actually, there is no events, so this is used for bootstrapping the layer. That is to read the configuration parameter.

Specified by:

addListener in interface jgroup.core.Layer

activate

public void activate()

Specified by:

activate in interface RemoteTestService

See Also:

RemoteTestService.activate()

halt

public void halt()

rtest

public void rtest(int[] array)
           throws java.rmi.RemoteException

Specified by:

rtest in interface InternalRemoteTest

Throws:

java.rmi.RemoteException

See Also:

jgroup.test.gm.InternalRemoteTest#rtest()

rtest

public java.lang.Object rtest(byte[] var)
                       throws java.rmi.RemoteException

Specified by:

rtest in interface InternalRemoteTest

Throws:

java.rmi.RemoteException

See Also:

InternalRemoteTest.rtest(int)

rtest

public java.lang.Object rtest(int var)
                       throws java.rmi.RemoteException

Specified by:

rtest in interface InternalRemoteTest

Throws:

java.rmi.RemoteException

See Also:

InternalRemoteTest.rtest(int)

rtest

public java.lang.Object rtest(java.lang.Object obj)
                       throws java.rmi.RemoteException

Specified by:

rtest in interface InternalRemoteTest

Throws:

java.rmi.RemoteException

See Also:

InternalRemoteTest.rtest(Object)

deliverObject

public java.lang.Object deliverObject(java.lang.Object msg,
                                      jgroup.core.MemberId sender,
                                      int seqNo)

Specified by:

deliverObject in interface jgroup.core.multicast.MulticastListener

See Also:

jgroup.core.multicast.MulticastListener#deliverObject(Object)

deliverStream

public java.lang.Object deliverStream(java.io.InputStream msg,
                                      jgroup.core.MemberId sender,
                                      int seqNo)

Specified by:

deliverStream in interface jgroup.core.multicast.MulticastListener

See Also:

jgroup.core.multicast.MulticastListener#deliverStream(InputStream)

getProtocolName

public java.lang.String getProtocolName()

Specified by:

getProtocolName in interface jgroup.core.multicast.MulticastListener

See Also:

MulticastListener.getProtocolName()