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.cluster_name
The name of the group to which this member is connected.
|
protected AsciiString |
MAKE_BATCH.cluster_name |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<AsciiString,javax.crypto.Cipher> |
Encrypt.key_map |
Modifier and Type | Method and Description |
---|---|
AsciiString |
TP.getClusterNameAscii() |
Modifier and Type | Method and Description |
---|---|
protected static void |
SHARED_LOOPBACK.register(AsciiString channel_name,
Address local_addr,
SHARED_LOOPBACK shared_loopback) |
protected static void |
SHARED_LOOPBACK.unregister(AsciiString channel_name,
Address local_addr) |
Constructor and Description |
---|
TpHeader(AsciiString n) |
Modifier and Type | Method and Description |
---|---|
protected void |
NAKACK2.handleMessages(Address dest,
Address sender,
java.util.List<LongTuple<Message>> msgs,
boolean oob,
AsciiString cluster_name) |
protected void |
NAKACK2.removeAndDeliver(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() |
AsciiString |
MessageBatch.getClusterName() |
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) |
MessageBatch |
MessageBatch.setClusterName(AsciiString name) |
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,
java.util.function.Predicate<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.