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.auth.sasl
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.cs	This package contains all client-server related interfaces and classes
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
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.protocols.rules
org.jgroups.protocols.tom
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	AnycastAddress	This type of address represents a subset of the cluster members in which the total order properties must be applied, e.g.

Fields in org.jgroups declared as Address

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

Fields in org.jgroups with type parameters of type Address

Modifier and Type	Field	Description
protected java.util.Collection<Address>	AnycastAddress.destinations
protected java.util.List<Address>	Membership.members

Methods in org.jgroups that return Address

Modifier and Type	Method	Description
Address	JChannel.address()
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()
protected Address	MergeView.get(int index)
Address	Channel.getAddress()	Deprecated. Returns the channel's own address.
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	Message.getDest()
Address[]	View.getMembersRaw()	Returns the underlying array.
Address	Message.getSrc()
Address	Message.src()

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

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

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method	Description
void	AnycastAddress.add(Address... addresses)
Membership	Membership.add(Address new_member)	Adds a new member to this membership.
Membership	Membership.add(Address... mbrs)
int	AnycastAddress.compareTo(Address o)
void	Channel.connect(java.lang.String cluster_name, Address target, long timeout)	Deprecated. Connects this channel to a group and gets a state from a specified state provider.
JChannel	JChannel.connect(java.lang.String cluster_name, Address target, long timeout)	Joins the cluster and gets the state from a specified state provider.
JChannel	JChannel.connect(java.lang.String cluster_name, Address target, long timeout, boolean useFlushIfPresent)	Joins the cluster and gets a 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, java.util.Collection<Address> members)
static View	View.create(Address coord, long id, Address... members)
Message	Message.dest(Address new_dest)
protected int	MergeView.get(Address member)
java.lang.String	Channel.getName(Address member)	Deprecated. Returns the logical name of a given member.
void	Channel.getState(Address target, long timeout)	Deprecated. Retrieves the full state from the target member.
JChannel	JChannel.getState(Address target, long timeout)	Retrieves the full state from the target member.
JChannel	JChannel.getState(Address target, long timeout, boolean useFlushIfPresent)	Retrieves state from the target member.
protected JChannel	JChannel.getState(Address target, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
protected void	AnycastAddress.internalAdd(Address address)
static java.lang.String	View.printDiff(Address[][] diff)
Membership	Membership.remove(Address old_member)	Removes an member from the membership.
void	Channel.send(Address dst, byte[] buf)	Deprecated. Sends a message.
void	Channel.send(Address dst, byte[] buf, int offset, int length)	Deprecated. Sends a message to a destination.
void	Channel.send(Address dst, java.lang.Object obj)	Deprecated. Helper method to create a Message with given parameters and invoke Channel.send(Message).
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, java.lang.Object obj)	Helper method to create a Message with given parameters and invoke JChannel.send(Message).
Message	Message.setDest(Address new_dest)
Message	Message.setSrc(Address new_src)
Message	Message.src(Address new_src)
default void	MembershipListener.suspect(Address suspected_mbr)	Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReceiverAdapter.suspect(Address mbr)
void	Message.writeToNoAddrs(Address src, java.io.DataOutput out, short... excluded_headers)	Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address

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

Modifier and Type	Method	Description
Membership	Membership.add(java.util.Collection<Address> v)	Adds a list of members to this membership
void	AnycastAddress.addAll(java.util.Collection<Address> addresses)
static View	View.create(Address coord, long id, java.util.Collection<Address> members)
Membership	Membership.merge(java.util.Collection<Address> new_mems, java.util.Collection<Address> suspects)	Merges membership with the new members and removes suspects.
Membership	Membership.remove(java.util.Collection<Address> v)	Removes all the members contained in v from this membership
Membership	Membership.retainAll(java.util.Collection<Address> v)
Membership	Membership.set(java.util.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.
void	Channel.startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)	Deprecated. Performs the flush of the cluster but only for the specified flush participants.
JChannel	JChannel.startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)	Performs the flush of the cluster but only for the specified flush participants.
void	Channel.stopFlush(java.util.List<Address> flushParticipants)	Deprecated. Stops the current flush of the cluster for the specified flush participants.
JChannel	JChannel.stopFlush(java.util.List<Address> flushParticipants)	Stops the current flush of the cluster for the specified flush participants.

Constructors in org.jgroups with parameters of type Address

Constructor	Description
AnycastAddress(Address... addresses)
Membership(Address... initial_members)
MergeView(Address creator, long id, java.util.List<Address> members, java.util.List<View> subgroups)	Creates a new view
MergeView(ViewId view_id, Address[] members, java.util.List<View> subgroups)
Message(Address dest)	Constructs a message given a destination address
Message(Address dest, byte[] buf)	Constructs a message given a destination and source address and the payload byte buffer
Message(Address dest, byte[] buf, int offset, int length)	Constructs a message.
Message(Address dest, java.lang.Object obj)	Constructs a message given a destination and source address and the payload object
Message(Address dest, Buffer buf)
UnreachableException(java.lang.String msg, Address member)
UnreachableException(Address member)
View(Address creator, long id, java.util.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

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

Uses of Address in org.jgroups.auth.sasl

Methods in org.jgroups.auth.sasl with parameters of type Address

Modifier and Type	Method	Description
Message	SaslClientContext.nextMessage(Address address, SaslHeader header)
Message	SaslContext.nextMessage(Address address, SaslHeader saslHeader)
Message	SaslServerContext.nextMessage(Address address, SaslHeader header)

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 Address	UnicastRequest.target

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

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

Methods in org.jgroups.blocks that return Address

Modifier and Type	Method	Description
Address[]	RequestOptions.exclusionList()
Address[]	RequestOptions.getExclusionList()
Address	PartitionedHashMap.getLocalAddress()
Address	ReplCache.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
Address	PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership)	Defines a hash function to pick the right node from the list of cluster nodes.

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

Modifier and Type	Method	Description
java.util.List<Address>	ReplicatedTree.getMembers()
java.util.List<Address>	ReplCache.ConsistentHashFunction.hash(K key, short replication_count)
java.util.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, java.lang.String meth, java.lang.Object[] args, java.lang.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> java.util.concurrent.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)
protected void	RequestCorrelator.handleResponse(Request req, Address sender, byte[] buf, int offset, int length, boolean is_exception)
boolean	RspFilter.isAcceptable(java.lang.Object response, Address sender)	Determines whether a response from a given sender should be added to the response list of the request
void	GroupRequest.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)	Callback (called by RequestCorrelator or Transport).
abstract void	Request.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)
void	UnicastRequest.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)	Callback (called by RequestCorrelator or Transport).
<T> T	MessageDispatcher.sendMessage(Address dest, byte[] data, int offset, int length, RequestOptions opts)	Sends a unicast message and - depending on the options - returns a result
<T> T	MessageDispatcher.sendMessage(Address dest, Buffer data, RequestOptions opts)	Sends a unicast message and - depending on the options - returns a result
<T> java.util.concurrent.CompletableFuture<T>	MessageDispatcher.sendMessageWithFuture(Address dest, byte[] data, int offset, int length, RequestOptions opts)	Sends a unicast message to the target defined by msg.getDest() and returns a future
<T> java.util.concurrent.CompletableFuture<T>	MessageDispatcher.sendMessageWithFuture(Address dest, Buffer data, RequestOptions opts)	Sends a unicast message to the target defined by msg.getDest() and returns a future
void	RequestCorrelator.sendUnicastRequest(Address dest, Buffer data, Request req, RequestOptions opts)	Sends a request to a single destination
RequestCorrelator	RequestCorrelator.setLocalAddress(Address a)
protected boolean	GroupRequest.setSuspected(Address mbr)
void	PartitionedHashMap.ConsistentHashFunction.suspect(Address suspected_mbr)
void	PartitionedHashMap.suspect(Address suspected_mbr)
void	ReplCache.suspect(Address suspected_mbr)
void	ReplicatedHashMap.suspect(Address suspected_mbr)	Called when a member is suspected

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

Modifier and Type	Method	Description
<T> RspList<T>	RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.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(java.util.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> java.util.concurrent.CompletableFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_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(java.util.Collection<Address> dests, byte[] data, int offset, int length, RequestOptions options, boolean block_for_results)
protected <T> GroupRequest<T>	MessageDispatcher.cast(java.util.Collection<Address> dests, Buffer data, RequestOptions options, boolean block_for_results)
<T> RspList<T>	MessageDispatcher.castMessage(java.util.Collection<Address> dests, byte[] data, int offset, int length, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
<T> RspList<T>	MessageDispatcher.castMessage(java.util.Collection<Address> dests, Buffer data, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
<T> java.util.concurrent.CompletableFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Buffer data, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
Address	PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership)	Defines a hash function to pick the right node from the list of cluster nodes.
void	ReplCache.ConsistentHashFunction.installNodes(java.util.List<Address> new_nodes)
void	ReplCache.HashFunction.installNodes(java.util.List<Address> nodes)	When the topology changes, this method will be called.
protected void	GroupRequest.sendRequest(Buffer data, java.util.Collection<Address> targetMembers)
void	RequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs, Buffer data, Request req, RequestOptions opts)	Sends a request to a group.
protected <X extends MessageDispatcher> X	MessageDispatcher.setMembers(java.util.List<Address> new_mbrs)
protected void	MessageDispatcher.updateStats(java.util.Collection<Address> dests, boolean anycast, boolean sync, long time)
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)

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

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

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

Constructor	Description
GroupRequest(RequestCorrelator corr, java.util.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 java.util.Map<Address,Connection>	BaseServer.conns

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

Modifier and Type	Method	Description
Address	BaseServer.localAddress()
protected static Address	BaseServer.localAddress(java.net.InetAddress bind_addr, int local_port, java.net.InetAddress external_addr, int external_port)
Address	Client.localAddress()
abstract Address	Connection.localAddress()
Address	NioConnection.localAddress()
Address	TcpConnection.localAddress()
abstract Address	Connection.peerAddress()
Address	NioConnection.peerAddress()
Address	TcpConnection.peerAddress()
protected Address	NioConnection.readPeerAddress()
protected Address	TcpConnection.readPeerAddress(java.net.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
void	BaseServer.addConnection(Address peer_addr, Connection conn)
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)
Connection	BaseServer.getConnection(Address dest)	Creates a new connection to dest, or returns an existing one
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, java.io.DataInput in, int len)
void	BaseServer.receive(Address sender, java.nio.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
void	Receiver.receive(Address sender, java.io.DataInput in)
void	Receiver.receive(Address sender, java.nio.ByteBuffer buf)	Delivers a message from a given sender to the application
void	ReceiverAdapter.receive(Address sender, byte[] buf, int offset, int length)
void	ReceiverAdapter.receive(Address sender, java.io.DataInput in)
void	ReceiverAdapter.receive(Address sender, java.nio.ByteBuffer buf)	The default implementation assumes that ByteBuffer.flip() or ByteBuffer.rewind() was called on buf before invoking this callback
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, java.nio.ByteBuffer data)
void	NioClient.send(Address dest, byte[] data, int offset, int length)
void	NioClient.send(Address dest, java.nio.ByteBuffer data)
void	TcpClient.send(Address dest, byte[] data, int offset, int length)
void	TcpClient.send(Address dest, java.nio.ByteBuffer data)
protected void	NioConnection.sendLocalAddress(Address local_addr)
protected void	TcpConnection.sendLocalAddress(Address local_addr)	Send the cookie first, then the 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.retainAll(java.util.Collection<Address> current_mbrs)	Removes all connections which are not in current_mbrs

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

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 stub and binds it, use TcpConnection.connect(Address) to connect

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, java.io.DataInput in)
void	PubClient.receive(Address sender, java.nio.ByteBuffer buf)
void	PubServer.receive(Address sender, byte[] buf, int offset, int length)
void	PubServer.receive(Address sender, java.io.DataInput in)
void	PubServer.receive(Address sender, java.nio.ByteBuffer buf)
void	QuoteClient.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr)	Called when a member is suspected

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

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

Uses of Address in org.jgroups.demos.wb

Fields in org.jgroups.demos.wb declared as Address

Modifier and Type	Field	Description
Address	Node.addr

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

Modifier and Type	Method	Description
void	GraphPanel.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.suspect(Address obj)

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

Modifier and Type	Method	Description
void	GraphPanel.adjustNodes(java.util.List<Address> v)

Uses of Address in org.jgroups.fork

Fields in org.jgroups.fork declared as Address

Modifier and Type	Field	Description
protected Address	ForkProtocolStack.local_addr

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

Modifier and Type	Method	Description
ForkChannel	ForkChannel.connect(java.lang.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)

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

Modifier and Type	Method	Description
ForkChannel	ForkChannel.startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)
ForkChannel	ForkChannel.stopFlush(java.util.List<Address> flushParticipants)

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
protected Address	NAMING.Header.addr
protected Address	Executing.Owner.address
protected Address	CENTRAL_EXECUTOR.coord
protected Address	CENTRAL_LOCK.coord
protected Address	CENTRAL_LOCK2.coord
protected Address	COUNTER.coord	The address of the cluster coordinator.
protected Address	FORWARD_TO_COORD.coord	the address of the current coordinator, all msgs are forwarded to it
protected Address	RELAY.coord	Deprecated.
protected Address	SEQUENCER.coord
protected Address	SEQUENCER2.coord
protected Address	Discovery.current_coord
protected Address	FD.FdHeader.from
protected Address	ASYM_ENCRYPT.key_server_addr
protected Address	ABP.local_addr	Deprecated.
protected Address	AUTH.local_addr
protected Address	BARRIER.local_addr
protected Address	COUNTER.local_addr
protected Address	DAISYCHAIN.local_addr
protected Address	DETECT_LOOPBACKS.local_addr
protected Address	Discovery.local_addr
protected Address	Encrypt.local_addr
protected Address	Executing.local_addr
protected Address	FailureDetection.local_addr
protected Address	FD_HOST.local_addr
protected Address	FD_SOCK.local_addr
protected Address	FD.local_addr
protected Address	FlowControl.local_addr
protected Address	FORK.local_addr
protected Address	FORWARD_TO_COORD.local_addr
protected Address	FRAG2.local_addr
protected Address	FRAG3.local_addr
protected Address	KeyExchange.local_addr
protected Address	Locking.local_addr
protected Address	MAKE_BATCH.local_addr
protected Address	MERGE3.local_addr
protected Address	NAMING.local_addr
protected Address	PDC.local_addr
protected Address	PERF.local_addr
protected Address	RELAY.local_addr	Deprecated.
protected Address	RSVP.local_addr
protected Address	SASL.local_addr	Deprecated.
protected Address	SEQUENCER.local_addr
protected Address	SEQUENCER2.local_addr
protected Address	SERIALIZE.local_addr
protected Address	SIZE.local_addr
protected Address	STOMP.local_addr
protected Address	TP.local_addr	The address (host and port) of this member
protected Address	UNICAST3.local_addr
protected Address	VERIFY_SUSPECT.local_addr
protected Address	DISCARD.localAddress
protected Address	PDC.Mapping.logical_addr
protected Address	FD_SOCK.FdHeader.mbr
protected Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected Address	RELAY.RelayHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD_SOCK.ping_dest
protected Address	FD.ping_dest
protected Address	Locking.Request.sender
protected Address	PingData.sender
protected Address	EncryptHeader.server
protected Address	VERIFY_SUSPECT.Entry.suspect
protected Address	RSVP.Entry.target
protected Address	AlternatingBundler.target_dest

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

Modifier and Type	Field	Description
protected java.util.Map<Address,java.net.SocketAddress>	SimpleTCP.addr_table
protected java.util.List<Address>	COUNTER.backup_coords	Backup coordinators.
protected java.util.List<Address>	CENTRAL_EXECUTOR.backups
protected java.util.List<Address>	CENTRAL_LOCK.backups
protected LazyRemovalCache<Address,IpAddress>	FD_SOCK.cache	Cache of member addresses and their ServerSocket addresses
protected java.util.concurrent.ConcurrentMap<Address,PhysicalAddress>	PDC.cache
protected AgeOutCache<Address>	UNICAST3.cache
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.curr_mbrs
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	SEQUENCER.delivery_table
protected java.util.Map<Address,java.lang.String>	STOMP.endpoints
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Long,FRAG2.FragEntry>>	FRAG2.fragment_list
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Integer,FRAG3.FragEntry>>	FRAG3.fragment_list
protected static java.util.function.Function<AsciiString,java.util.Map<Address,SHARED_LOOPBACK>>	SHARED_LOOPBACK.FUNC
protected Promise<java.util.Map<Address,IpAddress>>	FD_SOCK.get_cache_promise	Used to rendezvous on GET_CACHE and GET_CACHE_RSP
protected java.util.Set<Address>	BARRIER.holes
protected java.util.Map<java.net.InetAddress,java.util.List<Address>>	FD_HOST.hosts	Map of hosts and their cluster members, updated on view changes.
protected java.util.Set<Address>	DISCARD.ignoredMembers
protected ExpiryCache<Address>	UNICAST3.last_sync_sent	Keep track of when a SEND_FIRST_SEQNO message was sent to a given sender
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.left_mbrs
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache	Cache which maintains mappings between logical and physical addresses.
protected java.util.Set<Address>	FD_SOCK.FdHeader.mbrs
protected java.util.Collection<Address>	FD.FdHeader.mbrs
protected java.util.Collection<? extends Address>	PingData.mbrs
protected java.util.Map<Address,Message>	BARRIER.mcast_queue
protected java.util.Collection<Address>	DISCARD.members
protected java.util.List<Address>	FailureDetection.members
protected java.util.List<Address>	FD_HOST.members
protected java.util.List<Address>	FD_SOCK.members
protected java.util.List<Address>	FD.members
protected java.util.List<Address>	FRAG2.members
protected java.util.List<Address>	FRAG3.members
protected java.util.List<Address>	RSVP.members
protected java.util.List<Address>	SIZE.members
protected java.util.Set<Address>	TP.members	The members of this group (updated when a member joins or leaves).
protected java.util.List<Address>	UNICAST3.members
protected java.util.Map<Address,java.util.List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.new_mbrs
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_ucast
protected java.util.List<Address>	FD_SOCK.pingable_mbrs
protected java.util.List<Address>	FD.pingable_mbrs	Members from which we select ping_dest.
protected static LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<PhysicalAddress>>	TP.print_function
protected java.util.Map<Address,byte[]>	ASYM_ENCRYPT.pub_map
protected java.util.Map<Address,Credit>	FlowControl.received	Keeps track of credits per member at the receiver.
protected java.util.concurrent.ConcurrentHashMap<Address,ABP.Entry>	ABP.recv_map	Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.ReceiverEntry>	UNICAST3.recv_table
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_ucast
protected static java.util.Map<AsciiString,java.util.Map<Address,SHARED_LOOPBACK>>	SHARED_LOOPBACK.routing_table	Map of cluster names and address-protocol mappings.
protected java.util.Map<Address,SaslContext>	SASL.sasl_context	Deprecated.
protected java.util.concurrent.ConcurrentHashMap<Address,ABP.Entry>	ABP.send_map	Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.SenderEntry>	UNICAST3.send_table
protected java.util.Map<Address,? extends Credit>	UFC.sent	Map: keys are members, values are credits left.
protected static java.lang.ThreadLocal<Address>	ASYM_ENCRYPT.srv_addr
protected SuppressLog<Address>	TP.suppress_log_different_cluster	Log to suppress identical warnings for messages from members in different clusters
protected SuppressLog<Address>	TP.suppress_log_different_version	Log to suppress identical warnings for messages from members with different (incompatible) versions
protected BoundedList<Tuple<Address,java.lang.Long>>	FailureDetection.suspect_history
protected java.util.Set<Address>	FailureDetection.suspected_mbrs
protected java.util.Set<Address>	FD_HOST.suspected_mbrs
protected java.util.Set<Address>	FD_SOCK.suspected_mbrs
protected java.util.List<Address>	FD.Broadcaster.suspected_mbrs
protected java.util.List<Address>	FD.BroadcastTask.suspected_members
protected java.util.Set<Address>	FD_SOCK.BroadcastTask.suspects
protected java.util.concurrent.ConcurrentMap<Address,java.lang.Long>	FD_ALL.timestamps
protected java.util.Map<Address,java.util.concurrent.atomic.AtomicBoolean>	FD_ALL2.timestamps
protected java.util.Map<Address,FD_ALL3.Bitmap>	FD_ALL3.timestamps
protected java.util.Map<Address,Message>	BARRIER.ucast_queue
protected java.util.Map<Address,java.lang.String>	RELAY.ViewData.uuids
protected java.util.Map<Address,ViewId>	MERGE3.views
protected ExpiryCache<Address>	TP.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 java.util.Map<Address,java.lang.Long>	UNICAST3.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method	Description
protected Address	FD_SOCK.determineCoordinator()
protected Address	FD_SOCK.determinePingDest()
Address	AUTH.getAddress()
Address	Executing.Owner.getAddress()
Address	PingData.getAddress()
Address	SASL.getAddress()	Deprecated.
protected static Address	ASYM_ENCRYPT.getCachedServerAddress()
Address	CENTRAL_EXECUTOR.getCoord()
Address	CENTRAL_LOCK.getCoord()
Address	SEQUENCER.getCoordinator()
Address	SEQUENCER2.getCoordinator()
Address	SEQUENCER.getLocalAddress()
Address	SEQUENCER2.getLocalAddress()
Address	PDC.Mapping.getLogicalAddr()
Address	PDC.Mapping.getPhysicalAddr()
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
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	DISCARD.localAddress()
Address	TP.localAddress()
Address	Locking.Request.sender()
Address	EncryptHeader.server()

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

Modifier and Type	Method	Description
protected java.util.Map<ViewId,java.util.Set<Address>>	MERGE3.convertViews()
AgeOutCache<Address>	UNICAST3.getAgeOutCache()
protected java.util.List<Address>	FD.Broadcaster.getSuspectedMembers()
protected abstract java.util.Map<Address,?>	FailureDetection.getTimestamps()
protected java.util.Map<Address,?>	FD_ALL.getTimestamps()
protected java.util.Map<Address,?>	FD_ALL2.getTimestamps()
protected java.util.Map<Address,?>	FD_ALL3.getTimestamps()
java.util.Collection<? extends Address>	PingData.mbrs()
protected java.util.Map<Address,IpAddress>	FD_SOCK.unmarshal(byte[] buffer, int offset, int length)
protected java.util.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
protected void	TP._send(Message msg, 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, java.lang.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, java.lang.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	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)
protected boolean	SimpleTCP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected boolean	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected boolean	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr, boolean overwrite)
protected void	UNICAST3.addQueuedMessages(Address sender, UNICAST3.ReceiverEntry entry, java.util.Collection<Message> queued_msgs)
protected static java.lang.String	Discovery.addressAsString(Address address)
protected static java.lang.String	PDC.addressAsString(Address address)
protected static java.lang.String	FILE_PING.addressToFilename(Address mbr)
protected void	FD_SOCK.BroadcastTask.addSuspectedMember(Address mbr)	Adds a suspected member.
protected void	FD.Broadcaster.addSuspectedMember(Address mbr)	Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
protected long	FlowControl.adjustCredit(java.util.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 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	UNICAST3.closeConnection(Address mbr)	Removes and resets from connection table (which is already locked).
void	UNICAST3.closeReceiveConnection(Address mbr)
void	UNICAST3.closeSendConnection(Address mbr)
protected void	FD.computePingDest(Address remove)	Computes pingable_mbrs (based on the current membership and the suspected members) and ping_dest
protected boolean	JDBC_PING.contains(java.lang.String cluster_name, Address addr)
static RELAY.RelayHeader	RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id)
protected javax.net.ssl.SSLSocket	SSL_KEY_EXCHANGE.createSocketTo(Address target)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
void	Discovery.discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
void	TCPPING.discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
void	TP.doSend(byte[] buf, int offset, int length, Address dest)
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)
protected ABP.Entry	ABP.getEntry(java.util.concurrent.ConcurrentMap<Address,ABP.Entry> map, Address dest)	Deprecated.
protected java.net.InetAddress	FD_HOST.getHostFor(Address mbr)
protected java.util.List<Locking.Request>	Locking.ClientLockTable.getPendingRequests(Address sender)
protected PhysicalAddress	FD_HOST.getPhysicalAddress(Address logical_addr)
protected PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
int	UFC_NB.getQueuedMessagesTo(Address dest)
long	FlowControl.getReceiverCreditsFor(Address mbr)
protected UNICAST3.ReceiverEntry	UNICAST3.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id)
long	UFC.getSenderCreditsFor(Address mbr)
protected UNICAST3.SenderEntry	UNICAST3.getSenderEntry(Address dst)
protected void	DH_KEY_EXCHANGE.handle(DH_KEY_EXCHANGE.DhHeader hdr, Address sender)
protected void	UNICAST3.handleAckReceived(Address sender, long seqno, short conn_id, int timestamp)	Add the ACK to hashtable.sender.sent_msgs
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, java.util.List<LongTuple<Message>> msgs, boolean oob)
protected void	NAMING.handleCacheRequest(Address sender)	Typically received by the coord, which sends its cache contents to the sender (new joiner).
protected void	Executing.handleConsumerFoundResponse(long threadId, Address address)
protected void	Executing.handleConsumerReadyRequest(long requestId, Address address)
protected void	Executing.handleConsumerUnreadyRequest(long requestId, Address address)
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(java.util.Map<Address,Credit> map, Address sender, long requested_credits)
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	UNICAST3.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected void	Discovery.handleDiscoveryResponse(PingData data, Address sender)
protected void	Executing.handleExceptionResponse(Address source, long requestId, java.lang.Throwable throwable)
protected void	Executing.handleInterruptRequest(Address source, long requestId)
protected void	CENTRAL_LOCK2.handleLockInfoRequest(Address requester)
protected void	Locking.handleLockInfoRequest(Address requester)
protected void	CENTRAL_LOCK2.handleLockInfoResponse(Address sender, Locking.Request rsp)
protected void	Locking.handleLockInfoResponse(Address sender, Locking.Request rsp)
protected boolean	ABP.Entry.handleMessage(Address sender, byte msg_bit)
protected void	COUNTER.handleRequest(COUNTER.Request req, Address sender)
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender, int timestamp)	We need to resend the first message with our conn_id
protected void	COUNTER.handleResponse(COUNTER.Response rsp, Address sender)
protected void	RSVP.handleResponse(Address member, short id)
protected void	DH_KEY_EXCHANGE.handleSecretKeyRequest(java.security.PublicKey dh_public_key, Address sender)
protected void	DH_KEY_EXCHANGE.handleSecretKeyResponse(java.security.PublicKey dh_public_key, byte[] encrypted_secret_key, byte[] version, Address sender)
protected void	Executing.handleTaskRejectedResponse(Address source, long requestId)
protected void	Executing.handleTaskRequest(long requestId, Address address)
protected void	Executing.handleTaskSubmittedRequest(java.lang.Runnable runnable, Address source, long requestId, long threadId)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
protected void	Executing.handleValueResponse(Address source, long requestId, java.lang.Object value)
protected void	UNICAST3.handleXmitRequest(Address sender, SeqnoList missing)
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, javax.crypto.SecretKey key, byte[] version)
protected boolean	Encrypt.inView(Address sender, java.lang.String error_msg)
protected boolean	Discovery.isCoord(Address member)
protected boolean	RELAY.isLocal(Address dest)	Deprecated. Does the payload match the 'site' ID.
protected boolean	FD_HOST.isPinger(Address mbr)
boolean	UFC_NB.isQueuingTo(Address dest)
ASYM_ENCRYPT	ASYM_ENCRYPT.keyServerAddr(Address ks)
DISCARD	DISCARD.localAddress(Address addr)
<T extends Encrypt<E>> T	Encrypt.localAddress(Address addr)
MAKE_BATCH	MAKE_BATCH.localAddress(Address a)
protected int	RingBufferBundler.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
protected int	RingBufferBundlerLockless.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int available_msgs, int max_bundle_size)
protected int	RingBufferBundlerLockless2.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
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)
protected void	UNICAST3.processInternalMessage(Table<Message> win, Address sender)
void	BasicTCP.receive(Address sender, java.nio.ByteBuffer buf)
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, java.io.DataInput in)
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(java.lang.String clustername, Address addr)
protected void	JDBC_PING.remove(java.lang.String clustername, Address addr)
protected void	RACKSPACE_PING.remove(java.lang.String clustername, Address addr)
protected void	S3_PING.remove(java.lang.String clustername, Address addr)	Deprecated.
protected void	SWIFT_PING.remove(java.lang.String clustername, Address addr)
protected void	SEQUENCER2.removeAndDeliver(Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(Table<Message> win, Address sender)	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)
protected void	UNICAST3.removeReceiveConnection(Address mbr)
protected void	UNICAST3.removeSendConnection(Address mbr)
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
protected void	FD_SOCK.BroadcastTask.removeSuspectedMember(Address suspected_mbr)
void	MFC.replenish(Address mbr, long credits)
protected void	UNICAST3.retransmit(SeqnoList missing, Address sender)	Sends a retransmit request to the given sender
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
protected void	COUNTER.send(Address dest, Buffer buffer)
protected void	FORWARD_TO_COORD.send(Address target, long ack_id, byte type)
protected void	Locking.send(Address dest, Locking.Request req)
void	TCP_NIO2.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
protected void	FORWARD_TO_COORD.sendAck(Address target, long ack_id)
protected void	UNICAST3.sendAck(Address dst, long seqno, short conn_id)
protected void	UNICAST3.sendAckFor(Address dest)
void	UNICAST3.sendClose(Address dest, short conn_id)
protected void	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, java.lang.String counter_name)
protected void	CENTRAL_LOCK.sendCreateLockRequest(Address dest, java.lang.String lock_name, Owner owner)
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	CENTRAL_LOCK.sendDeleteLockRequest(Address dest, java.lang.String lock_name)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name, Address sender, boolean coord)
Locking.Request	Locking.Request.sender(Address sender)
protected void	FD.sendHeartbeatResponse(Address dest)
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, java.lang.String error_msg)
protected void	SASL.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)	Deprecated.
protected void	CENTRAL_LOCK2.sendLockInfoRequestTo(Buffer buf, Address[] mbrs, Address exclude)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	SASL.sendMergeRejectionMessage(Address dest)	Deprecated.
protected void	BaseBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)
protected void	RemoveQueueBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)
protected void	FORWARD_TO_COORD.sendNotCoord(Address target, long ack_id)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
protected void	SASL.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)	Deprecated.
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	Executing.sendRequest(Address dest, Executing.Type type, long requestId, java.lang.Object object)
protected void	Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)
protected void	Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, Owner owner, long timeout, boolean is_trylock)
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest)
protected void	COUNTER.sendResponse(Address dest, 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	Executing.sendThreadRequest(Address dest, long threadId, Executing.Type type, long requestId, java.lang.Object object)
protected void	SimpleTCP.sendTo(Address dest, byte[] buffer, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToAllMembers(java.lang.String group, Address sender, byte[] data, int offset, int length)
protected void	CENTRAL_EXECUTOR.sendToCoordinator(Executing.Type type, long requestId, Address value)
protected abstract void	Executing.sendToCoordinator(Executing.Type type, long requestId, Address address)
protected void	SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
protected void	TP.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
protected void	TUNNEL.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToSingleMember(java.lang.String group, Address dest, Address sender, byte[] data, int offset, int length)
protected void	TUNNEL.sendUnicast(Address dest, byte[] data, int offset, 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)
protected void	TP.setInAllThreadFactories(java.lang.String cluster_name, Address local_address, java.lang.String pattern)
DISCARD	DISCARD.setLocalAddress(Address localAddress)
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender)	Checks if a message should be passed up, or not
protected void	FD.Broadcaster.startBroadcastTask(Address suspect)	Starts a new task, or - if already running - adds the argument to the running task.
protected void	SEQUENCER.startFlusher(Address new_coord)
boolean	TP.unicastDestMismatch(Address dest)
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 java.util.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.unsuspect(Address mbr)
void	VERIFY_SUSPECT.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	FD.updateTimestamp(Address sender)
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 java.io.File	PDC.writeToTempFile(java.io.File dir, Address logical_addr, Address physical_addr, java.lang.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 boolean	VERIFY_SUSPECT.addSuspects(java.util.Collection<Address> list)	Adds suspected members to the suspect list.
protected long	FlowControl.adjustCredit(java.util.Map<Address,Credit> map, Address sender, int length)	Check whether sender has enough credits left.
protected void	FD_SOCK.BroadcastTask.adjustSuspectedMembers(java.util.List<Address> new_mbrship)	Removes all elements from suspected_mbrs that are not in the new membership
protected void	VERIFY_SUSPECT.adjustSuspectedMembers(java.util.List<Address> new_mbrship)	Removes all elements from suspects that are not in the new membership
protected void	CENTRAL_LOCK.copyLocksTo(java.util.List<Address> new_joiners)
protected void	CENTRAL_EXECUTOR.copyQueueTo(java.util.List<Address> new_joiners)
static java.util.List<View>	MERGE3.detectDifferentViews(java.util.Map<Address,View> map)
protected void	Discovery.disseminateDiscoveryInformation(java.util.List<Address> current_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)	Disseminates cache information (UUID/IP adddress/port/name) to the given members
protected void	TP.fetchPhysicalAddrs(java.util.List<Address> missing)
protected Responses	TP.fetchResponsesFromDiscoveryProtocol(java.util.List<Address> missing)
Responses	Discovery.findMembers(java.util.List<Address> members, boolean initial_discovery, boolean async, long timeout)
protected abstract void	Discovery.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)	Fetches information (e.g.
void	FILE_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
Responses	LOCAL_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, boolean async, long timeout)
void	LOCAL_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
protected void	MULTI_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
protected void	MULTI_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async)
void	PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	SHARED_LOOPBACK_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	TCPGOSSIP.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	TCPPING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
protected void	BARRIER.flushQueue(java.util.Map<Address,Message> queue)
protected ABP.Entry	ABP.getEntry(java.util.concurrent.ConcurrentMap<Address,ABP.Entry> map, Address dest)	Deprecated.
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
protected void	FlowControl.handleCreditRequest(java.util.Map<Address,Credit> map, Address sender, long requested_credits)
protected Locking.Response	Locking.ServerLock.handleView(java.util.List<Address> members)
protected void	FlowControl.handleViewChange(java.util.List<Address> mbrs)
protected void	MFC.handleViewChange(java.util.List<Address> mbrs)
protected void	UFC.handleViewChange(java.util.List<Address> mbrs)
protected void	Discovery.invokeFindMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async)	Calls Discovery.findMembers(List, boolean, Responses)
protected void	MULTI_PING.invokeFindMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async)
static Buffer	FD_SOCK.marshal(LazyRemovalCache<Address,IpAddress> addrs)
FD_SOCK.FdHeader	FD_SOCK.FdHeader.mbrs(java.util.Set<Address> members)
PingData	PingData.mbrs(java.util.Collection<? extends Address> mbrs)
protected static java.lang.String	FlowControl.printMap(java.util.Map<Address,? extends Credit> m)
protected void	FILE_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	JDBC_PING.readAll(java.sql.Connection connection, java.util.List<Address> members, java.lang.String clustername, Responses rsps)
protected void	JDBC_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	RACKSPACE_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	S3_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)	Deprecated.
protected void	SWIFT_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	S3_PING.readResponse(org.jgroups.protocols.S3_PING.GetResponse rsp, java.util.List<Address> mbrs, Responses responses)	Deprecated.
protected void	FD_SOCK.resetPingableMembers(java.util.Collection<Address> new_mbrs)
abstract void	BasicTCP.retainAll(java.util.Collection<Address> members)
protected boolean	RSVP.Entry.retainAll(java.util.Collection<Address> members)
void	TCP_NIO2.retainAll(java.util.Collection<Address> members)
void	TCP.retainAll(java.util.Collection<Address> members)
protected void	FailureDetection.retainKeys(java.util.List<Address> mbrs)
protected void	PING.sendDiscoveryRequest(java.lang.String cluster_name, java.util.List<Address> members_to_find, boolean initial_discovery)
protected void	TP.sendToMembers(java.util.Collection<Address> mbrs, byte[] buf, int offset, int length)	Fetches the physical addrs for mbrs and sends the msg to each physical address.
protected void	RELAY.sendViewOnLocalCluster(java.util.List<Address> destinations, byte[] buffer)	Deprecated.
protected void	RELAY.sendViewOnLocalCluster(RELAY.ViewData data, boolean use_seperate_thread, java.util.List<Address> new_mbrs)	Deprecated.
protected void	RELAY.sendViewOnLocalCluster(View remote_view, View global_view, boolean use_seperate_thread, java.util.List<Address> new_mbrs)	Deprecated.
protected static Buffer	ASYM_ENCRYPT.serializeKeys(java.util.Map<Address,byte[]> keys)
protected void	Discovery.startCacheDissemination(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
protected void	FailureDetection.suspect(java.util.List<Address> suspects)
protected void	FD_HOST.suspect(java.util.List<Address> suspects)
protected void	FD_SOCK.suspect(java.util.Set<Address> suspects)
protected void	VERIFY_SUSPECT.verifySuspect(java.util.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

Constructor	Description
Entry(Address member)	Unicast entry
Entry(Address suspect, long target_time)
FdHeader(byte type, Address mbr)
FdHeader(byte type, Address mbr, IpAddress sock_addr)
FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)
Flusher(Address new_coord)
Header(NAMING.Type t, Address addr, java.lang.String name)
Mapping(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name)
Owner(Address address, long requestId)
PingData(Address sender, boolean is_server)
PingData(Address sender, boolean is_server, java.lang.String logical_name, PhysicalAddress physical_addr)

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

Constructor	Description
DiscoveryCacheDisseminationTask(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
Entry(java.util.Collection<Address> members)	Multicast entry
FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)

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
java.util.List<Address>	DNSResolver.resolveIps(java.lang.String dnsQuery, DNSResolver.DNSRecordType recordType)

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

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

Uses of Address in org.jgroups.protocols.pbcast

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.local_addr
protected Address	NAKACK2.local_addr
protected Address	STABLE.local_addr
protected Address	STATE_TRANSFER.local_addr
protected Address	StreamingStateTransfer.local_addr
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 Address	StreamingStateTransfer.StateGetter.requester
protected Address	MergeData.sender
protected Address	StreamingStateTransfer.state_provider
protected Address	STATE.StateOutputStream.stateRequester

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

Modifier and Type	Field	Description
protected java.util.concurrent.ConcurrentMap<Address,java.util.Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
protected java.util.concurrent.ConcurrentMap<Address,java.util.Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
protected java.util.List<Address>	GMS.joining	Members joined but for which no view has been received yet
protected Promise<Address>	Leaver.leave_promise
protected java.util.List<Address>	GMS.leaving	Members excluded from group, but for which no view has been received yet
protected java.util.List<Address>	NAKACK2.members
protected java.util.List<Address>	STATE_TRANSFER.members
protected java.util.List<Address>	StreamingStateTransfer.members
protected BoundedList<Address>	GMS.prev_members	Keeps track of old members (up to num_prev_mbrs)
protected ProcessingQueue<Address>	STATE_TRANSFER.state_requesters	List of members requesting state
protected 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 java.util.Map<Address,View>	GmsImpl.Request.views
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table	Map to store sent and received messages (keyed by sender)
protected java.util.Map<Address,java.lang.Long>	NAKACK2.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/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(java.util.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
protected java.util.List<Address>	GMS.computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Computes a merge membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects)	Computes the regular membership
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Default implementation for a merge.
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.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 java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(java.util.Collection<java.util.Collection<Address>> subviews)	Old default implementation for a merge.
java.util.Iterator<Address>	DeltaView.iterator()
protected java.util.Collection<? extends Address>	GMS.readMembers(byte[] buffer, int offset, int length)
protected Tuple<java.util.Collection<? extends Address>,Digest>	FLUSH.readParticipantsAndDigest(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, java.util.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<java.io.InputStream,java.lang.Object>	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected Tuple<java.io.InputStream,java.lang.Object>	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract Tuple<java.io.InputStream,java.lang.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, java.lang.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, java.io.OutputStream out, boolean use_separate_thread)
Table<Message>	NAKACK2.getWindow(Address sender)	Returns the receive window for sender; only used for testing.
protected java.lang.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, java.util.Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.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, java.util.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	NAKACK2.handleMessages(Address dest, Address sender, java.util.List<LongTuple<Message>> msgs, boolean oob, AsciiString cluster_name)
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	STABLE.handleUpEvent(STABLE.StableHeader hdr, Address sender, Digest digest)
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, boolean useFlushIfPresent)
void	CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
protected void	ClientGmsImpl.joinInternal(Address mbr, boolean joinWithStateTransfer, boolean useFlushIfPresent)	Makes this process join a group.
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
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_name)	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)
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, java.lang.Throwable exception)
protected void	StreamingStateTransfer.sendException(Address requester, java.lang.Throwable exception)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	GMS.sendJoinResponse(Buffer 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(java.io.InputStream in, java.lang.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, java.lang.Object message)
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.
protected boolean	GMS.wouldBeNewCoordinator(Address potential_new_coord)	Checks whether the potential_new_coord would be the new coordinator (2nd in line)

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, java.util.Collection<? extends Address> mbrs)
protected void	Merger.MergeTask._run(MergeId new_merge_id, java.util.Collection<Address> coordsCopy)	Runs the merge protocol as a leader
protected void	NAKACK2.adjustReceivers(java.util.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, java.util.Collection<Address> expected_acks, java.util.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
protected java.util.List<Address>	GMS.computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Computes a merge membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects)	Computes the regular membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects)	Computes the regular membership
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.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(java.util.Map<Address,View> views)	Returns the address of the merge leader
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(java.util.Map<Address,java.util.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(java.util.Map<Address,java.util.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).
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Default implementation for a merge.
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.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 java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(java.util.Collection<java.util.Collection<Address>> subviews)	Old default implementation for a merge.
View	GMS.getNextView(java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspected_mbrs)	Computes the next view.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.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, java.util.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 Buffer	FLUSH.marshal(java.util.Collection<? extends Address> participants, Digest digest)
protected static Buffer	GMS.marshal(java.util.Collection<? extends Address> mbrs)
void	GmsImpl.merge(java.util.Map<Address,View> views)
void	Merger.merge(java.util.Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
void	ServerGmsImpl.merge(java.util.Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
protected void	Merger.MergeTask.removeRejectedMergeRequests(java.util.Collection<Address> coords)	Removed rejected merge requests from merge_rsps and coords.
static void	Merger.sanitizeViews(java.util.Map<Address,View> map)	Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061).
protected void	GMS.sendJoinResponses(JoinRsp jr, java.util.Collection<Address> joiners)
protected void	Merger.sendMergeCancelledMessage(java.util.Collection<Address> coords, MergeId merge_id)
protected void	Merger.sendMergeView(java.util.Collection<Address> coords, MergeData combined_merge_data, MergeId merge_id)	Sends the new view and digest to all subgroup coordinators.
void	Merger.MergeTask.start(java.util.Map<Address,View> views)
protected boolean	ParticipantGmsImpl.wouldIBeCoordinator(java.util.Collection<Address> leaving_mbrs)	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

Constructor	Description
DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)
GmsHeader(byte type, Address mbr)
GmsHeader(byte type, Address mbr, boolean useFlushIfPresent)	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, java.util.Map<Address,View> views)
Request(int type, Address mbr, java.util.Map<Address,View> views, boolean useFlushPresent)
StateGetter(Address requester, java.io.OutputStream output)
StateOutputStream(Address stateRequester)

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

Constructor	Description
Request(int type, Address mbr, java.util.Map<Address,View> views)
Request(int type, Address mbr, java.util.Map<Address,View> views, boolean useFlushPresent)

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	RELAY2.Relay2Header.final_dest
protected Address	RELAY2.local_addr
protected Address	RELAY2.Relay2Header.original_sender
protected 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 java.util.List<Address>	RELAY2.members
protected java.util.List<Address>	RELAY2.site_masters

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

Modifier and Type	Method	Description
Address	RELAY2.Relay2Header.getFinalDest()
Address	RELAY2.getLocalAddress()
Address	RELAY2.Relay2Header.getOriginalSender()
protected Address	RELAY2.pickSiteMaster(Address sender)	Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)	Needs to pick a member from a list of addresses of site masters
Address	Route.siteMaster()

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

Modifier and Type	Method	Description
protected java.util.List<Address>	RELAY2.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 java.util.Map<java.lang.String,java.util.List<Address>>	Relayer.Bridge.extract(View view)	Returns a map containing the site keys and addresses as values
java.util.List<Address>	RELAY2.members()
java.util.List<Address>	RELAY2.siteMasters()

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

Modifier and Type	Method	Description
int	SiteMaster.compareTo(Address other)
int	SiteUUID.compareTo(Address other)
protected boolean	Relayer.Bridge.contains(java.util.List<Route> routes, Address addr)
protected Message	Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected java.lang.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 PhysicalAddress	RELAY2.getPhysicalAddress(Address mbr)
protected Route	Relayer.getRoute(java.lang.String site, Address sender)
protected boolean	RELAY2.handleAdminMessage(RELAY2.Relay2Header hdr, Address sender)	Handles SITES_UP/SITES_DOWN/TOPO_REQ/TOPO_RSP messages
Route	SiteMasterPicker.pickRoute(java.lang.String site, java.util.List<Route> routes, Address original_sender)	Picks a route to a given remote site from a list of routes.
protected Address	RELAY2.pickSiteMaster(Address sender)	Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)	Needs to pick a member from a list of addresses of site masters
void	Route.send(Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.sendSiteUnreachableTo(Address src, java.lang.String target_site)	Sends a SITE-UNREACHABLE message to the sender of the message.
protected void	RELAY2.sendToBridges(Address sender, Message msg, java.lang.String... excluded_sites)	Sends the message via all bridges excluding the excluded_sites bridges
protected boolean	RELAY2.sendTopoReq(JChannel bridge, Address dest)

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

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

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

Constructor	Description
Relay2Header(byte type, Address final_dest, Address original_sender)
Route(Address site_master, JChannel bridge, RELAY2 relay, Log log)

Uses of Address in org.jgroups.protocols.rules

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

Modifier and Type	Field	Description
protected Address	SUPERVISOR.local_addr	Deprecated.

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

Modifier and Type	Method	Description
Address	SUPERVISOR.getLocalAddress()	Deprecated.

Uses of Address in org.jgroups.protocols.tom

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

Modifier and Type	Method	Description
Address	MessageID.getAddress()

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

Modifier and Type	Method	Description
java.util.Set<Address>	SenderManager.getDestination(MessageID messageID)	obtains the destination set of a message
java.util.Collection<Address>	DeliveryManagerImpl.handleView(View newView)	Updates the current view in use and returns a Collection with the members that left the cluster.

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

Modifier and Type	Method	Description
long	SenderManager.addPropose(MessageID messageID, Address from, long sequenceNumber)	Add a propose from a member in destination set

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

Modifier and Type	Method	Description
void	SenderManager.addNewMessageToSend(MessageID messageID, java.util.Collection<Address> destinations, long initialSequenceNumber, boolean deliverToMyself)	Add a new message sent
long	SenderManager.removeLeavers(MessageID messageID, java.util.Collection<Address> leavers)

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

Constructor	Description
MessageID(Address address, long id)

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).
class	IpAddressUUID	IpAddress with a 'semi'-UUID to prevent reincarnation when the port is fixed.

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
protected Address	GossipRouter.Entry.client_addr
protected Address	RouterStubManager.local_addr
Address	StateTransferInfo.target

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

Modifier and Type	Field	Description
protected java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.ConcurrentMap<Address,GossipRouter.Entry>>	GossipRouter.address_mappings

Methods in org.jgroups.stack that return Address

Modifier and Type	Method	Description
Address	AddressGenerator.generateAddress()
Address	GossipData.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
java.util.List<Address>	LargestWinningPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Called when a merge happened.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Compute a new membership based on a number of subviews
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.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, java.lang.String group, Address addr, PhysicalAddress phys_addr, java.lang.String logical_name)
int	IpAddress.compareTo(Address o)	implements the java.lang.Comparable interface
int	IpAddressUUID.compareTo(Address o)
void	RouterStub.connect(java.lang.String group, Address addr, java.lang.String logical_name, PhysicalAddress phys_addr)	Registers mbr with the GossipRouter under the given group, with the given logical name and physical address.
void	RouterStub.disconnect(java.lang.String group, Address addr)
protected void	GossipRouter.handleGetMembersRequest(Address sender, java.io.DataInput in)
protected void	GossipRouter.handleRegister(Address sender, java.io.DataInput in)
void	GossipRouter.receive(Address sender, byte[] buf, int offset, int length)
void	GossipRouter.receive(Address sender, java.io.DataInput in)
void	RouterStub.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, java.io.DataInput in)
void	RouterStub.receive(Address sender, java.nio.ByteBuffer buf)
protected void	GossipRouter.removeAddressMapping(java.lang.String group, Address addr)
protected void	GossipRouter.removeFromAddressMappings(Address client_addr)
protected void	GossipRouter.route(java.lang.String group, Address dest, byte[] msg, int offset, int length)
void	RouterStub.sendToAllMembers(java.lang.String group, Address sender, byte[] data, int offset, int length)
protected void	GossipRouter.sendToMember(Address dest, byte[] buf, int offset, int len)
protected void	GossipRouter.sendToMember(Address dest, GossipData request)
void	RouterStub.sendToMember(java.lang.String group, Address dest, Address sender, byte[] data, int offset, int length)
GossipData	GossipData.setSender(Address s)

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

Modifier and Type	Method	Description
java.util.List<Address>	LargestWinningPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Called when a merge happened.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews)	Compute a new membership based on a number of subviews
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects)	Computes a new membership based on existing, joining, leaving and suspected members.
protected void	GossipRouter.sendToAllMembersInGroup(java.util.Set<java.util.Map.Entry<Address,GossipRouter.Entry>> dests, byte[] buf, int offset, int len)
protected void	GossipRouter.sendToAllMembersInGroup(java.util.Set<java.util.Map.Entry<Address,GossipRouter.Entry>> dests, GossipData request)

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

Constructor	Description
Entry(Address client_addr, PhysicalAddress phys_addr, java.lang.String logical_name)
GossipData(GossipType type, java.lang.String group, Address addr)
GossipData(GossipType type, java.lang.String group, Address addr, byte[] buffer)
GossipData(GossipType type, java.lang.String group, Address addr, byte[] buffer, int offset, int length)
GossipData(GossipType type, java.lang.String group, Address addr, java.lang.String logical_name, PhysicalAddress physical_addr)
GossipData(GossipType type, java.lang.String group, Address addr, java.util.List<PingData> ping_data)
GossipData(GossipType type, java.lang.String group, Address addr, java.util.List<PingData> ping_data, PhysicalAddress physical_addr)
RouterStubManager(Protocol owner, java.lang.String cluster_name, Address local_addr, java.lang.String logical_name, PhysicalAddress phys_addr, long 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	UUID	Logical address which is unique over space and time.

Fields in org.jgroups.util declared as Address

Modifier and Type	Field	Description
protected Address	Owner.address
protected Address	MessageBatch.dest	The destination address.
protected Address	ForwardQueue.local_addr
protected Address	Digest.Entry.member
protected Address[]	Digest.members
protected Address	ForwardQueue.Flusher.new_coord
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 static LazyRemovalCache<Address,java.lang.String>	NameCache.cache	Keeps track of associations between addresses and logical names
protected java.util.Map<Address,java.lang.Long>	CreditMap.credits
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	ForwardQueue.delivery_table
protected java.util.concurrent.ConcurrentMap<Address,MaxOneThreadPerSender.Entry>	MaxOneThreadPerSender.MessageTable.map
protected java.util.Map<Address,java.util.Queue<Message>>	MessageCache.map
protected java.util.List<Address>	AckCollector.missing_acks	List of members from whom we haven't received an ACK yet
protected static LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<java.lang.String>>	NameCache.print_function
protected java.util.concurrent.ConcurrentMap<Address,RpcStats.Result>	RpcStats.stats
protected java.util.List<Address>	AckCollector.suspected_mbrs

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

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

Methods in org.jgroups.util that return Address

Modifier and Type	Method	Description
static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(java.lang.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	OneTimeAddressGenerator.generateAddress()
Address	Owner.getAddress()
Address	MessageBatch.getDest()
Address	ForwardQueue.getLocalAddr()
Address	Digest.Entry.getMember()
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()
static Address	Util.readAddress(java.io.DataInput in)
static Address[]	Util.readAddresses(java.io.DataInput in)
Address	MessageBatch.sender()

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

Modifier and Type	Method	Description
static java.util.Collection<Address>	Util.determineActualMergeCoords(java.util.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 java.util.List<Address>	Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)	Returns all members that left between 2 views.
static java.util.Collection<Address>	Util.determineMergeCoords(java.util.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 java.util.Collection<Address>	Util.determineMergeParticipants(java.util.Map<Address,View> map)	Determines the members which take part in a merge.
static java.util.Map<Address,java.lang.String>	NameCache.getContents()	Returns a copy of the cache's contents
java.util.List<Tuple<Address,java.lang.Long>>	CreditMap.getMembersWithCreditsLessThan(long min_credits)
java.util.List<Address>	CreditMap.getMembersWithInsufficientCredits(long credit_needed)
java.util.List<Address>	ResponseCollector.getMissing()	Returns a list of members which didn't send a valid response
java.util.Map<Address,T>	ResponseCollector.getResults()
java.util.List<Address>	RspList.getSuspectedMembers()
java.util.List<Address>	ResponseCollector.getValidResults()
java.util.Set<Address>	CreditMap.keys()
static java.util.List<Address>	Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
static java.util.List<Address>	Util.newMembers(java.util.List<Address> old_list, java.util.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)
MessageCache	MessageCache.add(Address sender, Message msg)
static void	NameCache.add(Address uuid, java.lang.String logical_name)
boolean	ResponseCollector.add(Address member, T data)
boolean	ResponseCollectorTask.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(java.util.Collection<Address> members, Address... exclude)
protected void	AckCollector.addAll(Address... members)
RspList<T>	RspList.addRsp(Address sender, T retval)
protected void	RpcStats.addToResults(Address dest, boolean sync, long time)
static void	Util.bufferToArray(Address sender, java.nio.ByteBuffer buf, Receiver target)
protected boolean	ForwardQueue.canDeliver(Address sender, long seqno)	Checks if seqno has already been received from sender.
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)
protected void	ForwardQueue.doFlush(Address new_target)
java.util.Collection<Message>	MessageCache.drain(Address sender)
protected int	Digest.find(Address mbr)
PingData	Responses.findResponseFrom(Address mbr)
void	ForwardQueue.flush(Address new_target, java.util.List<Address> mbrs)
protected void	ForwardQueue.flushMessagesInForwardTable(Address target)	Sends all messages currently in forward_table to the new target (changing the dest field).
java.lang.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 dest, Address sender)
static java.lang.String	NameCache.get(Address logical_addr)
static int	Util.getRank(java.util.Collection<Address> members, Address addr)
static int	Util.getRank(View view, Address addr)	Returns the rank of a member in a given view
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)
java.lang.Long	CreditMap.putIfAbsent(Address key)
java.lang.Long	CreditMap.remove(Address key)
static void	NameCache.remove(Address addr)
java.lang.Long	NonBlockingCreditMap.remove(Address key)
void	ResponseCollector.remove(Address member)
void	CreditMap.replenish(Address sender, long new_credits)
void	NonBlockingCreditMap.replenish(Address sender, long new_credits)
AckCollector	AckCollector.reset(java.util.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)
MutableDigest	MutableDigest.set(Address member, long highest_delivered_seqno, long highest_received_seqno)
MessageBatch	MessageBatch.setDest(Address dest)
void	ForwardQueue.setLocalAddr(Address local_addr)
MessageBatch	MessageBatch.setSender(Address sender)
static int	Util.size(Address addr)
static long	Util.size(Address[] addrs)
protected void	ForwardQueue.startFlusher(Address new_coord)
void	AckCollector.suspect(Address member)
void	AckCollector.suspect(Address... members)
void	ResponseCollector.suspect(Address member)
java.lang.String	Digest.toString(Address[] order, boolean print_highest_received)
static void	Util.writeAddress(Address addr, java.io.DataOutput out)
static void	Util.writeAddresses(Address[] addrs, java.io.DataOutput out)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> msgs, java.io.DataOutput dos, boolean multicast, short transport_id)	Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, java.io.DataOutput dos, boolean multicast)

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

Modifier and Type	Method	Description
void	AckCollector.ack(java.util.Collection<Address> members)
static void	NameCache.add(java.util.Map<Address,java.lang.String> map)
protected void	AckCollector.addAll(java.util.Collection<Address> members)
protected void	AckCollector.addAll(java.util.Collection<Address> members, java.util.Collection<Address> exclude)
protected void	AckCollector.addAll(java.util.Collection<Address> members, Address... exclude)
void	RpcStats.addAnycast(boolean sync, long time, java.util.Collection<Address> dests)
static byte[]	Util.collectionToByteBuffer(java.util.Collection<Address> c)
protected void	Digest.createArrays(java.util.Map<Address,long[]> map)
static java.util.List<View>	Util.detectDifferentViews(java.util.Map<Address,View> map)
static java.util.Collection<Address>	Util.determineActualMergeCoords(java.util.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 java.util.List<Address>	Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)	Returns all members that left between 2 views.
static java.util.Collection<Address>	Util.determineMergeCoords(java.util.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 java.util.Collection<Address>	Util.determineMergeParticipants(java.util.Map<Address,View> map)	Determines the members which take part in a merge.
void	ForwardQueue.flush(Address new_target, java.util.List<Address> mbrs)
static int	Util.getRank(java.util.Collection<Address> members, Address addr)
static java.util.List<Address>	Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
static java.util.List<Address>	Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
void	ResponseCollector.remove(java.util.List<Address> members)
static void	NameCache.removeAll(java.util.Collection<Address> mbrs)
void	AckCollector.reset(java.util.Collection<Address> members)
AckCollector	AckCollector.reset(java.util.Collection<Address> expected_acks, java.util.Collection<Address> exclude)
AckCollector	AckCollector.reset(java.util.Collection<Address> expected_acks, Address... exclude)
void	ResponseCollector.reset(java.util.Collection<Address> members)
boolean	AckCollector.retainAll(java.util.Collection<Address> members)
static void	NameCache.retainAll(java.util.Collection<Address> logical_addrs)
boolean	ResponseCollector.retainAll(java.util.List<Address> members)
boolean	ResponseCollectorTask.retainAll(java.util.List<Address> members)
void	RpcStats.retainAll(java.util.Collection<Address> members)
static long	Util.size(java.util.Collection<? extends Address> addrs)	Returns the marshalled size of a Collection of Addresses.
static boolean	Util.startFlush(JChannel c, java.util.List<Address> flushParticipants)	Performs the flush of the given channel and the specified flush participants
static boolean	Util.startFlush(JChannel c, java.util.List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)	Performs the flush of the given channel for the specified flush participants and the given number of attempts along with random sleep time after each such attempt.
void	AckCollector.suspect(java.util.Collection<Address> members)
protected void	MaxOneThreadPerSender.MessageTable.viewChange(java.util.List<Address> mbrs)
void	MaxOneThreadPerSender.viewChange(java.util.List<Address> members)
static void	Util.writeAddresses(java.util.Collection<? extends Address> v, java.io.DataOutput out)	Writes a list of Addresses.

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

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 highest_delivered, long highest_received)
Flusher(Address new_coord)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs, java.util.function.Predicate<Message> filter)
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)
ResponseCollectorTask(Address... members)

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

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