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 itselfjava.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 cachesvoid
Cache. disableReaping()
java.lang.String
ReplCache. dump()
void
Cache. enableReaping(long interval)
Runs the reaper every interval ms, evicts expired itemsV
Cache. get(K key)
V
ReplCache. get(K key)
Returns the value associated with keyV
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 cachesvoid
ReplCache. remove(K key, boolean synchronous)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 cachesvoid
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 connectionsjava.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>
TTP. bundler(java.lang.String type)
void
RATE_LIMITER2. changeInterval(long new_interval)
void
MERGE3. checkInconsistencies()
void
FRAG2. clearAllFragments()
void
FRAG3. clearAllFragments()
void
TCP_NIO2. clearConnections()
TCP
TCP. clearConnections()
<T extends TP>
TTP. clearDifferentClusterCache()
<T extends TP>
TTP. clearDifferentVersionCache()
<T extends UDP>
TUDP. clearDroppedMessagesCache()
<T extends TCPPING>
TTCPPING. clearDynamicHostList()
void
FRAG2. clearFragmentsFor(Address mbr)
void
FRAG3. clearFragmentsFor(Address mbr)
void
TP. clearLogicalAddressCache()
Clears the cache.void
ReliableMulticast. clearNonMemberCache()
void
MERGE3. clearViews()
void
UNICAST3. closeIdleConnections()
void
NAKACK3. compact()
void
TP. disableDiagnostics()
java.lang.String
JDBC_PING2. dump(java.lang.String cluster)
java.lang.String
TransferQueueBundler2. dump()
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()
<T extends TP>
TTP. enableBlockingTimerTasks(boolean flag)
<T extends TP>
TTP. 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
UNICAST3. printAgeOutCache()
java.lang.String
ReliableMulticast. printBatches()
java.lang.String
TCP_NIO2. printBuffers()
java.lang.String
FD_SOCK. printCache()
java.lang.String
PDC. printCache()
java.lang.String
Encrypt. printCachedGroupKeys()
java.lang.String
FD_SOCK2. 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
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
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
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
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
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
UNICAST3. sendPendingAcks()
SOS
SOS. setCommand(java.lang.String filename)
void
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
UNICAST3. triggerXmit()
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()
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
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()
-
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>
TRELAY. 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 sitesjava.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 RTTsjava.lang.String
RTT. rtt(int num_reqs, int size, boolean details, boolean exclude_self)
Sends N requests to all members and computes RTTs
-