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.conf |
Provides ways to configure a protocol stack.
|
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.tom | |
org.jgroups.tests.perf | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected Header[] |
Message.headers
All headers are placed here
|
Modifier and Type | Method and Description |
---|---|
<T extends Header> |
Message.getHeader(short... ids)
Returns a header for a range of IDs, or null if not found
|
<T extends Header> |
Message.getHeader(short id) |
Modifier and Type | Method and Description |
---|---|
protected static Header[] |
Message.createHeaders(int size) |
protected static Header |
Message.readHeader(DataInput in) |
Header |
Header.setProtId(short id) |
Modifier and Type | Method and Description |
---|---|
Map<Short,Header> |
Message.getHeaders()
Returns a reference to the headers hashmap, which is immutable.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.putHeader(short id,
Header hdr)
Puts a header given an ID into the hashmap.
|
protected static void |
Message.writeHeader(Header hdr,
DataOutput out) |
Modifier and Type | Class and Description |
---|---|
class |
ChallengeResponseHeader |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
ChallengeResponseHeader.create() |
Modifier and Type | Class and Description |
---|---|
static class |
RequestCorrelator.Header
The header for RequestCorrelator messages
|
static class |
RequestCorrelator.MultiDestinationHeader |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
RequestCorrelator.Header.create() |
Supplier<? extends Header> |
RequestCorrelator.MultiDestinationHeader.create() |
Modifier and Type | Method and Description |
---|---|
protected static void |
ClassConfigurator.checkSameId(Header hdr,
short magic) |
Modifier and Type | Class and Description |
---|---|
protected static class |
ABP.ABPHeader |
class |
AuthHeader
AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
|
static class |
COMPRESS.CompressHeader |
static class |
COUNTER.CounterHeader |
static class |
DAISYCHAIN.DaisyHeader |
static class |
DH_KEY_EXCHANGE.DhHeader |
class |
EncryptHeader |
static class |
EXAMPLE.ExampleHeader |
static class |
Executing.ExecutorHeader |
class |
FcHeader
Header used by various flow control protocols
|
static class |
FD_ALL.HeartbeatHeader |
static class |
FD_ALL2.HeartbeatHeader |
static class |
FD_SOCK.FdHeader |
static class |
FD.FdHeader |
static class |
FORK.ForkHeader |
protected static class |
FORWARD_TO_COORD.ForwardHeader |
class |
Frag3Header |
class |
FragHeader |
static class |
Locking.LockingHeader |
static class |
MERGE3.MergeHeader |
static class |
NAMING.Header |
protected static class |
PERF.PerfHeader |
class |
PingHeader
Used to send discovery requests and responses
|
static class |
RELAY.RelayHeader |
protected static class |
RSVP.RsvpHeader |
class |
SaslHeader |
static class |
SEQUENCER.SequencerHeader |
static class |
SEQUENCER2.SequencerHeader |
static class |
STOMP.StompHeader |
class |
TpHeader
Generic transport header, used by TP.
|
class |
UnicastHeader3
Moved out of
UNICAST3 into separate class. |
static class |
VERIFY_SUSPECT.VerifyHeader |
Modifier and Type | Method and Description |
---|---|
protected abstract Header |
FlowControl.getCreditRequestHeader() |
protected Header |
UFC.getCreditRequestHeader() |
protected Header |
MFC.getCreditRequestHeader() |
protected abstract Header |
FlowControl.getReplenishHeader() |
protected Header |
UFC.getReplenishHeader() |
protected Header |
MFC.getReplenishHeader() |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
FORK.ForkHeader.create() |
Supplier<? extends Header> |
FD_SOCK.FdHeader.create() |
Supplier<? extends Header> |
STOMP.StompHeader.create() |
Supplier<? extends Header> |
FragHeader.create() |
Supplier<? extends Header> |
Locking.LockingHeader.create() |
Supplier<? extends Header> |
FD.FdHeader.create() |
Supplier<? extends Header> |
COUNTER.CounterHeader.create() |
Supplier<? extends Header> |
Executing.ExecutorHeader.create() |
Supplier<? extends Header> |
PERF.PerfHeader.create() |
Supplier<? extends Header> |
NAMING.Header.create() |
Supplier<? extends Header> |
RELAY.RelayHeader.create() |
Supplier<? extends Header> |
PingHeader.create() |
Supplier<? extends Header> |
COMPRESS.CompressHeader.create() |
Supplier<? extends Header> |
VERIFY_SUSPECT.VerifyHeader.create() |
Supplier<? extends Header> |
FORWARD_TO_COORD.ForwardHeader.create() |
Supplier<? extends Header> |
FD_ALL2.HeartbeatHeader.create() |
Supplier<? extends Header> |
ABP.ABPHeader.create() |
Supplier<? extends Header> |
MERGE3.MergeHeader.create() |
Supplier<? extends Header> |
SaslHeader.create() |
Supplier<? extends Header> |
DAISYCHAIN.DaisyHeader.create() |
Supplier<? extends Header> |
EncryptHeader.create() |
Supplier<? extends Header> |
FcHeader.create() |
Supplier<? extends Header> |
SEQUENCER2.SequencerHeader.create() |
Supplier<? extends Header> |
EXAMPLE.ExampleHeader.create() |
Supplier<? extends Header> |
SEQUENCER.SequencerHeader.create() |
Supplier<? extends Header> |
FD_ALL.HeartbeatHeader.create() |
Supplier<? extends Header> |
DH_KEY_EXCHANGE.DhHeader.create() |
Supplier<? extends Header> |
AuthHeader.create() |
Supplier<? extends Header> |
UnicastHeader3.create() |
Supplier<? extends Header> |
TpHeader.create() |
Supplier<? extends Header> |
RSVP.RsvpHeader.create() |
Supplier<? extends Header> |
Frag3Header.create() |
Modifier and Type | Class and Description |
---|---|
static class |
FLUSH.FlushHeader |
static class |
GMS.GmsHeader |
class |
NakAckHeader2
Header used by
NAKACK2 |
static class |
STABLE.StableHeader |
static class |
STATE_TRANSFER.StateHeader
Wraps data for a state request/response.
|
static class |
StreamingStateTransfer.StateHeader |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
STABLE.StableHeader.create() |
Supplier<? extends Header> |
STATE_TRANSFER.StateHeader.create() |
Supplier<? extends Header> |
StreamingStateTransfer.StateHeader.create() |
Supplier<? extends Header> |
GMS.GmsHeader.create() |
Supplier<? extends Header> |
FLUSH.FlushHeader.create() |
Supplier<? extends Header> |
NakAckHeader2.create() |
Modifier and Type | Class and Description |
---|---|
static class |
RELAY2.Relay2Header |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
RELAY2.Relay2Header.create() |
Modifier and Type | Class and Description |
---|---|
class |
ToaHeader
The header for the Total Order Anycast (TOA) protocol
|
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
ToaHeader.create() |
Modifier and Type | Class and Description |
---|---|
protected static class |
MPerf.MPerfHeader |
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
MPerf.MPerfHeader.create() |
Modifier and Type | Method and Description |
---|---|
static <T extends Header> |
Headers.getHeader(Header[] hdrs,
short... ids)
Returns the header associated with a set of IDs
|
static <T extends Header> |
Headers.getHeader(Header[] hdrs,
short id)
Returns the header associated with an ID
|
Modifier and Type | Method and Description |
---|---|
static Header[] |
Headers.copy(Header[] headers) |
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.resize(Header[] headers)
Increases the capacity of the array and copies the contents of the old into the new array
|
Modifier and Type | Method and Description |
---|---|
static Map<Short,Header> |
Headers.getHeaders(Header[] hdrs) |
Modifier and Type | Method and Description |
---|---|
static Header[] |
Headers.copy(Header[] headers) |
static <T extends Header> |
Headers.getHeader(Header[] hdrs,
short... ids)
Returns the header associated with a set of IDs
|
static <T extends Header> |
Headers.getHeader(Header[] hdrs,
short id)
Returns the header associated with an ID
|
static Map<Short,Header> |
Headers.getHeaders(Header[] hdrs) |
static int |
Headers.marshalledSize(Header[] hdrs) |
static String |
Headers.printHeaders(Header[] hdrs) |
static String |
Headers.printObjectHeaders(Header[] hdrs) |
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.resize(Header[] headers)
Increases the capacity of the array and copies the contents of the old into the new array
|
static int |
Headers.size(Header[] hdrs) |
static int |
Headers.size(Header[] hdrs,
short... excluded_ids) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.