|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ManagedOperation | |
---|---|
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.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. |
Uses of ManagedOperation in org.jgroups |
---|
Methods in org.jgroups with annotations of type ManagedOperation | |
---|---|
void |
JChannel.close()
|
void |
JChannel.connect(java.lang.String cluster_name)
|
protected void |
JChannel.connect(java.lang.String cluster_name,
boolean useFlushIfPresent)
Connects the channel to a group. |
void |
JChannel.disconnect()
|
java.util.Map<java.lang.String,java.lang.Object> |
JChannel.dumpStats()
|
java.util.Map<java.lang.String,java.lang.Object> |
JChannel.dumpStats(java.lang.String protocol_name)
|
java.lang.String |
JChannel.dumpTimerQueue()
|
java.lang.String |
JChannel.printProtocolSpec(boolean include_properties)
Returns a pretty-printed form of all the protocols. |
void |
JChannel.resetStats()
|
java.lang.String |
JChannel.toString(boolean details)
|
Uses of ManagedOperation in org.jgroups.blocks |
---|
Methods in org.jgroups.blocks with annotations of type ManagedOperation | |
---|---|
void |
ReplCache.clear()
Removes all keys and values in the L2 and L1 caches |
void |
Cache.disableReaping()
|
java.lang.String |
PartitionedHashMap.dump()
|
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 |
PartitionedHashMap.get(K key)
|
V |
ReplCache.get(K key)
Returns the value associated with key |
void |
PartitionedHashMap.put(K key,
V val)
|
void |
ReplCache.put(K key,
V val)
|
V |
Cache.put(K key,
V val,
long caching_time)
|
void |
PartitionedHashMap.put(K key,
V val,
long caching_time)
Adds a key/value to the cache, replacing a previous item if there was one |
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 |
PartitionedHashMap.remove(K key)
|
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 |
PartitionedHashMap.start()
|
void |
ReplCache.start()
|
void |
MemcachedConnector.start()
|
void |
Cache.stop()
|
void |
PartitionedHashMap.stop()
|
void |
ReplCache.stop()
|
void |
MemcachedConnector.stop()
|
java.lang.String |
Cache.toString()
|
Uses of ManagedOperation in org.jgroups.demos |
---|
Methods in org.jgroups.demos with annotations of type ManagedOperation | |
---|---|
java.lang.String |
JmxDemo.sayName()
|
Uses of ManagedOperation in org.jgroups.protocols |
---|
Methods in org.jgroups.protocols with annotations of type ManagedOperation | |
---|---|
void |
TCPGOSSIP.addInitialHost(java.lang.String hostname,
int port)
|
void |
FRAG2.clearAllFragments()
|
void |
TP.clearDifferentClusterCache()
|
void |
TP.clearDifferentVersionCache()
|
void |
TCPPING.clearDynamicHostList()
|
void |
FRAG2.clearFragmentsFor(Address mbr)
|
void |
MERGE3.clearViews()
|
java.lang.String |
COUNTER.dumpPendingRequests()
|
static java.lang.String |
SHARED_LOOPBACK.dumpRoutingTable()
|
java.lang.String |
SCOPE.dumpScopes()
|
java.util.Map<java.lang.String,java.lang.Object> |
SEQUENCER.dumpStats()
|
java.lang.String |
TP.dumpTimerTasks()
|
java.lang.String |
MERGE3.dumpViews()
|
void |
TP.evictLogicalAddressCache()
|
void |
SCOPE.expire(short scope)
Multicasts an EXPIRE message to all members, and - on reception - each member removes the scope locally |
java.lang.String |
Discovery.findAllViewsAsString()
|
java.lang.String |
Discovery.findInitialMembersAsString()
|
void |
BARRIER.openBarrier()
|
java.lang.String |
UNICAST.printAgeOutCache()
|
java.lang.String |
UNICAST2.printAgeOutCache()
|
java.lang.String |
FD_SOCK.printCache()
|
java.lang.String |
PDC.printCache()
|
java.lang.String |
TCP.printConnections()
|
java.lang.String |
UNICAST.printConnections()
|
java.lang.String |
UNICAST2.printConnections()
|
java.lang.String |
COUNTER.printCounters()
|
java.lang.String |
FC.printCreditors()
|
java.lang.String |
MFC.printCredits()
|
java.lang.String |
FC.printCredits()
|
java.lang.String |
UFC.printCredits()
|
java.lang.String |
Locking.printLocks()
|
java.lang.String |
TP.printLogicalAddressCache()
|
java.lang.String |
FC.printReceiverCredits()
|
java.lang.String |
FlowControl.printReceiverCredits()
|
java.lang.String |
UNICAST.printReceiveWindowMessages()
|
java.lang.String |
UNICAST2.printReceiveWindowMessages()
|
java.lang.String |
MFC.printSenderCredits()
|
java.lang.String |
FC.printSenderCredits()
|
java.lang.String |
UFC.printSenderCredits()
|
java.lang.String |
UNICAST.printSendWindowMessages()
|
java.lang.String |
UNICAST2.printSendWindowMessages()
|
java.lang.String |
SEQUENCER.printStats()
|
java.lang.String |
FD_SOCK.printSuspectHistory()
|
java.lang.String |
FD.printSuspectHistory()
|
java.lang.String |
FD_ALL.printSuspectHistory()
|
java.lang.String |
FD_ALL.printTimestamps()
|
java.lang.String |
TP.printWhoHasCache()
|
void |
UNICAST.reapIdleConnections()
|
void |
UNICAST2.reapIdleConnections()
|
void |
UNICAST.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used ! |
void |
UNICAST2.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used ! |
void |
SCOPE.removeAllQueues()
|
boolean |
TCPGOSSIP.removeInitialHost(java.lang.String hostname,
int port)
|
void |
SEQUENCER.resetStats()
|
void |
MERGE2.sendMergeSolicitation()
Discovers members and detects whether we have multiple coordinator. |
void |
UNICAST2.sendStableMessages()
|
void |
Discovery.setForceSendingDiscoveryRsps(boolean flag)
|
void |
RELAY.setRelay(boolean relay)
|
java.lang.String |
FC.showLastBlockingTimes()
|
void |
FD.startFailureDetection()
|
void |
FD_ALL.startFailureDetection()
|
void |
DISCARD.startGui()
|
void |
MERGE2.startMergeTask()
|
void |
FD.stopFailureDetection()
|
void |
FD_ALL.stopFailureDetection()
|
void |
DISCARD.stopGui()
|
void |
MERGE2.stopMergeTask()
|
void |
UNICAST2.triggerXmit()
|
void |
MFC.unblock()
Allows to unblock a blocked sender from an external program, e.g. |
void |
FC.unblock()
Allows to unblock a blocked sender from an external program, e.g. |
void |
FlowControl.unblock()
Allows to unblock all blocked senders from an external program, e.g. |
void |
Locking.unlockAll()
|
Uses of ManagedOperation in org.jgroups.protocols.pbcast |
---|
Methods in org.jgroups.protocols.pbcast with annotations of type ManagedOperation | |
---|---|
void |
GMS.cancelMerge()
|
void |
NAKACK2.clearNonMemberCache()
|
void |
NAKACK.clearNonMemberCache()
|
void |
StreamingStateTransfer.closeBarrierAndSuspendStable()
|
void |
STATE_TRANSFER.closeBarrierAndSuspendStable()
|
void |
NAKACK2.compact()
|
void |
NAKACK.compact()
|
java.lang.String |
GMS.dumpViewHandlerHistory()
|
java.lang.String |
GMS.dumpViewHandlerQueue()
|
java.lang.String |
NAKACK2.dumpXmitTablesNumCurrentRows()
|
void |
GMS.fixDigests()
|
void |
STABLE.gc()
|
void |
StreamingStateTransfer.openBarrierAndResumeStable()
|
void |
STATE_TRANSFER.openBarrierAndResumeStable()
|
java.lang.String |
NAKACK2.printDigestHistory()
|
java.lang.String |
NAKACK.printDigestHistory()
|
java.lang.String |
NAKACK.printLossRates()
|
java.lang.String |
GMS.printMergeIdHistory()
|
java.lang.String |
NAKACK2.printMessages()
|
java.lang.String |
NAKACK.printMessages()
|
java.lang.String |
GMS.printPreviousMembers()
|
java.lang.String |
GMS.printPreviousViews()
|
java.lang.String |
NAKACK.printRetransmitStats()
|
java.lang.String |
NAKACK.printRetransmitTableSizes()
|
java.lang.String |
NAKACK2.printStabilityMessages()
|
java.lang.String |
NAKACK.printStabilityMessages()
|
void |
NAKACK2.resetStats()
|
void |
GMS.resumeViewHandler()
|
void |
STABLE.runMessageGarbageCollection()
|
boolean |
FLUSH.setBypass(boolean flag)
|
void |
FLUSH.startFlush()
|
void |
FLUSH.stopFlush()
|
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 | |
---|---|
java.lang.String |
RELAY2.printRoutes()
|
Uses of ManagedOperation in org.jgroups.protocols.rules |
---|
Methods in org.jgroups.protocols.rules with annotations of type ManagedOperation | |
---|---|
java.lang.String |
SUPERVISOR.dumpRules()
|
java.lang.String |
SUPERVISOR.executions()
|
void |
SUPERVISOR.installRule(long interval,
java.lang.String classname)
|
void |
SUPERVISOR.installRule(java.lang.String name,
long interval,
java.lang.String classname)
|
void |
SUPERVISOR.uninstallRule(java.lang.String name)
|
Uses of ManagedOperation in org.jgroups.protocols.tom |
---|
Methods in org.jgroups.protocols.tom with annotations of type ManagedOperation | |
---|---|
java.lang.String |
TOA.getMessageList()
|
Uses of ManagedOperation in org.jgroups.stack |
---|
Methods in org.jgroups.stack with annotations of type ManagedOperation | |
---|---|
void |
GossipRouter.clear()
|
java.lang.String |
GossipRouter.dumpAddresssMappings()
|
java.lang.String |
GossipRouter.dumpRoutingTable()
|
java.lang.String |
GossipRouter.dumpRoutingTableDetailed()
|
void |
Protocol.resetStatistics()
|
void |
GossipRouter.start()
Lifecycle operation. |
void |
GossipRouter.stop()
Always called before destroy(). |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |