程序包 | 说明 |
---|---|
com.fr.third.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
com.fr.third.jgroups.api | |
com.fr.third.jgroups.auth | |
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.blocks.executor | |
com.fr.third.jgroups.blocks.mux | |
com.fr.third.jgroups.fork | |
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.
|
限定符和类型 | 字段和说明 |
---|---|
static Event |
Event.FIND_INITIAL_MBRS_EVT |
static Event |
Event.FIND_MBRS_EVT |
static Event |
Event.GET_DIGEST_EVT |
限定符和类型 | 方法和说明 |
---|---|
protected void |
JChannel._connect(Event connect_event) |
java.lang.Object |
JChannel.down(Event evt)
Sends an event down the protocol stack.
|
java.lang.Object |
Channel.down(Event evt)
Enables access to event mechanism of a channel and is normally not used by clients directly.
|
java.lang.Object |
UpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
java.lang.Object |
JChannel.up(Event evt)
Callback method
Called by the ProtocolStack when a message is received. |
限定符和类型 | 方法和说明 |
---|---|
boolean |
DiscoveryInterceptor.preHandle(Event evt)
预处理回调方法,实现处理器的预处理
|
boolean |
DiscoveryHandler.preHandle(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
boolean |
DemoToken.handleUpEvent(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
MessageDispatcher.handleUpEvent(Event evt) |
boolean |
RequestCorrelator.receive(Event evt)
Callback.
|
限定符和类型 | 类和说明 |
---|---|
class |
ExecutorEvent
Defines an event class for the execution of an entity.
|
限定符和类型 | 方法和说明 |
---|---|
protected ImmutableReference<java.lang.Object> |
MuxUpHandler.handleStateTransferEvent(Event evt)
Extension point for subclasses called by up() when an event
related to state transfer is received, allowing the subclass
to override the default behavior of passing the event to the
default up handler.
|
java.lang.Object |
MuxUpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
ForkProtocolStack.down(Event evt) |
java.lang.Object |
ForkProtocol.down(Event evt) |
java.lang.Object |
ForkChannel.down(Event evt) |
java.lang.Object |
ForkProtocolStack.up(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
AUTH.callUpHandlers(Event evt) |
protected void |
SEQUENCER.deliver(Message msg,
Event evt,
SEQUENCER.SequencerHeader hdr) |
protected void |
SEQUENCER2.deliver(Message msg,
Event evt,
SEQUENCER2.SequencerHeader hdr) |
protected void |
UNICAST3.deliverMessage(Event evt,
Address sender,
long seqno) |
java.lang.Object |
VERIFY_SUSPECT.down(Event evt) |
java.lang.Object |
UNICAST3.down(Event evt) |
java.lang.Object |
UNICAST2.down(Event evt) |
java.lang.Object |
UNICAST.down(Event evt) |
java.lang.Object |
TRACE.down(Event evt) |
java.lang.Object |
TP.down(Event evt)
Caller by the layer above this layer.
|
java.lang.Object |
TP.ProtocolAdapter.down(Event evt) |
java.lang.Object |
TCPPING.down(Event evt) |
java.lang.Object |
STOMP.down(Event evt) |
java.lang.Object |
STATS.down(Event evt) |
java.lang.Object |
SIZE.down(Event evt) |
java.lang.Object |
SHUFFLE.down(Event evt) |
java.lang.Object |
SHARED_LOOPBACK.down(Event evt) |
java.lang.Object |
SEQUENCER2.down(Event evt) |
java.lang.Object |
SEQUENCER.down(Event evt) |
java.lang.Object |
SCOPE.down(Event evt)
已过时。
|
java.lang.Object |
SASL.down(Event evt) |
java.lang.Object |
RSVP.down(Event evt) |
java.lang.Object |
RELAY.down(Event evt) |
java.lang.Object |
RATE_LIMITER.down(Event evt) |
java.lang.Object |
PRIO.down(Event evt)
An event is to be sent down the stack.
|
java.lang.Object |
PERF.down(Event evt) |
java.lang.Object |
PDC.down(Event evt) |
java.lang.Object |
MERGE3.down(Event evt) |
java.lang.Object |
MERGE2.down(Event evt)
已过时。
|
java.lang.Object |
MAKE_BATCH.down(Event evt) |
java.lang.Object |
Locking.down(Event evt) |
java.lang.Object |
JDBC_PING.down(Event evt) |
java.lang.Object |
HDRS.down(Event evt) |
java.lang.Object |
FRAG2.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
java.lang.Object |
FRAG.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
java.lang.Object |
FORWARD_TO_COORD.down(Event evt) |
java.lang.Object |
FlowControl.down(Event evt) |
java.lang.Object |
FILE_PING.down(Event evt) |
java.lang.Object |
FD_SOCK.down(Event evt) |
java.lang.Object |
FD_HOST.down(Event evt) |
java.lang.Object |
FD_ALL2.down(Event evt) |
java.lang.Object |
FD_ALL.down(Event evt) |
java.lang.Object |
FD.down(Event evt) |
java.lang.Object |
FC.down(Event evt)
已过时。
|
java.lang.Object |
Executing.down(Event evt) |
java.lang.Object |
EXAMPLE.down(Event evt) |
java.lang.Object |
ENCRYPT.down(Event evt) |
java.lang.Object |
DUPL.down(Event evt) |
java.lang.Object |
Discovery.down(Event evt) |
java.lang.Object |
DISCARD_PAYLOAD.down(Event evt) |
java.lang.Object |
DISCARD.down(Event evt) |
java.lang.Object |
DELAY.down(Event evt) |
java.lang.Object |
DAISYCHAIN.down(Event evt) |
java.lang.Object |
COUNTER.down(Event evt) |
java.lang.Object |
COMPRESS.down(Event evt)
We compress the payload if it is larger than
min_size . |
java.lang.Object |
BARRIER.down(Event evt) |
java.lang.Object |
AUTH.down(Event evt)
An event is to be sent down the stack.
|
protected static GMS.GmsHeader |
AUTH.getGMSHeader(Event evt)
Get the header from a GMS message
|
protected void |
UNICAST3.handleDataReceived(Address sender,
long seqno,
short conn_id,
boolean first,
Message msg,
Event evt)
Check whether the hashtable contains an entry e for
sender (create if not). |
protected boolean |
UNICAST2.handleDataReceived(Address sender,
long seqno,
short conn_id,
boolean first,
Message msg,
Event evt)
Check whether the hashmap contains an entry e for
sender (create if not). |
protected void |
UNICAST.handleDataReceived(Address sender,
long seqno,
short conn_id,
boolean first,
Message msg,
Event evt)
Check whether the hashtable contains an entry e for
sender (create if not). |
protected java.lang.Object |
UDP.handleDownEvent(Event evt) |
java.lang.Object |
TUNNEL.handleDownEvent(Event evt) |
protected java.lang.Object |
TP.handleDownEvent(Event evt) |
protected java.lang.Object |
BasicTCP.handleDownEvent(Event evt) |
protected java.lang.Object |
UFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected java.lang.Object |
MFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected abstract java.lang.Object |
FlowControl.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected java.lang.Object |
ENCRYPT.handleEncryptedMessage(Message msg,
Event evt,
ENCRYPT.EncryptHeader hdr) |
boolean |
AUTH.UpHandler.handleUpEvent(Event evt)
Called when an up event has been received
|
protected void |
TP.passToAllUpProtocols(Event evt) |
java.lang.Object |
VERIFY_SUSPECT.up(Event evt) |
java.lang.Object |
UNICAST3.up(Event evt) |
java.lang.Object |
UNICAST2.up(Event evt) |
java.lang.Object |
UNICAST.up(Event evt) |
java.lang.Object |
TRACE.up(Event evt) |
java.lang.Object |
TP.up(Event evt)
handle the UP event.
|
java.lang.Object |
TP.ProtocolAdapter.up(Event evt) |
java.lang.Object |
STOMP.up(Event evt) |
java.lang.Object |
STATS.up(Event evt) |
java.lang.Object |
SIZE.up(Event evt) |
java.lang.Object |
SHUFFLE.up(Event evt) |
java.lang.Object |
SEQUENCER2.up(Event evt) |
java.lang.Object |
SEQUENCER.up(Event evt) |
java.lang.Object |
SCOPE.up(Event evt)
已过时。
|
java.lang.Object |
SASL.up(Event evt) |
java.lang.Object |
RSVP.up(Event evt) |
java.lang.Object |
RELAY.up(Event evt) |
java.lang.Object |
PRIO.up(Event evt)
An event was received from the layer below.
|
java.lang.Object |
PERF.up(Event evt) |
java.lang.Object |
MPING.up(Event evt) |
java.lang.Object |
MERGE3.up(Event evt) |
java.lang.Object |
MERGE2.up(Event evt)
已过时。
|
java.lang.Object |
MAKE_BATCH.up(Event evt) |
java.lang.Object |
Locking.up(Event evt) |
java.lang.Object |
HDRS.up(Event evt) |
java.lang.Object |
FRAG2.up(Event evt)
If event is a message, if it is fragmented, re-assemble fragments into big message and pass up the stack.
|
java.lang.Object |
FRAG.up(Event evt)
If event is a message, if it is fragmented, re-assemble fragments into big message and pass up the stack.
|
java.lang.Object |
FORWARD_TO_COORD.up(Event evt) |
java.lang.Object |
FORK.up(Event evt) |
java.lang.Object |
FlowControl.up(Event evt) |
java.lang.Object |
FD_SOCK.up(Event evt) |
java.lang.Object |
FD_ALL2.up(Event evt) |
java.lang.Object |
FD_ALL.up(Event evt) |
java.lang.Object |
FD.up(Event evt) |
java.lang.Object |
FC.up(Event evt)
已过时。
|
java.lang.Object |
Executing.up(Event evt) |
java.lang.Object |
EXAMPLE.up(Event evt) |
java.lang.Object |
ENCRYPT.up(Event evt) |
java.lang.Object |
DUPL.up(Event evt) |
java.lang.Object |
Discovery.up(Event evt) |
java.lang.Object |
DISCARD.up(Event evt) |
java.lang.Object |
DELAY.up(Event evt) |
java.lang.Object |
DAISYCHAIN.up(Event evt) |
java.lang.Object |
COUNTER.up(Event evt) |
java.lang.Object |
COMPRESS.up(Event evt)
If there is no header, we pass the message up.
|
java.lang.Object |
BARRIER.up(Event evt) |
java.lang.Object |
AUTH.up(Event evt)
An event was received from the layer below.
|
构造器和说明 |
---|
PRIO.PriorityMessage(Event event,
byte priority) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
StreamingStateTransfer.down(Event evt) |
java.lang.Object |
STATE_TRANSFER.down(Event evt) |
java.lang.Object |
STABLE.down(Event evt) |
java.lang.Object |
NAKACK2.down(Event evt)
Callback.
|
java.lang.Object |
NAKACK.down(Event evt)
Callback.
|
java.lang.Object |
GMS.down(Event evt) |
java.lang.Object |
FLUSH.down(Event evt) |
protected void |
NAKACK2.send(Event evt,
Message msg)
Adds the message to the sent_msgs table and then passes it down the stack.
|
protected void |
NAKACK.send(Event evt,
Message msg)
Adds the message to the sent_msgs table and then passes it down the stack.
|
java.lang.Object |
StreamingStateTransfer.up(Event evt) |
java.lang.Object |
STATE_TRANSFER.up(Event evt) |
java.lang.Object |
STABLE.up(Event evt) |
java.lang.Object |
NAKACK2.up(Event evt)
Callback.
|
java.lang.Object |
NAKACK.up(Event evt)
Callback.
|
java.lang.Object |
GMS.up(Event evt) |
java.lang.Object |
FLUSH.up(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
RELAY2.down(Event evt) |
java.lang.Object |
RELAY2.up(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
SUPERVISOR.down(Event evt) |
java.lang.Object |
EventHandler.down(Event evt)
Called when a down event is received
|
java.lang.Object |
SUPERVISOR.up(Event evt) |
java.lang.Object |
EventHandler.up(Event evt)
Called when an up event is received
|
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
TOA.down(Event evt) |
java.lang.Object |
TOA.up(Event evt) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
ProtocolStack.down(Event evt) |
java.lang.Object |
Protocol.down(Event evt)
An event is to be sent down the stack.
|
java.lang.Object |
ProtocolStack.up(Event evt) |
java.lang.Object |
Protocol.up(Event evt)
An event was received from the layer below.
|