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.
|
Modifier and Type | Field and Description |
---|---|
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 Collection<PhysicalAddress> |
PingData.physical_addrs |
protected static LazyRemovalCache.Printable<Address,PhysicalAddress> |
TP.print_function |
Modifier and Type | Method and Description |
---|---|
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 |
TP.getPhysicalAddressFromCache(Address logical_addr) |
Modifier and Type | Method and Description |
---|---|
Collection<PhysicalAddress> |
TCPPING.fetchClusterMembers(String cluster_name) |
Collection<PhysicalAddress> |
TCPGOSSIP.fetchClusterMembers(String cluster_name) |
Collection<PhysicalAddress> |
PING.fetchClusterMembers(String cluster_name) |
Collection<PhysicalAddress> |
FILE_PING.fetchClusterMembers(String cluster_name) |
abstract Collection<PhysicalAddress> |
Discovery.fetchClusterMembers(String cluster_name)
Grab all current cluster members
|
Collection<PhysicalAddress> |
PingData.getPhysicalAddrs() |
Modifier and Type | Method and Description |
---|---|
protected void |
TP.addPhysicalAddressToCache(Address logical_addr,
PhysicalAddress physical_addr) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
TUNNEL.TUNNELPolicy.connect(List<RouterStub> stubs,
String group,
Address addr,
String logical_name,
List<PhysicalAddress> phys_addrs) |
void |
TCPPING.discoveryRequestReceived(Address sender,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
void |
Discovery.discoveryRequestReceived(Address sender,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
protected void |
Discovery.sendDiscoveryResponse(Address logical_addr,
List<PhysicalAddress> physical_addrs,
boolean is_server,
boolean return_view_only,
String logical_name,
Address sender) |
Constructor and Description |
---|
PingData(Address own_addr,
View view,
boolean is_server,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
PingData(Address own_addr,
View view,
ViewId view_id,
boolean is_server,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
Modifier and Type | Class and Description |
---|---|
class |
IpAddress
Network-dependent address (Internet).
|
Modifier and Type | Method and Description |
---|---|
Collection<PhysicalAddress> |
GossipData.getPhysicalAddresses() |
Modifier and Type | Method and Description |
---|---|
void |
RouterStub.connect(String group,
Address addr,
String logical_name,
List<PhysicalAddress> phys_addrs)
Register this process with the router under
group . |
Constructor and Description |
---|
GossipData(byte type,
String group,
Address addr,
List<Address> mbrs,
List<PhysicalAddress> physical_addrs) |
GossipData(byte type,
String group,
Address addr,
String logical_name,
List<PhysicalAddress> phys_addrs) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.