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.protocols.rules | |
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 |
---|---|
protected java.util.Map<Owner,Tuple<COUNTER.Request,Promise>> |
COUNTER.pending_requests |
protected BoundedList<Tuple<Address,java.lang.Long>> |
FD_ALL.suspect_history |
protected BoundedList<Tuple<Address,java.lang.Long>> |
FD_ALL2.suspect_history |
protected BoundedList<Tuple<java.net.InetAddress,java.lang.Long>> |
FD_HOST.suspect_history |
Modifier and Type | Method and Description |
---|---|
protected Tuple<javax.crypto.SecretKey,byte[]> |
KeyExchange.getSecretKeyFromAbove()
Fetches the secret key from a protocol above us
|
Modifier and Type | Method and Description |
---|---|
protected void |
KeyExchange.setSecretKeyAbove(Tuple<javax.crypto.SecretKey,byte[]> key)
Sets the secret key in a protocol above us
|
Modifier and Type | Method and Description |
---|---|
protected void |
UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry,
Address sender,
java.util.List<Tuple<java.lang.Long,Message>> msgs,
boolean oob) |
protected java.lang.String |
UNICAST3.printMessageList(java.util.List<Tuple<java.lang.Long,Message>> list) |
Modifier and Type | Method and Description |
---|---|
static Tuple<View,Digest> |
GMS._readViewAndDigest(byte[] buffer,
int offset,
int length) |
protected Tuple<java.io.InputStream,java.lang.Object> |
STATE_SOCK.createStreamToProvider(Address provider,
StreamingStateTransfer.StateHeader hdr) |
protected Tuple<java.io.InputStream,java.lang.Object> |
STATE.createStreamToProvider(Address provider,
StreamingStateTransfer.StateHeader hdr) |
protected abstract Tuple<java.io.InputStream,java.lang.Object> |
StreamingStateTransfer.createStreamToProvider(Address provider,
StreamingStateTransfer.StateHeader hdr)
Creates an InputStream to the state provider to read the state.
|
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest.
|
protected Tuple<java.util.Collection<? extends Address>,Digest> |
FLUSH.readParticipantsAndDigest(byte[] buffer,
int offset,
int length) |
protected Tuple<View,Digest> |
GMS.readViewAndDigest(byte[] buffer,
int offset,
int length) |
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) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,Tuple<Rule,java.util.concurrent.Future<?>>> |
SUPERVISOR.rules |
Modifier and Type | Field and Description |
---|---|
protected static java.util.concurrent.ConcurrentMap<java.lang.String,Tuple<TP,ProtocolStack.RefCounter>> |
ProtocolStack.singleton_transports
Holds the shared transports, keyed by 'TP.singleton_name'.
|
Modifier and Type | Method and Description |
---|---|
static java.util.concurrent.ConcurrentMap<java.lang.String,Tuple<TP,ProtocolStack.RefCounter>> |
ProtocolStack.getSingletonTransports() |
Modifier and Type | Method and Description |
---|---|
java.util.List<Tuple<Address,java.lang.Long>> |
CreditMap.getMembersWithCreditsLessThan(long min_credits) |
Modifier and Type | Method and Description |
---|---|
boolean |
Table.add(java.util.List<Tuple<java.lang.Long,T>> list)
Adds elements from list to the table
|
boolean |
Table.add(java.util.List<Tuple<java.lang.Long,T>> list,
boolean remove_added_elements)
Adds elements from list to the table, removes elements from list that were not added to the table
|
boolean |
Table.add(java.util.List<Tuple<java.lang.Long,T>> list,
boolean remove_added_elements,
T const_value)
Adds elements from the list to the table
|
protected long |
Table.findHighestSeqno(java.util.List<Tuple<java.lang.Long,T>> list) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.