程序包 | 说明 |
---|---|
com.fr.cluster.engine.core.jchannel | |
com.fr.cluster.engine.core.lock | |
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.blocks.atomic | |
com.fr.third.jgroups.blocks.executor | |
com.fr.third.jgroups.blocks.locking | |
com.fr.third.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
com.fr.third.jgroups.fork | |
com.fr.third.jgroups.jmx | |
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.relay | |
com.fr.third.jgroups.protocols.relay.config | |
com.fr.third.jgroups.stack |
Support for managing protocol stacks.
|
com.fr.third.jgroups.tests | |
com.fr.third.jgroups.tests.perf | |
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
static JChannel |
JChannelFactory.build(ProtocolStackType type) |
构造器和说明 |
---|
FineClusterLockFactory(JChannel jChannel) |
限定符和类型 | 方法和说明 |
---|---|
JChannel |
JChannel.name(java.lang.String name) |
JChannel |
JChannel.receiver(Receiver r) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
JChannel.init(JChannel ch) |
构造器和说明 |
---|
JChannel(JChannel ch)
Creates a channel with the same configuration as the channel passed to this constructor.
|
构造器和说明 |
---|
ReplicatedTree(JChannel channel)
Expects an already connected channel.
|
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
CounterService.ch |
限定符和类型 | 方法和说明 |
---|---|
void |
CounterService.setChannel(JChannel ch) |
构造器和说明 |
---|
CounterService(JChannel ch) |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
ExecutionService.ch |
protected JChannel |
ExecutionRunner.ch |
限定符和类型 | 方法和说明 |
---|---|
void |
ExecutionService.setChannel(JChannel ch) |
void |
ExecutionRunner.setChannel(JChannel ch) |
构造器和说明 |
---|
ExecutionRunner(JChannel channel) |
ExecutionService.DistributedFuture(JChannel channel,
java.util.concurrent.locks.Lock unfinishedLock,
java.util.concurrent.locks.Condition condition,
java.util.Set<java.util.concurrent.Future<?>> futuresToFinish,
java.util.concurrent.Callable<V> callable)
Creates a FutureTask that will upon running, execute the
given Callable.
|
ExecutionService.DistributedFuture(JChannel channel,
java.util.concurrent.locks.Lock unfinishedLock,
java.util.concurrent.locks.Condition condition,
java.util.Set<java.util.concurrent.Future<?>> futuresToFinish,
java.lang.Runnable runnable,
V result)
Creates a FutureTask that will upon running, execute the
given Runnable, and arrange that get will return the
given result on successful completion.
|
ExecutionService(JChannel ch) |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
LockService.ch |
限定符和类型 | 方法和说明 |
---|---|
void |
LockService.setChannel(JChannel ch) |
构造器和说明 |
---|
LockService(JChannel ch) |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
RelayDemoRpc.ch |
protected JChannel |
LockServiceDemo.ch |
protected JChannel |
ExecutionServiceDemo.ch |
protected JChannel |
CounterServiceDemo.ch |
限定符和类型 | 方法和说明 |
---|---|
void |
ReplicatedHashMapDemo.start(JChannel channel) |
void |
LockServiceDemo.start(JChannel ch) |
void |
CounterServiceDemo.start(JChannel ch) |
void |
Chat.start(JChannel ch)
Method called from other app, injecting channel
|
构造器和说明 |
---|
Draw(JChannel channel) |
Draw(JChannel channel,
boolean use_state,
long state_timeout) |
限定符和类型 | 类和说明 |
---|---|
class |
ForkChannel
Implementation of a ForkChannel, which is a light-weight channel.
|
限定符和类型 | 字段和说明 |
---|---|
protected java.util.concurrent.ConcurrentMap<java.lang.String,JChannel> |
ForkProtocolStack.fork_channels |
限定符和类型 | 方法和说明 |
---|---|
JChannel |
ForkProtocolStack.get(java.lang.String fork_channel_id) |
JChannel |
ForkChannel.name(java.lang.String name) |
JChannel |
ForkProtocolStack.putIfAbsent(java.lang.String fork_channel_id,
JChannel fork_channel) |
限定符和类型 | 方法和说明 |
---|---|
JChannel |
ForkProtocolStack.putIfAbsent(java.lang.String fork_channel_id,
JChannel fork_channel) |
限定符和类型 | 方法和说明 |
---|---|
static void |
JmxConfigurator.registerChannel(JChannel channel,
javax.management.MBeanServer server,
java.lang.String name)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.registerChannel(JChannel channel,
javax.management.MBeanServer server,
java.lang.String domain,
java.lang.String cluster_name,
boolean register_protocols)
Registers an already created channel with the given MBeanServer.
|
static void |
JmxConfigurator.unregisterChannel(JChannel c,
javax.management.MBeanServer server,
java.lang.String clusterName) |
static void |
JmxConfigurator.unregisterChannel(JChannel c,
javax.management.MBeanServer server,
java.lang.String domain,
java.lang.String clusterName) |
static javax.management.DynamicMBean |
JmxConfigurator.wrap(JChannel ch)
Wrap JChannel with DynamicMBean interface.
|
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
RELAY.bridge
The bridge between the two local clusters, usually based on a TCP config
|
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
Relayer.Route.bridge |
protected JChannel |
Relayer.Bridge.channel |
限定符和类型 | 方法和说明 |
---|---|
JChannel |
Relayer.Route.bridge() |
JChannel |
RELAY2.getBridge(java.lang.String site_name)
Returns the bridge channel to a given site
|
构造器和说明 |
---|
Relayer.Bridge(JChannel ch,
java.lang.String cluster_name,
java.lang.String channel_name,
AddressGenerator addr_generator) |
Relayer.Route(Address site_master,
JChannel bridge) |
限定符和类型 | 方法和说明 |
---|---|
abstract JChannel |
RelayConfig.BridgeConfig.createChannel() |
JChannel |
RelayConfig.PropertiesBridgeConfig.createChannel() |
JChannel |
RelayConfig.ProgrammaticBridgeConfig.createChannel() |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
ProtocolStack.channel |
限定符和类型 | 方法和说明 |
---|---|
JChannel |
ProtocolStack.getChannel() |
限定符和类型 | 方法和说明 |
---|---|
void |
ProtocolStack.setChannel(JChannel ch) |
构造器和说明 |
---|
ProtocolStack(JChannel channel) |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
FlowControlTest.ch |
protected JChannel |
UnicastTest.channel |
限定符和类型 | 方法和说明 |
---|---|
protected void |
UnicastTest._init(JChannel ch,
long sleep_time,
boolean busy_sleep,
java.lang.String name) |
protected static java.util.List<java.lang.String> |
UnicastTestRpc.getSites(JChannel channel) |
限定符和类型 | 字段和说明 |
---|---|
protected JChannel |
MPerfRpc.channel |
protected JChannel |
MPerf.channel |
限定符和类型 | 方法和说明 |
---|---|
protected static java.util.List<java.lang.String> |
UPerf.getSites(JChannel channel) |
限定符和类型 | 方法和说明 |
---|---|
static JChannel |
Util.createChannel(Protocol... prots) |
限定符和类型 | 方法和说明 |
---|---|
static boolean |
Util.isCoordinator(JChannel ch) |
static void |
Util.registerChannel(JChannel channel,
java.lang.String name) |