p2p.simulator.overlay
Class OverlayMonitor

java.lang.Object
  extended by p2p.simulator.overlay.OverlayMonitor

public class OverlayMonitor
extends java.lang.Object


Constructor Summary
OverlayMonitor(int threadPoolSize, Overlay Over, Cluster clusterMgr)
           
 
Method Summary
 void addDeleteHops(int hops)
           
 void addInsertHops(int hops)
           
 void addLookupHops(int hops)
           
 void addMsgToPeer(long peerId)
           
 int getCurrentPeers()
           
 java.util.HashMap getDeleteFt()
           
 java.util.HashMap getInsertFt()
           
 java.util.HashMap getLoadFt()
           
 java.util.HashMap getLookupFt()
           
 int[] getNumOfMessages()
           
 Overlay getOverlay()
           
 java.util.HashMap getRoutingFt()
           
 void hashNumberOfMsgs(int nofMessages)
           
 boolean notifyPeer(long id)
           
 void registerLogger(java.util.logging.Logger logger)
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OverlayMonitor

public OverlayMonitor(int threadPoolSize,
                      Overlay Over,
                      Cluster clusterMgr)
Method Detail

notifyPeer

public boolean notifyPeer(long id)

addMsgToPeer

public void addMsgToPeer(long peerId)

addLookupHops

public void addLookupHops(int hops)

getLookupFt

public java.util.HashMap getLookupFt()

addInsertHops

public void addInsertHops(int hops)

getInsertFt

public java.util.HashMap getInsertFt()

addDeleteHops

public void addDeleteHops(int hops)

getDeleteFt

public java.util.HashMap getDeleteFt()

getLoadFt

public java.util.HashMap getLoadFt()

getRoutingFt

public java.util.HashMap getRoutingFt()

hashNumberOfMsgs

public void hashNumberOfMsgs(int nofMessages)

getNumOfMessages

public int[] getNumOfMessages()

registerLogger

public void registerLogger(java.util.logging.Logger logger)

getOverlay

public Overlay getOverlay()

stop

public void stop()

getCurrentPeers

public int getCurrentPeers()