Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.cs |
This package contains all client-server related interfaces and classes
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Field and Description |
---|---|
protected boolean |
Channel.discard_own_messages |
protected boolean |
JChannel.stats
Collect statistics
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
JChannel.getAddressAsString() |
java.lang.String |
JChannel.getAddressAsUUID() |
java.lang.String |
JChannel.getClusterName() |
int |
JChannel.getNumberOfTasksInTimer() |
long |
JChannel.getReceivedBytes() |
long |
JChannel.getReceivedMessages() |
long |
JChannel.getSentBytes() |
long |
JChannel.getSentMessages() |
java.lang.String |
Channel.getState() |
int |
JChannel.getTimerThreads() |
static java.lang.String |
JChannel.getVersion() |
java.lang.String |
JChannel.getViewAsString() |
boolean |
Channel.isClosed()
Determines whether the channel is in the closed state.
|
boolean |
Channel.isConnected()
Determines whether the channel is connected to a group.
|
boolean |
Channel.isConnecting()
Determines whether the channel is in the connecting state; this means
Channel.connect(String) has been
called, but hasn't returned yet |
boolean |
Channel.isOpen()
Determines whether the channel is open; ie.
|
void |
JChannel.setName(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
int |
ReplCache.getClusterSize() |
java.lang.String |
ReplCache.getLocalAddressAsString() |
java.lang.String |
PartitionedHashMap.getLocalAddressAsString() |
int |
Cache.getSize() |
java.lang.String |
ReplCache.getView() |
java.lang.String |
PartitionedHashMap.getView() |
boolean |
ReplCache.isL1CacheEnabled() |
boolean |
PartitionedHashMap.isL1CacheEnabled() |
boolean |
Cache.isReapingEnabled() |
Modifier and Type | Field and Description |
---|---|
protected long |
BaseServer.conn_expire_time |
protected int |
NioBaseServer.max_send_buffers |
protected int |
NioBaseServer.num_selects |
protected int |
BaseServer.recv_buf_size |
protected int |
BaseServer.send_buf_size |
protected boolean |
BaseServer.use_peer_connections |
Modifier and Type | Method and Description |
---|---|
int |
BaseServer.getNumConnections() |
int |
BaseServer.getNumOpenConnections() |
boolean |
BaseServer.running() |
Modifier and Type | Method and Description |
---|---|
void |
JmxDemo.foobar() |
int |
JmxDemo.getAccountNumber() |
int |
JmxDemo.getMaxAge() |
static int |
JmxDemo.getMyFoo() |
java.lang.String |
JmxDemo.getNumberAsString() |
static boolean |
JmxDemo.isFlag() |
void |
JmxDemo.setAccountNumber(int num) |
void |
JmxDemo.setMaxAge(int age) |
void |
JmxDemo.setMyNumber(long new_number) |
void |
JmxDemo.setNumber(int num) |
void |
JmxDemo.setOtherNumber(int num) |
Modifier and Type | Field and Description |
---|---|
protected AsciiString |
TP.cluster_name
The name of the group to which this member is connected.
|
protected java.lang.String |
STOMP.endpoint |
protected boolean |
RSVP.handle_unicasts |
protected boolean |
FD_ALL.has_suspected_mbrs |
protected boolean |
FD_ALL2.has_suspected_mbrs |
protected boolean |
FD_HOST.has_suspected_mbrs |
protected boolean |
CENTRAL_EXECUTOR.is_coord |
protected boolean |
RELAY.is_coord |
protected boolean |
MERGE3.is_coord |
protected boolean |
MERGE2.is_coord
Deprecated.
|
protected boolean |
Discovery.is_coord |
protected boolean |
CENTRAL_LOCK.is_coord |
int |
DAISYCHAIN.msgs_forwarded |
int |
DAISYCHAIN.msgs_sent |
protected long |
TP.num_batches_received |
protected long |
TP.num_batches_sent |
protected int |
RATE_LIMITER.num_blockings |
protected long |
TP.num_bytes_received |
protected long |
TP.num_bytes_sent |
protected long |
RATE_LIMITER.num_bytes_sent_in_period
Keeps track of the number of bytes sent in the current time period
|
protected int |
Discovery.num_discovery_requests |
protected int |
DISCARD.num_down |
protected int |
FD_ALL.num_heartbeats_received |
protected int |
FD_ALL2.num_heartbeats_received |
protected int |
FD_ALL.num_heartbeats_sent |
protected int |
FD_ALL2.num_heartbeats_sent |
protected long |
TP.num_incoming_msgs_received |
protected int |
MERGE2.num_inconsistent_views
Deprecated.
|
protected long |
TP.num_internal_msgs_received |
protected int |
FD_HOST.num_liveness_checks |
protected int |
MERGE3.num_merge_events |
protected int |
MERGE2.num_merge_events
Deprecated.
|
protected int |
UNICAST2.num_messages_received
Deprecated.
|
protected int |
UNICAST2.num_messages_sent
Deprecated.
|
protected long |
TP.num_msgs_received |
protected long |
TP.num_msgs_sent |
protected long |
TP.num_oob_msgs_received |
protected int |
TP.num_rejected_msgs |
protected long |
TP.num_single_msgs_received |
protected long |
TP.num_single_msgs_sent |
protected long |
TP.num_single_msgs_sent_instead_of_batch |
protected int |
FD_ALL.num_suspect_events |
protected int |
FD_ALL2.num_suspect_events |
protected int |
FD_HOST.num_suspect_events |
protected int |
DISCARD.num_up |
protected boolean |
ASYM_ENCRYPT.queue_up_msgs |
protected int |
FILE_PING.reads |
protected boolean |
Discovery.transport_supports_multicasting |
protected View |
SHARED_LOOPBACK.view |
protected int |
FILE_PING.writes |
protected java.util.concurrent.atomic.AtomicLong |
UNICAST3.xmit_reqs_received |
protected java.util.concurrent.atomic.AtomicLong |
UNICAST2.xmit_reqs_received
Deprecated.
|
protected java.util.concurrent.atomic.AtomicLong |
UNICAST3.xmit_reqs_sent |
protected java.util.concurrent.atomic.AtomicLong |
UNICAST2.xmit_reqs_sent
Deprecated.
|
protected java.util.concurrent.atomic.AtomicLong |
UNICAST3.xmit_rsps_sent |
protected java.util.concurrent.atomic.AtomicLong |
UNICAST2.xmit_rsps_sent
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
int |
TP.bundlerNumSpins() |
void |
TP.bundlerNumSpins(int spins) |
java.lang.String |
TP.bundlerWaitStrategy() |
void |
TP.bundlerWaitStrategy(java.lang.String strategy) |
java.lang.String |
Locking.getAddress() |
java.lang.String |
COUNTER.getAddress() |
java.lang.String |
Executing.getAddress() |
java.lang.String |
TP.ProtocolAdapter.getAddressAsString() |
java.lang.String |
TP.ProtocolAdapter.getAddressAsUUID() |
int |
UNICAST.getAgeOutCacheSize()
Deprecated.
|
int |
UNICAST3.getAgeOutCacheSize() |
int |
UNICAST2.getAgeOutCacheSize()
Deprecated.
|
double |
RATE_LIMITER.getAverageBlockTime() |
double |
MFC.getAverageTimeBlocked() |
double |
FC.getAverageTimeBlocked()
Deprecated.
|
double |
UFC.getAverageTimeBlocked() |
double |
TP.getAvgBatchSize() |
double |
DELIVERY_TIME.getAvgDeliveryTime() |
java.lang.String |
COUNTER.getBackupCoords() |
java.lang.String |
CENTRAL_EXECUTOR.getBackups() |
java.lang.String |
CENTRAL_LOCK.getBackups() |
java.lang.String |
RELAY.getBridgeView() |
long |
SEQUENCER2.getBroadcast() |
long |
SEQUENCER.getBroadcast() |
int |
TP.getBundlerBufferSize() |
java.lang.String |
TP.getBundlerClass() |
java.lang.String |
TP.getClusterName() |
java.lang.String |
TP.ProtocolAdapter.getClusterName() |
java.lang.String |
CENTRAL_EXECUTOR.getCoordinator() |
java.lang.String |
CENTRAL_LOCK.getCoordinator() |
java.lang.String |
MERGE2.getCurrentCoord()
Deprecated.
|
java.lang.String |
Discovery.getCurrentCoord() |
int |
FORWARD_TO_COORD.getDeliveryTableSize() |
int |
TP.getDifferentClusterMessages() |
int |
TP.getDifferentVersionMessages() |
int |
UDP.getDroppedMessage() |
java.lang.String |
TCPPING.getDynamicHostList() |
java.lang.String |
STOMP.getEndpoints() |
int |
FORK.getForkStacks() |
long |
SEQUENCER.getForwarded() |
int |
FORWARD_TO_COORD.getForwardTableSize() |
int |
SEQUENCER.getForwardTableSize() |
int |
SEQUENCER2.getFwdQueueSize() |
java.lang.String |
RELAY.getGlobalView() |
java.lang.String |
BARRIER.getHoles() |
java.lang.String |
DISCARD.getIgnoredMembers() |
int |
BARRIER.getInFlightThreadsCount() |
java.lang.String |
TCPPING.getInitialHostsList() |
int |
TP.getInternalPoolSize() |
int |
TP.getInternalPoolSizeActive() |
int |
TP.getInternalQueueSize() |
java.lang.String |
ASYM_ENCRYPT.getKeyServerAddress() |
java.lang.String |
UNICAST.getLocalAddress()
Deprecated.
|
java.lang.String |
FD_SOCK.getLocalAddress() |
java.lang.String |
FD.getLocalAddress() |
java.lang.String |
UNICAST3.getLocalAddress() |
java.lang.String |
TP.getLocalAddress() |
java.lang.String |
FD_ALL.getLocalAddress() |
java.lang.String |
FD_ALL2.getLocalAddress() |
java.lang.String |
UNICAST2.getLocalAddress()
Deprecated.
|
java.lang.String |
TP.getLocalPhysicalAddress() |
java.lang.String |
RELAY.getLocalView() |
java.lang.String |
UNICAST.getMembers()
Deprecated.
|
java.lang.String |
FD_SOCK.getMembers() |
java.lang.String |
FD.getMembers() |
java.lang.String |
UNICAST3.getMembers() |
java.lang.String |
FD_ALL.getMembers() |
java.lang.String |
FD_ALL2.getMembers() |
java.lang.String |
UNICAST2.getMembers()
Deprecated.
|
long |
UNICAST.getNumAcksReceived()
Deprecated.
|
long |
UNICAST3.getNumAcksReceived() |
long |
UNICAST.getNumAcksSent()
Deprecated.
|
long |
UNICAST3.getNumAcksSent() |
int |
SCOPE.getNumActiveThreads()
Deprecated.
|
int |
MFC.getNumberOfBlockings() |
int |
FC.getNumberOfBlockings()
Deprecated.
|
int |
UFC.getNumberOfBlockings() |
int |
FC.getNumberOfCreditRequestsReceived()
Deprecated.
|
int |
FlowControl.getNumberOfCreditRequestsReceived() |
int |
FC.getNumberOfCreditRequestsSent()
Deprecated.
|
int |
FlowControl.getNumberOfCreditRequestsSent() |
int |
FC.getNumberOfCreditResponsesReceived()
Deprecated.
|
int |
FlowControl.getNumberOfCreditResponsesReceived() |
int |
FC.getNumberOfCreditResponsesSent()
Deprecated.
|
int |
FlowControl.getNumberOfCreditResponsesSent() |
int |
FD.getNumberOfHeartbeatsSent() |
int |
SCOPE.getNumberOfMessages()
Deprecated.
|
int |
UNICAST.getNumberOfMessagesInReceiveWindows()
Deprecated.
|
int |
SCOPE.getNumberOfReceiverScopes()
Deprecated.
|
int |
UNICAST.getNumConnections()
Deprecated.
|
int |
STOMP.getNumConnections() |
int |
UNICAST3.getNumConnections() |
int |
UNICAST2.getNumConnections()
Deprecated.
|
long |
UNICAST.getNumMessagesReceived()
Deprecated.
|
long |
UNICAST3.getNumMessagesReceived() |
long |
UNICAST.getNumMessagesSent()
Deprecated.
|
long |
UNICAST3.getNumMessagesSent() |
int |
UNICAST.getNumReceiveConnections()
Deprecated.
|
int |
UNICAST3.getNumReceiveConnections() |
int |
UNICAST2.getNumReceiveConnections()
Deprecated.
|
int |
UNICAST.getNumSendConnections()
Deprecated.
|
int |
UNICAST3.getNumSendConnections() |
int |
UNICAST2.getNumSendConnections()
Deprecated.
|
int |
STOMP.getNumSubscriptions() |
int |
FD_SOCK.getNumSuspectedMembers() |
int |
FD_SOCK.getNumSuspectEventsGenerated() |
int |
FD.getNumSuspectEventsGenerated() |
static int |
TP.getNumThreads() |
int |
TP.getNumTimerTasks() |
int |
UNICAST.getNumUnackedMessages()
Deprecated.
The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
|
int |
UNICAST3.getNumUnackedMessages()
The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
|
long |
UNICAST.getNumXmits()
Deprecated.
|
long |
UNICAST3.getNumXmits() |
int |
TP.getOOBPoolSize() |
int |
TP.getOOBPoolSizeActive() |
int |
TP.getOOBQueueSize() |
int |
TCP_NIO.getOpenConnections()
Deprecated.
|
int |
TCP_NIO2.getOpenConnections() |
int |
TCP.getOpenConnections() |
int |
RSVP.getPendingRsvpRequests() |
java.lang.String |
FD_SOCK.getPingableMembers() |
java.lang.String |
FD.getPingableMembers() |
java.lang.String |
FD_SOCK.getPingDest() |
java.lang.String |
FD.getPingDest() |
long |
SEQUENCER2.getReceivedBroadcasts() |
long |
SEQUENCER.getReceivedBroadcasts() |
long |
STATS.getReceivedBytes() |
long |
SEQUENCER.getReceivedForwards() |
long |
STATS.getReceivedMcastBytes() |
long |
STATS.getReceivedMcastMessages() |
long |
STATS.getReceivedMessages() |
long |
SEQUENCER2.getReceivedRequests() |
long |
STATS.getReceivedUnicastBytes() |
long |
STATS.getReceivedUnicastMessages() |
int |
TP.getRegularPoolSize() |
int |
TP.getRegularPoolSizeActive() |
int |
TP.getRegularQueueSize() |
java.lang.String |
RELAY.getRemoteView() |
long |
STATS.getSentBytes() |
long |
STATS.getSentMcastBytes() |
long |
STATS.getSentMcastMessages() |
long |
STATS.getSentMessages() |
long |
STATS.getSentUnicastBytes() |
long |
STATS.getSentUnicastMessages() |
java.lang.String |
STOMP.getSubscriptions() |
java.lang.String |
FD_SOCK.getSuspectedMembers() |
java.lang.String |
FD_ALL.getSuspectedMembers() |
java.lang.String |
FD_ALL2.getSuspectedMembers() |
java.lang.String |
FD_HOST.getSuspectedMembers() |
java.lang.String |
VERIFY_SUSPECT.getSuspects() |
java.lang.String |
TP.getTimerClass() |
int |
TP.getTimerQueueSize() |
int |
TP.getTimerThreads() |
long |
UNICAST3.getTimestamper() |
long |
RATE_LIMITER.getTotalBlockTime() |
long |
FC.getTotalTimeBlocked()
Deprecated.
|
short |
TP.ProtocolAdapter.getTransportName() |
java.lang.String |
Locking.getView() |
java.lang.String |
COUNTER.getView() |
java.lang.String |
Discovery.getView() |
java.lang.String |
Executing.getView() |
int |
MERGE3.getViews() |
long |
UNICAST.getXmitTableMissingMessages()
Deprecated.
|
long |
UNICAST3.getXmitTableMissingMessages() |
long |
UNICAST2.getXmitTableMissingMessages()
Deprecated.
|
int |
UNICAST.getXmitTableNumCompactions()
Deprecated.
|
int |
UNICAST3.getXmitTableNumCompactions() |
int |
UNICAST2.getXmitTableNumCompactions()
Deprecated.
|
int |
UNICAST.getXmitTableNumMoves()
Deprecated.
|
int |
UNICAST3.getXmitTableNumMoves() |
int |
UNICAST2.getXmitTableNumMoves()
Deprecated.
|
int |
UNICAST.getXmitTableNumPurges()
Deprecated.
|
int |
UNICAST3.getXmitTableNumPurges() |
int |
UNICAST2.getXmitTableNumPurges()
Deprecated.
|
int |
UNICAST.getXmitTableNumResizes()
Deprecated.
|
int |
UNICAST3.getXmitTableNumResizes() |
int |
UNICAST2.getXmitTableNumResizes()
Deprecated.
|
long |
UNICAST.getXmitTableUndeliveredMessages()
Deprecated.
|
long |
UNICAST3.getXmitTableUndeliveredMessages() |
long |
UNICAST2.getXmitTableUndeliveredMessages()
Deprecated.
|
boolean |
TCP_NIO2.isAcceptorRunning() |
boolean |
BARRIER.isClosed() |
boolean |
UNICAST.isConnectionReaperRunning()
Deprecated.
|
boolean |
UNICAST2.isConnectionReaperRunning()
Deprecated.
|
boolean |
SEQUENCER2.isCoordinator() |
boolean |
SEQUENCER.isCoordinator() |
boolean |
TP.isDiagnosticsHandlerRunning() |
boolean |
MERGE3.isInfoSenderRunning() |
boolean |
JDBC_PING.isInfoWriterRunning() |
boolean |
FILE_PING.isInfoWriterRunning() |
boolean |
ASYM_ENCRYPT.isKeyServer() |
boolean |
TP.isLogicalAddressCacheReaperRunning() |
boolean |
MERGE3.isMergeTaskRunning() |
boolean |
MERGE2.isMergeTaskRunning()
Deprecated.
|
boolean |
FD.isMonitorRunning() |
boolean |
FD_SOCK.isNodeCrashMonitorRunning() |
boolean |
BARRIER.isOpenerScheduled() |
boolean |
FD_HOST.isPingerRunning() |
protected boolean |
RSVP.isResendTaskRunning() |
boolean |
FD_ALL.isRunning() |
boolean |
FD_ALL2.isRunning() |
boolean |
TCP_NIO2.isSelectorOpen() |
boolean |
MERGE3.isViewConsistencyCheckerRunning() |
boolean |
UNICAST.isXmitTaskRunning()
Deprecated.
|
boolean |
UNICAST3.isXmitTaskRunning() |
boolean |
UNICAST2.isXmitTaskRunning()
Deprecated.
|
double |
PERF.latencyInMs() |
double |
PERF.latencyInNs() |
static java.lang.String |
TP.loggerType() |
int |
TCP_NIO2.numPartialWrites() |
int |
TCP_NIO2.numSelects() |
int |
ASYM_ENCRYPT.queueSize() |
void |
TCP_NIO2.readerIdleTime(long t) |
java.lang.String |
EncryptBase.version() |
Modifier and Type | Field and Description |
---|---|
protected long |
STABLE.num_bytes_received
The total number of bytes received from unicast and multicast messages
|
protected int |
NAKACK.num_messages_received
Deprecated.
|
protected int |
NAKACK2.num_messages_received |
protected int |
NAKACK.num_messages_sent
Deprecated.
|
protected int |
NAKACK2.num_messages_sent |
protected boolean |
STABLE.suspended
When true, don't take part in garbage collection: neither send STABLE messages nor handle STABILITY messages
|
protected java.util.concurrent.atomic.AtomicLong |
NAKACK2.xmit_reqs_received |
protected java.util.concurrent.atomic.AtomicLong |
NAKACK2.xmit_reqs_sent |
protected java.util.concurrent.atomic.AtomicLong |
NAKACK2.xmit_rsps_received |
protected java.util.concurrent.atomic.AtomicLong |
NAKACK2.xmit_rsps_sent |
Modifier and Type | Method and Description |
---|---|
double |
FLUSH.getAverageFlushDuration() |
double |
StreamingStateTransfer.getAverageStateSize() |
double |
STATE_TRANSFER.getAverageStateSize() |
int |
NAKACK2.getBecomeServerQueueSizeActual() |
long |
NAKACK.getCurrentSeqno()
Deprecated.
|
long |
NAKACK2.getCurrentSeqno() |
java.lang.String |
GMS.getImplementation() |
java.lang.String |
GMS.getLocalAddress() |
java.lang.String |
GMS.getMembers() |
java.lang.String |
GMS.getMergeId() |
int |
NAKACK.getNonMemberMessages()
Deprecated.
|
int |
NAKACK2.getNonMemberMessages() |
int |
FLUSH.getNumberOfFlushes() |
long |
StreamingStateTransfer.getNumberOfStateBytesSent() |
long |
STATE_TRANSFER.getNumberOfStateBytesSent() |
int |
StreamingStateTransfer.getNumberOfStateRequests() |
int |
STATE_TRANSFER.getNumberOfStateRequests() |
int |
GMS.getNumberOfViews() |
int |
GMS.getNumMembers() |
int |
NAKACK.getPendingXmitRequests()
Deprecated.
|
long |
NAKACK.getSizeOfAllMessages()
Deprecated.
|
long |
NAKACK2.getSizeOfAllMessages() |
long |
NAKACK.getSizeOfAllMessagesInclHeaders()
Deprecated.
|
long |
NAKACK2.getSizeOfAllMessagesInclHeaders() |
int |
STABLE.getStabilityReceived() |
int |
STABLE.getStabilitySent() |
int |
STABLE.getStableReceived() |
int |
STABLE.getStableSent() |
boolean |
STABLE.getStableTaskRunning() |
long |
StreamingStateTransfer.getThreadPoolCompletedTasks() |
int |
StreamingStateTransfer.getThreadPoolSize() |
long |
FLUSH.getTotalTimeInFlush() |
java.lang.String |
GMS.getView() |
int |
GMS.getViewHandlerSize() |
long |
NAKACK2.getXmitTableCapacity() |
int |
NAKACK.getXmitTableMissingMessages()
Deprecated.
|
int |
NAKACK2.getXmitTableMissingMessages() |
int |
NAKACK2.getXmitTableNumCompactions() |
int |
NAKACK2.getXmitTableNumCurrentRows() |
int |
NAKACK2.getXmitTableNumMoves() |
int |
NAKACK2.getXmitTableNumPurges() |
int |
NAKACK2.getXmitTableNumResizes() |
int |
NAKACK.getXmitTableSize()
Deprecated.
|
int |
NAKACK2.getXmitTableUndeliveredMsgs() |
boolean |
GMS.isCoord() |
boolean |
GMS.isMergeInProgress() |
boolean |
GMS.isMergeKillerRunning() |
boolean |
GMS.isMergeTaskRunning() |
boolean |
GMS.isViewHandlerSuspended() |
boolean |
NAKACK2.isXmitTaskRunning() |
boolean |
NAKACK2.resendTaskRunning() |
void |
NAKACK2.setResendLastSeqno(boolean flag) |
Modifier and Type | Field and Description |
---|---|
protected boolean |
RELAY2.forwarding_protocol_present
Whether or not FORWARD_TO_COORD is on the stack
|
protected boolean |
RELAY2.is_site_master |
Modifier and Type | Method and Description |
---|---|
long |
RELAY2.getAvgMsgsDeliveringLocally() |
long |
RELAY2.getAvgMsgsForwardingToLocalMbr() |
long |
RELAY2.getAvgMsgsForwardingToSM() |
long |
RELAY2.getAvgMsgsRelaying() |
long |
RELAY2.getNumForwardedToLocalMbr() |
long |
RELAY2.getNumForwardedToSiteMaster() |
long |
RELAY2.getNumLocalDeliveries() |
long |
RELAY2.getNumRelayed() |
long |
RELAY2.getTimeDeliveringLocally() |
long |
RELAY2.getTimeForwardingToLocalMbr() |
long |
RELAY2.getTimeForwardingToSM() |
long |
RELAY2.getTimeRelaying() |
boolean |
RELAY2.isSiteMaster() |
Modifier and Type | Field and Description |
---|---|
protected int |
SUPERVISOR.num_event_handlers |
Modifier and Type | Method and Description |
---|---|
int |
SUPERVISOR.getNumRules() |
Modifier and Type | Method and Description |
---|---|
double |
TOA.getAvgDataMessageReceivedDuration() |
double |
TOA.getAvgFinalMessageReceivedDuration() |
double |
TOA.getAvgLastProposeMessageReceivedDuration() |
double |
TOA.getAvgNumberOfUnicastSentPerAnycast() |
double |
TOA.getAvgProposeMessageReceivedDuration() |
double |
TOA.getAvgToaSendDuration() |
int |
TOA.getNumberOfAnycastMessagesDelivered() |
int |
TOA.getNumberOfAnycastMessagesSent() |
int |
TOA.getNumberOfDataMessagesDelivered() |
int |
TOA.getNumberOfFinalAnycastSent() |
int |
TOA.getNumberOfFinalMessagesDelivered() |
int |
TOA.getNumberOfProposeMessageReceived() |
int |
TOA.getNumberOfProposeMessageSent() |
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
GossipRouter.bind_addr |
protected long |
GossipRouter.expiry_time |
protected int |
GossipRouter.port |
Modifier and Type | Method and Description |
---|---|
boolean |
GossipRouter.running() |
Copyright © 1998-2020 Red Hat. All Rights Reserved.