|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object net.sf.neem.Protocol
public class Protocol
Implementation of the NeEM management bean.
Method Summary | |
---|---|
void |
addPeer(java.lang.String addr,
int port)
Connect to a new peer. |
int |
getAcceptedSocks()
Get number of socket connections accepted. |
int |
getBufferSize()
Get the default size of socket buffers. |
int |
getBytesReceived()
Get number of raw bytes received. |
int |
getBytesSent()
Get number of raw bytes transmitted. |
int |
getConnectedSocks()
Get number of successful sockets connected. |
int |
getDataReceived()
Get number of data packets received. |
int |
getDataSent()
Get number of data packets transmitted. |
int |
getDelivered()
Get number of messages delivered to the application. |
int |
getGossipFanout()
Get the number of gossip target for each round. |
int |
getHintsReceived()
Get number of packet hints received. |
int |
getHintsSent()
Get number of packet hints transmitted. |
int |
getJoinRequests()
Get number of direct join requests received. |
java.net.InetSocketAddress |
getLocalAddress()
Local listening socket. |
java.util.UUID |
getLocalId()
Get globally unique local id. |
int |
getMaxIds()
Get the maximum number of cached message ids. |
int |
getMinPullSize()
Get the minimum size of messages that can be pulled. |
int |
getMulticast()
Get number of messages multicast locally by the application. |
int |
getOverlayFanout()
Get the number of neighbors. |
int |
getPacketsReceived()
Get number of packets received. |
int |
getPacketsSent()
Get number of packets transmited. |
java.net.InetSocketAddress[] |
getPeerAddresses()
Get list of currently connected peers. |
java.util.UUID[] |
getPeerIds()
Get list of currently connected peer ids. |
java.net.InetSocketAddress |
getPublicAddress()
Get the address being advertised to peers. |
int |
getPullPeriod()
Get period for retrying to pull known messages. |
int |
getPullReceived()
Get number of pull request transmitted. |
int |
getPullSent()
Get number of pull requests transmitted. |
int |
getPurgedConnections()
Get number of connections purged after overflowing local neighborhood. |
int |
getPushTimeToLive()
Get the maximum number of times that a message is pushed. |
int |
getQueueSize()
Get the default size of buffer queues. |
int |
getShufflePeriod()
Get the delay between periodic shuffle. |
int |
getShufflesReceived()
Get number of shuffle requests received. |
int |
getShufflesSent()
Get number of shuffle requests transmitted. |
int |
getTimeToLive()
Get the maximum number of times that a message is relayed. |
void |
resetCounters()
Resets all counters. |
void |
setBufferSize(int size)
Set the default size of socket buffers. |
void |
setGossipFanout(int fanout)
Set the number of gossip target for each round. |
void |
setMaxIds(int max)
Set the maximum number of cached message ids. |
void |
setMinPullSize(int minPullSize)
Set the minimum size of messages that can be pulled. |
void |
setOverlayFanout(int fanout)
Set the number of neighbors. |
void |
setPullPeriod(int pullPeriod)
Set period for retrying to pull known messages. |
void |
setPushTimeToLive(int pushttl)
Set the maximum number of times that a message is pushed. |
void |
setQueueSize(int size)
Set the default size of buffer queues. |
void |
setShufflePeriod(int period)
Set the delay between periodic shuffle. |
void |
setTimeToLive(int ttl)
Set the maximum number of times that a message is relayed. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public int getGossipFanout()
ProtocolMBean
getGossipFanout
in interface ProtocolMBean
public void setGossipFanout(int fanout)
ProtocolMBean
setGossipFanout
in interface ProtocolMBean
fanout
- number of targetspublic int getMaxIds()
ProtocolMBean
getMaxIds
in interface ProtocolMBean
public void setMaxIds(int max)
ProtocolMBean
setMaxIds
in interface ProtocolMBean
max
- number of idspublic int getMinPullSize()
ProtocolMBean
getMinPullSize
in interface ProtocolMBean
public void setMinPullSize(int minPullSize)
ProtocolMBean
setMinPullSize
in interface ProtocolMBean
minPullSize
- size in bytespublic int getPullPeriod()
ProtocolMBean
getPullPeriod
in interface ProtocolMBean
public void setPullPeriod(int pullPeriod)
ProtocolMBean
setPullPeriod
in interface ProtocolMBean
pullPeriod
- period in millisecondspublic int getPushTimeToLive()
ProtocolMBean
getPushTimeToLive
in interface ProtocolMBean
public void setPushTimeToLive(int pushttl)
ProtocolMBean
setPushTimeToLive
in interface ProtocolMBean
pushttl
- number of hopspublic int getTimeToLive()
ProtocolMBean
getTimeToLive
in interface ProtocolMBean
public void setTimeToLive(int ttl)
ProtocolMBean
setTimeToLive
in interface ProtocolMBean
ttl
- number of hopspublic int getDelivered()
ProtocolMBean
getDelivered
in interface ProtocolMBean
public int getMulticast()
ProtocolMBean
getMulticast
in interface ProtocolMBean
public int getDataReceived()
ProtocolMBean
getDataReceived
in interface ProtocolMBean
public int getDataSent()
ProtocolMBean
getDataSent
in interface ProtocolMBean
public int getHintsReceived()
ProtocolMBean
getHintsReceived
in interface ProtocolMBean
public int getHintsSent()
ProtocolMBean
getHintsSent
in interface ProtocolMBean
public int getPullReceived()
ProtocolMBean
getPullReceived
in interface ProtocolMBean
public int getPullSent()
ProtocolMBean
getPullSent
in interface ProtocolMBean
public java.util.UUID getLocalId()
ProtocolMBean
getLocalId
in interface ProtocolMBean
public java.util.UUID[] getPeerIds()
ProtocolMBean
getPeerIds
in interface ProtocolMBean
public java.net.InetSocketAddress getPublicAddress()
ProtocolMBean
getPublicAddress
in interface ProtocolMBean
public int getOverlayFanout()
ProtocolMBean
getOverlayFanout
in interface ProtocolMBean
public void setOverlayFanout(int fanout)
ProtocolMBean
setOverlayFanout
in interface ProtocolMBean
fanout
- number of neighborspublic int getShufflePeriod()
ProtocolMBean
getShufflePeriod
in interface ProtocolMBean
public void setShufflePeriod(int period)
ProtocolMBean
setShufflePeriod
in interface ProtocolMBean
period
- in millisecondspublic int getJoinRequests()
ProtocolMBean
getJoinRequests
in interface ProtocolMBean
public int getPurgedConnections()
ProtocolMBean
getPurgedConnections
in interface ProtocolMBean
public int getShufflesReceived()
ProtocolMBean
getShufflesReceived
in interface ProtocolMBean
public int getShufflesSent()
ProtocolMBean
getShufflesSent
in interface ProtocolMBean
public java.net.InetSocketAddress getLocalAddress()
ProtocolMBean
getLocalAddress
in interface ProtocolMBean
public java.net.InetSocketAddress[] getPeerAddresses()
ProtocolMBean
getPeerAddresses
in interface ProtocolMBean
public void addPeer(java.lang.String addr, int port)
ProtocolMBean
addPeer
in interface ProtocolMBean
addr
- hostname or address of peerport
- listening port numberpublic int getQueueSize()
ProtocolMBean
getQueueSize
in interface ProtocolMBean
public void setQueueSize(int size)
ProtocolMBean
setQueueSize
in interface ProtocolMBean
size
- number of messagespublic int getBufferSize()
ProtocolMBean
getBufferSize
in interface ProtocolMBean
public void setBufferSize(int size)
ProtocolMBean
setBufferSize
in interface ProtocolMBean
size
- size in bytespublic int getAcceptedSocks()
ProtocolMBean
getAcceptedSocks
in interface ProtocolMBean
public int getConnectedSocks()
ProtocolMBean
getConnectedSocks
in interface ProtocolMBean
public int getPacketsReceived()
ProtocolMBean
getPacketsReceived
in interface ProtocolMBean
public int getPacketsSent()
ProtocolMBean
getPacketsSent
in interface ProtocolMBean
public int getBytesReceived()
ProtocolMBean
getBytesReceived
in interface ProtocolMBean
public int getBytesSent()
ProtocolMBean
getBytesSent
in interface ProtocolMBean
public void resetCounters()
ProtocolMBean
resetCounters
in interface ProtocolMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |