程序包 | 说明 |
---|---|
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.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
PingData |
PingData.coord(boolean c) |
protected static PingData |
Discovery.deserialize(byte[] data) |
PingData |
PingData.mbrs(java.util.Collection<? extends Address> mbrs) |
protected PingData |
Discovery.readPingData(byte[] buffer,
int offset,
int length) |
PingData |
PingData.server(boolean c) |
限定符和类型 | 方法和说明 |
---|---|
static java.util.List<PingData> |
SHARED_LOOPBACK.getDiscoveryResponsesFor(java.lang.String cluster_name) |
protected java.util.List<PingData> |
FILE_PING.read(java.io.File file) |
protected java.util.List<PingData> |
FILE_PING.read(java.io.InputStream in) |
protected java.util.List<PingData> |
Discovery.read(java.io.InputStream in) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
Discovery.addResponse(PingData rsp,
boolean overwrite) |
protected void |
Discovery.handleDiscoveryResponse(PingData data,
Address sender) |
protected void |
JDBC_PING.insert(java.sql.Connection connection,
PingData data,
java.lang.String clustername,
java.lang.String address) |
static Buffer |
Discovery.marshal(PingData data) |
protected byte[] |
Discovery.serializeWithoutView(PingData data)
Creates a byte[] representation of the PingData, but DISCARDING the view it contains.
|
protected void |
TP.setPingData(PingData data) |
protected void |
JDBC_PING.writeToDB(PingData data,
java.lang.String clustername) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
FILE_PING.write(java.util.List<PingData> list,
java.io.OutputStream out) |
protected void |
Discovery.write(java.util.List<PingData> list,
java.io.OutputStream out) |
protected void |
SWIFT_PING.write(java.util.List<PingData> list,
java.lang.String clustername) |
protected void |
S3_PING.write(java.util.List<PingData> list,
java.lang.String clustername) |
protected void |
RACKSPACE_PING.write(java.util.List<PingData> list,
java.lang.String clustername) |
protected void |
FILE_PING.write(java.util.List<PingData> list,
java.lang.String clustername) |
限定符和类型 | 方法和说明 |
---|---|
protected static java.lang.String |
ClientGmsImpl.print(java.util.List<PingData> rsps) |
限定符和类型 | 字段和说明 |
---|---|
protected PingData[] |
Responses.PingDataIterator.data |
protected PingData[] |
Responses.ping_rsps |
限定符和类型 | 方法和说明 |
---|---|
PingData |
Responses.findResponseFrom(Address mbr) |
PingData |
Responses.PingDataIterator.next() |
限定符和类型 | 方法和说明 |
---|---|
java.util.List<PingData> |
Responses.get(long timeout)
已过时。
|
java.util.Iterator<PingData> |
Responses.iterator() |
protected java.util.List<PingData> |
Responses.toList() |
限定符和类型 | 方法和说明 |
---|---|
protected void |
Responses.add(PingData data) |
void |
Responses.addResponse(PingData rsp,
boolean overwrite) |
protected int |
Responses.find(PingData data) |
限定符和类型 | 方法和说明 |
---|---|
static java.lang.String |
Util.printPingData(java.util.List<PingData> rsps) |
构造器和说明 |
---|
Responses.PingDataIterator(PingData[] data,
int end_index) |