| 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.