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.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.cs
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.fork
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.dns
org.jgroups.protocols.pbcast
org.jgroups.protocols.relay
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

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

Classes in org.jgroups that implement Address

Modifier and Type	Class	Description
class	NullAddress

Fields in org.jgroups declared as Address

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

Fields in org.jgroups with type parameters of type Address

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

Methods in org.jgroups that return Address

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

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

Modifier and Type	Method	Description
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
Membership	Membership.add(Address new_member)	Adds a new member to this membership.
Membership	Membership.add(Address... mbrs)
int	NullAddress.compareTo(Address that)
JChannel	JChannel.connect(java.lang.String cluster_name, Address target, long timeout)	Joins the cluster and gets the state from a specified state provider. This method invokes connect and getState methods.
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)
default Message	Message.dest(Address new_dest)
protected int	MergeView.get(Address member)
Address	Membership.getNext(Address mbr)	Returns the members next to mbr.
Address	Membership.getPrevious(Address mbr)	Returns the members to the left of mbr
JChannel	JChannel.getState(Address target, long timeout)	Retrieves the full state from the target member. The state transfer is initiated by invoking getState() on this channel.
boolean	Membership.isCoord(Address mbr)
static java.lang.String	View.printDiff(Address[][] diff)
Membership	Membership.remove(Address old_member)	Removes a member from the membership.
JChannel	JChannel.send(Address dst, byte[] buf)	Sends a message.
JChannel	JChannel.send(Address dst, byte[] buf, int offset, int length)	Sends a message to a destination.
JChannel	JChannel.send(Address dst, java.lang.Object obj)	Helper method to create a Message with given parameters and invoke JChannel.send(Message).
Message	BaseMessage.setDest(Address new_dest)
Message	Message.setDest(Address new_dest)	Sets the destination address to send the message to.
UpHandler	UpHandler.setLocalAddress(Address a)
BatchMessage	BatchMessage.setOrigSender(Address s)
Message	BaseMessage.setSrc(Address new_src)
Message	Message.setSrc(Address new_src)	Sets the address of the sender of this message
default Message	Message.src(Address new_src)
void	BaseMessage.writeToNoAddrs(Address src, java.io.DataOutput out)
void	Message.writeToNoAddrs(Address src, java.io.DataOutput out)	Writes the message to an output stream excluding the destination (and possibly source) address

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

Modifier and Type	Method	Description
Membership	Membership.add(java.util.Collection<Address> v)	Adds a list of members to this membership
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.

Constructors in org.jgroups with parameters of type Address

Constructor	Description
BaseMessage(Address dest)	Constructs a message given a destination address
BatchMessage(Address dest, int capacity)
BatchMessage(Address dest, Address src, Message[] msgs, int index)
BytesMessage(Address dest)	Constructs a message given a destination address
BytesMessage(Address dest, byte[] array)	Constructs a message given a destination and source address and the payload byte array
BytesMessage(Address dest, byte[] array, int offset, int length)	Constructs a message.
BytesMessage(Address dest, java.lang.Object obj)	Constructs a message given a destination and source address and the payload object
BytesMessage(Address dest, ByteArray array)
CompositeMessage(Address dest)
CompositeMessage(Address dest, Message... messages)
EmptyMessage(Address dest)
LongMessage(Address dest, long v)
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)
NioMessage(Address dest)	Constructs a message given a destination address
NioMessage(Address dest, java.nio.ByteBuffer buf)	Constructs a message given a destination and source address and the payload byte buffer
ObjectMessage(Address dest)	Constructs a message given a destination address
ObjectMessage(Address dest, java.lang.Object obj)	Constructs a message given a destination address and the payload object
ObjectMessage(Address dest, SizeStreamable obj)	Constructs a message given a destination address and the payload object
UnreachableException(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
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.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	ReplCache.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()

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

Modifier and Type	Method	Description
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)
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.memberUnreachable(Address mbr)
abstract void	Request.memberUnreachable(Address mbr)
void	UnicastRequest.memberUnreachable(Address mbr)
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 extends Protocol> T	MessageDispatcher.ProtocolAdapter.setAddress(Address addr)
UpHandler	MessageDispatcher.ProtocolAdapter.setLocalAddress(Address a)
RequestCorrelator	RequestCorrelator.setLocalAddress(Address a)
void	RequestCorrelator.setMemberUnreachable(Address mbr)
protected boolean	GroupRequest.setSuspected(Address mbr)
protected boolean	RequestCorrelator.skip(RequestCorrelator.Header hdr, Address sender)

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

Modifier and Type	Method	Description
<T> RspList<T>	RpcDispatcher.callRemoteMethods(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 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, Message msg, RequestOptions options, boolean block_for_results)
<T> RspList<T>	MessageDispatcher.castMessage(java.util.Collection<Address> dests, Message msg, 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, Message msg, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
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	RequestCorrelator.sendAnycastRequest(Message req, java.util.Collection<Address> dest_mbrs)
<T> void	RequestCorrelator.sendMulticastRequest(java.util.Collection<Address> dest_mbrs, Message msg, Request<T> req, RequestOptions opts)	Sends a request to a group.
protected void	GroupRequest.sendRequest(Message msg, java.util.Collection<Address> targetMembers)
protected <X extends MessageDispatcher> X	MessageDispatcher.setMembers(java.util.List<Address> new_mbrs)
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(Protocol down_prot, RequestHandler handler, Address local_addr)	Constructor.
UnicastRequest(RequestCorrelator corr, Address target, RequestOptions options)

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

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()
Address	Connection.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)
boolean	BaseServer.closeConnection(Address addr)
boolean	BaseServer.closeConnection(Address addr, boolean notify)
abstract void	Connection.connect(Address dest)
void	NioConnection.connect(Address dest)
protected void	NioConnection.connect(Address dest, boolean send_local_addr)
void	TcpConnection.connect(Address dest)
protected void	TcpConnection.connect(Address dest, boolean send_local_addr, boolean use_acks)
boolean	BaseServer.connectionEstablishedTo(Address address)
protected abstract Connection	BaseServer.createConnection(Address dest)	Creates a new connection object to target dest, but doesn't yet connect it
protected NioConnection	NioBaseServer.createConnection(Address dest)
protected TcpConnection	TcpBaseServer.createConnection(Address dest)
void	BaseServer.flush(Address dest)
Connection	BaseServer.getConnection(Address dest)	Creates a new connection to dest, or returns an existing one
Connection	BaseServer.getConnection(Address dest, boolean retry)
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
default void	Receiver.receive(Address sender, java.io.DataInput in)	Deprecated, for removal: This API element is subject to removal in a future version.
default void	Receiver.receive(Address sender, java.io.DataInput in, int length)	Receive data from the given sender
default 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	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 our port number.
protected <T> boolean	BaseServer.validateArgs(Address dest, T buffer)

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

Modifier and Type	Method	Description
void	BaseServer.forAllConnections(java.util.function.BiConsumer<Address,Connection> c)
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 to a remote peer, use TcpConnection.connect(Address) to connect
TcpConnectionNonBlocking(Address peer_addr, TcpBaseServer server)

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, int length)
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, int length)
void	PubServer.receive(Address sender, java.nio.ByteBuffer buf)

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.fork

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)

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
protected Address	COUNTER.coord	The address of the cluster coordinator.
protected Address	SEQUENCER.coord
protected Address	SEQUENCER2.coord
protected Address	Discovery.current_coord
protected Address	FD_SOCK2.PingDest.dest
protected Address	ASYM_ENCRYPT.key_server_addr
protected Address	BatchBundler.local_addr
protected Address	PerDestinationBundler.local_addr
protected Address	PDC.Mapping.logical_addr
protected Address	FD_SOCK.FdHeader.mbr
protected Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected static Address	PerDestinationBundler.NULL
protected static Address	STATS.NULL_DEST
protected Address	DAISYCHAIN.DaisyHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD_SOCK.ping_dest
protected Address	NakAckHeader.sender
protected Address	PingData.sender
protected Address	EncryptHeader.server
protected Address	FD_SOCK2.FdHeader.srv
protected Address	FD_SOCK2.Request.suspect
protected Address	VERIFY_SUSPECT.Entry.suspect
protected Address	VERIFY_SUSPECT2.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.Map<Address,MessageBatch>	ReliableMulticast.batches
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,PerDestinationBundler.SendBuffer>	PerDestinationBundler.dests
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_SOCK2.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>	FRAG.members
protected java.util.List<Address>	FRAG2.members
protected java.util.List<Address>	FRAG3.members
protected java.util.List<Address>	ReliableMulticast.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,org.jgroups.protocols.TransferQueueBundler2.Buffer>	TransferQueueBundler2.messages
protected java.util.Map<Address,BATCH.Buffer>	BATCH.msgMap
protected java.util.Map<Address,BATCH2.Buffer>	BATCH2.msgMap
protected java.util.concurrent.ConcurrentMap<Address,BatchBundler.Buffer>	BatchBundler.msgMap
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 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.ConcurrentMap<Address,MsgStats>	STATS.received	Maintains stats per receiver
protected java.util.Map<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,UNICAST3.SenderEntry>	UNICAST3.send_table
protected java.util.concurrent.ConcurrentMap<Address,MsgStats>	STATS.sent	Maintains stats per target destination
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 java.util.Map<Address,java.lang.Long>	ReliableMulticast.stable_xmit_map
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 SuppressLog<Address>	ReliableMulticast.suppress_log_non_member	Log to suppress identical warnings for messages from non-members
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.Set<Address>	FD_SOCK.BroadcastTask.suspects
protected java.util.Set<Address>	FD_SOCK2.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,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,Buffer<Message>>	ReliableMulticast.xmit_table	Map to store sent and received messages (keyed by sender)
protected java.util.Map<Address,java.lang.Long>	ReliableMulticast.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539)
protected java.util.Map<Address,java.lang.Long>	UNICAST3.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per member (applicable only for received messages (ReceiverEntry)): https://issues.redhat.com/browse/JGRP-1539

Methods in org.jgroups.protocols that return Address

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

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()
LazyRemovalCache<Address,PhysicalAddress>	TP.getLogicalAddressCache()
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)
boolean	SimpleTCP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
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 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 void	FD_SOCK2.broadcastUnuspectMessage(Address mbr)
protected static void	ASYM_ENCRYPT.cacheServerAddress(Address srv)
protected boolean	SEQUENCER.canDeliver(Address sender, long seqno)	Checks if seqno has already been received from sender.
void	FRAG2.clearFragmentsFor(Address mbr)
void	FRAG3.clearFragmentsFor(Address mbr)
void	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 boolean	FD_SOCK2.connectTo(Address new_ping_dest, Membership mbrs)
protected boolean	FD_SOCK2.connectTo(IpAddress dest, Address logical_addr)
protected void	FD_SOCK2.connectToNextPingDest(Address already_suspect)
protected boolean	JDBC_PING.contains(java.lang.String cluster_name, Address addr)
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id, Address dest)
protected javax.net.ssl.SSLSocket	SSL_KEY_EXCHANGE.createSocketTo(Address target)
static NakAckHeader	NakAckHeader.createXmitRequestHeader(Address orginal_sender)
protected void	JDBC_PING2.delete(java.lang.String clustername, Address addressToDelete)
protected void	JDBC_PING2.delete(java.sql.Connection conn, java.lang.String clustername, Address addressToDelete)
protected void	ReliableMulticast.deliver(Message msg, Address sender, long seqno, Buffer<Message> win, java.lang.String error_msg)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
protected Message	SERIALIZE.deserialize(Address sender, byte[] buf, int offset, int length)
protected FD_SOCK2.PingDest	FD_SOCK2.PingDest.dest(Address d)
protected boolean	FD_SOCK2.PingDest.destChanged(Address a)
void	Discovery.discoveryRequestReceived(Address sender, 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	COUNTER.AddAndGetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.CompareAndSetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.DeleteRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.GetOrCreateRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.ReconcileRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.Request.execute(COUNTER protocol, Address sender)
void	COUNTER.ResendPendingRequests.execute(COUNTER protocol, Address sender)
void	COUNTER.SetRequest.execute(COUNTER protocol, Address sender)
void	COUNTER.UpdateRequest.execute(COUNTER protocol, Address sender)
void	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)
Digest	ReliableMulticast.getDigest(Address mbr)
protected java.net.InetAddress	FD_HOST.getHostFor(Address mbr)
protected PhysicalAddress	FD_HOST.getPhysicalAddress(Address logical_addr)
protected java.util.List<IpAddress>	FD_SOCK2.getPhysicalAddresses(Address a)	Returns the physical addresses for in range [a+offset..a+offset+port_range
PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
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, Address dest)
long	UFC.getSenderCreditsFor(Address mbr)
protected UNICAST3.SenderEntry	UNICAST3.getSenderEntry(Address dst)
Table<Message>	UNICAST3.getSendWindow(Address target)	Used for testing only!
<T extends Buffer<Message>> T	ReliableMulticast.getWindow(Address sender)	Returns the receive window for sender; only used for testing.
protected void	DH_KEY_EXCHANGE.handle(DH_KEY_EXCHANGE.DhHeader hdr, Address sender)
protected java.lang.Object	FD_SOCK2.handle(FD_SOCK2.FdHeader hdr, Address sender)
protected void	NAKACK4.handleAck(Address sender, long ack)
protected void	ReliableMulticast.handleAck(Address sender, long ack)
protected void	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, Address original_dest)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	MFC.handleCredit(Address sender, long increase)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(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(java.util.List<PingData> data, Address sender)
protected void	Discovery.handleDiscoveryResponse(PingData data, Address sender)
protected void	ReliableMulticast.handleHighestSeqno(Address sender, long seqno)	Compares the sender's highest seqno with my highest seqno: if the sender's is higher, ask sender for retransmission
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender, int timestamp)	We need to resend the first message with our conn_id
protected void	COUNTER.handleResponse(org.jgroups.protocols.COUNTER.Response rsp, Address sender)
protected void	RSVP.handleResponse(Address member, short id)
protected void	DH_KEY_EXCHANGE.handleSecretKeyRequest(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	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
protected void	ReliableMulticast.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender)	Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
protected void	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	UNICAST3.isLocal(Address addr)
boolean	LocalTransport.isLocalMember(Address addr)	Returns true if addr is a local member, false otherwise
protected boolean	UNICAST3.isLocalSiteMaster(Address dest)
protected boolean	FD_HOST.isPinger(Address mbr)
boolean	UFC_NB.isQueuingTo(Address dest)
ASYM_ENCRYPT	ASYM_ENCRYPT.keyServerAddr(Address ks)
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)
void	FD_SOCK2.receive(Address sender, byte[] buf, int offset, int length)
void	FD_SOCK2.receive(Address sender, java.io.DataInput in, int length)
void	TP.receive(Address sender, byte[] data, int offset, int length)	Subclasses must call this method when a unicast or multicast message has been received.
void	TP.receive(Address sender, java.io.DataInput in, int ignoredLength)
MsgStats	MsgStats.received(Address dest, int length)
protected static void	SHARED_LOOPBACK.register(AsciiString cluster, Address local_addr, SHARED_LOOPBACK shared_loopback)
protected void	TP.registerLocalAddress(Address addr)	Associates the address with the physical address fetched from the cache
protected void	FILE_PING.remove(java.lang.String clustername, Address addr)
protected void	JDBC_PING.remove(java.lang.String clustername, Address addr)
protected void	JDBC_PING2.remove(java.lang.String clustername, Address addr)
protected void	RACKSPACE_PING.remove(java.lang.String clustername, Address addr)
protected void	SWIFT_PING.remove(java.lang.String clustername, Address addr)
protected void	ReliableMulticast.removeAndDeliver(Buffer<Message> win, Address sender, boolean loopback, AsciiString cluster)	Efficient way of checking whether another thread is already processing messages from sender.
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)
void	UNICAST3.removeReceiveConnection(Address mbr)
void	UNICAST3.removeSendConnection(Address mbr)
protected void	FD_SOCK2.BroadcastTask.removeSuspect(Address suspect)
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
protected boolean	VERIFY_SUSPECT2.removeSuspect(Address suspect)
protected void	FD_SOCK.BroadcastTask.removeSuspectedMember(Address suspected_mbr)
void	MFC.replenish(Address mbr, long credits)
protected void	ReliableMulticast.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	ReliableMulticast.retransmit(SeqnoList missing_msgs, Address sender, boolean multicast_xmit_request)
protected void	UNICAST3.retransmit(SeqnoList missing, Address sender, Address real_dest)	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, ByteArray buffer)
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	NAKACK4.sendAck(Address to, Buffer<Message> win)
protected void	ReliableMulticast.sendAck(Address to, Buffer<Message> win)
protected void	UNICAST3.sendAck(Address dst, long seqno, short conn_id, Address real_dest)
protected void	PerDestinationBundler.SendBuffer.sendBatch(Address destination, FastArray<Message> list)
void	UNICAST3.sendClose(Address dest, short conn_id)
protected void	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, java.lang.String counter_name)
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, long credits_needed)	We cannot send this request as OOB message, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected void	Discovery.sendDiscoveryResponse(java.util.List<PingData> list, Address sender)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name, Address sender, boolean coord)
protected void	FD_SOCK.sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr)	Sends or broadcasts a I_HAVE_SOCK response.
protected void	AUTH.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	BaseBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)
protected void	BatchBundler.Buffer.sendMessageList(Address dest, Address src, Message[] list, int length)
protected void	PerDestinationBundler.SendBuffer.sendMessageList(Address dest, Address src, FastArray<Message> list)
protected void	RemoveQueueBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)
protected void	PerDestinationBundler.SendBuffer.sendMessages(Address dest, Address src, FastArray<Message> list)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest, Address original_dest)
protected void	COUNTER.sendResponse(Address dest, org.jgroups.protocols.COUNTER.Response<?> rsp)
protected void	RSVP.sendResponse(Address dest, short id)
protected void	SEQUENCER2.sendSeqnoResponse(Address original_sender, long seqno, int num_seqnos)
protected void	PerDestinationBundler.SendBuffer.sendSingleMessage(Address dest, Message msg)
void	LocalTransport.sendTo(Address dest, byte[] buf, int offset, int length)	Sends a message to a given local member.
protected void	SHARED_LOOPBACK.sendTo(Address dest, byte[] buf, int offset, int length)
protected void	SimpleTCP.sendTo(Address dest, byte[] buffer, int offset, int length)
protected void	TP.sendTo(Address dest, byte[] buf, int offset, int length)
protected void	TUNNEL.sendTo(Address dest, byte[] buf, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToAllMembers(java.lang.String group, Address sender, byte[] data, 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	ReliableMulticast.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
MsgStats	MsgStats.sent(Address dest, int length)
protected void	ASYM_ENCRYPT.serializeKeys(ByteArrayDataOutputStream out, boolean serialize_shared_keys, Address serialize_only)	Serializes all public keys and their corresponding encrypted shared group keys into a buffer
EncryptHeader	EncryptHeader.server(Address s)
FD_SOCK2.FdHeader	FD_SOCK2.FdHeader.serverAddress(Address a)
DISCARD	DISCARD.setAddress(Address localAddress)
<T extends Protocol> T	FORK.setAddress(Address addr)
<T extends Protocol> T	TP.setAddress(Address addr)
protected void	TP.setInAllThreadFactories(java.lang.String cluster_name, Address local_address, java.lang.String pattern)
DAISYCHAIN.DaisyHeader	DAISYCHAIN.DaisyHeader.setOriginalSender(Address s)
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender)	Checks if a message should be passed up, or not
protected void	SEQUENCER.startFlusher(Address new_coord)
boolean	TP.unicastDestMismatch(Address dest)
protected void	ReliableMulticast.unknownMember(Address sender, java.lang.Object message)
protected static void	SHARED_LOOPBACK.unregister(AsciiString cluster, Address local_addr)
protected void	ASYM_ENCRYPT.unserializeAndInstallKeys(Address sender, byte[] version, ByteArrayDataInputStream in)	Unserializes public keys and installs them to pub_map, then reads encrypted shared keys and install our own
protected 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_SOCK2.unsuspect(Address mbr)
void	VERIFY_SUSPECT.unsuspect(Address mbr)
void	VERIFY_SUSPECT2.unsuspect(Address mbr)
protected abstract void	FailureDetection.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL2.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL3.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	VERIFY_SUSPECT.verifySuspectWithICMP(Address suspected_mbr)
protected boolean	TP.versionMatch(short version, Address sender)
protected void	FILE_PING.writeAll(Address[] excluded_mbrs)
protected void	PDC.writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr)
protected 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 void	FD_SOCK2.BroadcastTask.addSuspects(java.util.List<Address> mbrs)
protected boolean	VERIFY_SUSPECT.addSuspects(java.util.Collection<Address> list)	Adds suspected members to the suspect list.
protected boolean	VERIFY_SUSPECT2.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	NAKACK4.adjustReceivers(java.util.List<Address> members)
protected void	ReliableMulticast.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).
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	FD_SOCK2.BroadcastTask.adjustSuspects(java.util.List<Address> mbrs)	Removes all elements from suspects that are not in the new membership
protected void	FD_SOCK2.broadcastSuspectMessage(java.util.List<Address> suspected_members)	Sends a SUSPECT message to all group members.
protected void	Discovery.callFindMembersInAllDiscoveryProtocols(java.util.List<Address> mbrs, boolean initial_discovery, Responses rsps)	Calls Discovery.findMembers(List, boolean, Responses) in this protocol and all discovery protocols below
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)
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 void	FlowControl.handleCreditRequest(java.util.Map<Address,Credit> map, Address sender, long requested_credits)
protected void	BATCH.handleViewChange(java.util.List<Address> mbrs)
protected void	BATCH2.handleViewChange(java.util.List<Address> mbrs)
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)
static ByteArray	FD_SOCK.marshal(LazyRemovalCache<Address,IpAddress> addrs)
FD_SOCK.FdHeader	FD_SOCK.FdHeader.mbrs(java.util.Set<Address> members)
FD_SOCK2.FdHeader	FD_SOCK2.FdHeader.mbrs(java.util.Collection<Address> m)
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	JDBC_PING2.readAll(java.util.List<Address> members, java.lang.String cluster, Responses rsps)
protected void	RACKSPACE_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	SWIFT_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
void	UNICAST3.removeSendConnection(java.util.function.Predicate<Address> pred)
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 static ByteArray	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	FD_SOCK2.suspect(java.util.Collection<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
protected void	VERIFY_SUSPECT2.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
Buffer(Address address)
Buffer(Address address)
Buffer(Address address)
DaisyHeader(Address original_sender)
Entry(Address member)	Unicast entry
Entry(Address suspect, long target_time)
Entry(Address suspect, long target_time)
FdHeader(byte type, Address mbr)
FdHeader(byte type, Address mbr, IpAddress sock_addr)
Flusher(Address new_coord)
Mapping(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name)
PingData(Address sender, boolean is_server)
PingData(Address sender, boolean is_server, java.lang.String logical_name, PhysicalAddress physical_addr)
ReceiverEntry(Table<Message> received_msgs, short recv_conn_id, Address real_dest)
Request(FD_SOCK2.Request.Type type, Address suspect)
SendBuffer(Address dest)

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

Uses of Address in org.jgroups.protocols.dns

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

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

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.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 java.util.Map<Address,java.lang.Long>	NAKACK2.stable_xmit_map
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.redhat.com/browse/JGRP-1539)

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

Modifier and Type	Method	Description
protected Address	GMS.determineCoordinator()
protected Address	STATE_TRANSFER.determineCoordinator()	Return the first element of members which is not me.
protected Address	StreamingStateTransfer.determineCoordinator()
protected Address	Merger.determineMergeLeader(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)

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	STABLE.handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)
protected void	STABLE.handleStableMessage(Digest d, Address sender, ViewId view_id)	Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
protected void	STATE.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	StreamingStateTransfer.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE_SOCK.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateRsp(Digest digest, Address sender, byte[] state)	Set the digest and the send the state up to the application
protected void	StreamingStateTransfer.handleStateRsp(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	NAKACK2.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender)	Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
void	ClientGmsImpl.join(Address address)
void	CoordGmsImpl.join(Address ignored)
abstract void	GmsImpl.join(Address mbr)
void	ParticipantGmsImpl.join(Address ignored)
protected void	ClientGmsImpl.joinInternal(Address mbr, boolean joinWithStateTransfer)	Makes this process join a group.
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr)
void	CoordGmsImpl.joinWithStateTransfer(Address ignored)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr)
void	ParticipantGmsImpl.joinWithStateTransfer(Address ignored)
GMS.GmsHeader	GMS.GmsHeader.mbr(Address mbr)
protected void	STATE_TRANSFER.punchHoleFor(Address member)
protected void	StreamingStateTransfer.punchHoleFor(Address member)
protected void	NAKACK2.removeAndDeliver(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster_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, 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(ByteArray marshalled_rsp, Address dest)
protected void	Leaver.sendLeaveRequest(Address coord, Address leaving_mbr)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id)	Send back a response containing view and digest to sender
protected void	GMS.sendViewAck(Address dest)
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
protected void	StreamingStateTransfer.setStateInApplication(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)
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 ByteArray	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://issues.redhat.com/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)	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)
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)

Uses of Address in org.jgroups.protocols.relay

Subinterfaces of Address in org.jgroups.protocols.relay

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

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

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

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

Modifier and Type	Field	Description
protected Address	RelayHeader.final_dest
protected Address	RelayHeader.original_sender
protected 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.function.Supplier<Address>	DefaultRouteStatusListener.addr_getter
protected java.util.function.Supplier<Address>	RandomSiteMasterPicker.addr_supplier
protected java.util.Map<Address,Address>	StickySiteMasterPicker.local_sm_cache
protected java.util.Map<Address,Address>	StickySiteMasterPicker.local_sm_cache
protected java.util.List<Address>	RELAY.members
protected java.util.Map<Address,Route>	StickySiteMasterPicker.route_cache
protected java.util.List<Address>	RELAY.site_masters

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

Modifier and Type	Method	Description
Address	DefaultRouteStatusListener.addr()
protected Address	RELAY3.checkLocalAddress(Address dest)
Address	RelayHeader.getFinalDest()
Address	RelayHeader.getOriginalSender()
Address	RandomSiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)
protected Address	RELAY.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	StickySiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)
Address	Route.siteMaster()

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

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

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

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

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

Modifier and Type	Method	Description
SiteMasterPicker	RandomSiteMasterPicker.addressSupplier(java.util.function.Supplier<Address> s)
Address	RandomSiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)
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	StickySiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender)

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

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

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

Constructor	Description
DefaultRouteStatusListener(java.util.function.Supplier<Address> s)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

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

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
protected Address	GossipRouter.Entry.client_addr
protected Address	Protocol.local_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.Map<java.lang.String,java.util.concurrent.ConcurrentMap<Address,GossipRouter.Entry>>	GossipRouter.address_mappings
protected java.util.Map<Address,ByteArrayDataOutputStream>	GossipRouter.output_streams

Methods in org.jgroups.stack that return Address

Modifier and Type	Method	Description
Address	Protocol.addr()
Address	AddressGenerator.generateAddress()	Deprecated.
default Address	AddressGenerator.generateAddress(java.lang.String name)
Address	GossipData.getAddress()
Address	Protocol.getAddress()
Address	GossipData.getSender()
Address	GossipRouter.localAddress()

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

Modifier and Type	Method	Description
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)
<T extends Protocol> T	Protocol.addr(Address addr)
int	IpAddress.compareTo(Address o)	implements the java.lang.Comparable interface
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 ByteArrayDataOutputStream	GossipRouter.getOutputStream(Address mbr, int size)
protected void	GossipRouter.handleGetMembersRequest(Address sender, java.io.DataInput in)
protected void	GossipRouter.handleHeartbeat(Address sender)
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, int length)
void	GossipRouter.receive(Address sender, java.nio.ByteBuffer buf)
void	RouterStub.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, java.io.DataInput in, int length)
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)
protected void	GossipRouter.route(java.lang.String group, Address dest, java.nio.ByteBuffer buf)
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, java.nio.ByteBuffer buf)
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)
<T extends Protocol> T	Protocol.setAddress(Address addr)
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, java.nio.ByteBuffer buf)
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(Log log, TimeScheduler timer, java.lang.String cluster_name, Address local_addr, java.lang.String logical_name, PhysicalAddress phys_addr, long reconnect_interval)
StateTransferInfo(Address target)
StateTransferInfo(Address target, long timeout)
StateTransferInfo(Address target, long timeout, byte[] state)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

Modifier and Type	Class	Description
class	ExtendedUUID	Subclass of UUID accommodating additional data such as a flag and a small hashmap.
class	FlagsUUID	Subclass of UUID accommodating additional data such as a flag.
class	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	ThreadPool.address
protected Address	MessageBatch.dest	The destination address.
protected Address	Digest.Entry.member
protected Address[]	Digest.members
protected Address	MaxOneThreadPerSender.Entry.sender
protected Address	MessageBatch.sender	The sender of the message batch

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

Modifier and Type	Field	Description
protected java.util.Map<Address,java.lang.Long>	AckTable.acks
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,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.Map<Address,RpcStats.RTTStat>	RpcStats.rtt_stats
protected java.util.Map<Address,AverageMinMax>	RTT.rtts
protected java.util.Map<Address,RpcStats.Result>	RpcStats.stats
protected java.util.Map<Address,long[]>	RTT.times

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.addressFromString(java.lang.String s)
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	ThreadPool.getAddress()
Address	MessageBatch.getDest()
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
java.util.Map<Address,AverageMinMax>	RTT._rtt(int num_reqs, int size, boolean exclude_self)
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()
static java.util.Map<java.lang.String,java.util.List<Address>>	Util.getSites(View bridge_view, java.lang.String excluding_site)
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)
long	AckTable.ack(Address sender, long seqno)	Adds an ACK from a sender to the map.
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)
static java.lang.String	Util.addressToString(Address addr)
RspList<T>	RspList.addRsp(Address sender, T retval)
void	RpcStats.addRTTStats(Address sender, RTTHeader hdr)
protected void	RpcStats.addToResults(Address dest, boolean sync, long time)
static void	Util.bufferToArray(Address sender, java.nio.ByteBuffer buf, Receiver target)
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)
java.util.Collection<Message>	MessageCache.drain(Address sender)
protected int	Digest.find(Address mbr)
PingData	Responses.findResponseFrom(Address mbr)
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 sender, boolean multicast)
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
protected void	RTT.handleRequest(Address sender, TpHeader hdr)
protected void	RTT.handleResponse(Address sender, int index)
boolean	Responses.isCoord(Address addr)
static boolean	Util.isCoordinator(View view, Address local_addr)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
MutableDigest	MutableDigest.merge(Address member, long highest_delivered_seqno, long highest_received_seqno)	Similar to set(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno)
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)
static void	Util.removeFromViews(Address mbr, JChannel... channels)
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)
MessageBatch	MessageBatch.set(Address dest, Address sender, Message[] msgs)
MutableDigest	MutableDigest.set(Address member, long highest_delivered_seqno, long highest_received_seqno)
ThreadPool	ThreadPool.setAddress(Address a)
MessageBatch	MessageBatch.setDest(Address dest)
MessageBatch	MessageBatch.setSender(Address sender)
static int	Util.size(Address addr)
static long	Util.size(Address[] addrs)
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)	Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, Message[] msgs, int offset, int length, java.io.DataOutput dos, boolean multicast)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, FastArray<Message> msgs, java.io.DataOutput dos, boolean multicast)
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)
AckTable	AckTable.adjust(java.util.List<Address> mbrs)	Removes left members from and adds new members to the map
static byte[]	Util.collectionToByteBuffer(java.util.Collection<Address> c)
protected void	Digest.createArrays(java.util.Map<Address,long[]> 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.
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.
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)
Entry(Address sender, boolean mcast, AsciiString cluster_name)
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, 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)