|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectnet.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 ProtocolMBeanpublic void setGossipFanout(int fanout)
ProtocolMBean
setGossipFanout in interface ProtocolMBeanfanout - number of targetspublic int getMaxIds()
ProtocolMBean
getMaxIds in interface ProtocolMBeanpublic void setMaxIds(int max)
ProtocolMBean
setMaxIds in interface ProtocolMBeanmax - number of idspublic int getMinPullSize()
ProtocolMBean
getMinPullSize in interface ProtocolMBeanpublic void setMinPullSize(int minPullSize)
ProtocolMBean
setMinPullSize in interface ProtocolMBeanminPullSize - size in bytespublic int getPullPeriod()
ProtocolMBean
getPullPeriod in interface ProtocolMBeanpublic void setPullPeriod(int pullPeriod)
ProtocolMBean
setPullPeriod in interface ProtocolMBeanpullPeriod - period in millisecondspublic int getPushTimeToLive()
ProtocolMBean
getPushTimeToLive in interface ProtocolMBeanpublic void setPushTimeToLive(int pushttl)
ProtocolMBean
setPushTimeToLive in interface ProtocolMBeanpushttl - number of hopspublic int getTimeToLive()
ProtocolMBean
getTimeToLive in interface ProtocolMBeanpublic void setTimeToLive(int ttl)
ProtocolMBean
setTimeToLive in interface ProtocolMBeanttl - number of hopspublic int getDelivered()
ProtocolMBean
getDelivered in interface ProtocolMBeanpublic int getMulticast()
ProtocolMBean
getMulticast in interface ProtocolMBeanpublic int getDataReceived()
ProtocolMBean
getDataReceived in interface ProtocolMBeanpublic int getDataSent()
ProtocolMBean
getDataSent in interface ProtocolMBeanpublic int getHintsReceived()
ProtocolMBean
getHintsReceived in interface ProtocolMBeanpublic int getHintsSent()
ProtocolMBean
getHintsSent in interface ProtocolMBeanpublic int getPullReceived()
ProtocolMBean
getPullReceived in interface ProtocolMBeanpublic int getPullSent()
ProtocolMBean
getPullSent in interface ProtocolMBeanpublic java.util.UUID getLocalId()
ProtocolMBean
getLocalId in interface ProtocolMBeanpublic java.util.UUID[] getPeerIds()
ProtocolMBean
getPeerIds in interface ProtocolMBeanpublic java.net.InetSocketAddress getPublicAddress()
ProtocolMBean
getPublicAddress in interface ProtocolMBeanpublic int getOverlayFanout()
ProtocolMBean
getOverlayFanout in interface ProtocolMBeanpublic void setOverlayFanout(int fanout)
ProtocolMBean
setOverlayFanout in interface ProtocolMBeanfanout - number of neighborspublic int getShufflePeriod()
ProtocolMBean
getShufflePeriod in interface ProtocolMBeanpublic void setShufflePeriod(int period)
ProtocolMBean
setShufflePeriod in interface ProtocolMBeanperiod - in millisecondspublic int getJoinRequests()
ProtocolMBean
getJoinRequests in interface ProtocolMBeanpublic int getPurgedConnections()
ProtocolMBean
getPurgedConnections in interface ProtocolMBeanpublic int getShufflesReceived()
ProtocolMBean
getShufflesReceived in interface ProtocolMBeanpublic int getShufflesSent()
ProtocolMBean
getShufflesSent in interface ProtocolMBeanpublic java.net.InetSocketAddress getLocalAddress()
ProtocolMBean
getLocalAddress in interface ProtocolMBeanpublic java.net.InetSocketAddress[] getPeerAddresses()
ProtocolMBean
getPeerAddresses in interface ProtocolMBean
public void addPeer(java.lang.String addr,
int port)
ProtocolMBean
addPeer in interface ProtocolMBeanaddr - hostname or address of peerport - listening port numberpublic int getQueueSize()
ProtocolMBean
getQueueSize in interface ProtocolMBeanpublic void setQueueSize(int size)
ProtocolMBean
setQueueSize in interface ProtocolMBeansize - number of messagespublic int getBufferSize()
ProtocolMBean
getBufferSize in interface ProtocolMBeanpublic void setBufferSize(int size)
ProtocolMBean
setBufferSize in interface ProtocolMBeansize - size in bytespublic int getAcceptedSocks()
ProtocolMBean
getAcceptedSocks in interface ProtocolMBeanpublic int getConnectedSocks()
ProtocolMBean
getConnectedSocks in interface ProtocolMBeanpublic int getPacketsReceived()
ProtocolMBean
getPacketsReceived in interface ProtocolMBeanpublic int getPacketsSent()
ProtocolMBean
getPacketsSent in interface ProtocolMBeanpublic int getBytesReceived()
ProtocolMBean
getBytesReceived in interface ProtocolMBeanpublic int getBytesSent()
ProtocolMBean
getBytesSent in interface ProtocolMBeanpublic void resetCounters()
ProtocolMBean
resetCounters in interface ProtocolMBean
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||