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.tests | |
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(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 List<PingData> |
SHARED_LOOPBACK.getDiscoveryResponsesFor(String cluster_name) |
protected List<PingData> |
FILE_PING.read(File file) |
protected List<PingData> |
FILE_PING.read(InputStream in) |
protected List<PingData> |
Discovery.read(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(Connection connection,
PingData data,
String clustername,
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,
String clustername,
boolean overwrite) |
Modifier and Type | Method and Description |
---|---|
void |
TCPGOSSIP.members(List<PingData> mbrs) |
protected void |
FILE_PING.write(List<PingData> list,
OutputStream out) |
protected void |
Discovery.write(List<PingData> list,
OutputStream out) |
protected void |
SWIFT_PING.write(List<PingData> list,
String clustername) |
protected void |
FILE_PING.write(List<PingData> list,
String clustername) |
protected void |
RACKSPACE_PING.write(List<PingData> list,
String clustername) |
protected void |
S3_PING.write(List<PingData> list,
String clustername) |
Modifier and Type | Method and Description |
---|---|
protected static String |
ClientGmsImpl.print(List<PingData> rsps) |
Modifier and Type | Method and Description |
---|---|
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(List<PingData> mbrs) |
protected void |
RouterStub.notifyResponse(String group,
List<PingData> list) |
void |
GossipData.setPingData(List<PingData> mbrs) |
Constructor and Description |
---|
GossipData(GossipType type,
String group,
Address addr,
List<PingData> ping_data) |
GossipData(GossipType type,
String group,
Address addr,
List<PingData> ping_data,
PhysicalAddress physical_addr) |
Modifier and Type | Method and Description |
---|---|
void |
RouterStubGet.members(List<PingData> mbrs) |
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 |
---|---|
List<PingData> |
Responses.get(long timeout)
Deprecated.
|
Iterator<PingData> |
Responses.iterator() |
protected 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 String |
Util.printPingData(List<PingData> rsps) |
Constructor and Description |
---|
PingDataIterator(PingData[] data,
int end_index) |
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.