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.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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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> |
Discovery.read(java.io.InputStream in) |
protected java.util.List<PingData> |
FILE_PING.read(java.io.InputStream in) |
Modifier and Type | Method and Description |
---|---|
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,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
void |
TCPGOSSIP.members(java.util.List<PingData> mbrs) |
protected void |
Discovery.write(java.util.List<PingData> list,
java.io.OutputStream out) |
protected void |
FILE_PING.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 |
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 void |
S3_PING.write(java.util.List<PingData> list,
java.lang.String clustername) |
Modifier and Type | Method and Description |
---|---|
protected static java.lang.String |
ClientGmsImpl.print(java.util.List<PingData> rsps) |
Modifier and Type | Method and Description |
---|---|
java.util.List<PingData> |
GossipData.getPingData() |
Modifier and Type | Method and Description |
---|---|
GossipData |
GossipData.addPingData(PingData data) |
Modifier and Type | Method and Description |
---|---|
void |
RouterStub.MembersNotification.members(java.util.List<PingData> mbrs) |
protected void |
RouterStub.notifyResponse(java.lang.String group,
java.util.List<PingData> list) |
void |
GossipData.setPingData(java.util.List<PingData> mbrs) |
Constructor and Description |
---|
GossipData(GossipType type,
java.lang.String group,
Address addr,
java.util.List<PingData> ping_data) |
GossipData(GossipType type,
java.lang.String group,
Address addr,
java.util.List<PingData> ping_data,
PhysicalAddress physical_addr) |
Modifier and Type | Field and Description |
---|---|
protected PingData[] |
Responses.PingDataIterator.data |
protected PingData[] |
Responses.ping_rsps |
Modifier and Type | Method and Description |
---|---|
PingData |
Responses.findResponseFrom(Address mbr) |
PingData |
Responses.PingDataIterator.next() |
Modifier and Type | Method and Description |
---|---|
java.util.List<PingData> |
Responses.get(long timeout)
Deprecated.
|
java.util.Iterator<PingData> |
Responses.iterator() |
protected java.util.List<PingData> |
Responses.toList() |
Modifier and Type | Method and Description |
---|---|
protected void |
Responses.add(PingData data) |
void |
Responses.addResponse(PingData rsp,
boolean overwrite) |
protected int |
Responses.find(PingData data) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
Util.printPingData(java.util.List<PingData> rsps) |
Constructor and Description |
---|
PingDataIterator(PingData[] data,
int end_index) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.