Uses of Class
org.jgroups.annotations.ManagedOperation

Packages that use ManagedOperation

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
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.dns
org.jgroups.protocols.pbcast
org.jgroups.protocols.relay
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of ManagedOperation in org.jgroups

Methods in org.jgroups with annotations of type ManagedOperation

Modifier and Type	Method	Description
void	JChannel.close()	Destroys the channel and its associated resources (e.g.
JChannel	JChannel.connect(java.lang.String cluster_name)	Joins the cluster.
JChannel	JChannel.disconnect()	Leaves the cluster (disconnects the channel if it is connected).
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Object>>	JChannel.dumpStats()	Returns a map of statistics of the various protocols and of the channel itself
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Object>>	JChannel.dumpStats(java.lang.String protocol_name)
java.lang.String	JChannel.printProtocolSpec(boolean include_props)	Dumps all protocols in string format.
java.lang.String	JChannel.toString(boolean details)

Uses of ManagedOperation in org.jgroups.blocks

Methods in org.jgroups.blocks with annotations of type ManagedOperation

Modifier and Type	Method	Description
void	ReplCache.clear()	Removes all keys and values in the L2 and L1 caches
void	Cache.disableReaping()
java.lang.String	ReplCache.dump()
void	Cache.enableReaping(long interval)	Runs the reaper every interval ms, evicts expired items
V	Cache.get(K key)
V	ReplCache.get(K key)	Returns the value associated with key
V	Cache.put(K key, V val, long caching_time)
void	ReplCache.put(K key, V val)
void	ReplCache.put(K key, V val, short repl_count, long timeout)	Places a key/value pair into one or several nodes in the cluster.
void	ReplCache.put(K key, V val, short repl_count, long timeout, boolean synchronous)	Places a key/value pair into one or several nodes in the cluster.
void	ReplCache.remove(K key)	Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
void	ReplCache.remove(K key, boolean synchronous)	Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
void	Cache.start()
void	ReplCache.start()
void	Cache.stop()
void	ReplCache.stop()
java.lang.String	Cache.toString()

Uses of ManagedOperation in org.jgroups.blocks.cs

Methods in org.jgroups.blocks.cs with annotations of type ManagedOperation

Modifier and Type	Method	Description
java.lang.String	NioBaseServer.printBuffers()	Prints send and receive buffers for all connections
java.lang.String	BaseServer.printConnections()
void	NioServer.start()
void	NioServer.stop()

Uses of ManagedOperation in org.jgroups.demos

Methods in org.jgroups.demos with annotations of type ManagedOperation

Modifier and Type	Method	Description
static java.lang.String	JmxDemo.sayName()

Uses of ManagedOperation in org.jgroups.protocols

Methods in org.jgroups.protocols with annotations of type ManagedOperation

Modifier and Type	Method	Description
CLEAR_FLAGS	CLEAR_FLAGS.addFlag(boolean down, java.lang.String flag)
void	TCPGOSSIP.addInitialHost(java.lang.String hostname, int port)
void	Discovery.addToCache(java.lang.String filename)
<T extends TP> T	TP.bundler(java.lang.String type)
void	NAKACK4.changeCapacity(int new_capacity)	Changes the capacity of the buffer, basically by creating a new buffer and copying the messages from the old one.
void	UNICAST4.changeCapacity(int new_capacity)	Changes the capacity of all buffers, basically by creating new buffers and copying the messages from the old ones.
void	RATE_LIMITER2.changeInterval(long new_interval)
void	MERGE3.checkInconsistencies()
void	FRAG2.clearAllFragments()
void	FRAG3.clearAllFragments()
ReliableMulticast	ReliableMulticast.clearCachedBatches()
ReliableUnicast	ReliableUnicast.clearCachedBatches()
UNICAST3	UNICAST3.clearCachedBatches()
void	TCP_NIO2.clearConnections()
TCP	TCP.clearConnections()
<T extends TP> T	TP.clearDifferentClusterCache()
<T extends TP> T	TP.clearDifferentVersionCache()
<T extends UDP> T	UDP.clearDroppedMessagesCache()
<T extends TCPPING> T	TCPPING.clearDynamicHostList()
void	FRAG2.clearFragmentsFor(Address mbr)
void	FRAG3.clearFragmentsFor(Address mbr)
void	TP.clearLogicalAddressCache()	Clears the cache.
void	ReliableMulticast.clearNonMemberCache()
void	MERGE3.clearViews()
void	ReliableUnicast.closeIdleConnections()
void	UNICAST3.closeIdleConnections()
void	NAKACK3.compact()
void	TP.disableDiagnostics()
java.lang.String	JDBC_PING2.dump(java.lang.String cluster)
void	Discovery.dumpCache(java.lang.String output_filename)
java.lang.String	COUNTER.dumpPendingRequests()
static java.lang.String	SHARED_LOOPBACK.dumpRoutingTable()
java.lang.String	TP.dumpTimerTasks()
java.lang.String	MERGE3.dumpViews()
java.lang.String	NAKACK3.dumpXmitTablesNumCurrentRows()
void	TP.enableAllStats(boolean flag)
<T extends TP> T	TP.enableBlockingTimerTasks(boolean flag)
<T extends TP> T	TP.enableDiagnostics()
void	TP.evictLogicalAddressCache()
java.lang.String	SOS.exec()
java.lang.String	Discovery.findInitialMembersAsString()
REVERSE	REVERSE.flush()
void	SHUFFLE.flush(boolean stop_shuffling)
void	INJECT_VIEW.injectView(java.lang.String newView)
boolean	FD_HOST.isAlive(java.lang.String host)
void	BARRIER.openBarrier()
static java.lang.String	LOCAL_PING.print()
java.lang.String	TCPGOSSIP.print()
java.lang.String	TUNNEL.print()
java.lang.String	NAKACK4.printAckTable()
java.lang.String	SimpleTCP.printAddressTable()
java.lang.String	ReliableUnicast.printAgeOutCache()
java.lang.String	UNICAST3.printAgeOutCache()
java.lang.String	ReliableMulticast.printBatches()
java.lang.String	BaseBundler.printBuffers()
java.lang.String	TCP_NIO2.printBuffers()
java.lang.String	FD_SOCK.printCache()
java.lang.String	PDC.printCache()
java.lang.String	ReliableMulticast.printCachedBatches()
java.lang.String	ReliableUnicast.printCachedBatches()
java.lang.String	UNICAST3.printCachedBatches()
java.lang.String	Encrypt.printCachedGroupKeys()
java.lang.String	FD_SOCK2.printConnections()
java.lang.String	ReliableUnicast.printConnections()
java.lang.String	TCP_NIO2.printConnections()
java.lang.String	TCP.printConnections()
java.lang.String	UNICAST3.printConnections()
java.lang.String	COUNTER.printCounters()
java.lang.String	MFC.printCredits()
java.lang.String	UFC.printCredits()
java.lang.String	ReliableMulticast.printDigestHistory()
java.lang.String	FD_HOST.printHosts()
protected java.lang.String	BARRIER.printInFlightThreads()
java.lang.String	TP.printLogicalAddressCache()
java.lang.String	ReliableMulticast.printMessages()
java.lang.String	RATE.printReceiveHistory()
java.lang.String	FlowControl.printReceiverCredits()
java.lang.String	ReliableUnicast.printReceiveWindowMessages()
java.lang.String	UNICAST3.printReceiveWindowMessages()
java.lang.String	TCPGOSSIP.printReconnectList()
java.lang.String	TUNNEL.printReconnectList()
java.lang.String	MFC.printSenderCredits()
java.lang.String	UFC.printSenderCredits()
java.lang.String	RATE.printSendHistory()
java.lang.String	ReliableUnicast.printSendWindowMessages()
java.lang.String	UNICAST3.printSendWindowMessages()
java.lang.String	ReliableMulticast.printStabilityMessages()
java.lang.String	STATS.printStats()
java.lang.String	TCPGOSSIP.printStubs()
java.lang.String	TUNNEL.printStubs()
java.lang.String	FailureDetection.printSuspectHistory()
java.lang.String	FD_HOST.printSuspectHistory()
java.lang.String	FD_SOCK.printSuspectHistory()
java.lang.String	FD_SOCK2.printSuspectHistory()
java.lang.String	FD_ALL.printTimestamps()
java.lang.String	FD_ALL2.printTimestamps()
java.lang.String	FD_ALL3.printTimestamps()
java.lang.String	FD_HOST.printTimestamps()
java.lang.String	TP.printWhoHasCache()
SOS	SOS.read()
void	SSL_KEY_EXCHANGE.reloadKeystoreAndTruststore()
void	ReliableUnicast.removeAllConnections()	This method is public only so it can be invoked by unit testing, but should not otherwise be used !
void	UNICAST3.removeAllConnections()	This method is public only so it can be invoked by unit testing, but should not otherwise be used !
CLEAR_FLAGS	CLEAR_FLAGS.removeAllFlags()
void	TP.removeCancelledTimerTasks()
int	ReliableUnicast.removeConnections(boolean remove_send_connections, boolean remove_receive_connections)	Removes send- and/or receive-connections whose state is not OPEN (CLOSING or CLOSED).
int	UNICAST3.removeConnections(boolean remove_send_connections, boolean remove_receive_connections)	Removes send- and/or receive-connections whose state is not OPEN (CLOSING or CLOSED).
int	ReliableUnicast.removeExpiredConnections()
int	UNICAST3.removeExpiredConnections()
CLEAR_FLAGS	CLEAR_FLAGS.removeFlag(boolean down, java.lang.String flag)
boolean	TCPGOSSIP.removeInitialHost(java.lang.String hostname, int port)
void	MFC.replenish(Address mbr, long credits)
void	RATE_LIMITER2.replenish()
void	ReliableMulticast.resetStats()
void	SEQUENCER.resetStats()
void	SEQUENCER2.resetStats()
void	Discovery.sendCacheInformation()
void	MERGE3.sendInfo()
void	NAKACK4.sendPendingAcks()
void	ReliableUnicast.sendPendingAcks()
void	UNICAST3.sendPendingAcks()
SOS	SOS.setCommand(java.lang.String filename)
<T extends TP> T	TP.setMessageProcessingPolicy(java.lang.String policy)
void	FailureDetection.startFailureDetection()
void	DISCARD.startGui()
boolean	FD_SOCK.startNodeCrashMonitor()
void	FailureDetection.stopFailureDetection()
void	DISCARD.stopGui()
void	ReliableMulticast.triggerXmit()
void	ReliableUnicast.triggerXmit()
void	UNICAST3.triggerXmit()
ReliableUnicast	ReliableUnicast.trimCachedBatches()
UNICAST3	UNICAST3.trimCachedBatches()
void	FlowControl.unblock()	Allows to unblock all blocked senders from an external program, e.g.
void	MFC.unblock()	Allows to unblock a blocked sender from an external program, e.g.
void	Discovery.weedOutCompletedDiscoveryResponses()	Removes responses which are done or whose timeout has expired (in the latter case, an expired response is marked as done)
void	FILE_PING.writeInfo()

Uses of ManagedOperation in org.jgroups.protocols.dns

Methods in org.jgroups.protocols.dns with annotations of type ManagedOperation

Modifier and Type	Method	Description
java.lang.String	DNS_PING.fetchFromDns()

Uses of ManagedOperation in org.jgroups.protocols.pbcast

Methods in org.jgroups.protocols.pbcast with annotations of type ManagedOperation

Modifier and Type	Method	Description
void	GMS.cancelMerge()
NAKACK2	NAKACK2.clearCachedBatches()
void	NAKACK2.clearNonMemberCache()
void	STATE_TRANSFER.closeBarrierAndSuspendStable()
void	StreamingStateTransfer.closeBarrierAndSuspendStable()
void	NAKACK2.compact()
java.lang.String	GMS.dumpViewHandlerHistory()
java.lang.String	GMS.dumpViewHandlerQueue()
java.lang.String	NAKACK2.dumpXmitTablesNumCurrentRows()
void	GMS.fixDigests()
void	STABLE.gc()
void	STATE_TRANSFER.openBarrierAndResumeStable()
void	StreamingStateTransfer.openBarrierAndResumeStable()
java.lang.String	NAKACK2.printCachedBatches()
java.lang.String	STABLE.printDigest()
java.lang.String	NAKACK2.printDigestHistory()
java.lang.String	GMS.printMergeIdHistory()
java.lang.String	NAKACK2.printMessages()
java.lang.String	GMS.printPreviousMembers()
java.lang.String	GMS.printPreviousViews()
java.lang.String	NAKACK2.printStabilityMessages()
java.lang.String	STABLE.printVotes()
void	NAKACK2.resetStats()
void	GMS.resumeViewHandler()
void	GMS.suspect(java.lang.String suspected_member)
void	GMS.suspendViewHandler()
void	NAKACK2.triggerXmit()
NAKACK2	NAKACK2.trimCachedBatches()

Uses of ManagedOperation in org.jgroups.protocols.relay

Methods in org.jgroups.protocols.relay with annotations of type ManagedOperation

Modifier and Type	Method	Description
<T extends RELAY> T	RELAY.clearNoRouteCache()
int	RELAY.getNumRoutes()
java.lang.String	Topology.print()
java.lang.String	Topology.print(java.lang.String site)	Dumps the members for a given site, or all sites
java.lang.String	RELAY2.printLocalTopology()
java.lang.String	RELAY3.printLocalTopology()
java.lang.String	RELAY.printRoutes()
java.lang.String	RELAY.printSites()
java.lang.String	RELAY2.printTopology(boolean all_sites)
java.lang.String	RELAY3.printTopology(boolean all_sites)
Topology	Topology.refresh()
Topology	Topology.refresh(java.lang.String site)	Refreshes the topology for a given site.
Topology	Topology.refresh(java.lang.String site, boolean return_entire_cache)

Uses of ManagedOperation in org.jgroups.stack

Methods in org.jgroups.stack with annotations of type ManagedOperation

Modifier and Type	Method	Description
java.lang.String	GossipRouter.dumpAddressMappings()
java.lang.String	GossipRouter.dumpRoutingTable()
void	Protocol.resetStatistics()
GossipRouter	GossipRouter.start()	Lifecycle operation.

Uses of ManagedOperation in org.jgroups.util

Methods in org.jgroups.util with annotations of type ManagedOperation

Modifier and Type	Method	Description
java.lang.String	MaxOneThreadPerSender.dump()
java.lang.String	RTT.rtt()
java.lang.String	RTT.rtt(int num_reqs, boolean details)	Sends N requests to all members and computes RTTs
java.lang.String	RTT.rtt(int num_reqs, int size, boolean details, boolean exclude_self)	Sends N requests to all members and computes RTTs