Package | Description |
---|---|
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.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 | Method and Description |
---|---|
protected static Tuple<Short,String> |
ClassConfigurator.parseClassData(Node protocol) |
Modifier and Type | Method and Description |
---|---|
protected static List<Tuple<Short,String>> |
ClassConfigurator.parse(InputStream stream) |
protected static List<Tuple<Short,String>> |
ClassConfigurator.readMappings(String name)
try to read the magic number configuration file as a Resource form the classpath using getResourceAsStream
if this fails this method tries to read the configuration file from mMagicNumberFile using a FileInputStream (not in classpath but somewhere else in the disk)
|
Modifier and Type | Field and Description |
---|---|
protected Map<Owner,Tuple<COUNTER.Request,Promise>> |
COUNTER.pending_requests |
Modifier and Type | Method and Description |
---|---|
protected void |
UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry,
Address sender,
List<Tuple<Long,Message>> msgs,
boolean oob) |
protected String |
UNICAST3.printMessageList(List<Tuple<Long,Message>> list) |
Modifier and Type | Method and Description |
---|---|
Tuple<View,Digest> |
GMS.getViewAndDigest()
Returns the current view and digest.
|
protected Tuple<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 sender,
List<Tuple<Long,Message>> msgs,
boolean oob,
String cluster_name) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Tuple<Rule,Future<?>>> |
SUPERVISOR.rules |
Modifier and Type | Field and Description |
---|---|
protected static ConcurrentMap<String,Tuple<TP,ProtocolStack.RefCounter>> |
ProtocolStack.singleton_transports
Holds the shared transports, keyed by 'TP.singleton_name'.
|
Modifier and Type | Method and Description |
---|---|
static ConcurrentMap<String,Tuple<TP,ProtocolStack.RefCounter>> |
ProtocolStack.getSingletonTransports() |
Modifier and Type | Method and Description |
---|---|
List<Tuple<Address,Long>> |
CreditMap.getMembersWithCreditsLessThan(long min_credits) |
Modifier and Type | Method and Description |
---|---|
boolean |
Table.add(List<Tuple<Long,T>> list)
Adds messages from list to the table
|
boolean |
Table.add(List<Tuple<Long,T>> list,
boolean remove_added_msgs)
Adds messages from list to the table, removes messages from list that were not added to the table
|
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.