Package | Description |
---|---|
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.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected AsciiString |
TP.SingleMessageHandlerWithClusterName.cluster |
protected AsciiString |
MAKE_BATCH.cluster_name |
protected AsciiString |
TP.cluster_name
The name of the group to which this member is connected.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<AsciiString,javax.crypto.Cipher> |
EncryptBase.key_map |
protected java.util.concurrent.ConcurrentMap<AsciiString,Protocol> |
TP.up_prots
If singleton_name is enabled, this map is used to de-multiplex incoming messages according to their cluster
names (attached to the message by the transport anyway).
|
Modifier and Type | Method and Description |
---|---|
protected AsciiString |
TP.SingleMessageHandler.getClusterName() |
protected AsciiString |
TP.SingleMessageHandlerWithClusterName.getClusterName() |
protected AsciiString |
TP.getClusterName(Message msg) |
AsciiString |
TP.getClusterNameAscii() |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ConcurrentMap<AsciiString,Protocol> |
TP.getUpProtocols() |
Modifier and Type | Method and Description |
---|---|
protected void |
TP.doSend(AsciiString cluster_name,
byte[] buf,
int offset,
int length,
Address dest) |
protected void |
TP.passMessageUp(Message msg,
AsciiString cluster_name,
boolean perform_cluster_name_matching,
boolean multicast,
boolean discard_own_mcast) |
protected static void |
SHARED_LOOPBACK.register(AsciiString channel_name,
Address local_addr,
SHARED_LOOPBACK shared_loopback) |
void |
UDP.sendMulticast(AsciiString cluster_name,
byte[] data,
int offset,
int length) |
void |
SHARED_LOOPBACK.sendMulticast(AsciiString cluster_name,
byte[] data,
int offset,
int length) |
void |
TUNNEL.sendMulticast(AsciiString cluster_name,
byte[] data,
int offset,
int length) |
void |
BasicTCP.sendMulticast(AsciiString cluster_name,
byte[] data,
int offset,
int length) |
abstract void |
TP.sendMulticast(AsciiString cluster_name,
byte[] data,
int offset,
int length)
Send to all members in the group.
|
protected static void |
SHARED_LOOPBACK.unregister(AsciiString channel_name,
Address local_addr) |
Constructor and Description |
---|
ProtocolAdapter(AsciiString cluster_name,
Address local_addr,
short transport_id,
Protocol up,
Protocol down,
java.lang.String pattern) |
SingleMessageHandlerWithClusterName(Message msg,
AsciiString cluster_name) |
TpHeader(AsciiString n) |
Modifier and Type | Method and Description |
---|---|
protected void |
NAKACK2.handleMessages(Address dest,
Address sender,
java.util.List<Tuple<java.lang.Long,Message>> msgs,
boolean oob,
AsciiString cluster_name) |
protected void |
NAKACK2.removeAndPassUp(Table<Message> buf,
Address sender,
boolean loopback,
AsciiString cluster_name)
Efficient way of checking whether another thread is already processing messages from sender.
|
Modifier and Type | Field and Description |
---|---|
protected AsciiString |
MessageBatch.cluster_name
The name of the cluster in which the message batch is sent, this is equivalent to TpHeader.cluster_name
|
Modifier and Type | Method and Description |
---|---|
AsciiString |
MessageBatch.clusterName() |
static AsciiString |
Bits.readAsciiString(java.nio.ByteBuffer buf)
Reads an AsciiString from buf.
|
static AsciiString |
Bits.readAsciiString(java.io.DataInput in)
Reads an AsciiString from buf.
|
Modifier and Type | Method and Description |
---|---|
MessageBatch |
MessageBatch.clusterName(AsciiString name) |
int |
AsciiString.compareTo(AsciiString str) |
static int |
Bits.size(AsciiString str)
Measures the number of bytes required to encode an AsciiSring.
|
static void |
Bits.writeAsciiString(AsciiString s,
java.nio.ByteBuffer buf)
Writes an AsciiString to buf.
|
static void |
Bits.writeAsciiString(AsciiString s,
java.io.DataOutput out)
Writes an AsciiString to buf.
|
Constructor and Description |
---|
AsciiString(AsciiString str) |
MessageBatch(Address dest,
Address sender,
AsciiString cluster_name,
boolean multicast,
java.util.Collection<Message> msgs) |
MessageBatch(Address dest,
Address sender,
AsciiString cluster_name,
boolean multicast,
java.util.Collection<Message> msgs,
Filter<Message> filter) |
MessageBatch(Address dest,
Address sender,
AsciiString cluster_name,
boolean multicast,
MessageBatch.Mode mode,
int capacity) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.