程序包 | 说明 |
---|---|
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.stack |
Support for managing protocol stacks.
|
com.fr.third.jgroups.tests | |
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 字段和说明 |
---|---|
protected PhysicalAddress |
TP.local_physical_addr |
protected PhysicalAddress |
SHARED_LOOPBACK.physical_addr |
protected PhysicalAddress |
PingData.physical_addr |
protected PhysicalAddress |
MERGE3.MergeHeader.physical_addr |
限定符和类型 | 字段和说明 |
---|---|
protected java.util.concurrent.ConcurrentMap<Address,PhysicalAddress> |
PDC.cache |
protected BoundedList<PhysicalAddress> |
TCPPING.dynamic_hosts
https://jira.jboss.org/jira/browse/JGRP-989
|
protected LazyRemovalCache<Address,PhysicalAddress> |
TP.logical_addr_cache
Cache which maintains mappings between logical and physical addresses.
|
protected static LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<PhysicalAddress>> |
TP.print_function |
限定符和类型 | 方法和说明 |
---|---|
PhysicalAddress |
PingData.getPhysicalAddr() |
protected PhysicalAddress |
UDP.getPhysicalAddress() |
protected PhysicalAddress |
TUNNEL.getPhysicalAddress() |
protected abstract PhysicalAddress |
TP.getPhysicalAddress() |
protected PhysicalAddress |
TCP_NIO.getPhysicalAddress() |
protected PhysicalAddress |
TCP.getPhysicalAddress() |
protected PhysicalAddress |
SHARED_LOOPBACK.getPhysicalAddress() |
protected PhysicalAddress |
FD_HOST.getPhysicalAddress(Address logical_addr) |
protected PhysicalAddress |
TP.getPhysicalAddressFromCache(Address logical_addr) |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.Collection<PhysicalAddress> |
TP.getAllPhysicalAddressesFromCache() |
java.util.List<PhysicalAddress> |
TCPPING.getInitialHosts()
Returns the list of initial hosts as configured by the user via XML.
|
java.util.Collection<PhysicalAddress> |
PingData.getPhysicalAddrs()
已过时。
|
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
FILE_PING.addDiscoveryResponseToCaches(Address mbr,
java.lang.String logical_name,
PhysicalAddress physical_addr)
Only add the discovery response if the logical address is not present or the physical addrs are different
|
protected boolean |
Discovery.addDiscoveryResponseToCaches(Address mbr,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
protected void |
MERGE3.addInfo(Address sender,
ViewId view_id,
java.lang.String logical_name,
PhysicalAddress physical_addr)
Adds received INFO to views hashmap
|
protected boolean |
TP.addPhysicalAddressToCache(Address logical_addr,
PhysicalAddress physical_addr) |
void |
TUNNEL.TUNNELPolicy.connect(java.util.List<RouterStub> stubs,
java.lang.String group,
Address addr,
java.lang.String logical_name,
PhysicalAddress phys_addr) |
static MERGE3.MergeHeader |
MERGE3.MergeHeader.createInfo(ViewId view_id,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
void |
TCPPING.discoveryRequestReceived(Address sender,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
void |
Discovery.discoveryRequestReceived(Address sender,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
protected void |
Discovery.sendDiscoveryResponse(Address logical_addr,
PhysicalAddress physical_addr,
java.lang.String logical_name,
Address sender,
boolean coord) |
void |
UDP.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
void |
TUNNEL.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
abstract void |
TP.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length)
Send a unicast to 1 member.
|
void |
SHARED_LOOPBACK.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
void |
BasicTCP.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
protected void |
PDC.writeNodeToDisk(Address logical_addr,
PhysicalAddress physical_addr) |
限定符和类型 | 方法和说明 |
---|---|
void |
TCPPING.setInitialHosts(java.util.List<PhysicalAddress> initial_hosts) |
构造器和说明 |
---|
MERGE3.MergeHeader(MERGE3.MergeHeader.Type type,
ViewId view_id,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
PDC.Mapping(Address logical_addr,
PhysicalAddress physical_addr,
java.lang.String logical_name) |
PingData(Address sender,
boolean is_server,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
构造器和说明 |
---|
PingData(Address sender,
View view,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
已过时。
Use the constructor wityh a single PhysicalAddress instead
|
PingData(Address sender,
View view,
ViewId view_id,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
已过时。
Use the constructor with a single PhysicalAddress instead
|
限定符和类型 | 类和说明 |
---|---|
class |
IpAddress
Network-dependent address (Internet).
|
限定符和类型 | 方法和说明 |
---|---|
PhysicalAddress |
GossipData.getPhysicalAddress() |
限定符和类型 | 方法和说明 |
---|---|
java.util.Collection<PhysicalAddress> |
GossipData.getPhysicalAddresses()
已过时。
Use
GossipData.getPhysicalAddress() instead |
限定符和类型 | 方法和说明 |
---|---|
void |
RouterStub.connect(java.lang.String group,
Address addr,
java.lang.String logical_name,
PhysicalAddress phys_addr)
Register this process with the router under
group . |
构造器和说明 |
---|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs,
PhysicalAddress physical_addr) |
GossipData(byte type,
java.lang.String group,
Address addr,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
构造器和说明 |
---|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List<Address> mbrs,
java.util.List<PhysicalAddress> physical_addrs)
已过时。
Use the constructor wityh a single PhysicalAddress instead
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.lang.String logical_name,
java.util.List<PhysicalAddress> physical_addrs)
已过时。
Use the constructor wityh a single PhysicalAddress instead
|
限定符和类型 | 字段和说明 |
---|---|
protected PhysicalAddress |
UnicastTestTcp.destination |
限定符和类型 | 方法和说明 |
---|---|
static java.util.List<PhysicalAddress> |
Util.parseCommaDelimitedHosts(java.lang.String hosts,
int port_range)
Input is "daddy[8880],sindhu[8880],camille[5555].
|