程序包 | 说明 |
---|---|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.stack |
Support for managing protocol stacks.
|
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 字段和说明 |
---|---|
protected java.util.Map<java.lang.Long,Responses> |
Discovery.ping_responses |
限定符和类型 | 方法和说明 |
---|---|
protected Responses |
TP.fetchResponsesFromDiscoveryProtocol(java.util.List<Address> missing) |
Responses |
Discovery.findMembers(java.util.List<Address> members,
boolean initial_discovery,
boolean async) |
限定符和类型 | 方法和说明 |
---|---|
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 |
SHARED_LOOPBACK_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) |
void |
JDBC_PING.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) |
protected abstract void |
Discovery.findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g. physical address, logical name) for the given member addresses.
|
protected void |
JDBC_PING.readAll(java.sql.Connection connection,
java.util.List<Address> members,
java.lang.String clustername,
Responses rsps) |
protected void |
SWIFT_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 |
RACKSPACE_PING.readAll(java.util.List<Address> members,
java.lang.String clustername,
Responses responses) |
protected void |
JDBC_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.readResponse(com.fr.third.jgroups.protocols.S3_PING.GetResponse rsp,
java.util.List<Address> mbrs,
Responses responses) |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
void |
RouterStub.getMembers(java.lang.String group,
Responses rsps) |
限定符和类型 | 方法和说明 |
---|---|
protected Responses |
Responses._done() |
Responses |
Responses.clear() |
Responses |
Responses.done() |