rice.rm.testing
Class DistRMRegrTestApp

java.lang.Object
  rice.pastry.client.PastryAppl
      rice.pastry.client.CommonAPIAppl
          rice.rm.testing.RMRegrTestApp
              rice.rm.testing.DistRMRegrTestApp

All Implemented Interfaces:

MessageReceiver, RMClient

public class DistRMRegrTestApp

extends RMRegrTestApp

Nested Class Summary

Nested classes inherited from class rice.rm.testing.RMRegrTestApp

RMRegrTestApp.ReplicateEntry

Field Summary

static int	checkFreq
static int	checkStart
static int	insertionFreq
boolean	m_firstNodeInSystem
ScheduledMessage	m_objectInsertionMsg
static int	numObjects
static int	numObjectsInPeriod
int	numRefreshed
int	numReplicated
static int	refreshFreq
static int	refreshStart

Fields inherited from class rice.rm.testing.RMRegrTestApp

_sendOptions, m_appCount, m_keys, m_pastryNode, m_pendingObjects, m_refreshedKeys, m_rm, rFactor

Fields inherited from class rice.pastry.client.PastryAppl

address, instance, thePastryNode

Constructor Summary

DistRMRegrTestApp(PastryNode pn, Credentials cred, boolean firstNodeInSystem, java.lang.String instance)

Method Summary

Id	generateTopicId(java.lang.String topicName)
void	rmIsReady(RM rm) This upcall is simply to denote that the underlying replica manager (rm) is ready.

Methods inherited from class rice.rm.testing.RMRegrTestApp

checkPassed, clearRefreshedKeys, deliver, fetch, getCredentials, getLocalHandle, getPastryNode, getPendingObject, heartbeat, isResponsible, periodicMaintenance, printRange, refresh, remove, removePendingObject, replicate, replicateSuccess, scan, store

Methods inherited from class rice.pastry.client.CommonAPIAppl

forward, leafSetChange, localLookup, messageForAppl, neighborSet, notifyReady, range, range, receiveMessage, replicaSet, route, update

Methods inherited from class rice.pastry.client.PastryAppl

enrouteMessage, getAddress, getLeafSet, getNodeHandle, getNodeId, getRoutingTable, isClosest, registerReceiver, routeMsg, routeMsgDirect, routeSetChange, sendMessage

Methods inherited from class java.lang.Object

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

Field Detail

m_firstNodeInSystem

public boolean m_firstNodeInSystem

insertionFreq

public static int insertionFreq

numObjectsInPeriod

public static int numObjectsInPeriod

numObjects

public static int numObjects

refreshFreq

public static int refreshFreq

refreshStart

public static int refreshStart

checkFreq

public static int checkFreq

checkStart

public static int checkStart

numReplicated

public int numReplicated

numRefreshed

public int numRefreshed

m_objectInsertionMsg

public ScheduledMessage m_objectInsertionMsg

Constructor Detail

DistRMRegrTestApp

public DistRMRegrTestApp(PastryNode pn,
                         Credentials cred,
                         boolean firstNodeInSystem,
                         java.lang.String instance)

Method Detail

rmIsReady

public void rmIsReady(RM rm)

Description copied from interface: RMClient

This upcall is simply to denote that the underlying replica manager (rm) is ready. The 'rm' should henceforth be used by this RMClient to issue the downcalls on the RM interface.

Specified by:

rmIsReady in interface RMClient

Overrides:

rmIsReady in class RMRegrTestApp

generateTopicId

public Id generateTopicId(java.lang.String topicName)