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 java.util.Map<java.lang.Long,Responses> |
Discovery.ping_responses |
Modifier and Type | Method and Description |
---|---|
protected Responses |
TP.fetchResponsesFromDiscoveryProtocol(java.util.List<Address> missing) |
Responses |
Discovery.findMembers(java.util.List<Address> members,
boolean initial_discovery,
boolean async) |
Modifier and Type | Method and Description |
---|---|
void |
JDBC_PING.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
protected abstract void |
Discovery.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g.
|
void |
SHARED_LOOPBACK_PING.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
TCPPING.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
TCPGOSSIP.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
FILE_PING.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
PING.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses) |
protected void |
JDBC_PING.readAll(java.sql.Connection connection,
java.util.List<Address> members,
java.lang.String clustername,
Responses rsps) |
protected void |
JDBC_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
SWIFT_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
RACKSPACE_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
FILE_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
S3_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
S3_PING.readResponse(org.jgroups.protocols.S3_PING.GetResponse rsp,
java.util.List<Address> mbrs,
Responses responses) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ClientGmsImpl.firstOfAllClients(Address joiner,
Responses rsps)
Handles the case where no coord responses were received.
|
protected static java.lang.String |
ClientGmsImpl.print(Responses rsps) |
Modifier and Type | Method and Description |
---|---|
protected Responses |
Responses._done() |
Responses |
Responses.clear() |
Responses |
Responses.done() |
Copyright © 1998-2020 Red Hat. All Rights Reserved.