Package | Description |
---|---|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
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 | Field and Description |
---|---|
protected PhysicalAddress |
TP.local_physical_addr |
protected PhysicalAddress |
SHARED_LOOPBACK.physical_addr |
protected PhysicalAddress |
MERGE3.MergeHeader.physical_addr |
protected PhysicalAddress |
PingData.physical_addr |
Modifier and Type | Field and Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
PhysicalAddress |
PingData.getPhysicalAddr() |
protected PhysicalAddress |
UDP.getPhysicalAddress() |
protected PhysicalAddress |
SHARED_LOOPBACK.getPhysicalAddress() |
protected PhysicalAddress |
TUNNEL.getPhysicalAddress() |
protected PhysicalAddress |
TCP_NIO.getPhysicalAddress()
Deprecated.
|
protected PhysicalAddress |
TCP_NIO2.getPhysicalAddress() |
PhysicalAddress |
AUTH.getPhysicalAddress() |
protected abstract PhysicalAddress |
TP.getPhysicalAddress() |
protected PhysicalAddress |
TCP.getPhysicalAddress() |
protected PhysicalAddress |
FD_HOST.getPhysicalAddress(Address logical_addr) |
protected PhysicalAddress |
TP.getPhysicalAddressFromCache(Address logical_addr) |
Modifier and Type | Method and Description |
---|---|
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()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
Discovery.addDiscoveryResponseToCaches(Address mbr,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
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 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) |
static MERGE3.MergeHeader |
MERGE3.MergeHeader.createInfo(ViewId view_id,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
void |
Discovery.discoveryRequestReceived(Address sender,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
void |
TCPPING.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 |
SHARED_LOOPBACK.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
void |
TUNNEL.sendUnicast(PhysicalAddress dest,
byte[] data,
int offset,
int length) |
void |
BasicTCP.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.
|
protected void |
PDC.writeNodeToDisk(Address logical_addr,
PhysicalAddress physical_addr) |
Modifier and Type | Method and Description |
---|---|
void |
TCPPING.setInitialHosts(java.util.List<PhysicalAddress> initial_hosts) |
Constructor and Description |
---|
Mapping(Address logical_addr,
PhysicalAddress physical_addr,
java.lang.String logical_name) |
MergeHeader(MERGE3.MergeHeader.Type type,
ViewId view_id,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
PingData(Address sender,
boolean is_server,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
Constructor and Description |
---|
PingData(Address sender,
View view,
boolean is_server,
java.lang.String logical_name,
java.util.Collection<PhysicalAddress> physical_addrs)
Deprecated.
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)
Deprecated.
Use the constructor with a single PhysicalAddress instead
|
Modifier and Type | Class and Description |
---|---|
class |
IpAddress
Network-dependent address (Internet).
|
Modifier and Type | Field and Description |
---|---|
protected PhysicalAddress |
GossipRouter.Entry.phys_addr |
protected PhysicalAddress |
RouterStubManager.phys_addr |
Modifier and Type | Method and Description |
---|---|
PhysicalAddress |
GossipData.getPhysicalAddress() |
Modifier and Type | Method and Description |
---|---|
protected void |
GossipRouter.addAddressMapping(Address sender,
java.lang.String group,
Address addr,
PhysicalAddress phys_addr,
java.lang.String logical_name) |
void |
RouterStub.connect(java.lang.String group,
Address addr,
java.lang.String logical_name,
PhysicalAddress phys_addr)
Registers mbr with the GossipRouter under the given group, with the given logical name and physical address.
|
Constructor and Description |
---|
Entry(Address client_addr,
PhysicalAddress phys_addr,
java.lang.String logical_name) |
GossipData(GossipType type,
java.lang.String group,
Address addr,
java.util.List<PingData> ping_data,
PhysicalAddress physical_addr) |
GossipData(GossipType type,
java.lang.String group,
Address addr,
java.lang.String logical_name,
PhysicalAddress physical_addr) |
RouterStubManager(Protocol owner,
java.lang.String cluster_name,
Address local_addr,
java.lang.String logical_name,
PhysicalAddress phys_addr,
long interval) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<PhysicalAddress> |
Util.parseCommaDelimitedHosts(java.lang.String hosts,
int port_range)
Input is "daddy[8880],sindhu[8880],camille[5555].
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.