Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.auth | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.executor | |
org.jgroups.blocks.mux | |
org.jgroups.fork | |
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.
|
Modifier and Type | Field and Description |
---|---|
static Event |
Event.FIND_INITIAL_MBRS_EVT |
static Event |
Event.FIND_MBRS_EVT |
static Event |
Event.GET_DIGEST_EVT |
Modifier and Type | Method and Description |
---|---|
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 |
JChannel.up(Event evt)
Callback method
Called by the ProtocolStack when a message is received. |
java.lang.Object |
UpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DemoToken.handleUpEvent(Event evt) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
MessageDispatcher.handleUpEvent(Event evt) |
boolean |
RequestCorrelator.receive(Event evt)
Callback.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecutorEvent
Defines an event class for the execution of an entity.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
ForkProtocol.down(Event evt) |
java.lang.Object |
ForkProtocolStack.down(Event evt) |
java.lang.Object |
ForkChannel.down(Event evt) |
java.lang.Object |
ForkProtocolStack.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
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 |
RELAY.down(Event evt) |
java.lang.Object |
FORWARD_TO_COORD.down(Event evt) |
java.lang.Object |
PERF.down(Event evt) |
java.lang.Object |
Locking.down(Event evt) |
java.lang.Object |
DUPL.down(Event evt) |
java.lang.Object |
FC.down(Event evt)
Deprecated.
|
java.lang.Object |
STATS.down(Event evt) |
java.lang.Object |
TRACE.down(Event evt) |
java.lang.Object |
DISCARD.down(Event evt) |
java.lang.Object |
SHARED_LOOPBACK.down(Event evt) |
java.lang.Object |
JDBC_PING.down(Event evt) |
java.lang.Object |
SASL.down(Event evt) |
java.lang.Object |
MAKE_BATCH.down(Event evt) |
java.lang.Object |
RSVP.down(Event evt) |
java.lang.Object |
PDC.down(Event evt) |
java.lang.Object |
UNICAST.down(Event evt)
Deprecated.
|
java.lang.Object |
MERGE3.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 |
FD_SOCK.down(Event evt) |
java.lang.Object |
SHUFFLE.down(Event evt) |
java.lang.Object |
COUNTER.down(Event evt) |
java.lang.Object |
FD.down(Event evt) |
java.lang.Object |
FORK.down(Event evt) |
java.lang.Object |
ASYM_ENCRYPT.down(Event evt) |
java.lang.Object |
ABP.down(Event evt) |
java.lang.Object |
MERGE2.down(Event evt)
Deprecated.
|
java.lang.Object |
SIZE.down(Event evt) |
java.lang.Object |
SEQUENCER2.down(Event evt) |
java.lang.Object |
FRAG.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
java.lang.Object |
Discovery.down(Event evt) |
java.lang.Object |
STOMP.down(Event evt) |
java.lang.Object |
DISCARD_PAYLOAD.down(Event evt) |
java.lang.Object |
FlowControl.down(Event evt) |
java.lang.Object |
TCPPING.down(Event evt) |
java.lang.Object |
HDRS.down(Event evt) |
java.lang.Object |
ENCRYPT.down(Event evt)
Deprecated.
|
java.lang.Object |
UNICAST3.down(Event evt) |
java.lang.Object |
SEQUENCER.down(Event evt) |
java.lang.Object |
EXAMPLE.down(Event evt) |
java.lang.Object |
AUTH.down(Event evt)
An event is to be sent down the stack.
|
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 |
DELAY.down(Event evt) |
java.lang.Object |
FILE_PING.down(Event evt) |
java.lang.Object |
VERIFY_SUSPECT.down(Event evt) |
java.lang.Object |
BARRIER.down(Event evt) |
java.lang.Object |
FD_ALL.down(Event evt) |
java.lang.Object |
EncryptBase.down(Event evt) |
java.lang.Object |
FD_ALL2.down(Event evt) |
java.lang.Object |
FRAG2.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
java.lang.Object |
COMPRESS.down(Event evt)
We compress the payload if it is larger than
min_size . |
java.lang.Object |
Executing.down(Event evt) |
java.lang.Object |
KeyExchange.down(Event evt) |
java.lang.Object |
UNICAST2.down(Event evt)
Deprecated.
|
java.lang.Object |
SCOPE.down(Event evt)
Deprecated.
|
java.lang.Object |
FD_HOST.down(Event evt) |
java.lang.Object |
DAISYCHAIN.down(Event evt) |
protected static GMS.GmsHeader |
AUTH.getGMSHeader(Event evt)
Get the header from a GMS message
|
protected void |
FORK.getStateFromMainAndForkChannels(Event evt) |
protected void |
UNICAST.handleDataReceived(Address sender,
long seqno,
short conn_id,
boolean first,
Message msg,
Event evt)
Deprecated.
Check whether the hashtable contains an entry e for
sender (create if not). |
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)
Deprecated.
Check whether the hashmap 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 |
BasicTCP.handleDownEvent(Event evt) |
protected java.lang.Object |
TP.handleDownEvent(Event evt) |
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 |
UFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected java.lang.Object |
ENCRYPT.handleEncryptedMessage(Message msg,
Event evt,
ENCRYPT.EncryptHeader hdr)
Deprecated.
|
boolean |
AUTH.UpHandler.handleUpEvent(Event evt)
Called when an up event has been received
|
protected void |
TP.passToAllUpProtocols(Event evt) |
java.lang.Object |
RELAY.up(Event evt) |
java.lang.Object |
FORWARD_TO_COORD.up(Event evt) |
java.lang.Object |
PERF.up(Event evt) |
java.lang.Object |
Locking.up(Event evt) |
java.lang.Object |
DELIVERY_TIME.up(Event evt) |
java.lang.Object |
DUPL.up(Event evt) |
java.lang.Object |
FC.up(Event evt)
Deprecated.
|
java.lang.Object |
STATS.up(Event evt) |
java.lang.Object |
TRACE.up(Event evt) |
java.lang.Object |
DISCARD.up(Event evt) |
java.lang.Object |
SASL.up(Event evt) |
java.lang.Object |
MAKE_BATCH.up(Event evt) |
java.lang.Object |
RSVP.up(Event evt) |
java.lang.Object |
UNICAST.up(Event evt)
Deprecated.
|
java.lang.Object |
MERGE3.up(Event evt) |
java.lang.Object |
PRIO.up(Event evt)
An event was received from the layer below.
|
java.lang.Object |
FD_SOCK.up(Event evt) |
java.lang.Object |
SHUFFLE.up(Event evt) |
java.lang.Object |
COUNTER.up(Event evt) |
java.lang.Object |
FD.up(Event evt) |
java.lang.Object |
FORK.up(Event evt) |
java.lang.Object |
ASYM_ENCRYPT.up(Event evt) |
java.lang.Object |
MPING.up(Event evt) |
java.lang.Object |
ABP.up(Event evt) |
java.lang.Object |
MERGE2.up(Event evt)
Deprecated.
|
java.lang.Object |
SIZE.up(Event evt) |
java.lang.Object |
SEQUENCER2.up(Event evt) |
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 |
Discovery.up(Event evt) |
java.lang.Object |
STOMP.up(Event evt) |
java.lang.Object |
FlowControl.up(Event evt) |
java.lang.Object |
HDRS.up(Event evt) |
java.lang.Object |
ENCRYPT.up(Event evt)
Deprecated.
|
java.lang.Object |
UNICAST3.up(Event evt) |
java.lang.Object |
SEQUENCER.up(Event evt) |
java.lang.Object |
EXAMPLE.up(Event evt) |
java.lang.Object |
AUTH.up(Event evt)
An event was received from the layer below.
|
java.lang.Object |
TP.up(Event evt)
handle the UP event.
|
java.lang.Object |
TP.ProtocolAdapter.up(Event evt) |
java.lang.Object |
DELAY.up(Event evt) |
java.lang.Object |
SSL_KEY_EXCHANGE.up(Event evt) |
java.lang.Object |
VERIFY_SUSPECT.up(Event evt) |
java.lang.Object |
BARRIER.up(Event evt) |
java.lang.Object |
FD_ALL.up(Event evt) |
java.lang.Object |
EncryptBase.up(Event evt) |
java.lang.Object |
FD_ALL2.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 |
COMPRESS.up(Event evt)
If there is no header, we pass the message up.
|
java.lang.Object |
Executing.up(Event evt) |
java.lang.Object |
UNICAST2.up(Event evt)
Deprecated.
|
java.lang.Object |
SCOPE.up(Event evt)
Deprecated.
|
java.lang.Object |
DAISYCHAIN.up(Event evt) |
Constructor and Description |
---|
PriorityMessage(Event event,
byte priority) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
GMS.down(Event evt) |
java.lang.Object |
STABLE.down(Event evt) |
java.lang.Object |
StreamingStateTransfer.down(Event evt) |
java.lang.Object |
FLUSH.down(Event evt) |
java.lang.Object |
NAKACK.down(Event evt)
Deprecated.
Callback.
|
java.lang.Object |
NAKACK2.down(Event evt)
Callback.
|
java.lang.Object |
STATE_TRANSFER.down(Event evt) |
protected void |
NAKACK.send(Event evt,
Message msg)
Deprecated.
Adds the message to the sent_msgs table and then passes it down the stack.
|
protected void |
NAKACK2.send(Event evt,
Message msg)
Adds the message to the sent_msgs table and then passes it down the stack.
|
java.lang.Object |
GMS.up(Event evt) |
java.lang.Object |
STABLE.up(Event evt) |
java.lang.Object |
StreamingStateTransfer.up(Event evt) |
java.lang.Object |
FLUSH.up(Event evt) |
java.lang.Object |
NAKACK.up(Event evt)
Deprecated.
Callback.
|
java.lang.Object |
NAKACK2.up(Event evt)
Callback.
|
java.lang.Object |
STATE_TRANSFER.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
RELAY2.down(Event evt) |
java.lang.Object |
RELAY2.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
EventHandler.down(Event evt)
Called when a down event is received
|
java.lang.Object |
SUPERVISOR.down(Event evt) |
java.lang.Object |
EventHandler.up(Event evt)
Called when an up event is received
|
java.lang.Object |
SUPERVISOR.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
TOA.down(Event evt) |
java.lang.Object |
TOA.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.