Uses of Interface
org.jgroups.Address

Packages that use Address

Package	Description
org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.admin
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.cs
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.fork
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.dns
org.jgroups.protocols.pbcast
org.jgroups.protocols.relay
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

Modifier and Type	Interface	Description
interface	PhysicalAddress	Represents a physical (as opposed to logical) address

Classes in org.jgroups that implement Address

Modifier and Type	Class	Description
class	NullAddress

Subinterfaces with type arguments of type Address in org.jgroups

Modifier and Type	Interface	Description
interface	Address	Address identifies cluster member.

Classes in org.jgroups that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	View	A view is a local representation of the current membership of a group.

Fields in org.jgroups declared as Address

Modifier and Type	Field	Description
protected Address	ViewId.creator
protected Address	BaseMessage.dest
protected Address	JChannel.local_addr
protected final Address	UnreachableException.member
protected Address[]	View.members	An array containing all the members of the view.
static final Address	Global.NULL_ADDRESS
protected Address	BatchMessage.orig_src
protected Address	BaseMessage.sender

Fields in org.jgroups with type parameters of type Address

Modifier and Type	Field	Description
protected final List<Address>	Membership.members

Methods in org.jgroups that return Address

Modifier and Type	Method	Description
Address	JChannel.address()
default Address	Message.dest()
protected Address	JChannel.determineCoordinator()
static Address[][]	View.diff(View from, View to)	Returns the difference between 2 views from and to.
Address	Membership.elementAt(int index)	Returns the component at the specified index
protected Address	JChannel.generateAddress(String name)
protected Address	MergeView.get(int index)
Address	JChannel.getAddress()
Address	View.getCoord()
Address	View.getCreator()	Returns the creator of this view if this view was created with the empty constructur, null will be returned
Address	ViewId.getCreator()	Returns the address of the member that issued this view
Address	BaseMessage.getDest()
Address	Message.getDest()	Returns the destination address to send the message to.
Address	Membership.getFirst()
Address[]	View.getMembersRaw()	Returns the underlying array.
Address	Membership.getNext(Address mbr)	Returns the members next to mbr.
Address	BatchMessage.getOrigSender()
Address	Membership.getPrevious(Address mbr)	Returns the members to the left of mbr
Address	BaseMessage.getSrc()
Address	Message.getSrc()	Returns the address of the sender
Address	Membership.nextCoord()
default Address	Message.src()

Methods in org.jgroups that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	Membership.getMembers()	Returns a copy (clone) of the members in this membership.
List<Address>	View.getMembers()	Returns the member list
Iterator<Address>	View.iterator()
static List<Address>	View.leftMembers(View one, View two)	Returns a list of members which left from view one to two
static List<Address>	View.newMembers(View old, View new_view)

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method	Description
Membership	Membership.add(Address new_member)	Adds a new member to this membership.
Membership	Membership.add(Address... mbrs)
int	NullAddress.compareTo(Address that)
JChannel	JChannel.connect(String cluster_name, Address target, long timeout)	Joins the cluster and gets the state from a specified state provider.
boolean	Membership.contains(Address member)	Returns true if the provided member belongs to this membership
boolean	View.containsMember(Address mbr)	Returns true if this view contains a certain member
boolean	View.containsMembers(Address... mbrs)	Returns true if all mbrs are elements of this view, false otherwise
static View	View.create(Address coord, long id, Collection<Address> members)
static View	View.create(Address coord, long id, Address... members)
default Message	Message.dest(Address new_dest)
protected int	MergeView.get(Address member)
Address	Membership.getNext(Address mbr)	Returns the members next to mbr.
Address	Membership.getPrevious(Address mbr)	Returns the members to the left of mbr
JChannel	JChannel.getState(Address target, long timeout)	Retrieves the full state from the target member. The state transfer is initiated by invoking getState() on this channel.
boolean	Membership.isCoord(Address mbr)
static String	View.printDiff(Address[][] diff)
Membership	Membership.remove(Address old_member)	Removes a member from the membership.
JChannel	JChannel.send(Address dst, byte[] buf)	Sends a message.
JChannel	JChannel.send(Address dst, byte[] buf, int offset, int length)	Sends a message to a destination.
JChannel	JChannel.send(Address dst, Object obj)	Helper method to create a Message with given parameters and invoke JChannel.send(Message).
Message	BaseMessage.setDest(Address new_dest)
Message	Message.setDest(Address new_dest)	Sets the destination address to send the message to.
UpHandler	UpHandler.setLocalAddress(Address a)
BatchMessage	BatchMessage.setOrigSender(Address s)
Message	BaseMessage.setSrc(Address new_src)
Message	Message.setSrc(Address new_src)	Sets the address of the sender of this message
int	BaseMessage.sizeNoAddrs(Address src)
int	Message.sizeNoAddrs(Address src)	Returns the exact size of the marshalled message without destination (and possibly source) address
default Message	Message.src(Address new_src)
void	BaseMessage.writeToNoAddrs(Address src, DataOutput out)
void	Message.writeToNoAddrs(Address src, DataOutput out)	Writes the message to an output stream excluding the destination (and possibly source) address

Method parameters in org.jgroups with type arguments of type Address

Modifier and Type	Method	Description
Membership	Membership.add(Collection<Address> v)	Adds a list of members to this membership
static View	View.create(Address coord, long id, Collection<Address> members)
Membership	Membership.merge(Collection<Address> new_mems, Collection<Address> suspects)	Merges membership with the new members and removes suspects.
Membership	Membership.remove(Collection<Address> v)	Removes all the members contained in v from this membership
Membership	Membership.retainAll(Collection<Address> v)
Membership	Membership.set(Collection<Address> v)	Clears the membership and adds all members of v This method will clear out all the old members of this membership by invoking the Clear method.

Constructors in org.jgroups with parameters of type Address

Modifier	Constructor	Description
	BaseMessage(Address dest)	Constructs a message given a destination address
	BatchMessage(Address dest, int capacity)
	BatchMessage(Address dest, Address src, Message[] msgs, int index)
	BytesMessage(Address dest)	Constructs a message given a destination address
	BytesMessage(Address dest, byte[] array)	Constructs a message given a destination and source address and the payload byte array
	BytesMessage(Address dest, byte[] array, int offset, int length)	Constructs a message.
	BytesMessage(Address dest, Object obj)	Constructs a message given a destination and source address and the payload object
	BytesMessage(Address dest, ByteArray array)
	CompositeMessage(Address dest)
	CompositeMessage(Address dest, Collection<Message> messages)
	CompositeMessage(Address dest, Message... messages)
	EmptyMessage(Address dest)
	LongMessage(Address dest, long v)
	Membership(Address... initial_members)
	MergeView(Address creator, long id, List<Address> members, List<View> subgroups)	Creates a new view
	MergeView(ViewId view_id, Address[] members, List<View> subgroups)
	NioMessage(Address dest)	Constructs a message given a destination address
	NioMessage(Address dest, ByteBuffer buf)	Constructs a message given a destination and source address and the payload byte buffer
	ObjectMessage(Address dest)	Constructs a message given a destination address
	ObjectMessage(Address dest, Object obj)	Constructs a message given a destination address and the payload object
	ObjectMessage(Address dest, SizeStreamable obj)	Constructs a message given a destination address and the payload object
	UnreachableException(String msg, Address member)
	UnreachableException(Address member)
	View(Address creator, long id, List<Address> members)	Creates a new view
	View(ViewId view_id, Address[] members)	Creates a new view.
	ViewId(Address creator)	Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
	ViewId(Address creator, long id)	Creates a ViewID with the coordinator address and the given Lamport timestamp.

Constructor parameters in org.jgroups with type arguments of type Address

Modifier	Constructor	Description
	Membership(Collection<Address> initial_members)	Creates a Membership with a given initial members.
	MergeView(Address creator, long id, List<Address> members, List<View> subgroups)	Creates a new view
	MergeView(ViewId view_id, List<Address> members, List<View> subgroups)	Creates a new merge view
	View(Address creator, long id, List<Address> members)	Creates a new view
	View(ViewId view_id, Collection<Address> members)	Creates a new view

Uses of Address in org.jgroups.admin

Fields in org.jgroups.admin with type parameters of type Address

Modifier and Type	Field	Description
protected Map<Address,View>	PartitionHandler.ViewInfo.views

Methods in org.jgroups.admin that return Address

Modifier and Type	Method	Description
Address	TwoPhaseCommit.dest()	Returns the value of the dest record component.
protected static Address	PartitionHandler.getByValue(Map<Address,String> cache, String name)

Methods in org.jgroups.admin that return types with arguments of type Address

Modifier and Type	Method	Description
protected List<Address>	PartitionHandler.getMembers(String view)
List<Address>	TwoPhaseCommit.targets()	Returns the value of the targets record component.

Methods in org.jgroups.admin with parameters of type Address

Modifier and Type	Method	Description
boolean	SwitchAdminHandler.handleConnect(String s, Address sender)	Connects the channel and waits for expected_members.
boolean	SwitchAdminHandler.handleCreateNewStack(String s, Address sender)	Gets the version and config.
void	TwoPhaseCommit.handleResponse(Address sender, String rsp)
void	AdminClient.receive(Address sender, byte[] buf, int offset, int length)
void	AdminClient.receive(Address sender, DataInput in, int length)
protected void	Admin.sendAdminRequest(Address dest, String key, String args)
String	ProbeAdminHandler.sendProbeRequest(Address dest, String cmd)	Sends a probe command to all members of the current cluster.

Method parameters in org.jgroups.admin with type arguments of type Address

Modifier and Type	Method	Description
protected static Address	PartitionHandler.getByValue(Map<Address,String> cache, String name)

Constructors in org.jgroups.admin with parameters of type Address

Modifier	Constructor	Description
	TwoPhaseCommit(String key, String name, AdminHandler admin, Address dest, List<Address> targets, String prepare, String rollback, String commit, long timeout)
	TwoPhaseCommit(String key, String name, AdminHandler admin, Address dest, List<Address> targets, String prepare, String rollback, String commit, long timeout, ResponseCollector<String> rsps)	Creates an instance of a TwoPhaseCommit record class.

Constructor parameters in org.jgroups.admin with type arguments of type Address

Modifier	Constructor	Description
	TwoPhaseCommit(String key, String name, AdminHandler admin, Address dest, List<Address> targets, String prepare, String rollback, String commit, long timeout)
	TwoPhaseCommit(String key, String name, AdminHandler admin, Address dest, List<Address> targets, String prepare, String rollback, String commit, long timeout, ResponseCollector<String> rsps)	Creates an instance of a TwoPhaseCommit record class.
	ViewInfo(Map<Address,View> views)

Uses of Address in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Address

Modifier and Type	Field	Description
Address[]	RequestCorrelator.MultiDestinationHeader.exclusion_list	Contains a list of members who should not receive the request (others will drop).
protected Address[]	RequestOptions.exclusion_list	A list of members which should be excluded from a call
protected Address	MessageDispatcher.local_addr
protected Address	RequestCorrelator.local_addr	The address of this group member
protected final Address	UnicastRequest.target

Fields in org.jgroups.blocks with type parameters of type Address

Modifier and Type	Field	Description
protected Collection<Address>	MessageDispatcher.members

Methods in org.jgroups.blocks that return Address

Modifier and Type	Method	Description
Address[]	RequestOptions.exclusionList()
Address[]	RequestOptions.getExclusionList()
Address	ReplCache.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()

Methods in org.jgroups.blocks that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	ReplicatedTree.getMembers()
List<Address>	ReplCache.ConsistentHashFunction.hash(K key, short replication_count)
List<Address>	ReplCache.HashFunction.hash(K key, short replication_count)	Function that, given a key and a replication count, returns replication_count number of different addresses of nodes.

Methods in org.jgroups.blocks with parameters of type Address

Modifier and Type	Method	Description
<T> T	RpcDispatcher.callRemoteMethod(Address dest, String meth, Object[] args, Class<?>[] types, RequestOptions opts)	Invokes a method in a cluster member and - if blocking - returns the result
<T> T	RpcDispatcher.callRemoteMethod(Address dest, MethodCall call, RequestOptions options)	Invokes a method in a cluster member and - if blocking - returns the result
<T> CompletableFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions opts)	Invokes a method in a cluster member and - if blocking - returns the result
protected static RequestCorrelator	MessageDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)
RequestOptions	RequestOptions.exclusionList(Address... mbrs)
boolean	RspFilter.isAcceptable(Object response, Address sender)	Determines whether a response from a given sender should be added to the response list of the request
void	GroupRequest.memberUnreachable(Address mbr)
abstract void	Request.memberUnreachable(Address mbr)
void	UnicastRequest.memberUnreachable(Address mbr)
void	GroupRequest.receiveResponse(Object response_value, Address sender, boolean is_exception)	Callback (called by RequestCorrelator or Transport).
abstract void	Request.receiveResponse(Object response_value, Address sender, boolean is_exception)
void	UnicastRequest.receiveResponse(Object response_value, Address sender, boolean is_exception)	Callback (called by RequestCorrelator or Transport).
<T extends Protocol> T	MessageDispatcher.ProtocolAdapter.setAddress(Address addr)
UpHandler	MessageDispatcher.ProtocolAdapter.setLocalAddress(Address a)
RequestCorrelator	RequestCorrelator.setLocalAddress(Address a)
void	RequestCorrelator.setMemberUnreachable(Address mbr)
protected boolean	GroupRequest.setSuspected(Address mbr)
protected boolean	RequestCorrelator.skip(RequestCorrelator.Header hdr, Address sender)

Method parameters in org.jgroups.blocks with type arguments of type Address

Modifier and Type	Method	Description
<T> RspList<T>	RpcDispatcher.callRemoteMethods(Collection<Address> dests, String method_name, Object[] args, Class<?>[] types, RequestOptions options)	Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> RspList<T>	RpcDispatcher.callRemoteMethods(Collection<Address> dests, MethodCall method_call, RequestOptions opts)	Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> CompletableFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall call, RequestOptions options)	Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
protected <T> GroupRequest<T>	MessageDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
<T> RspList<T>	MessageDispatcher.castMessage(Collection<Address> dests, Message msg, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
<T> CompletableFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
void	ReplCache.ConsistentHashFunction.installNodes(List<Address> new_nodes)
void	ReplCache.HashFunction.installNodes(List<Address> nodes)	When the topology changes, this method will be called.
protected void	RequestCorrelator.sendAnycastRequest(Message req, Collection<Address> dest_mbrs)
<T> void	RequestCorrelator.sendMulticastRequest(Collection<Address> dest_mbrs, Message msg, Request<T> req, RequestOptions opts)	Sends a request to a group.
protected void	GroupRequest.sendRequest(Message msg, Collection<Address> targetMembers)
protected <X extends MessageDispatcher> X	MessageDispatcher.setMembers(List<Address> new_mbrs)
void	ReplicatedHashMap.Notification.viewChange(View view, List<Address> mbrs_joined, List<Address> mbrs_left)

Constructors in org.jgroups.blocks with parameters of type Address

Modifier	Constructor	Description
	MultiDestinationHeader(byte type, long id, short corr_id, Address[] exclusion_list)
	RequestCorrelator(Protocol down_prot, RequestHandler handler, Address local_addr)	Constructor.
	UnicastRequest(RequestCorrelator corr, Address target, RequestOptions options)

Constructor parameters in org.jgroups.blocks with type arguments of type Address

Modifier	Constructor	Description
	GroupRequest(RequestCorrelator corr, Collection<Address> targets, RequestOptions options)

Uses of Address in org.jgroups.blocks.cs

Fields in org.jgroups.blocks.cs declared as Address

Modifier and Type	Field	Description
protected Address	BaseServer.local_addr
protected Address	Connection.peer_addr
protected Address	NioClient.remote_addr
protected Address	TcpClient.remote_addr

Fields in org.jgroups.blocks.cs with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<Address, Connection>	BaseServer.conns
protected final Map<Address,Lock>	BaseServer.locks

Methods in org.jgroups.blocks.cs that return Address

Modifier and Type	Method	Description
Address	BaseServer.localAddress()
protected static Address	BaseServer.localAddress(InetAddress bind_addr, int local_port, InetAddress external_addr, int external_port)
Address	Client.localAddress()
abstract Address	Connection.localAddress()
Address	NioConnection.localAddress()
Address	TcpConnection.localAddress()
Address	Connection.peerAddress()
Address	NioConnection.PeerAddressReader.readPeerAddress(SocketChannel ch)
protected Address	TcpConnection.readPeerAddress(Socket client_sock)	Reads the peer's address.
Address	Client.remoteAddress()
Address	NioClient.remoteAddress()
Address	TcpClient.remoteAddress()

Methods in org.jgroups.blocks.cs with parameters of type Address

Modifier and Type	Method	Description
boolean	BaseServer.closeConnection(Address addr)
boolean	BaseServer.closeConnection(Address addr, boolean notify)
abstract void	Connection.connect(Address dest)
void	NioConnection.connect(Address dest)
protected void	NioConnection.connect(Address dest, boolean send_local_addr)
void	TcpConnection.connect(Address dest)
protected void	TcpConnection.connect(Address dest, boolean send_local_addr)
boolean	BaseServer.connectionEstablishedTo(Address address)
protected abstract Connection	BaseServer.createConnection(Address dest)	Creates a new connection object to target dest, but doesn't yet connect it
protected NioConnection	NioBaseServer.createConnection(Address dest)
protected TcpConnection	TcpBaseServer.createConnection(Address dest)
void	BaseServer.flush(Address dest)
Connection	BaseServer.getConnection(Address dest)	Creates a new connection to dest, or returns an existing one
protected Lock	BaseServer.getLock(Address dest)
void	BaseServer.handleIncomingConnection(Address peer_addr, Connection conn)
void	BaseServer.handleOutgoingConnection(Address dest, Connection conn)
protected void	TcpConnection.handshake(SSLSocket ssl, Address dest, long timeout)	Performs the TLS handshake, bounded by timeout ms, which is what is left of sock_conn_timeout after the TCP connect, so that the connection setup as a whole is bounded by it.
boolean	BaseServer.hasConnection(Address address)
void	BaseServer.receive(Address sender, byte[] data, int offset, int length)	Called by a Connection implementation when a message has been received.
void	BaseServer.receive(Address sender, DataInput in, int len)
void	BaseServer.receive(Address sender, ByteBuffer buf)	Called by a Connection implementation when a message has been received
void	Receiver.receive(Address sender, byte[] buf, int offset, int length)	Delivers a message from a given sender to the application
default void	Receiver.receive(Address sender, DataInput in, int length)	Receive data from the given sender
default void	Receiver.receive(Address sender, ByteBuffer buf)	Delivers a message from a given sender to the application
void	ReceiverAdapter.receive(Address sender, byte[] buf, int offset, int length)
void	BaseServer.removeConnectionIfPresent(Address address, Connection conn)	Only removes the connection if conns.get(address) == conn
void	BaseServer.replaceConnection(Address address, Connection conn)
void	BaseServer.send(Address dest, byte[] data, int offset, int length)
void	BaseServer.send(Address dest, ByteBuffer buf)
void	NioClient.send(Address dest, byte[] data, int offset, int length)
void	NioClient.send(Address dest, ByteBuffer buf)
void	TcpClient.send(Address dest, byte[] data, int offset, int length)
void	TcpClient.send(Address dest, ByteBuffer buf)
protected void	NioConnection.sendLocalAddress(Address local_addr)
protected void	TcpConnection.sendLocalAddress(Address local_addr)	Send the cookie first, then our port number.
protected <T> boolean	BaseServer.validateArgs(Address dest, T buffer)

Method parameters in org.jgroups.blocks.cs with type arguments of type Address

Modifier and Type	Method	Description
void	BaseServer.forAllConnections(BiConsumer<Address, Connection> c)
void	BaseServer.retainAll(Collection<Address> current_mbrs)
void	BaseServer.retainAll(Collection<Address> current_mbrs, Predicate<PhysicalAddress> is_mbr)	Removes all connections which are not in current_mbrs

Constructors in org.jgroups.blocks.cs with parameters of type Address

Modifier	Constructor	Description
	NioConnection(Address peer_addr, NioBaseServer server)	Creates a connection stub and binds it, use NioConnection.connect(Address) to connect
	TcpConnection(Address peer_addr, TcpBaseServer server)	Creates a connection to a remote peer, use TcpConnection.connect(Address) to connect
	TcpConnectionNonBlocking(Address peer_addr, TcpBaseServer server, int max_size)	Deprecated, for removal: This API element is subject to removal in a future version.

Uses of Address in org.jgroups.demos

Methods in org.jgroups.demos with parameters of type Address

Modifier and Type	Method	Description
void	Topology.addNode(Address member)
void	PubClient.receive(Address sender, byte[] buf, int offset, int length)
void	PubClient.receive(Address sender, DataInput in, int length)
void	PubClient.receive(Address sender, ByteBuffer buf)
void	PubServer.receive(Address sender, byte[] buf, int offset, int length)
void	PubServer.receive(Address sender, DataInput in, int length)
void	PubServer.receive(Address sender, ByteBuffer buf)

Method parameters in org.jgroups.demos with type arguments of type Address

Modifier and Type	Method	Description
void	ReplicatedHashMapDemo.viewChange(View view, List<Address> new_mbrs, List<Address> old_mbrs)

Uses of Address in org.jgroups.fork

Methods in org.jgroups.fork with parameters of type Address

Modifier and Type	Method	Description
ForkChannel	ForkChannel.connect(String cluster_name, Address target, long timeout)
ForkChannel	ForkChannel.getState(Address target, long timeout)
protected ForkChannel	ForkChannel.setLocalAddress(Address local_addr)
void	ForkProtocolStack.setLocalAddress(Address addr)

Uses of Address in org.jgroups.protocols

Classes in org.jgroups.protocols that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	ReliableUnicast	Base class for reliable unicast protocols
class	UNICAST3	Reliable unicast protocol using a combination of positive and negative acks.

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
protected Address	COUNTER.coord	The address of the cluster coordinator.
protected Address	SEQUENCER.coord
protected Address	SEQUENCER2.coord
protected Address	Discovery.current_coord
protected Address	FD_SOCK2.PingDest.dest
protected Address	ASYM_ENCRYPT.key_server_addr
protected Address	PerDestinationBundler.local_addr
protected Address	PDC.Mapping.logical_addr
protected Address	FD_SOCK.FdHeader.mbr
protected final Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected static final Address	PerDestinationBundler.NULL
protected static final Address	STATS.NULL_DEST
protected Address	DAISYCHAIN.DaisyHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD_SOCK.ping_dest
protected Address	NakAckHeader.sender
protected Address	PingData.sender
protected Address	EncryptHeader.server
protected Address	FD_SOCK2.FdHeader.srv
protected final Address	RSVP.Entry.target

Fields in org.jgroups.protocols with type parameters of type Address

Modifier and Type	Field	Description
protected List<Address>	COUNTER.backup_coords	Backup coordinators.
protected LazyRemovalCache<Address, IpAddress>	FD_SOCK.cache	Cache of member addresses and their ServerSocket addresses
protected final ConcurrentMap<Address, PhysicalAddress>	PDC.cache
protected AgeOutCache<Address>	ReliableUnicast.cache
protected AgeOutCache<Address>	UNICAST3.cache
protected final Map<Address, MessageBatch>	ReliableMulticast.cached_batches
protected final Map<Address, MessageBatch>	ReliableUnicast.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841).
protected final Map<Address, MessageBatch>	UNICAST3.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841)
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.curr_mbrs
protected final ConcurrentMap<Address, BoundedHashMap<Long,Long>>	SEQUENCER.delivery_table
protected final Map<Address, PerDestinationBundler.SendBuffer>	PerDestinationBundler.dests
protected final Map<Address,String>	STOMP.endpoints
protected final ConcurrentMap<Address, ConcurrentMap<Long, FRAG2.FragEntry>>	FRAG2.fragment_list
protected final ConcurrentMap<Address, ConcurrentMap<Integer, FRAG3.FragEntry>>	FRAG3.fragment_list
protected final Function<Address, List<Message>>	BaseBundler.FUNC
protected static final Function<AsciiString, Map<Address, SHARED_LOOPBACK>>	SHARED_LOOPBACK.FUNC
protected static final Function<Address,MsgStats>	STATS.FUNC
protected final Promise<Map<Address, IpAddress>>	FD_SOCK.get_cache_promise	Used to rendezvous on GET_CACHE and GET_CACHE_RSP
protected final Set<Address>	BARRIER.holes
protected final Map<InetAddress, List<Address>>	FD_HOST.hosts	Map of hosts and their cluster members, updated on view changes.
protected final Set<Address>	DISCARD.ignoredMembers
protected ExpiryCache<Address>	ReliableUnicast.last_sync_sent	Keep track of when a SEND_FIRST_SEQNO message was sent to a given sender
protected ExpiryCache<Address>	UNICAST3.last_sync_sent	Keep track of when a SEND_FIRST_SEQNO message was sent to a given sender
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.left_mbrs
protected LazyRemovalCache<Address, PhysicalAddress>	TPConfig.logical_addr_cache	Maintains mappings between logical and physical addresses.
protected Set<Address>	FD_SOCK.FdHeader.mbrs
protected Collection<Address>	FD_SOCK2.FdHeader.mbrs
protected Collection<? extends Address>	PingData.mbrs
protected final Map<Address,Message>	BARRIER.mcast_queue
protected List<Address>	BaseBundler.members
protected final Collection<Address>	DISCARD.members
protected final List<Address>	FailureDetection.members
protected final List<Address>	FD_HOST.members
protected List<Address>	FD_SOCK.members
protected final List<Address>	FRAG.members
protected final List<Address>	FRAG2.members
protected final List<Address>	FRAG3.members
protected List<Address>	ReliableMulticast.members
protected List<Address>	ReliableUnicast.members
protected List<Address>	RSVP.members
protected final Set<Address>	TPConfig.members
protected List<Address>	UNICAST3.members
protected Map<Address, BATCH2.Buffer>	BATCH2.msgMap
protected final Map<Address, List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.new_mbrs
protected final Map<Address, List<Message>>	MAKE_BATCH.oob_map_mcast
protected final Map<Address, List<Message>>	MAKE_BATCH.oob_map_ucast
protected final List<Address>	FD_SOCK.pingable_mbrs
protected static final LazyRemovalCache.Printable<Address, LazyRemovalCache.Entry<PhysicalAddress>>	TPConfig.print_function
protected final Map<Address,byte[]>	ASYM_ENCRYPT.pub_map
protected final Map<Address,Credit>	FlowControl.received	Keeps track of credits per member at the receiver.
protected final ConcurrentMap<Address,MsgStats>	STATS.received	Maintains stats per receiver
protected final Map<Address, ReliableUnicast.ReceiverEntry>	ReliableUnicast.recv_table
protected final Map<Address, UNICAST3.ReceiverEntry>	UNICAST3.recv_table
protected final Map<Address, List<Message>>	MAKE_BATCH.reg_map_mcast
protected final Map<Address, List<Message>>	MAKE_BATCH.reg_map_ucast
protected static final Map<AsciiString, Map<Address, SHARED_LOOPBACK>>	SHARED_LOOPBACK.routing_table	Map of cluster names and address-protocol mappings.
protected final Map<Address, ReliableUnicast.SenderEntry>	ReliableUnicast.send_table
protected final Map<Address, UNICAST3.SenderEntry>	UNICAST3.send_table
protected final ConcurrentMap<Address,MsgStats>	STATS.sent	Maintains stats per target destination
protected final Map<Address, ? extends Credit>	UFC.sent	Map: keys are members, values are credits left.
protected static final ThreadLocal<Address>	ASYM_ENCRYPT.srv_addr
protected final Map<Address,Long>	ReliableMulticast.stable_xmit_map
protected SuppressLog<Address>	BaseBundler.suppress_log
protected SuppressLog<Address>	TPConfig.suppress_log_different_cluster	Log to suppress identical warnings for messages from members in different clusters
protected SuppressLog<Address>	TPConfig.suppress_log_different_version	Log to suppress identical warnings for messages from members with different (incompatible) versions
protected SuppressLog<Address>	ReliableMulticast.suppress_log_non_member	Log to suppress identical warnings for messages from non-members
protected final BoundedList<Tuple<Address,Long>>	FailureDetection.suspect_history
protected final Set<Address>	FailureDetection.suspected_mbrs
protected final Set<Address>	FD_HOST.suspected_mbrs
protected final Set<Address>	FD_SOCK.suspected_mbrs
protected final Set<Address>	FD_SOCK.BroadcastTask.suspects
protected final Set<Address>	FD_SOCK2.BroadcastTask.suspects
protected final ConcurrentMap<Address,Long>	FD_ALL.timestamps
protected final Map<Address, AtomicBoolean>	FD_ALL2.timestamps
protected final Map<Address, FD_ALL3.Bitmap>	FD_ALL3.timestamps
protected final Map<Address,Message>	BARRIER.ucast_queue
protected final Map<Address,ViewId>	MERGE3.views
protected ExpiryCache<Address>	TPConfig.who_has_cache	Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after who_has_cache_timeout ms
protected final Map<Address, ReliableMulticast.Entry>	ReliableMulticast.xmit_table	Map to store sent and received messages (keyed by sender)
protected final Map<Address,Long>	ReliableMulticast.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539)
protected final Map<Address,Long>	ReliableUnicast.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per member (applicable only for received messages (ReceiverEntry)): https://issues.redhat.com/browse/JGRP-1539
protected final Map<Address,Long>	UNICAST3.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per member (applicable only for received messages (ReceiverEntry)): https://issues.redhat.com/browse/JGRP-1539

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method	Description
protected Address	FD_SOCK2.PingDest.dest()
protected Address	FD_SOCK.determineCoordinator()
protected Address	FD_SOCK.determinePingDest()
Address	PingData.getAddress()
protected static Address	ASYM_ENCRYPT.getCachedServerAddress()
Address	SEQUENCER.getCoordinator()
Address	SEQUENCER2.getCoordinator()
Address	PDC.Mapping.getLogicalAddr()
Address	DAISYCHAIN.DaisyHeader.getOriginalSender()
Address	PDC.Mapping.getPhysicalAddr()
Address	NakAckHeader.getSender()
Address	PingData.getSender()
Address	DH_KEY_EXCHANGE.getServerLocation()
abstract Address	KeyExchange.getServerLocation()	Returns the address of the server, e.g.
Address	SSL_KEY_EXCHANGE.getServerLocation()
Address	ASYM_ENCRYPT.keyServerAddr()
Address	EncryptHeader.server()
Address	FD_SOCK2.Request.suspect()	Returns the value of the suspect record component.
Address	VERIFY_SUSPECT.Entry.suspect()	Returns the value of the suspect record component.
Address	VERIFY_SUSPECT2.Entry.suspect()	Returns the value of the suspect record component.

Methods in org.jgroups.protocols that return types with arguments of type Address

Modifier and Type	Method	Description
protected Map<ViewId, Set<Address>>	MERGE3.convertViews()
AgeOutCache<Address>	ReliableUnicast.getAgeOutCache()
AgeOutCache<Address>	UNICAST3.getAgeOutCache()
LazyRemovalCache<Address, PhysicalAddress>	TPConfig.getLogicalAddressCache()
protected abstract Map<Address,?>	FailureDetection.getTimestamps()
protected Map<Address,?>	FD_ALL.getTimestamps()
protected Map<Address,?>	FD_ALL2.getTimestamps()
protected Map<Address,?>	FD_ALL3.getTimestamps()
Collection<? extends Address>	PingData.mbrs()
Map<Address,Credit>	FlowControl.received()
Map<Address, ? extends Credit>	UFC.sent()
protected Map<Address, IpAddress>	FD_SOCK.unmarshal(byte[] buffer, int offset, int length)
protected Map<Address,byte[]>	ASYM_ENCRYPT.unserializeKeys(Address sender, byte[] buf, int offset, int length)

Methods in org.jgroups.protocols with parameters of type Address

Modifier and Type	Method	Description
ReliableUnicast.ReceiverEntry	ReliableUnicast._getReceiverEntry(Address sender, long seqno, boolean first, short conn_id, Address real_dest)
ReliableUnicast.SenderEntry	ReliableUnicast._getSenderEntry(Address dest)
protected void	RSVP.Entry.ack(Address member)
void	COUNTER.ReconciliationTask.add(COUNTER.ReconcileResponse rsp, Address sender)
protected void	LOCAL_PING.addAddressToLocalCache(Address addr, PhysicalAddress phys_addr)
protected boolean	Discovery.addDiscoveryResponseToCaches(Address mbr, String logical_name, PhysicalAddress physical_addr)
DISCARD	DISCARD.addIgnoredMembers(Address... senders)
DISCARD	DISCARD.addIgnoreMember(Address sender)	Messages from this sender will get dropped
protected void	MERGE3.addInfo(Address sender, ViewId view_id, String logical_name, PhysicalAddress physical_addr)	Adds received INFO to views hashmap
protected Message	ASYM_ENCRYPT.addKeysToMessage(Message msg, boolean copy, boolean add_secret_keys, Address serialize_only)	Adds the public and/or encrypted shared keys to the payload of msg.
protected void	ReliableUnicast.addMessage(ReliableUnicast.ReceiverEntry entry, Address sender, long seqno, Message msg)
protected void	UNICAST3.addMessage(UNICAST3.ReceiverEntry entry, Address sender, long seqno, Message msg)
protected ASYM_ENCRYPT.Processing	ASYM_ENCRYPT.addMetadata(Message msg, boolean add_secret_keys, Address include_secret_key_only_for, boolean attach_fetch_key_header)
boolean	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected boolean	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr, boolean overwrite)
protected void	ReliableUnicast.addQueuedMessages(Address sender, ReliableUnicast.ReceiverEntry entry, Collection<Message> queued_msgs)
protected void	UNICAST3.addQueuedMessages(Address sender, UNICAST3.ReceiverEntry entry, Collection<Message> queued_msgs)
protected static String	Discovery.addressAsString(Address address)
protected static String	PDC.addressAsString(Address address)
protected static String	FILE_PING.addressToFilename(Address mbr)
protected void	FD_SOCK.BroadcastTask.addSuspectedMember(Address mbr)	Adds a suspected member.
protected long	FlowControl.adjustCredit(Map<Address,Credit> map, Address sender, int length)	Check whether sender has enough credits left.
protected void	SEQUENCER.broadcast(Message msg, boolean copy, Address original_sender, long seqno, boolean resend)
protected void	FD_SOCK.broadcastSuspectMessage(Address suspected_mbr)	Sends a SUSPECT message to all group members.
protected void	FD_SOCK.broadcastUnuspectMessage(Address mbr)
protected void	FD_SOCK2.broadcastUnuspectMessage(Address mbr)
protected static void	ASYM_ENCRYPT.cacheServerAddress(Address srv)
protected boolean	SEQUENCER.canDeliver(Address sender, long seqno)	Checks if seqno has already been received from sender.
void	FRAG2.clearFragmentsFor(Address mbr)
void	FRAG3.clearFragmentsFor(Address mbr)
void	ReliableUnicast.closeConnection(Address mbr)	Removes and resets from connection table (which is already locked).
void	UNICAST3.closeConnection(Address mbr)	Removes and resets from connection table (which is already locked).
void	ReliableUnicast.closeReceiveConnection(Address mbr)
void	UNICAST3.closeReceiveConnection(Address mbr)
void	ReliableUnicast.closeSendConnection(Address mbr)
void	UNICAST3.closeSendConnection(Address mbr)
protected ReliableUnicast.ReceiverEntry	ReliableUnicast.compareConnIds(short other, short mine, boolean first, ReliableUnicast.ReceiverEntry e, Address sender, long seqno, Address real_dest)
protected boolean	FD_SOCK2.connectTo(Address new_ping_dest, Membership mbrs)
protected boolean	FD_SOCK2.connectTo(IpAddress dest, Address logical_addr)
protected void	FD_SOCK2.connectToNextPingDest(Address already_suspect)
protected boolean	JDBC_PING.contains(String cluster_name, Address addr)
protected ReliableUnicast.ReceiverEntry	ReliableUnicast.createReceiverEntry(Address sender, long seqno, short conn_id, Address dest)
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id, Address dest)
protected SSLSocket	SSL_KEY_EXCHANGE.createSocketTo(Address target)
static NakAckHeader	NakAckHeader.createXmitRequestHeader(Address orginal_sender)
protected void	JDBC_PING2.delete(String clustername, Address addressToDelete)
protected void	JDBC_PING2.delete(Connection conn, String clustername, Address addressToDelete)
protected void	ReliableMulticast.deliver(Message msg, Address sender, long seqno, ReliableMulticast.Entry entry, String error_msg)
protected void	ReliableUnicast.deliverBatch(MessageBatch batch, ReliableUnicast.Entry entry, Address original_dest)
protected void	ReliableUnicast.deliverMessage(Message msg, Address sender, long seqno)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
protected Message	SERIALIZE.deserialize(Address sender, byte[] buf, int offset, int length)
protected FD_SOCK2.PingDest	FD_SOCK2.PingDest.dest(Address d)
protected boolean	FD_SOCK2.PingDest.destChanged(Address a)
void	Discovery.discoveryRequestReceived(Address sender, String logical_name, PhysicalAddress physical_addr)
void	TCPPING.discoveryRequestReceived(Address sender, String logical_name, PhysicalAddress physical_addr)
void	TP.doSend(ByteBuffer buf, Address dest)
void	COUNTER.AddAndGetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.CompareAndSetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.DeleteRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.GetOrCreateRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.ReconcileRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.Request.execute(COUNTER protocol, Address sender)
void	COUNTER.ResendPendingRequests.execute(COUNTER protocol, Address sender)
void	COUNTER.SetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.UpdateRequest.execute(COUNTER protocol, Address sender)
void	ReliableUnicast.expired(Address key)	Called by AgeOutCache, to removed expired connections
void	UNICAST3.expired(Address key)	Called by AgeOutCache, to removed expired connections
protected IpAddress	FD_SOCK.fetchPingAddress(Address mbr)	Attempts to obtain the ping_addr first from the cache, then by unicasting q request to mbr, then by multicasting a request to all members.
void	DH_KEY_EXCHANGE.fetchSecretKeyFrom(Address target)
abstract void	KeyExchange.fetchSecretKeyFrom(Address target)	Needs to fetch the secret key from a given destination (usually the key server).
void	SSL_KEY_EXCHANGE.fetchSecretKeyFrom(Address target)
protected void	SEQUENCER.flush(Address new_coord)
<T extends Buffer<Message>> T	ReliableMulticast.getBuf(Address sender)	Returns the receive window for sender; only used for testing.
Digest	ReliableMulticast.getDigest(Address mbr)
protected ReliableMulticast.Entry	ReliableMulticast.getEntry(Address sender)
protected InetAddress	FD_HOST.getHostFor(Address mbr)
long	NAKACK4.getNumUnackedMessages(Address dest)
int	ReliableUnicast.getNumUnackedMessages(Address dest)
int	UNICAST3.getNumUnackedMessages(Address dest)
protected PhysicalAddress	FD_HOST.getPhysicalAddress(Address logical_addr)
protected List<IpAddress>	FD_SOCK2.getPhysicalAddresses(Address a)	Returns the physical addresses for in range [a+offset..a+offset+port_range
PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
long	FlowControl.getReceiverCreditsFor(Address mbr)
protected ReliableUnicast.ReceiverEntry	ReliableUnicast.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id, Address real_dest)
protected UNICAST3.ReceiverEntry	UNICAST3.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id, Address dest)
long	UFC.getSenderCreditsFor(Address mbr)
protected ReliableUnicast.SenderEntry	ReliableUnicast.getSenderEntry(Address dst)
protected UNICAST3.SenderEntry	UNICAST3.getSenderEntry(Address dst)
Table<Message>	UNICAST3.getSendWindow(Address target)	Used for testing only!
protected void	DH_KEY_EXCHANGE.handle(DH_KEY_EXCHANGE.DhHeader hdr, Address sender)
protected Object	FD_SOCK2.handle(FD_SOCK2.FdHeader hdr, Address sender)
protected void	NAKACK4.handleAck(Address sender, long ack)
protected void	ReliableMulticast.handleAck(Address sender, long ack)
protected void	ReliableUnicast.handleAckReceived(Address sender, long seqno, short conn_id, int timestamp)	Add the ACK to hashtable.sender.sent_msgs
protected void	UNICAST3.handleAckReceived(Address sender, long seqno, short conn_id, int timestamp)	Add the ACK to hashtable.sender.sent_msgs
protected void	ReliableUnicast.handleBatchReceived(ReliableUnicast.ReceiverEntry entry, Address sender, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	MFC.handleCredit(Address sender, long increase)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(Map<Address,Credit> map, Address sender, long requested_credits)
protected void	ReliableUnicast.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg)	Check whether the hashtable contains an entry e for sender (create if not).
protected void	UNICAST3.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg)	Check whether the hashtable contains an entry e for sender (create if not).
protected void	ReliableUnicast.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected void	UNICAST3.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected void	Discovery.handleDiscoveryResponse(List<PingData> data, Address sender)
protected void	Discovery.handleDiscoveryResponse(PingData data, Address sender)
protected void	ReliableMulticast.handleHighestSeqno(Address sender, long seqno)	Compares the sender's highest seqno with my highest seqno: if the sender's is higher, ask sender for retransmission
protected void	ReliableUnicast.handleResendingOfFirstMessage(Address sender, int timestamp)	We need to resend the first message with our conn_id
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender, int timestamp)	We need to resend the first message with our conn_id
protected void	COUNTER.handleResponse(org.jgroups.protocols.COUNTER.Response rsp, Address sender)
protected void	RSVP.handleResponse(Address member, short id)
protected void	DH_KEY_EXCHANGE.handleSecretKeyRequest(PublicKey dh_public_key, Address sender)
protected void	DH_KEY_EXCHANGE.handleSecretKeyResponse(PublicKey dh_public_key, byte[] encrypted_secret_key, byte[] version, Address sender)
protected void	ReliableUnicast.handleUpEvent(Address sender, Message msg, UnicastHeader hdr)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
protected void	ReliableMulticast.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender)	Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
protected void	ReliableUnicast.handleXmitRequest(Address sender, SeqnoList missing)
protected void	UNICAST3.handleXmitRequest(Address sender, SeqnoList missing)
boolean	ReliableUnicast.hasSendConnectionTo(Address dest)	Used for testing only
boolean	UNICAST3.hasSendConnectionTo(Address dest)	Used for testing only
protected void	ASYM_ENCRYPT.installPublicKeys(Address sender, byte[] buf, int offset, int length)
protected void	ASYM_ENCRYPT.installSharedGroupKey(Address sender, SecretKey key, byte[] version)
protected boolean	Encrypt.inView(Address sender, String error_msg)
protected boolean	Discovery.isCoord(Address member)
protected boolean	ReliableUnicast.isLocal(Address addr)
protected boolean	UNICAST3.isLocal(Address addr)
boolean	LocalTransport.isLocalMember(Address addr)	Returns true if addr is a local member, false otherwise
protected boolean	ReliableUnicast.isLocalSiteMaster(Address dest)
protected boolean	UNICAST3.isLocalSiteMaster(Address dest)
protected boolean	FD_HOST.isPinger(Address mbr)
ASYM_ENCRYPT	ASYM_ENCRYPT.keyServerAddr(Address ks)
protected void	BaseBundler.loopback(Address dest, Address sender, Iterable<Message> list, int size)
protected void	BaseBundler.loopback(Address dest, Address sender, Message[] list, int len)
protected abstract <T> boolean	FailureDetection.needsToBeSuspected(Address mbr, T value)
protected <T> boolean	FD_ALL.needsToBeSuspected(Address mbr, T value)
protected <T> boolean	FD_ALL2.needsToBeSuspected(Address mbr, T value)
protected <T> boolean	FD_ALL3.needsToBeSuspected(Address mbr, T value)
void	FD_SOCK2.receive(Address sender, byte[] buf, int offset, int length)
void	FD_SOCK2.receive(Address sender, DataInput in, int length)
void	TP.receive(Address sender, byte[] data, int offset, int length)	Subclasses must call this method when a unicast or multicast message has been received
void	TP.receive(Address sender, DataInput in, int ignoredLength)
MsgStats	MsgStats.received(Address dest, int length)
protected static void	SHARED_LOOPBACK.register(AsciiString cluster, Address local_addr, SHARED_LOOPBACK shared_loopback)
protected void	TP.registerLocalAddress(Address addr)	Associates the address with the physical address fetched from the cache
protected void	FILE_PING.remove(String clustername, Address addr)
protected void	JDBC_PING.remove(String clustername, Address addr)
protected void	JDBC_PING2.remove(String clustername, Address addr)
protected void	RACKSPACE_PING.remove(String clustername, Address addr)
protected void	SWIFT_PING.remove(String clustername, Address addr)
protected void	ReliableMulticast.removeAndDeliver(Buffer<Message> win, ReliableMulticast.Entry e, Address sender, boolean loopback, AsciiString cluster)	Efficient way of checking whether another thread is already processing messages from sender.
protected void	ReliableUnicast.removeAndDeliver(ReliableUnicast.Entry entry, Address sender, AsciiString cluster, int min_size)	Try to remove as many messages as possible from the table as pass them up.
protected void	SEQUENCER2.removeAndDeliver(Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(Table<Message> win, Address sender, AsciiString cluster, int min_size)	Try to remove as many messages as possible from the table as pass them up.
protected boolean	FD_SOCK.removeFromPingableMembers(Address mbr)
DISCARD	DISCARD.removeIgnoredMember(Address member)
protected void	TP.removeLogicalAddressFromCache(Address logical_addr)
protected void	PDC.removeNodeFromDisk(Address logical_addr)
void	ReliableUnicast.removeReceiveConnection(Address mbr)
void	UNICAST3.removeReceiveConnection(Address mbr)
void	ReliableUnicast.removeSendConnection(Address mbr)
void	UNICAST3.removeSendConnection(Address mbr)
protected void	FD_SOCK2.BroadcastTask.removeSuspect(Address suspect)
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
protected boolean	VERIFY_SUSPECT2.removeSuspect(Address suspect)
protected void	FD_SOCK.BroadcastTask.removeSuspectedMember(Address suspected_mbr)
void	MFC.replenish(Address mbr, long credits)
protected void	ReliableMulticast.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	ReliableMulticast.retransmit(SeqnoList missing_msgs, Address sender, boolean multicast_xmit_request)
protected void	ReliableUnicast.retransmit(SeqnoList missing, Address sender, Address real_dest)	Sends a retransmit request to the given sender
protected void	UNICAST3.retransmit(SeqnoList missing, Address sender, Address real_dest)	Sends a retransmit request to the given sender
protected void	COUNTER.send(Address dest, ByteArray buffer)
protected void	NAKACK4.sendAck(Address to, Buffer<Message> win)
protected void	ReliableMulticast.sendAck(Address to, Buffer<Message> win)
protected void	ReliableUnicast.sendAck(Address dst, ReliableUnicast.Entry entry, Address real_dest)
protected void	UNICAST3.sendAck(Address dst, long seqno, short conn_id, Address real_dest)
void	ReliableUnicast.sendClose(Address dest, short conn_id)
void	UNICAST3.sendClose(Address dest, short conn_id)
protected void	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, String counter_name)
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, long credits_needed)	We cannot send this request as OOB message, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected void	Discovery.sendDiscoveryResponse(List<PingData> list, Address sender)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, String logical_name, Address sender, boolean coord)
protected void	FD_SOCK.sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr)	Sends or broadcasts a I_HAVE_SOCK response.
protected void	AUTH.sendJoinRejectionMessage(Address dest, String error_msg)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	BaseBundler.sendMessageList(Address dest, Address src, List<Message> list, ByteBufferOutputStream out)
protected void	PerDestinationBundler.SendBuffer.sendMessages(Address dest, Address src, List<Message> list)
protected void	BaseBundler.sendMultiple(Address dst, Address sender, List<Message> list, ByteBufferOutputStream out)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	ReliableUnicast.sendRequestForFirstSeqno(Address dest, Address original_dest)
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest, Address original_dest)
protected void	COUNTER.sendResponse(Address dest, org.jgroups.protocols.COUNTER.Response<?> rsp)
protected void	RSVP.sendResponse(Address dest, short id)
protected void	SEQUENCER2.sendSeqnoResponse(Address original_sender, long seqno, int num_seqnos)
protected void	BaseBundler.sendSingle(Address dst, Message msg, ByteBufferOutputStream out)
protected void	BaseBundler.sendSingleMessage(Address dest, Message msg, ByteBufferOutputStream out)
void	LocalTransport.sendTo(Address dest, byte[] buf, int offset, int length)	Sends a message to a given local member.
default void	LocalTransport.sendTo(Address dest, ByteBuffer buf)
protected void	SHARED_LOOPBACK.sendTo(Address dest, ByteBuffer buf)
protected void	TP.sendTo(Address dest, ByteBuffer buf)
protected void	TUNNEL.sendTo(Address dest, ByteBuffer buf)
void	TUNNEL.TUNNELPolicy.sendToAllMembers(String group, Address sender, ByteBuffer data)
void	TUNNEL.TUNNELPolicy.sendToSingleMember(String group, Address dest, Address sender, ByteBuffer data)
protected void	ReliableMulticast.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
MsgStats	MsgStats.sent(Address dest, int length)
protected void	ASYM_ENCRYPT.serializeKeys(ByteArrayDataOutputStream out, boolean serialize_shared_keys, Address serialize_only)	Serializes all public keys and their corresponding encrypted shared group keys into a buffer
EncryptHeader	EncryptHeader.server(Address s)
FD_SOCK2.FdHeader	FD_SOCK2.FdHeader.serverAddress(Address a)
DISCARD	DISCARD.setAddress(Address localAddress)
<T extends Protocol> T	FORK.setAddress(Address addr)
<T extends Protocol> T	TP.setAddress(Address addr)
protected void	TP.setInAllThreadFactories(String cluster_name, Address local_address, String pattern)
DAISYCHAIN.DaisyHeader	DAISYCHAIN.DaisyHeader.setOriginalSender(Address s)
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender)	Checks if a message should be passed up, or not
protected void	SEQUENCER.startFlusher(Address new_coord)
boolean	TP.unicastDestMismatch(Address dest)
protected void	ReliableMulticast.unknownMember(Address sender, Object message)
protected static void	SHARED_LOOPBACK.unregister(AsciiString cluster, Address local_addr)
protected void	ASYM_ENCRYPT.unserializeAndInstallKeys(Address sender, byte[] version, ByteArrayDataInputStream in)	Unserializes public keys and installs them to pub_map, then reads encrypted shared keys and install our own
protected Map<Address,byte[]>	ASYM_ENCRYPT.unserializeKeys(Address sender, byte[] buf, int offset, int length)
protected boolean	FailureDetection.unsuspect(Address mbr)	Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack
protected boolean	FD_HOST.unsuspect(Address mbr)
protected void	FD_SOCK.unsuspect(Address mbr)
protected void	FD_SOCK2.unsuspect(Address mbr)
void	VERIFY_SUSPECT.unsuspect(Address mbr)
void	VERIFY_SUSPECT2.unsuspect(Address mbr)
protected abstract void	FailureDetection.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL2.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL3.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	VERIFY_SUSPECT.verifySuspectWithICMP(Address suspected_mbr)
protected boolean	TP.versionMatch(short version, Address sender)
protected void	FILE_PING.writeAll(Address[] excluded_mbrs)
protected void	PDC.writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr)
protected File	PDC.writeToTempFile(File dir, Address logical_addr, Address physical_addr, String logical_name)	Writes the data to a temporary file. The file is stored in the same directory as the other cluster files but is given the '.tmp' suffix

Method parameters in org.jgroups.protocols with type arguments of type Address

Modifier and Type	Method	Description
protected void	FD_SOCK2.BroadcastTask.addSuspects(List<Address> mbrs)
protected boolean	VERIFY_SUSPECT.addSuspects(Collection<Address> list)	Adds suspected members to the suspect list.
protected void	VERIFY_SUSPECT2.addSuspects(Collection<Address> list)	Adds suspected members to the suspect list.
protected long	FlowControl.adjustCredit(Map<Address,Credit> map, Address sender, int length)	Check whether sender has enough credits left.
protected void	NAKACK4.adjustReceivers(List<Address> members)
protected void	ReliableMulticast.adjustReceivers(List<Address> members)	Removes old members from xmit-table and adds new members to xmit-table (at seqnos hd=0, hr=0).
protected void	FD_SOCK.BroadcastTask.adjustSuspectedMembers(List<Address> new_mbrship)	Removes all elements from suspected_mbrs that are not in the new membership
protected void	VERIFY_SUSPECT.adjustSuspectedMembers(List<Address> new_mbrship)	Removes all elements from suspects that are not in the new membership
protected void	FD_SOCK2.BroadcastTask.adjustSuspects(List<Address> mbrs)	Removes all elements from suspects that are not in the new membership
protected void	FD_SOCK2.broadcastSuspectMessage(List<Address> suspected_members)	Sends a SUSPECT message to all group members.
protected void	Discovery.callFindMembersInAllDiscoveryProtocols(List<Address> mbrs, boolean initial_discovery, Responses rsps)	Calls Discovery.findMembers(List, boolean, Responses) in this protocol and all discovery protocols below
static List<View>	MERGE3.detectDifferentViews(Map<Address,View> map)
protected void	Discovery.disseminateDiscoveryInformation(List<Address> current_mbrs, List<Address> left_mbrs, List<Address> new_mbrs)	Disseminates cache information (UUID/IP adddress/port/name) to the given members
protected void	TP.fetchPhysicalAddrs(List<Address> missing)
protected Responses	TP.fetchResponsesFromDiscoveryProtocol(List<Address> missing)
Responses	Discovery.findMembers(List<Address> members, boolean initial_discovery, boolean async, long timeout)
protected abstract void	Discovery.findMembers(List<Address> members, boolean initial_discovery, Responses responses)	Fetches information (e.g.
void	FILE_PING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
void	JDBC_PING2.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
Responses	LOCAL_PING.findMembers(List<Address> members, boolean initial_discovery, boolean async, long timeout)
void	LOCAL_PING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
void	PING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
void	SHARED_LOOPBACK_PING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
void	TCPGOSSIP.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
void	TCPPING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)
protected void	BARRIER.flushQueue(Map<Address,Message> queue)
protected void	FlowControl.handleCreditRequest(Map<Address,Credit> map, Address sender, long requested_credits)
protected void	BATCH2.handleViewChange(List<Address> mbrs)
protected void	FlowControl.handleViewChange(List<Address> mbrs)
protected void	MFC.handleViewChange(List<Address> mbrs)
protected void	UFC.handleViewChange(List<Address> mbrs)
ReliableUnicast	ReliableUnicast.lastSync(ExpiryCache<Address> c)
static ByteArray	FD_SOCK.marshal(LazyRemovalCache<Address, IpAddress> addrs)
FD_SOCK.FdHeader	FD_SOCK.FdHeader.mbrs(Set<Address> members)
FD_SOCK2.FdHeader	FD_SOCK2.FdHeader.mbrs(Collection<Address> m)
PingData	PingData.mbrs(Collection<? extends Address> mbrs)
protected static String	FlowControl.printMap(Map<Address, ? extends Credit> m)
protected void	FILE_PING.readAll(List<Address> members, String clustername, Responses responses)
protected void	JDBC_PING.readAll(Connection connection, List<Address> members, String clustername, Responses rsps)
protected void	JDBC_PING.readAll(List<Address> members, String clustername, Responses responses)
protected void	JDBC_PING2.readAll(List<Address> members, String cluster, Responses rsps)
protected void	RACKSPACE_PING.readAll(List<Address> members, String clustername, Responses responses)
protected void	SWIFT_PING.readAll(List<Address> members, String clustername, Responses responses)
protected void	PerDestinationBundler.removeLeftMembers(List<Address> left_mbrs)
void	UNICAST3.removeSendConnection(Predicate<Address> pred)
protected void	FD_SOCK.resetPingableMembers(Collection<Address> new_mbrs)
abstract void	BasicTCP.retainAll(Collection<Address> members)
protected boolean	RSVP.Entry.retainAll(Collection<Address> members)
void	TCP_NIO2.retainAll(Collection<Address> members)
void	TCP.retainAll(Collection<Address> members)
protected void	FailureDetection.retainKeys(List<Address> mbrs)
protected void	PING.sendDiscoveryRequest(String cluster_name, List<Address> members_to_find, boolean initial_discovery)
protected static ByteArray	ASYM_ENCRYPT.serializeKeys(Map<Address,byte[]> keys)
protected void	Discovery.startCacheDissemination(List<Address> curr_mbrs, List<Address> left_mbrs, List<Address> new_mbrs)
protected void	FailureDetection.suspect(List<Address> suspects)
protected void	FD_HOST.suspect(List<Address> suspects)
protected void	FD_SOCK.suspect(Set<Address> suspects)
protected void	FD_SOCK2.suspect(Collection<Address> suspects)
protected void	VERIFY_SUSPECT.verifySuspect(Collection<Address> mbrs)	Sends ARE_YOU_DEAD message to suspected_mbr, wait for return or timeout
protected void	VERIFY_SUSPECT2.verifySuspect(Collection<Address> mbrs)	Sends ARE_YOU_DEAD message to suspected_mbr, wait for return or timeout

Constructors in org.jgroups.protocols with parameters of type Address

Modifier	Constructor	Description
protected	Buffer(Address address)
	DaisyHeader(Address original_sender)
protected	Entry(Address member)	Unicast entry
protected	Entry(Address suspect, long target_time)	Creates an instance of a Entry record class.
protected	Entry(Address suspect, long target_time)	Creates an instance of a Entry record class.
	FdHeader(byte type, Address mbr)
	FdHeader(byte type, Address mbr, IpAddress sock_addr)
	Flusher(Address new_coord)
	Mapping(Address logical_addr, PhysicalAddress physical_addr, String logical_name)
	PingData(Address sender, boolean is_server)
	PingData(Address sender, boolean is_server, String logical_name, PhysicalAddress physical_addr)
	ReceiverEntry(Buffer<Message> received_msgs, short recv_conn_id, Address real_dest)
	ReceiverEntry(Table<Message> received_msgs, short recv_conn_id, Address real_dest)
protected	Request(FD_SOCK2.Request.Type type, Address suspect)	Creates an instance of a Request record class.
	SendBuffer(Address dest)

Constructor parameters in org.jgroups.protocols with type arguments of type Address

Modifier	Constructor	Description
	DiscoveryCacheDisseminationTask(List<Address> curr_mbrs, List<Address> left_mbrs, List<Address> new_mbrs)
protected	Entry(Collection<Address> members)	Multicast entry

Uses of Address in org.jgroups.protocols.dns

Methods in org.jgroups.protocols.dns that return types with arguments of type Address

Modifier and Type	Method	Description
protected List<Address>	DefaultDNSResolver.resolveAAAAEntries(String dnsQuery)
protected List<Address>	AddressedDNSResolver.resolveAEntries(String dnsQuery, String srcPort)
protected List<Address>	DefaultDNSResolver.resolveAEntries(String dnsQuery)
protected List<Address>	DefaultDNSResolver.resolveAEntries(String dnsQuery, String srcPort)
protected List<Address>	DefaultDNSResolver.resolveIPEntries(String dnsQuery, String srcPort)
List<Address>	DefaultDNSResolver.resolveIps(String dnsQuery, DNSResolver.DNSRecordType recordType)
List<Address>	DNSResolver.resolveIps(String dnsQuery, DNSResolver.DNSRecordType recordType)
protected List<Address>	DefaultDNSResolver.resolveSRVEntries(String dnsQuery)

Method parameters in org.jgroups.protocols.dns with type arguments of type Address

Modifier and Type	Method	Description
void	DNS_PING.findMembers(List<Address> members, boolean initial_discovery, Responses responses)

Uses of Address in org.jgroups.protocols.pbcast

Classes in org.jgroups.protocols.pbcast that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	STATE_TRANSFER	STATE_TRANSFER protocol based on byte array transfer.
class	StreamingStateTransfer	Base class for state transfer protocols which use streaming (or chunking) to transfer state between two members.

Fields in org.jgroups.protocols.pbcast declared as Address

Modifier and Type	Field	Description
protected Address	STABLE.coordinator
protected Address[]	DeltaView.left_members	Members which left the view corresponding to ref_view_id
protected Address	GMS.GmsHeader.mbr
protected Address	GmsImpl.Request.mbr
protected Address[]	DeltaView.new_members	Members which joined the view corresponding to ref_view_id
protected final Address	StreamingStateTransfer.StateGetter.requester
protected final Address	MergeData.sender
protected Address	StreamingStateTransfer.state_provider
protected final Address	STATE.StateOutputStream.stateRequester

Fields in org.jgroups.protocols.pbcast with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<Address, MessageBatch>	NAKACK2.cached_batches	To cache batches for sending messages up the stack (https://issues.redhat.com/browse/JGRP-2841)
protected final ConcurrentMap<Address, Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
protected final ConcurrentMap<Address, Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
protected final List<Address>	GMS.joining	Members joined but for which no view has been received yet
protected final Promise<Address>	Leaver.leave_promise
protected final List<Address>	GMS.leaving	Members excluded from group, but for which no view has been received yet
protected List<Address>	NAKACK2.members
protected final List<Address>	STATE_TRANSFER.members
protected final List<Address>	StreamingStateTransfer.members
protected BoundedList<Address>	GMS.prev_members	Keeps track of old members (up to num_prev_mbrs)
protected final Map<Address,Long>	NAKACK2.stable_xmit_map
protected final ProcessingQueue<Address>	STATE_TRANSFER.state_requesters	List of members requesting state
protected final ProcessingQueue<Address>	StreamingStateTransfer.state_requesters	List of members requesting state.
protected SuppressLog<Address>	NAKACK2.suppress_log_non_member	Log to suppress identical warnings for messages from non-members
protected Map<Address,View>	GmsImpl.Request.views
protected final ConcurrentMap<Address, Table<Message>>	NAKACK2.xmit_table	Map to store sent and received messages (keyed by sender)
protected final Map<Address,Long>	NAKACK2.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539)

Methods in org.jgroups.protocols.pbcast that return Address

Modifier and Type	Method	Description
protected Address	GMS.determineCoordinator()
protected Address	STATE_TRANSFER.determineCoordinator()	Return the first element of members which is not me.
protected Address	StreamingStateTransfer.determineCoordinator()
protected Address	Merger.determineMergeLeader(Map<Address,View> views)	Returns the address of the merge leader
protected Address	GMS.determineNextCoordinator()	Returns the second-in-line
protected Address	GMS.getCoord()
Address[]	DeltaView.getLeftMembers()
Address	GMS.GmsHeader.getMember()
Address[]	DeltaView.getNewMembers()
Address	MergeData.getSender()
Address	NakAckHeader2.getSender()

Methods in org.jgroups.protocols.pbcast that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	GMS.computeNewMembership(Collection<Collection<Address>> subviews)	Computes a merge membership
List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
protected static Map<Address, Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
protected static Map<Address, Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Default implementation for a merge.
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
static List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(Collection<Collection<Address>> subviews)	Old default implementation for a merge.
Iterator<Address>	DeltaView.iterator()
protected Collection<? extends Address>	GMS.readMembers(byte[] buffer, int offset, int length)

Methods in org.jgroups.protocols.pbcast with parameters of type Address

Modifier and Type	Method	Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
protected void	STATE_TRANSFER.closeHoleFor(Address member)
protected void	StreamingStateTransfer.closeHoleFor(Address member)
void	Leaver.coordChanged(Address new_coord)	Callback to notify Leaver that the coord changed.
protected void	ParticipantGmsImpl.coordChanged(Address from, Address to)
protected void	ServerGmsImpl.coordChanged(Address from, Address to)
protected Tuple<InputStream, Object>	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected Tuple<InputStream, Object>	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract Tuple<InputStream, Object>	StreamingStateTransfer.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)	Creates an InputStream to the state provider to read the state.
protected void	STATE.createStreamToRequester(Address requester)
protected void	StreamingStateTransfer.createStreamToRequester(Address requester)	Creates an OutputStream to the state requester to write the state
static NakAckHeader2	NakAckHeader2.createXmitRequestHeader(Address orginal_sender)
protected void	NAKACK2.deliver(Message msg, Address sender, long seqno, String error_msg)
protected boolean	ClientGmsImpl.firstOfAllClients(Address joiner, Responses rsps)	Handles the case where no coord responses were received.
Digest	NAKACK2.getDigest(Address mbr)
protected static int	STABLE.getRank(Address member, View v)
protected void	STATE_TRANSFER.getStateFromApplication(Address requester, Digest digest)
protected void	StreamingStateTransfer.getStateFromApplication(Address requester, OutputStream out, boolean use_separate_thread)
Table<Message>	NAKACK2.getWindow(Address sender)	Returns the receive window for sender; only used for testing.
protected Object	STABLE.handle(STABLE.StableHeader hdr, Address sender, Digest digest)
void	STATE_TRANSFER.handle(Address state_requester)
void	StreamingStateTransfer.handle(Address state_requester)
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
void	Merger.handleDigestResponse(Address sender, Digest digest)
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
protected void	STATE.handleEOF(Address sender)
protected void	StreamingStateTransfer.handleEOF(Address sender)
protected void	NAKACK2.handleHighestSeqno(Address sender, long seqno)	Compares the sender's highest seqno with my highest seqno: if the sender's is higher, ask sender for retransmission
void	GmsImpl.handleLeaveResponse(Address sender)
void	Leaver.handleLeaveResponse(Address sender)
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
protected void	STABLE.handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)
protected void	STABLE.handleStableMessage(Digest d, Address sender, ViewId view_id)	Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
protected void	STATE.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	StreamingStateTransfer.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE_SOCK.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateRsp(Digest digest, Address sender, byte[] state)	Set the digest and the send the state up to the application
protected void	StreamingStateTransfer.handleStateRsp(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	NAKACK2.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender)	Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
void	ClientGmsImpl.join(Address address)
void	CoordGmsImpl.join(Address ignored)
abstract void	GmsImpl.join(Address mbr)
void	ParticipantGmsImpl.join(Address ignored)
protected void	ClientGmsImpl.joinInternal(Address mbr, boolean joinWithStateTransfer)	Makes this process join a group.
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr)
void	CoordGmsImpl.joinWithStateTransfer(Address ignored)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr)
void	ParticipantGmsImpl.joinWithStateTransfer(Address ignored)
GMS.GmsHeader	GMS.GmsHeader.mbr(Address mbr)
protected void	STATE_TRANSFER.punchHoleFor(Address member)
protected void	StreamingStateTransfer.punchHoleFor(Address member)
protected void	NAKACK2.removeAndDeliver(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster, int min_size)	Efficient way of checking whether another thread is already processing messages from sender.
protected void	NAKACK2.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	NAKACK2.retransmit(SeqnoList missing_msgs, Address sender, boolean multicast_xmit_request)
protected void	StreamingStateTransfer.sendEof(Address requester)
protected void	STATE_TRANSFER.sendException(Address requester, Throwable exception)
protected void	StreamingStateTransfer.sendException(Address requester, Throwable exception)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	GMS.sendJoinResponse(ByteArray marshalled_rsp, Address dest)
protected void	Leaver.sendLeaveRequest(Address coord, Address leaving_mbr)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id)	Send back a response containing view and digest to sender
protected void	GMS.sendViewAck(Address dest)
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
protected void	StreamingStateTransfer.setStateInApplication(InputStream in, Object resource, Address provider)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
protected void	NAKACK2.unknownMember(Address sender)
void	GmsImpl.unsuspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr)	Removes previously suspected member from list of currently suspected members
protected void	STABLE.updateLocalDigest(Digest d, Address sender)	Update my own digest from a digest received by somebody else.

Method parameters in org.jgroups.protocols.pbcast with type arguments of type Address

Modifier and Type	Method	Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
protected void	Merger.MergeTask._run(MergeId new_merge_id, Collection<Address> coordsCopy)	Runs the merge protocol as a leader
protected void	NAKACK2.adjustReceivers(List<Address> members)	Removes old members from xmit-table and adds new members to xmit-table (at seqnos hd=0, hr=0).
void	GMS.castViewChangeAndSendJoinRsps(View new_view, Digest digest, Collection<Address> expected_acks, Collection<Address> joiners, JoinRsp jr)	Broadcasts the new view and digest as VIEW messages, possibly sends JOIN-RSP messages to joiners and then waits for acks from expected_acks
List<Address>	GMS.computeNewMembership(Collection<Collection<Address>> subviews)	Computes a merge membership
List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
protected static Map<Address, Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
protected Address	Merger.determineMergeLeader(Map<Address,View> views)	Returns the address of the merge leader
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(Map<Address, Collection<Address>> coords, MergeId new_merge_id, long timeout)	Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(Map<Address, Collection<Address>> coords, MergeId new_merge_id, long timeout)	Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Default implementation for a merge.
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
static List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(Collection<Collection<Address>> subviews)	Old default implementation for a merge.
View	GMS.getNextView(Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspected_mbrs)	Computes the next view.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
protected static ByteArray	GMS.marshal(Collection<? extends Address> mbrs)
void	GmsImpl.merge(Map<Address,View> views)
void	Merger.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
void	ServerGmsImpl.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
protected void	Merger.MergeTask.removeRejectedMergeRequests(Collection<Address> coords)	Removed rejected merge requests from merge_rsps and coords.
static void	Merger.sanitizeViews(Map<Address,View> map)	Removes all members from a given view which don't have us in their view (https://issues.redhat.com/browse/JGRP-1061).
protected void	GMS.sendJoinResponses(JoinRsp jr, Collection<Address> joiners)
protected void	Merger.sendMergeCancelledMessage(Collection<Address> coords, MergeId merge_id)
protected void	Merger.sendMergeView(Collection<Address> coords, MergeData combined_merge_data, MergeId merge_id)	Sends the new view and digest to all subgroup coordinators.
protected void	GMS.sendViewChangeAndJoinResponse(Message view_change_msg, JoinRsp jr, Collection<Address> joiners)
void	Merger.MergeTask.start(Map<Address,View> views)
protected boolean	ParticipantGmsImpl.wouldIBeCoordinator(Collection<Address> leaving_mbrs, Collection<Address> suspected_members)	Determines whether this member is the new coordinator given a list of suspected members.

Constructors in org.jgroups.protocols.pbcast with parameters of type Address

Modifier	Constructor	Description
	DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)
	GmsHeader(byte type, Address mbr)	Used for JOIN_REQ or LEAVE_REQ header
	MergeData(Address sender, View view, Digest digest)
	MergeData(Address sender, View view, Digest digest, boolean merge_rejected)
	Request(int type, Address mbr)
	Request(int type, Address mbr, Map<Address,View> views)
	StateGetter(Address requester, OutputStream output)
	StateOutputStream(Address stateRequester)

Constructor parameters in org.jgroups.protocols.pbcast with type arguments of type Address

Modifier	Constructor	Description
	Request(int type, Address mbr, Map<Address,View> views)

Uses of Address in org.jgroups.protocols.relay

Subinterfaces of Address in org.jgroups.protocols.relay

Modifier and Type	Interface	Description
interface	SiteAddress	Address with a site suffix

Classes in org.jgroups.protocols.relay that implement Address

Modifier and Type	Class	Description
class	SiteMaster	Special address with the UUID part being 0: identifies the current (relay) coordinator of a given site.
class	SiteUUID	Implementation of SiteAddress

Fields in org.jgroups.protocols.relay declared as Address

Modifier and Type	Field	Description
protected Address	RelayHeader.final_dest
protected Address	RelayHeader.original_sender
protected final Address	Route.site_master	SiteUUID: address of the site master

Fields in org.jgroups.protocols.relay with type parameters of type Address

Modifier and Type	Field	Description
protected final Supplier<Address>	DefaultRouteStatusListener.addr_getter
protected Supplier<Address>	RandomSiteMasterPicker.addr_supplier
protected Map<Address,Address>	StickySiteMasterPicker.local_sm_cache
protected Map<Address,Address>	StickySiteMasterPicker.local_sm_cache
protected List<Address>	RELAY.members
protected Map<Address,Route>	StickySiteMasterPicker.route_cache
protected List<Address>	RELAY.site_masters

Methods in org.jgroups.protocols.relay that return Address

Modifier and Type	Method	Description
Address	DefaultRouteStatusListener.addr()
protected Address	RELAY3.checkLocalAddress(Address dest)
Address	RelayHeader.getFinalDest()
Address	RelayHeader.getOriginalSender()
Address	RandomSiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)
protected Address	RELAY.pickSiteMaster(Address sender)	Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)	Needs to pick a member from a list of addresses of site masters
Address	StickySiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)
Address	Route.siteMaster()

Methods in org.jgroups.protocols.relay that return types with arguments of type Address

Modifier and Type	Method	Description
protected static List<Address>	RELAY.determineSiteMasters(View view, int max_num_site_masters)	Iterates over the list of members and adds every member if the member's rank is below max_site_masters.
protected Map<String, List<Address>>	Relayer2.Bridge.extract(View view)	Returns a map containing the site keys and addresses as values
List<Address>	RELAY.members()
List<Address>	RELAY.siteMasters()

Methods in org.jgroups.protocols.relay with parameters of type Address

Modifier and Type	Method	Description
protected Address	RELAY3.checkLocalAddress(Address dest)
int	SiteMaster.compareTo(Address other)
int	SiteUUID.compareTo(Address other)
protected static boolean	Bridge.contains(List<Route> routes, Address addr)
protected boolean	Relayer2.Bridge.contains(List<Route> routes, Address addr)
protected Message	Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg, Collection<String> visited_sites)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected Object	RELAY3.deliver(Address next_dest, Message msg, boolean dont_relay)	Sends the message to a local destination.
protected Object	RELAY3.deliver(Address next_dest, Message msg, boolean dont_relay, boolean dont_loopback, boolean oob)
protected String	RELAY2.fetchTopoFromSiteMaster(Address sm)
protected void	RELAY2.forwardTo(Address next_dest, SiteAddress final_dest, Address original_sender, Message msg, boolean forward_to_current_coord)
protected Route	Relayer.getForwardingRouteMatching(String site, Address sender)	Returns a Route matching any of the ForwardingRoutes, or null if none matches
protected PhysicalAddress	RELAY.getPhysicalAddress(Address mbr)
protected Route	Relayer.getRoute(String site, Address sender)
protected boolean	RELAY2.handleAdminMessage(RelayHeader hdr, Address sender)	Handles SITES_UP/SITES_DOWN/TOPO_REQ/TOPO_RSP messages
void	DefaultRouteStatusListener.memberUnreachable(Address member)
default void	RouteStatusListener.memberUnreachable(Address member)	Sent back to the original sender when the unicast destination is not part of the local cluster (site)
Route	RandomSiteMasterPicker.pickRoute(String site, List<Route> routes, Address original_sender)
Route	SiteMasterPicker.pickRoute(String site, List<Route> routes, Address original_sender)	Picks a route to a given remote site from a list of routes.
Route	StickySiteMasterPicker.pickRoute(String site, List<Route> routes, Address original_sender)
Address	RandomSiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)
protected Address	RELAY.pickSiteMaster(Address sender)	Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)	Needs to pick a member from a list of addresses of site masters
Address	StickySiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)
void	Route.send(Address final_destination, Address original_sender, Message msg)
void	Route.send(Address final_destination, Address original_sender, Message msg, Collection<String> visited_sites)
protected void	RELAY3.sendMemberUnreachableTo(Address dest, Address member)	Sends a MBR-UNREACHABLE message to the sender of a unicast message
protected void	RELAY3.sendResponsesForAllSites(Address dest)
protected void	RELAY3.sendResponseTo(Address dest, boolean all_sites)	Returns information about all members of all sites, or only the local members of a given site
protected void	RELAY2.sendSiteUnreachableTo(Address src, String target_site)	Sends a SITE-UNREACHABLE message to the sender of the message.
protected void	RELAY3.sendSiteUnreachableTo(Address dest, String target_site)	Sends a SITE-UNREACHABLE message to the sender of the message.
protected void	RELAY2.sendToBridges(Address sender, Message msg, String... excluded_sites)	Sends the message via all bridges excluding the excluded_sites bridges
protected Object	RELAY3.sendToLocalSiteMaster(Address sender, Message msg)
protected boolean	RELAY2.sendTopoReq(JChannel bridge, Address dest)
RelayHeader	RelayHeader.setFinalDestination(Address d)
RelayHeader	RelayHeader.setOriginalSender(Address s)
protected void	RELAY.triggerMemberUnreachableEvent(Address mbr)
protected void	RELAY3.triggerMemberUnreachableEvent(Address mbr)

Method parameters in org.jgroups.protocols.relay with type arguments of type Address

Modifier and Type	Method	Description
SiteMasterPicker	RandomSiteMasterPicker.addressSupplier(Supplier<Address> s)
Address	RandomSiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)
Address	SiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)	Needs to pick a member from a list of addresses of site masters
Address	StickySiteMasterPicker.pickSiteMaster(List<Address> site_masters, Address original_sender)

Constructors in org.jgroups.protocols.relay with parameters of type Address

Modifier	Constructor	Description
	RelayHeader(byte type, Address final_dest, Address original_sender)
	Route(Address site_master, JChannel bridge, RELAY relay, Log log)

Constructor parameters in org.jgroups.protocols.relay with type arguments of type Address

Modifier	Constructor	Description
	DefaultRouteStatusListener(Supplier<Address> s)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

Modifier and Type	Class	Description
class	IpAddress	Network-dependent address (Internet).

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
protected Address	Protocol.local_addr
protected final Address	RouterStubManager.local_addr
Address	StateTransferInfo.target

Fields in org.jgroups.stack with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<String, ConcurrentMap<Address, GossipRouter.Entry>>	GossipRouter.address_mappings
protected final Map<Address, ByteBufferOutputStream>	GossipRouter.output_streams

Methods in org.jgroups.stack that return Address

Modifier and Type	Method	Description
Address	Protocol.addr()
Address	GossipRouter.Entry.client_addr()	Returns the value of the client_addr record component.
Address	AddressGenerator.generateAddress()	Deprecated, for removal: This API element is subject to removal in a future version.
default Address	AddressGenerator.generateAddress(String name)
Address	GossipData.getAddress()
Address	Protocol.getAddress()
Address	GossipData.getSender()
Address	GossipRouter.localAddress()

Methods in org.jgroups.stack that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	LargestWinningPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Called when a merge happened.
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Collection<Address>> subviews)	Compute a new membership based on a number of subviews
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes a new membership based on existing, joining, leaving and suspected members.

Methods in org.jgroups.stack with parameters of type Address

Modifier and Type	Method	Description
protected void	GossipRouter.addAddressMapping(Address sender, String group, Address addr, PhysicalAddress phys_addr, String logical_name)
<T extends Protocol> T	Protocol.addr(Address addr)
int	IpAddress.compareTo(Address o)	implements the java.lang.Comparable interface
void	RouterStub.connect(String group, Address addr, String logical_name, PhysicalAddress phys_addr)	Registers mbr with the GossipRouter under the given group, with the given logical name and physical address.
void	RouterStub.disconnect(String group, Address addr)
protected ByteBufferOutputStream	GossipRouter.getOutputStream(Address mbr, int size)
protected void	GossipRouter.handleGetMembersRequest(Address sender, DataInput in)
protected void	GossipRouter.handleHeartbeat(Address sender)
protected void	GossipRouter.handleRegister(Address sender, DataInput in)
void	GossipRouter.receive(Address sender, byte[] buf, int offset, int length)
void	GossipRouter.receive(Address sender, DataInput in, int length)	Used when use_nio is false (TcpConnection)
void	GossipRouter.receive(Address sender, ByteBuffer buf)	Used when use_nio=true (NioConnection)
void	RouterStub.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, DataInput in, int length)
protected void	GossipRouter.removeAddressMapping(String group, Address addr)
protected void	GossipRouter.removeFromAddressMappings(Address client_addr)
protected void	GossipRouter.route(String group, Address dest, Address sender, ByteBuffer buf)
protected void	GossipRouter.sendMembersResponse(Address to, GossipData rsp, String group)
void	RouterStub.sendToAllMembers(String group, Address sender, byte[] data, int offset, int length)
void	RouterStub.sendToAllMembers(String group, Address sender, ByteBuffer buf)
protected void	GossipRouter.sendToAllMembersInGroup(Set<Map.Entry<Address, GossipRouter.Entry>> dests, Address sender, ByteBuffer buf, boolean skip_self)
protected void	GossipRouter.sendToMember(Address dest, ByteBuffer buf)
void	RouterStub.sendToMember(String group, Address dest, Address sender, byte[] data, int offset, int length)
void	RouterStub.sendToMember(String group, Address dest, Address sender, ByteBuffer buf)
<T extends Protocol> T	Protocol.setAddress(Address addr)
GossipData	GossipData.setSender(Address s)
static void	GossipData.writeMetadata(DataOutput out, String group, Address addr, Address sender, int len)

Method parameters in org.jgroups.stack with type arguments of type Address

Modifier and Type	Method	Description
List<Address>	LargestWinningPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Called when a merge happened.
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Collection<Address>> subviews)	Compute a new membership based on a number of subviews
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes a new membership based on existing, joining, leaving and suspected members.
protected void	GossipRouter.sendToAllMembersInGroup(Set<Map.Entry<Address, GossipRouter.Entry>> dests, Address sender, ByteBuffer buf, boolean skip_self)

Constructors in org.jgroups.stack with parameters of type Address

Modifier	Constructor	Description
protected	Entry(Address client_addr, PhysicalAddress phys_addr, String logical_name)	Creates an instance of a Entry record class.
	GossipData(GossipType type, String group, Address addr)
	GossipData(GossipType type, String group, Address addr, byte[] buffer)
	GossipData(GossipType type, String group, Address addr, byte[] buffer, int offset, int length)
	GossipData(GossipType type, String group, Address addr, String logical_name, PhysicalAddress physical_addr)
	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)
	RouterStubManager(Log log, TimeScheduler timer, String cluster_name, Address local_addr, String logical_name, PhysicalAddress phys_addr, long reconnect_interval)
	StateTransferInfo(Address target)
	StateTransferInfo(Address target, long timeout)
	StateTransferInfo(Address target, long timeout, byte[] state)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

Modifier and Type	Class	Description
class	ExtendedUUID	Subclass of UUID accommodating additional data such as a flag and a small hashmap.
class	FlagsUUID	Subclass of UUID accommodating additional data such as a flag.
class	MillisAddress	Address with current time as key.
class	UUID	Logical address which is unique over space and time.

Subclasses with type arguments of type Address in org.jgroups.util

Modifier and Type	Class	Description
class	RspList<T>	Contains responses from all members.

Fields in org.jgroups.util declared as Address

Modifier and Type	Field	Description
protected Address	Owner.address
protected Address	ThreadPool.address
protected final Address	MaxOneThreadPerSender.Entry.dest
protected Address	MessageBatch.dest	The destination address.
protected Address[]	Digest.members
protected final Address	MaxOneThreadPerSender.Entry.sender
protected Address	MessageBatch.sender	The sender of the message batch

Fields in org.jgroups.util with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<Address,Long>	AckTable.acks
protected static final LazyRemovalCache<Address,String>	NameCache.cache	Keeps track of associations between addresses and logical names
protected final Map<Address,Long>	CreditMap.credits
protected static final Function<Address, Queue<Message>>	MessageCache.FUNC
protected static final Function<Address, RpcStats.RTTStat>	RpcStats.FUNC
protected static final Function<String, List<Address>>	Util.FUNC
protected static final Function<Address, RpcStats.Result>	RpcStats.FUNC2
protected final ConcurrentMap<Address, MaxOneThreadPerSender.Entry>	MaxOneThreadPerSender.MessageTable.map
protected final Map<Address, Queue<Message>>	MessageCache.map
protected final List<Address>	AckCollector.missing_acks
protected static final LazyRemovalCache.Printable<Address, LazyRemovalCache.Entry<String>>	NameCache.print_function
protected Map<Address, RpcStats.RTTStat>	RpcStats.rtt_stats
protected final Map<Address, AverageMinMax>	RTT.rtts
protected Map<Address, RpcStats.Result>	RpcStats.stats
protected final Map<Address,long[]>	RTT.times

Methods in org.jgroups.util with type parameters of type Address

Modifier and Type	Method	Description
static <T extends Collection<Address>> T	Util.readAddresses(DataInput in, IntFunction<T> factory)

Methods in org.jgroups.util that return Address

Modifier and Type	Method	Description
static Address	Util.addressFromString(String s)
static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(String name)
static Address[]	Util.createRandomAddresses(int num)	Returns an array of num random addresses, named A, B, C etc
static Address[]	Util.createRandomAddresses(int num, boolean use_numbers)
Address	MessageBatch.dest()
Address	MillisAddressGenerator.generateAddress()
Address	MillisAddressGenerator.generateAddress(String ignored)
Address	OneTimeAddressGenerator.generateAddress()
Address	Owner.getAddress()
Address	ThreadPool.getAddress()
Address	MessageBatch.getDest()
Address[]	Digest.getMembersRaw()	Don't use, this method is reserved for Bela ! :-)
Address[]	MutableDigest.getNonSetMembers()	Returns an array of members whose seqno is not set.
Address	MessageBatch.getSender()
Address	Digest.Entry.member()	Returns the value of the member record component.
static Address	Util.readAddress(DataInput in)
static Address[]	Util.readAddresses(DataInput in)
Address	MessageBatch.sender()

Methods in org.jgroups.util that return types with arguments of type Address

Modifier and Type	Method	Description
Map<Address, AverageMinMax>	RTT._rtt(int num_reqs, int size, boolean exclude_self)
static Collection<Address>	Util.determineActualMergeCoords(Map<Address,View> map)	Similar to Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual coord is when the sender of a view is the first member of that view
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs)	Returns all members that left between 2 views.
static Collection<Address>	Util.determineMergeCoords(Map<Address,View> map)	This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static Collection<Address>	Util.determineMergeParticipants(Map<Address,View> map)	Determines the members which take part in a merge.
static Map<Address,String>	NameCache.getContents()	Returns a copy of the cache's contents
static Map<Address,String>	NameCache.getContents(boolean skip_removed_values)
List<Tuple<Address,Long>>	CreditMap.getMembersWithCreditsLessThan(long min_credits)
List<Address>	CreditMap.getMembersWithInsufficientCredits(long credit_needed)
List<Address>	ResponseCollector.getMissing()	Returns a list of members which didn't send a valid response
List<Address>	PromoteNewestMemberOnCoordinatorLeave.getNewMembership(Collection<Address> currentMembers, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)
Map<Address,T>	ResponseCollector.getResults()
static Map<String, List<Address>>	Util.getSites(View bridge_view, String excluding_site)
List<Address>	RspList.getSuspectedMembers()
List<Address>	ResponseCollector.getValidResults()
Set<Address>	CreditMap.keys()
static List<Address>	Util.leftMembers(Collection<Address> old_list, Collection<Address> new_list)
static List<Address>	Util.newMembers(List<Address> old_list, List<Address> new_list)

Methods in org.jgroups.util with parameters of type Address

Modifier and Type	Method	Description
void	AckCollector.ack(Address member)
void	AckCollector.ack(Address... members)
long[]	AckTable.ack(Address sender, long seqno)
long[]	AckTable.ack(Address sender, long seqno, boolean add_if_absent)	Adds an ACK from a sender to the map.
MessageCache	MessageCache.add(Address sender, Message msg)
static void	NameCache.add(Address uuid, String logical_name)
boolean	ResponseCollector.add(Address member, T data)
Responses	Responses.add(Responses rsps, Address local_addr)
void	RpcStats.add(RpcStats.Type type, Address dest, boolean sync, long time)
protected void	AckCollector.addAll(Collection<Address> members, Address... exclude)
protected void	AckCollector.addAll(Address... members)
static String	Util.addressToString(Address addr)
RspList<T>	RspList.addRsp(Address sender, T retval)
void	RpcStats.addRTTStats(Address sender, RTTHeader hdr)
protected void	RpcStats.addToResults(Address dest, boolean sync, long time)
int	MillisAddress.compareTo(Address other)
int	UUID.compareTo(Address other)	Compares this UUID with the specified UUID.
boolean	Digest.contains(Address mbr)
boolean	Digest.containsAll(Address... members)
boolean	Responses.containsResponseFrom(Address mbr)
static MergeId	MergeId.create(Address addr)
protected void	CreditMap.decrementAndAdd(Address member, long new_credits)	Decrements credits bytes from all elements and adds new_credits to member (if non null).
MessageBatch	MessageBatch.dest(Address dest)
Collection<Message>	MessageCache.drain(Address sender)
protected int	Digest.find(Address mbr)
PingData	Responses.findResponseFrom(Address mbr)
Long	CreditMap.get(Address member)
long[]	Digest.get(Address member)	Returns the highest delivered and received seqnos associated with a member.
protected MaxOneThreadPerSender.Entry	MaxOneThreadPerSender.MessageTable.get(Address sender, Address dest)
static String	NameCache.get(Address logical_addr)
static int	Util.getRank(Collection<Address> members, Address addr)
static int	Util.getRank(View view, Address addr)	Returns the rank of a member in a given view
protected void	RTT.handleRequest(Address sender, TpHeader hdr)
protected void	RTT.handleResponse(Address sender, int index)
boolean	Responses.isCoord(Address addr)
static boolean	Util.isCoordinator(View view, Address local_addr)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
MutableDigest	MutableDigest.merge(Address member, long highest_delivered_seqno, long highest_received_seqno)	Similar to set(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno)
long	AckTable.min(Address mbr)
Long	CreditMap.putIfAbsent(Address key)
Long	CreditMap.remove(Address key)
static void	NameCache.remove(Address addr)
void	ResponseCollector.remove(Address member)
static void	Util.removeFromViews(Address mbr, JChannel... channels)
void	CreditMap.replenish(Address sender, long new_credits)
AckCollector	AckCollector.reset(Collection<Address> expected_acks, Address... exclude)
void	ResponseCollector.reset(Address... members)
static boolean	Util.sameHost(Address one, Address two)	Checks whether 2 Addresses are on the same host
MessageBatch	MessageBatch.sender(Address sender)
MessageBatch	MessageBatch.set(Address dest, Address sender, Message[] msgs)
MutableDigest	MutableDigest.set(Address member, long highest_delivered_seqno, long highest_received_seqno)
ThreadPool	ThreadPool.setAddress(Address a)
MessageBatch	MessageBatch.setDest(Address dest)
MessageBatch	MessageBatch.setSender(Address sender)
static int	Util.size(Address addr)
static int	Util.size(Address[] addrs)
void	AckCollector.suspect(Address member)
void	AckCollector.suspect(Address... members)
void	ResponseCollector.suspect(Address member)
String	Digest.toString(Address[] order, boolean print_highest_received)
static void	Util.writeAddress(Address addr, DataOutput out)
static void	Util.writeAddresses(Address[] addrs, DataOutput out)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, List<Message> msgs, DataOutput dos, boolean multicast)	Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, Message[] msgs, int offset, int length, DataOutput dos, boolean multicast)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, FastArray<Message> msgs, DataOutput dos, boolean multicast)
static void	Util.writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, DataOutput dos, boolean multicast)

Method parameters in org.jgroups.util with type arguments of type Address

Modifier and Type	Method	Description
void	AckCollector.ack(Collection<Address> members)
static void	NameCache.add(Map<Address,String> map)
protected void	AckCollector.addAll(Collection<Address> members)
protected void	AckCollector.addAll(Collection<Address> members, Collection<Address> exclude)
protected void	AckCollector.addAll(Collection<Address> members, Address... exclude)
void	RpcStats.addAnycast(boolean sync, long time, Collection<Address> dests)
AckTable	AckTable.adjust(List<Address> mbrs)	Removes left members from and adds new members to the map
static byte[]	Util.collectionToByteBuffer(Collection<Address> c)
protected void	Digest.createArrays(Map<Address,long[]> map)
static Collection<Address>	Util.determineActualMergeCoords(Map<Address,View> map)	Similar to Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual coord is when the sender of a view is the first member of that view
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs)	Returns all members that left between 2 views.
static Collection<Address>	Util.determineMergeCoords(Map<Address,View> map)	This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static Collection<Address>	Util.determineMergeParticipants(Map<Address,View> map)	Determines the members which take part in a merge.
List<Address>	PromoteNewestMemberOnCoordinatorLeave.getNewMembership(Collection<Address> currentMembers, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)
static int	Util.getRank(Collection<Address> members, Address addr)
static List<Address>	Util.leftMembers(Collection<Address> old_list, Collection<Address> new_list)
static List<Address>	Util.newMembers(List<Address> old_list, List<Address> new_list)
void	ResponseCollector.remove(List<Address> members)
static void	NameCache.removeAll(Collection<Address> mbrs)
void	AckCollector.reset(Collection<Address> members)
AckCollector	AckCollector.reset(Collection<Address> expected_acks, Collection<Address> exclude)
AckCollector	AckCollector.reset(Collection<Address> expected_acks, Address... exclude)
void	ResponseCollector.reset(Collection<Address> members)
boolean	AckCollector.retainAll(Collection<Address> members)
static void	NameCache.retainAll(Collection<Address> logical_addrs)
boolean	ResponseCollector.retainAll(List<Address> members)
void	RpcStats.retainAll(Collection<Address> members)
static int	Util.size(Collection<? extends Address> addrs)	Returns the marshalled size of a Collection of Addresses.
void	AckCollector.suspect(Collection<Address> members)
protected void	MaxOneThreadPerSender.MessageTable.viewChange(List<Address> mbrs)
void	MaxOneThreadPerSender.viewChange(List<Address> members)
static void	Util.writeAddresses(Collection<? extends Address> v, DataOutput out)	Writes a list of Addresses.

Constructors in org.jgroups.util with parameters of type Address

Modifier	Constructor	Description
	AckCollector(Address... members)
	Digest(Address[] members)	Only used internally, don't use !
	Digest(Address[] members, long[] seqnos)
	Digest(Address sender, long highest_delivered, long highest_received)
	Entry(Address member, long hd, long hr)	Creates an instance of a Entry record class.
protected	Entry(Address sender, Address dest, AsciiString cluster_name)
	MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, Collection<Message> msgs)
	MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, MessageBatch.Mode mode, int capacity)
	MutableDigest(Address[] members)
	Owner(Address address, long thread_id)
	ResponseCollector(Address... members)

Constructor parameters in org.jgroups.util with type arguments of type Address

Modifier	Constructor	Description
	AckCollector(Collection<Address> members)
	Digest(Map<Address,long[]> map)	Creates a new digest from an existing map by copying the keys and values from map
	ResponseCollector(Collection<Address> members)
	RspList(Map<Address,Rsp<T>> map)