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 Map<Long,Responses> |
Discovery.ping_responses |
Modifier and Type | Method and Description |
---|---|
protected Responses |
TP.fetchResponsesFromDiscoveryProtocol(List<Address> missing) |
Responses |
Discovery.findMembers(List<Address> members,
boolean initial_discovery,
boolean async) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Discovery.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g.
|
void |
TCPGOSSIP.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
PING.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
TCPPING.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
SHARED_LOOPBACK_PING.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
FILE_PING.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
void |
JDBC_PING.findMembers(List<Address> members,
boolean initial_discovery,
Responses responses) |
protected void |
JDBC_PING.readAll(Connection connection,
List<Address> members,
String clustername,
Responses rsps) |
protected void |
SWIFT_PING.readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
FILE_PING.readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
S3_PING.readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
RACKSPACE_PING.readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
JDBC_PING.readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
S3_PING.readResponse(org.jgroups.protocols.S3_PING.GetResponse rsp,
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 String |
ClientGmsImpl.print(Responses rsps) |
Modifier and Type | Method and Description |
---|---|
protected Responses |
Responses._done() |
Responses |
Responses.clear() |
Responses |
Responses.done() |
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.