程序包 | 说明 |
---|---|
com.fr.third.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.protocols.relay | |
com.fr.third.jgroups.protocols.rules | |
com.fr.third.jgroups.protocols.tom | |
com.fr.third.jgroups.stack |
Support for managing protocol stacks.
|
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
void |
ReplCache.clear()
Removes all keys and values in the L2 and L1 caches
|
void |
Cache.disableReaping() |
java.lang.String |
ReplCache.dump() |
java.lang.String |
PartitionedHashMap.dump() |
void |
Cache.enableReaping(long interval)
Runs the reaper every interval ms, evicts expired items
|
V |
ReplCache.get(K key)
Returns the value associated with key
|
V |
PartitionedHashMap.get(K key) |
V |
Cache.get(K key) |
void |
ReplCache.put(K key,
V val) |
void |
PartitionedHashMap.put(K key,
V val) |
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
|
V |
Cache.put(K key,
V val,
long caching_time) |
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 |
PartitionedHashMap.remove(K key) |
void |
ReplCache.remove(K key,
boolean synchronous)
Removes key in all nodes in the cluster, both from their local hashmaps and L1 caches
|
void |
ReplCache.start() |
void |
PartitionedHashMap.start() |
void |
MemcachedConnector.start() |
void |
Cache.start() |
void |
ReplCache.stop() |
void |
PartitionedHashMap.stop() |
void |
MemcachedConnector.stop() |
void |
Cache.stop() |
java.lang.String |
Cache.toString() |
限定符和类型 | 方法和说明 |
---|---|
java.lang.String |
JmxDemo.sayName() |
限定符和类型 | 方法和说明 |
---|---|
void |
TCPGOSSIP.addInitialHost(java.lang.String hostname,
int port) |
void |
Discovery.addToCache(java.lang.String filename) |
void |
MERGE3.checkInconsistencies() |
void |
FRAG2.clearAllFragments() |
void |
TP.clearDifferentClusterCache() |
void |
TP.clearDifferentVersionCache() |
void |
UDP.clearDroppedMessagesCache() |
void |
TCPPING.clearDynamicHostList() |
void |
FRAG2.clearFragmentsFor(Address mbr) |
void |
TP.clearLogicalAddressCache()
Clears the cache.
|
void |
MERGE3.clearViews() |
void |
UNICAST3.closeIdleConnections() |
void |
TP.disableDiagnostics() |
void |
Discovery.dumpCache(java.lang.String output_filename) |
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> |
SEQUENCER2.dumpStats() |
java.util.Map<java.lang.String,java.lang.Object> |
SEQUENCER.dumpStats() |
java.lang.String |
TP.dumpTimerTasks() |
java.lang.String |
MERGE3.dumpViews() |
void |
TP.enableDiagnostics() |
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 |
MERGE2.fetchAllViews()
已过时。
|
java.lang.String |
Discovery.findInitialMembersAsString() |
boolean |
FD_HOST.isAlive(java.lang.String host) |
void |
BARRIER.openBarrier() |
java.lang.String |
UNICAST3.printAgeOutCache() |
java.lang.String |
UNICAST2.printAgeOutCache() |
java.lang.String |
UNICAST.printAgeOutCache() |
java.lang.String |
PDC.printCache() |
java.lang.String |
FD_SOCK.printCache() |
java.lang.String |
UNICAST3.printConnections() |
java.lang.String |
UNICAST2.printConnections() |
java.lang.String |
UNICAST.printConnections() |
java.lang.String |
TCP.printConnections() |
java.lang.String |
COUNTER.printCounters() |
java.lang.String |
FC.printCreditors()
已过时。
|
java.lang.String |
UFC.printCredits() |
java.lang.String |
MFC.printCredits() |
java.lang.String |
FC.printCredits()
已过时。
|
java.lang.String |
FD_HOST.printHosts() |
protected java.lang.String |
BARRIER.printInFlightThreads() |
java.lang.String |
Locking.printLocks() |
java.lang.String |
TP.printLogicalAddressCache() |
java.lang.String |
FlowControl.printReceiverCredits() |
java.lang.String |
FC.printReceiverCredits()
已过时。
|
java.lang.String |
UNICAST3.printReceiveWindowMessages() |
java.lang.String |
UNICAST2.printReceiveWindowMessages() |
java.lang.String |
UNICAST.printReceiveWindowMessages() |
java.lang.String |
UFC.printSenderCredits() |
java.lang.String |
MFC.printSenderCredits() |
java.lang.String |
FC.printSenderCredits()
已过时。
|
java.lang.String |
UNICAST3.printSendWindowMessages() |
java.lang.String |
UNICAST2.printSendWindowMessages() |
java.lang.String |
UNICAST.printSendWindowMessages() |
java.lang.String |
SEQUENCER2.printStats() |
java.lang.String |
SEQUENCER.printStats() |
java.lang.String |
FD_SOCK.printSuspectHistory() |
java.lang.String |
FD_HOST.printSuspectHistory() |
java.lang.String |
FD_ALL2.printSuspectHistory() |
java.lang.String |
FD_ALL.printSuspectHistory() |
java.lang.String |
FD.printSuspectHistory() |
java.lang.String |
FD_HOST.printTimestamps() |
java.lang.String |
FD_ALL2.printTimestamps() |
java.lang.String |
FD_ALL.printTimestamps() |
java.lang.String |
TP.printWhoHasCache() |
void |
UNICAST2.reapIdleConnections() |
void |
UNICAST.reapIdleConnections() |
void |
UNICAST3.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 |
UNICAST.removeAllConnections()
This method is public only so it can be invoked by unit testing, but should not otherwise be used !
|
void |
SCOPE.removeAllQueues()
已过时。
|
int |
UNICAST3.removeExpiredConnections() |
boolean |
TCPGOSSIP.removeInitialHost(java.lang.String hostname,
int port) |
void |
SEQUENCER2.resetStats() |
void |
SEQUENCER.resetStats() |
void |
MERGE3.sendInfo() |
void |
MERGE2.sendMergeSolicitation()
已过时。
Discovers members and detects whether we have multiple coordinator.
|
void |
UNICAST3.sendPendingAcks() |
void |
UNICAST2.sendStableMessages() |
void |
Discovery.setForceSendingDiscoveryRsps(boolean flag) |
void |
RELAY.setRelay(boolean relay) |
java.lang.String |
FC.showLastBlockingTimes()
已过时。
|
void |
FD_ALL2.startFailureDetection() |
void |
FD_ALL.startFailureDetection() |
void |
FD.startFailureDetection() |
void |
DISCARD.startGui() |
void |
MERGE2.startMergeTask()
已过时。
|
boolean |
FD_SOCK.startNodeCrashMonitor() |
void |
FD_ALL2.stopFailureDetection() |
void |
FD_ALL.stopFailureDetection() |
void |
FD.stopFailureDetection() |
void |
DISCARD.stopGui() |
void |
MERGE2.stopMergeTask()
已过时。
|
void |
UNICAST3.triggerXmit() |
void |
UNICAST2.triggerXmit() |
void |
MFC.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 |
FC.unblock()
已过时。
Allows to unblock a blocked sender from an external program, e.g.
|
void |
Locking.unlockAll() |
限定符和类型 | 方法和说明 |
---|---|
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() |
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() |
限定符和类型 | 方法和说明 |
---|---|
java.lang.String |
RELAY2.printRoutes() |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.String |
TOA.getMessageList() |
限定符和类型 | 方法和说明 |
---|---|
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().
|