Package | Description |
---|---|
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.blocks.executor | |
org.jgroups.blocks.mux | |
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.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
static Event |
Event.GET_DIGEST_EVT |
Modifier and Type | Method and Description |
---|---|
Object |
JChannel.down(Event evt)
Sends a message through the protocol stack if the stack is available
|
Object |
Channel.down(Event evt)
Enables access to event mechanism of a channel and is normally not used by clients directly.
|
Object |
UpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
Object |
JChannel.up(Event evt)
Callback method
Called by the ProtocolStack when a message is received. |
Modifier and Type | Method and Description |
---|---|
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<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.
|
Object |
MuxUpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
Modifier and Type | Method and Description |
---|---|
Object |
VERIFY_SUSPECT.down(Event evt) |
Object |
UNICAST2.down(Event evt) |
Object |
UNICAST.down(Event evt) |
Object |
TRACE.down(Event evt) |
Object |
TP.down(Event evt)
Caller by the layer above this layer.
|
Object |
TP.ProtocolAdapter.down(Event evt) |
Object |
TCPPING.down(Event evt) |
Object |
STOMP.down(Event evt) |
Object |
STATS.down(Event evt) |
Object |
SIZE.down(Event evt) |
Object |
SHUFFLE.down(Event evt) |
Object |
SHARED_LOOPBACK.down(Event evt) |
Object |
SEQUENCER.down(Event evt) |
Object |
SCOPE.down(Event evt) |
Object |
RSVP.down(Event evt) |
Object |
RELAY.down(Event evt) |
Object |
RATE_LIMITER.down(Event evt) |
Object |
PRIO.down(Event evt)
An event is to be sent down the stack.
|
Object |
MERGE2.down(Event evt) |
Object |
Locking.down(Event evt) |
Object |
HTOTAL.down(Event evt) |
Object |
HDRS.down(Event evt) |
Object |
FlowControl.down(Event evt) |
Object |
FRAG2.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
Object |
FRAG.down(Event evt)
Fragment a packet if larger than frag_size (add a header).
|
Object |
FILE_PING.down(Event evt) |
Object |
FD_SOCK.down(Event evt) |
Object |
FD_SIMPLE.down(Event evt) |
Object |
FD_ALL.down(Event evt) |
Object |
FD.down(Event evt) |
Object |
FC.down(Event evt) |
Object |
Executing.down(Event evt) |
Object |
EXAMPLE.down(Event evt) |
Object |
ENCRYPT.down(Event evt) |
Object |
Discovery.down(Event evt)
An event is to be sent down the stack.
|
Object |
DUPL.down(Event evt) |
Object |
DISCARD_PAYLOAD.down(Event evt) |
Object |
DISCARD.down(Event evt) |
Object |
DELAY.down(Event evt) |
Object |
DAISYCHAIN.down(Event evt) |
Object |
COUNTER.down(Event evt) |
Object |
COMPRESS.down(Event evt)
We compress the payload if it is larger than
min_size . |
Object |
BARRIER.down(Event evt) |
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 |
UNICAST.handleDataReceived(Address sender,
long seqno,
long conn_id,
boolean first,
Message msg,
Event evt)
Check whether the hashtable contains an entry e for
sender (create if not). |
protected void |
UNICAST2.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). |
Object |
TUNNEL.handleDownEvent(Event evt) |
protected Object |
TP.handleDownEvent(Event evt) |
protected Object |
BasicTCP.handleDownEvent(Event evt) |
protected Object |
UFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected Object |
MFC.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected abstract Object |
FlowControl.handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
Object |
ENCRYPT.passItDown(Event evt) |
Object |
ENCRYPT.passItUp(Event evt) |
protected void |
TP.passToAllUpProtocols(Event evt) |
Object |
VERIFY_SUSPECT.up(Event evt) |
Object |
UNICAST2.up(Event evt) |
Object |
UNICAST.up(Event evt) |
Object |
TRACE.up(Event evt) |
Object |
TP.up(Event evt)
handle the UP event.
|
Object |
STOMP.up(Event evt) |
Object |
STATS.up(Event evt) |
Object |
SIZE.up(Event evt) |
Object |
SHUFFLE.up(Event evt) |
Object |
SEQUENCER.up(Event evt) |
Object |
SCOPE.up(Event evt) |
Object |
RSVP.up(Event evt) |
Object |
RELAY.up(Event evt) |
Object |
PRIO.up(Event evt)
An event was received from the layer below.
|
Object |
MPING.up(Event evt) |
Object |
MERGE2.up(Event evt) |
Object |
Locking.up(Event evt) |
Object |
HTOTAL.up(Event evt) |
Object |
HDRS.up(Event evt) |
Object |
FlowControl.up(Event evt) |
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.
|
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.
|
Object |
FD_SOCK.up(Event evt) |
Object |
FD_SIMPLE.up(Event evt) |
Object |
FD_ICMP.up(Event evt) |
Object |
FD_ALL.up(Event evt) |
Object |
FD.up(Event evt) |
Object |
FC.up(Event evt) |
Object |
Executing.up(Event evt) |
Object |
EXAMPLE.up(Event evt) |
Object |
ENCRYPT.up(Event evt) |
Object |
Discovery.up(Event evt)
An event was received from the layer below.
|
Object |
DUPL.up(Event evt) |
Object |
DISCARD.up(Event evt) |
Object |
DELAY_JOIN_REQ.up(Event evt) |
Object |
DELAY.up(Event evt) |
Object |
DAISYCHAIN.up(Event evt) |
Object |
COUNTER.up(Event evt) |
Object |
COMPRESS.up(Event evt)
If there is no header, we pass the message up.
|
Object |
BARRIER.up(Event evt) |
Object |
AUTH.up(Event evt)
An event was received from the layer below.
|
Modifier and Type | Method and Description |
---|---|
Object |
StreamingStateTransfer.down(Event evt) |
Object |
STATE_TRANSFER.down(Event evt) |
Object |
STABLE.down(Event evt) |
Object |
NAKACK.down(Event evt)
Callback.
|
Object |
GMS.down(Event evt) |
Object |
FLUSH.down(Event evt) |
Object |
StreamingStateTransfer.up(Event evt) |
Object |
STATE_TRANSFER.up(Event evt) |
Object |
STABLE.up(Event evt) |
Object |
NAKACK.up(Event evt)
Callback.
|
Object |
GMS.up(Event evt) |
Object |
FLUSH.up(Event evt) |
Modifier and Type | Method and Description |
---|---|
Object |
ProtocolStack.down(Event evt) |
Object |
Protocol.down(Event evt)
An event is to be sent down the stack.
|
Object |
ProtocolStack.up(Event evt) |
Object |
Protocol.up(Event evt)
An event was received from the layer below.
|
Modifier and Type | Method and Description |
---|---|
static String |
Util.printEvent(Event evt) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.