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.tests
org.jgroups.tests.perf
org.jgroups.tests.rt.transports
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 final Address	UnreachableException.member
protected Address[]	View.members	An array containing all the members of the view.
static final Address	Global.NULL_ADDRESS
protected Address	BatchMessage.orig_src
protected Address	BaseMessage.sender

Fields in org.jgroups with type parameters of type Address

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

Methods in org.jgroups that return Address

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

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

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

Methods in org.jgroups with parameters of type Address

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

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

Modifier and Type	Method	Description
Membership	Membership.add(Collection<Address> v)	Adds a list of members to this membership
static View	View.create(Address coord, long id, Collection<Address> members)
Membership	Membership.merge(Collection<Address> new_mems, Collection<Address> suspects)	Merges membership with the new members and removes suspects.
Membership	Membership.remove(Collection<Address> v)	Removes all the members contained in v from this membership
Membership	Membership.retainAll(Collection<Address> v)
Membership	Membership.set(Collection<Address> v)	Clears the membership and adds all members of v This method will clear out all the old members of this membership by invoking the Clear method.
JChannel	JChannel.startFlush(List<Address> flushParticipants, boolean automatic_resume)	Deprecated, for removal: This API element is subject to removal in a future version.
JChannel	JChannel.stopFlush(List<Address> flushParticipants)	Deprecated, for removal: This API element is subject to removal in a future version.

Constructors in org.jgroups with parameters of type Address

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

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

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

Uses of Address in org.jgroups.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
private Address	ReplCache.local_addr
protected Address	RequestCorrelator.local_addr	The address of this group member
protected final Address	UnicastRequest.target

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

Modifier and Type	Field	Description
protected Collection<Address>	MessageDispatcher.members
private final List<Address>	ReplicatedHashMap.members
(package private) final List<Address>	ReplicatedTree.members
private final SortedMap<Short,Address>	ReplCache.ConsistentHashFunction.nodes

Methods in org.jgroups.blocks that return Address

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

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

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

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

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

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

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

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

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

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

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

Uses of Address in org.jgroups.blocks.cs

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

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

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

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

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

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

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

Modifier and Type	Method	Description
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, DataInput in, int len)
void	BaseServer.receive(Address sender, ByteBuffer buf)	Called by a Connection implementation when a message has been received
void	Receiver.receive(Address sender, byte[] buf, int offset, int length)	Delivers a message from a given sender to the application
default void	Receiver.receive(Address sender, DataInput in)	Deprecated, for removal: This API element is subject to removal in a future version.
default void	Receiver.receive(Address sender, DataInput in, int length)	Receive data from the given sender
default void	Receiver.receive(Address sender, ByteBuffer buf)	Delivers a message from a given sender to the application
void	ReceiverAdapter.receive(Address sender, byte[] buf, int offset, int length)
void	BaseServer.removeConnectionIfPresent(Address address, Connection conn)	Only removes the connection if conns.get(address) == conn
void	BaseServer.replaceConnection(Address address, Connection conn)
void	BaseServer.send(Address dest, byte[] data, int offset, int length)
void	BaseServer.send(Address dest, ByteBuffer data)
void	NioClient.send(Address dest, byte[] data, int offset, int length)
void	NioClient.send(Address dest, ByteBuffer data)
void	TcpClient.send(Address dest, byte[] data, int offset, int length)
void	TcpClient.send(Address dest, 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(BiConsumer<Address,Connection> c)
void	BaseServer.retainAll(Collection<Address> current_mbrs)	Removes all connections which are not in current_mbrs

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

Modifier	Constructor	Description
	NioConnection(Address peer_addr, NioBaseServer server)	Creates a connection stub and binds it, use NioConnection.connect(Address) to connect
	TcpConnection(Address peer_addr, TcpBaseServer server)	Creates a connection to a remote peer, use TcpConnection.connect(Address) to connect
	TcpConnectionNonBlocking(Address peer_addr, TcpBaseServer server, int max_size)

Uses of Address in org.jgroups.demos

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

Modifier and Type	Field	Description
private final List<Address>	Draw.members
private final List<Address>	Topology.members

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

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

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

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

Uses of Address in org.jgroups.fork

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

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

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

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

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
protected Address	CENTRAL_LOCK.coord	Deprecated.
protected Address	CENTRAL_LOCK2.coord	Deprecated.
protected Address	COUNTER.coord	The address of the cluster coordinator.
protected Address	SEQUENCER.coord
protected Address	SEQUENCER2.coord
protected Address	Discovery.current_coord
private final Address	BATCH.Buffer.dest
private final Address	BATCH2.Buffer.dest
private final Address	BatchBundler.Buffer.dest
protected Address	FD_SOCK2.PingDest.dest
private final Address	PerDestinationBundler.SendBuffer.dest
(package private) Address	VERIFY_SUSPECT.VerifyHeader.from
(package private) Address	VERIFY_SUSPECT2.VerifyHeader.from
protected Address	ASYM_ENCRYPT.key_server_addr
protected Address	BatchBundler.local_addr
protected Address	PerDestinationBundler.local_addr
protected Address	PDC.Mapping.logical_addr
(package private) final Address	DISCARD.MyCheckBox.mbr
protected Address	FD_SOCK.FdHeader.mbr
protected final Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected static final Address	PerDestinationBundler.NULL
protected static final Address	STATS.NULL_DEST
protected Address	DAISYCHAIN.DaisyHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD_SOCK.ping_dest
private final Address	UNICAST3.ReceiverEntry.real_dest
private final Address	FRAG.FragmentationTable.sender
protected Address	Locking.Request.sender
protected Address	PingData.sender
protected Address	EncryptHeader.server
protected Address	FD_SOCK2.FdHeader.srv
protected final Address	FD_SOCK2.Request.suspect
protected final Address	VERIFY_SUSPECT.Entry.suspect
protected final Address	VERIFY_SUSPECT2.Entry.suspect
protected final 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 final Map<Address,SocketAddress>	SimpleTCP.addr_table
protected List<Address>	COUNTER.backup_coords	Backup coordinators.
protected final List<Address>	CENTRAL_LOCK.backups	Deprecated.
protected LazyRemovalCache<Address,IpAddress>	FD_SOCK.cache	Cache of member addresses and their ServerSocket addresses
protected final ConcurrentMap<Address,PhysicalAddress>	PDC.cache
protected AgeOutCache<Address>	UNICAST3.cache
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.curr_mbrs
protected final ConcurrentMap<Address,BoundedHashMap<Long,Long>>	SEQUENCER.delivery_table
protected final Map<Address,PerDestinationBundler.SendBuffer>	PerDestinationBundler.dests
protected final Map<Address,String>	STOMP.endpoints
private final HashMap<Address,FRAG.FragmentationTable>	FRAG.FragmentationList.frag_tables
protected final ConcurrentMap<Address,ConcurrentMap<Long,FRAG2.FragEntry>>	FRAG2.fragment_list
protected final ConcurrentMap<Address,ConcurrentMap<Integer,FRAG3.FragEntry>>	FRAG3.fragment_list
protected static final Function<AsciiString,Map<Address,SHARED_LOOPBACK>>	SHARED_LOOPBACK.FUNC
protected final Promise<Map<Address,IpAddress>>	FD_SOCK.get_cache_promise	Used to rendezvous on GET_CACHE and GET_CACHE_RSP
protected final Set<Address>	BARRIER.holes
protected final Map<InetAddress,List<Address>>	FD_HOST.hosts	Map of hosts and their cluster members, updated on view changes.
protected final Set<Address>	DISCARD.ignoredMembers
protected ExpiryCache<Address>	UNICAST3.last_sync_sent	Keep track of when a SEND_FIRST_SEQNO message was sent to a given sender
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.left_mbrs
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache	Cache which maintains mappings between logical and physical addresses.
protected Set<Address>	FD_SOCK.FdHeader.mbrs
protected Collection<Address>	FD_SOCK2.FdHeader.mbrs
protected Collection<? extends Address>	PingData.mbrs
protected final Map<Address,Message>	BARRIER.mcast_queue
protected final Collection<Address>	DISCARD.members
(package private) final List<Address>	EXAMPLE.members
protected final List<Address>	FailureDetection.members
protected final List<Address>	FD_HOST.members
protected List<Address>	FD_SOCK.members
protected final List<Address>	FRAG.members
protected final List<Address>	FRAG2.members
protected final List<Address>	FRAG3.members
protected List<Address>	RSVP.members
protected final List<Address>	SIZE.members
protected final Set<Address>	TP.members	The members of this group (updated when a member joins or leaves).
protected List<Address>	UNICAST3.members
protected final Map<Address,TransferQueueBundler2.Buffer>	TransferQueueBundler2.messages
protected Map<Address,BATCH.Buffer>	BATCH.msgMap
protected Map<Address,BATCH2.Buffer>	BATCH2.msgMap
protected ConcurrentMap<Address,BatchBundler.Buffer>	BatchBundler.msgMap
protected final Map<Address,List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected final List<Address>	Discovery.DiscoveryCacheDisseminationTask.new_mbrs
protected final Map<Address,List<Message>>	MAKE_BATCH.oob_map_mcast
protected final Map<Address,List<Message>>	MAKE_BATCH.oob_map_ucast
protected final List<Address>	FD_SOCK.pingable_mbrs
protected static final LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<PhysicalAddress>>	TP.print_function
protected final Map<Address,byte[]>	ASYM_ENCRYPT.pub_map
protected final Map<Address,Credit>	FlowControl.received	Keeps track of credits per member at the receiver.
protected final ConcurrentMap<Address,MsgStats>	STATS.received	Maintains stats per receiver
protected final ConcurrentMap<Address,UNICAST3.ReceiverEntry>	UNICAST3.recv_table
protected final Map<Address,List<Message>>	MAKE_BATCH.reg_map_mcast
protected final Map<Address,List<Message>>	MAKE_BATCH.reg_map_ucast
protected static final Map<AsciiString,Map<Address,SHARED_LOOPBACK>>	SHARED_LOOPBACK.routing_table	Map of cluster names and address-protocol mappings.
protected final ConcurrentMap<Address,UNICAST3.SenderEntry>	UNICAST3.send_table
protected final ConcurrentMap<Address,MsgStats>	STATS.sent	Maintains stats per target destination
protected final Map<Address,? extends Credit>	UFC.sent	Map: keys are members, values are credits left.
protected static final ThreadLocal<Address>	ASYM_ENCRYPT.srv_addr
protected 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 final BoundedList<Tuple<Address,Long>>	FailureDetection.suspect_history
protected final Set<Address>	FailureDetection.suspected_mbrs
protected final Set<Address>	FD_HOST.suspected_mbrs
protected final Set<Address>	FD_SOCK.suspected_mbrs
protected final Set<Address>	FD_SOCK.BroadcastTask.suspects
protected final Set<Address>	FD_SOCK2.BroadcastTask.suspects
protected final ConcurrentMap<Address,Long>	FD_ALL.timestamps
protected final Map<Address,AtomicBoolean>	FD_ALL2.timestamps
protected final Map<Address,FD_ALL3.Bitmap>	FD_ALL3.timestamps
protected final Map<Address,Message>	BARRIER.ucast_queue
protected final Map<Address,ViewId>	MERGE3.views
protected ExpiryCache<Address>	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 final Map<Address,Long>	UNICAST3.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per member (applicable only for received messages (ReceiverEntry)): https://issues.redhat.com/browse/JGRP-1539

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method	Description
protected Address	FD_SOCK2.PingDest.dest()
protected Address	FD_SOCK.determineCoordinator()
protected Address	FD_SOCK.determinePingDest()
Address	PingData.getAddress()
protected static Address	ASYM_ENCRYPT.getCachedServerAddress()
Address	CENTRAL_LOCK.getCoord()	Deprecated.
Address	SEQUENCER.getCoordinator()
Address	SEQUENCER2.getCoordinator()
Address	PDC.Mapping.getLogicalAddr()
Address	DAISYCHAIN.DaisyHeader.getOriginalSender()
Address	PDC.Mapping.getPhysicalAddr()
Address	PingData.getSender()
Address[]	FRAG.FragmentationList.getSenders()	returns a list of all the senders that have fragmentation tables opened.
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()
(package private) Address	UNICAST3.ReceiverEntry.realDest()
Address	Locking.Request.sender()
Address	EncryptHeader.server()

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

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

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

Modifier and Type	Method	Description
protected void	TP._send(Message msg, Address dest)
protected void	RSVP.Entry.ack(Address member)
void	COUNTER.ReconciliationTask.add(COUNTER.ReconcileResponse rsp, Address sender)
void	FRAG.FragmentationList.add(Address sender, FRAG.FragmentationTable table)	Adds a fragmentation table for this particular sender If this sender already has a fragmentation table, an IllegalArgumentException will be thrown.
protected void	LOCAL_PING.addAddressToLocalCache(Address addr, PhysicalAddress phys_addr)
protected boolean	Discovery.addDiscoveryResponseToCaches(Address mbr, String logical_name, PhysicalAddress physical_addr)
DISCARD	DISCARD.addIgnoredMembers(Address... senders)
DISCARD	DISCARD.addIgnoreMember(Address sender)	Messages from this sender will get dropped
protected void	MERGE3.addInfo(Address sender, ViewId view_id, String logical_name, PhysicalAddress physical_addr)	Adds received INFO to views hashmap
protected Message	ASYM_ENCRYPT.addKeysToMessage(Message msg, boolean copy, boolean add_secret_keys, Address serialize_only)	Adds the public and/or encrypted shared keys to the payload of msg.
protected void	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, Collection<Message> queued_msgs)
protected static String	Discovery.addressAsString(Address address)
protected static String	PDC.addressAsString(Address address)
protected static String	FILE_PING.addressToFilename(Address mbr)
protected void	FD_SOCK.BroadcastTask.addSuspectedMember(Address mbr)	Adds a suspected member.
protected long	FlowControl.adjustCredit(Map<Address,Credit> map, Address sender, int length)	Check whether sender has enough credits left.
protected void	SEQUENCER.broadcast(Message msg, boolean copy, Address original_sender, long seqno, boolean resend)
protected void	FD_SOCK.broadcastSuspectMessage(Address suspected_mbr)	Sends a SUSPECT message to all group members.
protected void	FD_SOCK.broadcastUnuspectMessage(Address mbr)
protected void	FD_SOCK2.broadcastUnuspectMessage(Address mbr)
protected static void	ASYM_ENCRYPT.cacheServerAddress(Address srv)
protected boolean	SEQUENCER.canDeliver(Address sender, long seqno)	Checks if seqno has already been received from sender.
void	FRAG2.clearFragmentsFor(Address mbr)
void	FRAG3.clearFragmentsFor(Address mbr)
void	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(String cluster_name, Address addr)
boolean	FRAG.FragmentationList.containsSender(Address sender)	returns true if this sender already holds a fragmentation for this sender, false otherwise
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id, Address dest)
protected SSLSocket	SSL_KEY_EXCHANGE.createSocketTo(Address target)
protected void	JDBC_PING2.delete(String clustername, Address addressToDelete)
protected void	JDBC_PING2.delete(Connection conn, String clustername, Address addressToDelete)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
protected Message	SERIALIZE.deserialize(Address sender, byte[] buf, int offset, int length)
protected FD_SOCK2.PingDest	FD_SOCK2.PingDest.dest(Address d)
protected boolean	FD_SOCK2.PingDest.destChanged(Address a)
void	Discovery.discoveryRequestReceived(Address sender, String logical_name, PhysicalAddress physical_addr)
void	TCPPING.discoveryRequestReceived(Address sender, String logical_name, PhysicalAddress physical_addr)
void	TP.doSend(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.UpdateFunctionRequest.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)
FRAG.FragmentationTable	FRAG.FragmentationList.get(Address sender)	returns a fragmentation table for this sender returns null if the sender doesn't have a fragmentation table
protected InetAddress	FD_HOST.getHostFor(Address mbr)
protected List<Locking.Request>	Locking.ClientLockTable.getPendingRequests(Address sender)
protected PhysicalAddress	FD_HOST.getPhysicalAddress(Address logical_addr)
protected List<IpAddress>	FD_SOCK2.getPhysicalAddresses(Address a)	Returns the physical addresses for in range [a+offset..a+offset+port_range
PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
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!
protected void	DH_KEY_EXCHANGE.handle(DH_KEY_EXCHANGE.DhHeader hdr, Address sender)
protected Object	FD_SOCK2.handle(FD_SOCK2.FdHeader hdr, Address sender)
protected void	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, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	MFC.handleCredit(Address sender, long increase)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(Map<Address,Credit> map, Address sender, long requested_credits)
protected void	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(List<PingData> data, Address sender)
protected void	Discovery.handleDiscoveryResponse(PingData data, Address sender)
protected void	CENTRAL_LOCK2.handleLockInfoRequest(Address requester)	Deprecated.
protected void	Locking.handleLockInfoRequest(Address requester)	Deprecated.
protected void	CENTRAL_LOCK2.handleLockInfoResponse(Address sender, Locking.Request rsp)	Deprecated.
protected void	Locking.handleLockInfoResponse(Address sender, Locking.Request rsp)	Deprecated.
private void	COUNTER.handleReconcileResponse(COUNTER.ReconcileResponse rsp, Address sender)
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender, int timestamp)	We need to resend the first message with our conn_id
protected void	COUNTER.handleResponse(COUNTER.Response rsp, Address sender)
protected void	RSVP.handleResponse(Address member, short id)
protected void	DH_KEY_EXCHANGE.handleSecretKeyRequest(PublicKey dh_public_key, Address sender)
protected void	DH_KEY_EXCHANGE.handleSecretKeyResponse(PublicKey dh_public_key, byte[] encrypted_secret_key, byte[] version, Address sender)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
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, SecretKey key, byte[] version)
protected boolean	Encrypt.inView(Address sender, 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)
private void	COUNTER.logSending(Address dst, Object data)
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, DataInput in, int length)
void	TP.receive(Address sender, byte[] data, int offset, int length)	Subclasses must call this method when a unicast or multicast message has been received.
void	TP.receive(Address sender, DataInput in, int ignoredLength)
MsgStats	MsgStats.received(Address dest, int length)
protected static void	SHARED_LOOPBACK.register(AsciiString cluster, Address local_addr, SHARED_LOOPBACK shared_loopback)
protected void	TP.registerLocalAddress(Address addr)	Associates the address with the physical address fetched from the cache
protected void	FILE_PING.remove(String clustername, Address addr)
boolean	FRAG.FragmentationList.remove(Address sender)	removes the fragmentation table from the list.
protected void	JDBC_PING.remove(String clustername, Address addr)
protected void	JDBC_PING2.remove(String clustername, Address addr)
protected void	RACKSPACE_PING.remove(String clustername, Address addr)
protected void	SWIFT_PING.remove(String clustername, Address addr)
protected void	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	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)
protected void	Locking.send(Address dest, Locking.Request req)	Deprecated.
void	TCP_NIO2.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
private TransferQueueBundler2.Buffer	TransferQueueBundler2.Buffer.send(Address dest, TP transport)
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, String counter_name)
protected void	CENTRAL_LOCK.sendCreateLockRequest(Address dest, String lock_name, Owner owner)	Deprecated.
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, long credits_needed)	We cannot send this request as OOB message, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected void	CENTRAL_LOCK.sendDeleteLockRequest(Address dest, String lock_name)	Deprecated.
protected void	Discovery.sendDiscoveryResponse(List<PingData> list, Address sender)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, String logical_name, Address sender, boolean coord)
Locking.Request	Locking.Request.sender(Address sender)
protected void	FD_SOCK.sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr)	Sends or broadcasts a I_HAVE_SOCK response.
protected void	AUTH.sendJoinRejectionMessage(Address dest, String error_msg)
protected void	CENTRAL_LOCK2.sendLockInfoRequestTo(Locking.Request req, Address[] mbrs, Address exclude)	Deprecated.
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	BaseBundler.sendMessageList(Address dest, Address src, 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, List<Message> list)
protected void	PerDestinationBundler.SendBuffer.sendMessages(Address dest, Address src, FastArray<Message> list)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	Locking.sendRequest(Address dest, Locking.Type type, String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)	Deprecated.
protected void	Locking.sendRequest(Address dest, Locking.Type type, String lock_name, Owner owner, long timeout, boolean is_trylock)	Deprecated.
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest, Address original_dest)
protected void	COUNTER.sendResponse(Address dest, COUNTER.Response<?> rsp)
protected void	RSVP.sendResponse(Address dest, short id)
protected void	SEQUENCER2.sendSeqnoResponse(Address original_sender, long seqno, int num_seqnos)
protected void	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.DefaultTUNNELPolicy.sendToAllMembers(String group, Address sender, byte[] data, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToAllMembers(String group, Address sender, byte[] data, int offset, int length)
void	TUNNEL.DefaultTUNNELPolicy.sendToSingleMember(String group, Address dest, Address sender, byte[] data, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToSingleMember(String group, Address dest, Address sender, byte[] data, int offset, int length)
protected void	TUNNEL.sendUnicast(Address dest, byte[] data, int offset, int length)
MsgStats	MsgStats.sent(Address dest, int length)
protected void	ASYM_ENCRYPT.serializeKeys(ByteArrayDataOutputStream out, boolean serialize_shared_keys, Address serialize_only)	Serializes all public keys and their corresponding encrypted shared group keys into a buffer
EncryptHeader	EncryptHeader.server(Address s)
FD_SOCK2.FdHeader	FD_SOCK2.FdHeader.serverAddress(Address a)
DISCARD	DISCARD.setAddress(Address localAddress)
<T extends Protocol> T	FORK.setAddress(Address addr)
<T extends Protocol> T	TP.setAddress(Address addr)
protected void	TP.setInAllThreadFactories(String cluster_name, Address local_address, String pattern)
DAISYCHAIN.DaisyHeader	DAISYCHAIN.DaisyHeader.setOriginalSender(Address s)
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender)	Checks if a message should be passed up, or not
protected void	SEQUENCER.startFlusher(Address new_coord)
boolean	TP.unicastDestMismatch(Address dest)
protected static void	SHARED_LOOPBACK.unregister(AsciiString cluster, Address local_addr)
protected void	ASYM_ENCRYPT.unserializeAndInstallKeys(Address sender, byte[] version, ByteArrayDataInputStream in)	Unserializes public keys and installs them to pub_map, then reads encrypted shared keys and install our own
protected Map<Address,byte[]>	ASYM_ENCRYPT.unserializeKeys(Address sender, byte[] buf, int offset, int length)
protected boolean	FailureDetection.unsuspect(Address mbr)	Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack
protected boolean	FD_HOST.unsuspect(Address mbr)
protected void	FD_SOCK.unsuspect(Address mbr)
protected void	FD_SOCK2.unsuspect(Address mbr)
void	VERIFY_SUSPECT.unsuspect(Address mbr)
void	VERIFY_SUSPECT2.unsuspect(Address mbr)
protected abstract void	FailureDetection.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL2.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	FD_ALL3.update(Address sender, boolean log_msg, boolean skip_if_exists)
protected void	VERIFY_SUSPECT.verifySuspectWithICMP(Address suspected_mbr)
protected boolean	TP.versionMatch(short version, Address sender)
protected void	FILE_PING.writeAll(Address[] excluded_mbrs)
protected void	PDC.writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr)
protected File	PDC.writeToTempFile(File dir, Address logical_addr, Address physical_addr, String logical_name)	Writes the data to a temporary file. The file is stored in the same directory as the other cluster files but is given the tmp suffix

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

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

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

Modifier	Constructor	Description
protected	Buffer(Address address)
protected	Buffer(Address address)
protected	Buffer(Address address)
	DaisyHeader(Address original_sender)
protected	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)
(package private)	FragmentationTable(Address sender)
	Mapping(Address logical_addr, PhysicalAddress physical_addr, String logical_name)
	MyCheckBox(String name, Address member)
	PingData(Address sender, boolean is_server)
	PingData(Address sender, boolean is_server, 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)
protected	SendBuffer(Address dest)
(package private)	VerifyHeader(short type, Address from)
(package private)	VerifyHeader(short type, Address from)

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

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

Uses of Address in org.jgroups.protocols.dns

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

Modifier and Type	Method	Description
(package private) List<Address>	DNS_PING.getMembers(String dns_query, DNSResolver.DNSRecordType dns_record_type)	Gets a list of IP addresses for the provided DNS query list and record type.
protected List<Address>	AddressedDNSResolver.resolveAEntries(String dnsQuery, String srcPort)
protected List<Address>	DefaultDNSResolver.resolveAEntries(String dnsQuery)
protected List<Address>	DefaultDNSResolver.resolveAEntries(String dnsQuery, String srcPort)
List<Address>	DefaultDNSResolver.resolveIps(String dnsQuery, DNSResolver.DNSRecordType recordType)
List<Address>	DNSResolver.resolveIps(String dnsQuery, DNSResolver.DNSRecordType recordType)
protected List<Address>	DefaultDNSResolver.resolveSRVEntries(String dnsQuery)

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

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

Uses of Address in org.jgroups.protocols.pbcast

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

Modifier and Type	Field	Description
protected Address	STABLE.coordinator
private Address	FLUSH.flushCoordinator	Deprecated, for removal: This API element is subject to removal in a future version. Group member that requested FLUSH.
protected Address[]	DeltaView.left_members	Members which left the view corresponding to ref_view_id
protected Address	GMS.GmsHeader.mbr
protected Address	GmsImpl.Request.mbr
protected Address[]	DeltaView.new_members	Members which joined the view corresponding to ref_view_id
protected final Address	StreamingStateTransfer.StateGetter.requester
protected final Address	MergeData.sender
(package private) Address	NakAckHeader2.sender
protected Address	StreamingStateTransfer.state_provider
protected final Address	STATE.StateOutputStream.stateRequester

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

Modifier and Type	Field	Description
protected final ConcurrentMap<Address,Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
protected final ConcurrentMap<Address,Collection<Address>>	Merger.MergeTask.coords	List of all subpartition coordinators and their members
private final Map<Address,Digest>	FLUSH.flushCompletedMap	Deprecated, for removal: This API element is subject to removal in a future version.
private final List<Address>	FLUSH.flushMembers	Deprecated, for removal: This API element is subject to removal in a future version.
private final List<Address>	FLUSH.flushNotCompletedMap	Deprecated, for removal: This API element is subject to removal in a future version.
protected final List<Address>	GMS.joining	Members joined but for which no view has been received yet
protected final Promise<Address>	Leaver.leave_promise
protected final List<Address>	GMS.leaving	Members excluded from group, but for which no view has been received yet
protected List<Address>	NAKACK2.members
protected final List<Address>	STATE_TRANSFER.members
protected final List<Address>	StreamingStateTransfer.members
protected BoundedList<Address>	GMS.prev_members	Keeps track of old members (up to num_prev_mbrs)
private final List<Address>	FLUSH.reconcileOks	Deprecated, for removal: This API element is subject to removal in a future version.
protected final Map<Address,Long>	NAKACK2.stable_xmit_map
protected final ProcessingQueue<Address>	STATE_TRANSFER.state_requesters	List of members requesting state
protected final ProcessingQueue<Address>	StreamingStateTransfer.state_requesters	List of members requesting state.
protected SuppressLog<Address>	NAKACK2.suppress_log_non_member	Log to suppress identical warnings for messages from non-members
private final Set<Address>	FLUSH.suspected	Deprecated, for removal: This API element is subject to removal in a future version.
private final Collection<Address>	ParticipantGmsImpl.suspected_mbrs
protected Map<Address,View>	GmsImpl.Request.views
protected final ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table	Map to store sent and received messages (keyed by sender)
protected final Map<Address,Long>	NAKACK2.xmit_task_map	Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539)

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

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

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

Modifier and Type	Method	Description
protected List<Address>	GMS.computeNewMembership(Collection<Collection<Address>> subviews)	Computes a merge membership
protected List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
protected static Map<Address,Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
protected static Map<Address,Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
private static List<Address>	ClientGmsImpl.getCoords(Iterable<PingData> mbrs)	Returns all members who are flagged as coordinator
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Default implementation for a merge.
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
static List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(Collection<Collection<Address>> subviews)	Old default implementation for a merge.
Iterator<Address>	DeltaView.iterator()
protected Collection<? extends Address>	GMS.readMembers(byte[] buffer, int offset, int length)
protected Tuple<Collection<? extends Address>,Digest>	FLUSH.readParticipantsAndDigest(byte[] buffer, int offset, int length)	Deprecated, for removal: This API element is subject to removal in a future version.

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

Modifier and Type	Method	Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
(package private) void	ClientGmsImpl.becomeSingletonMember(Address mbr)
protected void	STATE_TRANSFER.closeHoleFor(Address member)
protected void	StreamingStateTransfer.closeHoleFor(Address member)
void	Leaver.coordChanged(Address new_coord)	Callback to notify Leaver that the coord changed.
protected void	ParticipantGmsImpl.coordChanged(Address from, Address to)
protected void	ServerGmsImpl.coordChanged(Address from, Address to)
protected Tuple<InputStream,Object>	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected Tuple<InputStream,Object>	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract Tuple<InputStream,Object>	StreamingStateTransfer.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)	Creates an InputStream to the state provider to read the state.
protected void	STATE.createStreamToRequester(Address requester)
protected void	StreamingStateTransfer.createStreamToRequester(Address requester)	Creates an OutputStream to the state requester to write the state
static NakAckHeader2	NakAckHeader2.createXmitRequestHeader(Address orginal_sender)
protected void	NAKACK2.deliver(Message msg, Address sender, long seqno, String error_msg)
protected boolean	ClientGmsImpl.firstOfAllClients(Address joiner, Responses rsps)	Handles the case where no coord responses were received.
Digest	NAKACK2.getDigest(Address mbr)
protected static int	STABLE.getRank(Address member, View v)
protected void	STATE_TRANSFER.getStateFromApplication(Address requester, Digest digest)
protected void	StreamingStateTransfer.getStateFromApplication(Address requester, OutputStream out, boolean use_separate_thread)
Table<Message>	NAKACK2.getWindow(Address sender)	Returns the receive window for sender; only used for testing.
protected Object	STABLE.handle(STABLE.StableHeader hdr, Address sender, Digest digest)
void	STATE_TRANSFER.handle(Address state_requester)
void	StreamingStateTransfer.handle(Address state_requester)
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
void	Merger.handleDigestResponse(Address sender, Digest digest)
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
protected void	STATE.handleEOF(Address sender)
protected void	StreamingStateTransfer.handleEOF(Address sender)
protected void	NAKACK2.handleHighestSeqno(Address sender, long seqno)	Compares the sender's highest seqno with my highest seqno: if the sender's is higher, ask sender for retransmission
void	GmsImpl.handleLeaveResponse(Address sender)
void	Leaver.handleLeaveResponse(Address sender)
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
protected void	STABLE.handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)
protected void	STABLE.handleStableMessage(Digest d, Address sender, ViewId view_id)	Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
protected void	STATE.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	StreamingStateTransfer.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE_SOCK.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateRsp(Digest digest, Address sender, byte[] state)	Set the digest and the send the state up to the application
protected void	StreamingStateTransfer.handleStateRsp(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	NAKACK2.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender)	Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
void	ClientGmsImpl.join(Address address, boolean useFlushIfPresent)
void	CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
protected void	ClientGmsImpl.joinInternal(Address mbr, boolean joinWithStateTransfer, boolean useFlushIfPresent)	Makes this process join a group.
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
GMS.GmsHeader	GMS.GmsHeader.mbr(Address mbr)
private void	FLUSH.onFlushCompleted(Address address, Message m, FLUSH.FlushHeader header)	Deprecated, for removal: This API element is subject to removal in a future version.
private void	FLUSH.onStartFlush(Address flushStarter, Message msg, FLUSH.FlushHeader fh)	Deprecated, for removal: This API element is subject to removal in a future version.
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, Throwable exception)
protected void	StreamingStateTransfer.sendException(Address requester, Throwable exception)
(package private) void	ClientGmsImpl.sendJoinMessage(Address coord, Address mbr, boolean joinWithTransfer, boolean useFlushIfPresent)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	GMS.sendJoinResponse(ByteArray marshalled_rsp, Address dest)
protected void	Leaver.sendLeaveRequest(Address coord, Address leaving_mbr)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id)	Send back a response containing view and digest to sender
protected void	GMS.sendViewAck(Address dest)
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
protected void	StreamingStateTransfer.setStateInApplication(InputStream in, Object resource, Address provider)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
protected void	NAKACK2.unknownMember(Address sender)
void	GmsImpl.unsuspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr)	Removes previously suspected member from list of currently suspected members
protected void	STABLE.updateLocalDigest(Digest d, Address sender)	Update my own digest from a digest received by somebody else.
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, Collection<? extends Address> mbrs)
protected void	Merger.MergeTask._run(MergeId new_merge_id, Collection<Address> coordsCopy)	Runs the merge protocol as a leader
protected void	NAKACK2.adjustReceivers(List<Address> members)	Removes old members from xmit-table and adds new members to xmit-table (at seqnos hd=0, hr=0).
void	GMS.castViewChangeAndSendJoinRsps(View new_view, Digest digest, Collection<Address> expected_acks, Collection<Address> joiners, JoinRsp jr)	Broadcasts the new view and digest as VIEW messages, possibly sends JOIN-RSP messages to joiners and then waits for acks from expected_acks
protected List<Address>	GMS.computeNewMembership(Collection<Collection<Address>> subviews)	Computes a merge membership
protected List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
protected List<Address>	GMS.computeNewMembership(List<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes the regular membership
protected static Map<Address,Collection<Address>>	Merger.determineMergeCoords(Map<Address,View> views)	Needs to return a map of all subview coordinators and their views (as a collection of members).
protected Address	Merger.determineMergeLeader(Map<Address,View> views)	Returns the address of the merge leader
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(Map<Address,Collection<Address>> coords, MergeId new_merge_id, long timeout)	Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(Map<Address,Collection<Address>> coords, MergeId new_merge_id, long timeout)	Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Default implementation for a merge.
List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
static List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(Collection<Collection<Address>> subviews)	Old default implementation for a merge.
View	GMS.getNextView(Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspected_mbrs)	Computes the next view.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)	Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
protected static ByteArray	FLUSH.marshal(Collection<? extends Address> participants, Digest digest)	Deprecated, for removal: This API element is subject to removal in a future version.
protected static ByteArray	GMS.marshal(Collection<? extends Address> mbrs)
void	GmsImpl.merge(Map<Address,View> views)
void	Merger.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
void	ServerGmsImpl.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
private void	FLUSH.onSuspect(Collection<Address> addresses)	Deprecated, for removal: This API element is subject to removal in a future version.
private void	FLUSH.onSuspend(List<Address> members)	Deprecated, for removal: This API element is subject to removal in a future version. Starts the flush protocol
private void	FLUSH.rejectFlush(Collection<? extends Address> participants, long viewId)	Deprecated, for removal: This API element is subject to removal in a future version.
protected void	Merger.MergeTask.removeRejectedMergeRequests(Collection<Address> coords)	Removed rejected merge requests from merge_rsps and coords.
static void	Merger.sanitizeViews(Map<Address,View> map)	Removes all members from a given view which don't have us in their view (https://issues.redhat.com/browse/JGRP-1061).
protected void	GMS.sendJoinResponses(JoinRsp jr, Collection<Address> joiners)
private void	CoordGmsImpl.sendLeaveResponses(Collection<Address> leaving_members)
protected void	Merger.sendMergeCancelledMessage(Collection<Address> coords, MergeId merge_id)
protected void	Merger.sendMergeView(Collection<Address> coords, MergeData combined_merge_data, MergeId merge_id)	Sends the new view and digest to all subgroup coordinators.
void	Merger.MergeTask.start(Map<Address,View> views)
private void	FLUSH.startFlush(List<Address> flushParticipants)	Deprecated, for removal: This API element is subject to removal in a future version.
(package private) void	GMS.stopFlush(List<Address> members)
protected boolean	ParticipantGmsImpl.wouldIBeCoordinator(Collection<Address> leaving_mbrs, Collection<Address> suspected_members)	Determines whether this member is the new coordinator given a list of suspected members.

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

Modifier	Constructor	Description
	DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)
	GmsHeader(byte type, Address mbr)
	GmsHeader(byte type, Address mbr, boolean useFlushIfPresent)	Used for JOIN_REQ or LEAVE_REQ header
	MergeData(Address sender, View view, Digest digest)
	MergeData(Address sender, View view, Digest digest, boolean merge_rejected)
private	NakAckHeader2(byte type, Address sender)	Constructor for retransmit requests (XMIT_REQs) (low and high define the range of msgs)
	Request(int type, Address mbr)
	Request(int type, Address mbr, Map<Address,View> views)
	Request(int type, Address mbr, Map<Address,View> views, boolean useFlushPresent)
	StateGetter(Address requester, OutputStream output)
	StateOutputStream(Address stateRequester)

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

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

Uses of Address in org.jgroups.protocols.relay

Subinterfaces of Address in org.jgroups.protocols.relay

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Modifier	Constructor	Description
	DefaultRouteStatusListener(Supplier<Address> s)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

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

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
(package private) Address	GossipData.addr
protected final Address	GossipRouter.Entry.client_addr
protected Address	Protocol.local_addr
protected final Address	RouterStubManager.local_addr
(package private) Address	GossipData.sender
Address	StateTransferInfo.target

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

Modifier and Type	Field	Description
protected final Map<String,ConcurrentMap<Address,GossipRouter.Entry>>	GossipRouter.address_mappings
protected final Map<Address,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(String name)
Address	GossipData.getAddress()
Address	Protocol.getAddress()
Address	GossipData.getSender()
Address	GossipRouter.localAddress()

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

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

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

Modifier and Type	Method	Description
protected void	GossipRouter.addAddressMapping(Address sender, String group, Address addr, PhysicalAddress phys_addr, String logical_name)
<T extends Protocol> T	Protocol.addr(Address addr)
int	IpAddress.compareTo(Address o)	implements the java.lang.Comparable interface
void	RouterStub.connect(String group, Address addr, String logical_name, PhysicalAddress phys_addr)	Registers mbr with the GossipRouter under the given group, with the given logical name and physical address.
void	RouterStub.disconnect(String group, Address addr)
protected ByteArrayDataOutputStream	GossipRouter.getOutputStream(Address mbr, int size)
protected void	GossipRouter.handleGetMembersRequest(Address sender, DataInput in)
protected void	GossipRouter.handleHeartbeat(Address sender)
protected void	GossipRouter.handleRegister(Address sender, DataInput in)
void	GossipRouter.receive(Address sender, byte[] buf, int offset, int length)
void	GossipRouter.receive(Address sender, DataInput in, int length)
void	GossipRouter.receive(Address sender, ByteBuffer buf)
void	RouterStub.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, DataInput in, int length)
protected void	GossipRouter.removeAddressMapping(String group, Address addr)
protected void	GossipRouter.removeFromAddressMappings(Address client_addr)
protected void	GossipRouter.route(String group, Address dest, byte[] msg, int offset, int length)
protected void	GossipRouter.route(String group, Address dest, ByteBuffer buf)
void	RouterStub.sendToAllMembers(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, ByteBuffer buf)
protected void	GossipRouter.sendToMember(Address dest, GossipData request)
void	RouterStub.sendToMember(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
List<Address>	LargestWinningPolicy.getNewMembership(Collection<Collection<Address>> subviews)	Called when a merge happened.
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Collection<Address>> subviews)	Compute a new membership based on a number of subviews
List<Address>	MembershipChangePolicy.getNewMembership(Collection<Address> current_members, Collection<Address> joiners, Collection<Address> leavers, Collection<Address> suspects)	Computes a new membership based on existing, joining, leaving and suspected members.
protected void	GossipRouter.sendToAllMembersInGroup(Set<Map.Entry<Address,GossipRouter.Entry>> dests, byte[] buf, int offset, int len)
protected void	GossipRouter.sendToAllMembersInGroup(Set<Map.Entry<Address,GossipRouter.Entry>> dests, ByteBuffer buf)
protected void	GossipRouter.sendToAllMembersInGroup(Set<Map.Entry<Address,GossipRouter.Entry>> dests, GossipData request)

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

Modifier	Constructor	Description
	Entry(Address client_addr, PhysicalAddress phys_addr, String logical_name)
	GossipData(GossipType type, String group, Address addr)
	GossipData(GossipType type, String group, Address addr, byte[] buffer)
	GossipData(GossipType type, String group, Address addr, byte[] buffer, int offset, int length)
	GossipData(GossipType type, String group, Address addr, String logical_name, PhysicalAddress physical_addr)
	GossipData(GossipType type, String group, Address addr, List<PingData> ping_data)
	GossipData(GossipType type, String group, Address addr, List<PingData> ping_data, PhysicalAddress physical_addr)
	RouterStubManager(Log log, TimeScheduler timer, String cluster_name, Address local_addr, String logical_name, PhysicalAddress phys_addr, long reconnect_interval)
	StateTransferInfo(Address target)
	StateTransferInfo(Address target, long timeout)
	StateTransferInfo(Address target, long timeout, byte[] state)

Uses of Address in org.jgroups.tests

Fields in org.jgroups.tests declared as Address

Modifier and Type	Field	Description
private final Address	UnicastTestRpc.Invoker.dest
protected final Address	UnicastTest.Sender.destination
private Address	UnicastTestRpc.destination
private Address	UnicastTestRpc.local_addr
protected final Address	RoundTripRpc.Invoker.target

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

Modifier and Type	Field	Description
private final Collection<Address>	UnicastTestRpc.anycast_mbrs
private final Collection<Address>	UnicastTestRpc.Invoker.dests
(package private) final List<Address>	PingPong.members

Methods in org.jgroups.tests that return Address

Modifier and Type	Method	Description
private Address	FlowControlTest.getReceiver()
protected Address	UnicastTest.getReceiver()
private Address	UnicastTestRpc.getReceiver()

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

Modifier	Constructor	Description
	Invoker(short id, CountDownLatch latch, AtomicInteger sent_msgs, Address target)
	Invoker(Address dest, RequestOptions options, CountDownLatch latch)
	Sender(int num_msgs, int msg_size, Address destination, int print)

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

Modifier	Constructor	Description
	Invoker(Collection<Address> dests, RequestOptions options, CountDownLatch latch)

Uses of Address in org.jgroups.tests.perf

Fields in org.jgroups.tests.perf declared as Address

Modifier and Type	Field	Description
protected Address	MPerf.local_addr
protected Address	MPerfRpc.local_addr
private Address	ProgrammaticUPerf.local_addr
private static Address	ProgrammaticUPerf2.local_addr
private Address	UPerf.local_addr
protected Address	MPerfRpc.result_collector
protected Address[]	MPerf.Result.sources

Fields in org.jgroups.tests.perf with type parameters of type Address

Modifier and Type	Field	Description
protected ConcurrentHashMap<Address,LongAdder>	MPerf.MessageCounter.countMap
private final List<Address>	ProgrammaticUPerf.Invoker.dests
private final List<Address>	ProgrammaticUPerf2.Invoker.dests
private final List<Address>	UPerf.Invoker.dests
protected final List<Address>	MPerf.members
protected final List<Address>	MPerfRpc.members
protected final List<Address>	ProgrammaticUPerf.members
protected static final List<Address>	ProgrammaticUPerf2.members
protected final List<Address>	UPerf.members
protected final ConcurrentMap<Address,MPerfRpc.Stats>	MPerfRpc.received_msgs	Maintains stats per sender, will be sent to perf originator when all messages have been received
private final List<Address>	ProgrammaticUPerf.Invoker.targets
private final List<Address>	ProgrammaticUPerf2.Invoker.targets
private final List<Address>	UPerf.Invoker.targets

Methods in org.jgroups.tests.perf that return Address

Modifier and Type	Method	Description
private Address	UPerf.getReceiver()	Picks the next member in the view
private Address	ProgrammaticUPerf.Invoker.pickTarget()
private Address	ProgrammaticUPerf2.Invoker.pickTarget()
private Address	UPerf.Invoker.pickTarget()

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

Modifier and Type	Method	Description
protected List<Address>	MPerf.getSenders()
protected List<Address>	MPerfRpc.getSenders()
Map<Address,Long>	MPerf.MessageCounter.snapshot()

Methods in org.jgroups.tests.perf with parameters of type Address

Modifier and Type	Method	Description
void	UPerf.acceptResults(Address sender, PerfUtil.Results results)	Called by worker when done; response to UPerf.startTest()
void	MPerf.MessageCounter.addMessage(Address source)
void	MPerf.MessageCounter.addMessage(Address source, long count)
void	MPerfRpc.configReq(Address sender)
protected void	MPerf.handleConfigRequest(Address sender)
void	MPerfRpc.handleData(Address src, byte[] payload, long seqno, boolean check_order)
protected Object	MPerfRpc.invokeRpc(short method_id, Address dest, RequestOptions options, Object... args)
protected static String	MPerf.printPerSender(Address[] sender, long[] received, long msg_size, long diff)
void	MPerfRpc.result(Address sender, MPerfRpc.Result res)	Called when a result from a node is received
protected void	MPerf.send(Address target, Object payload, byte header, Message.Flag... flags)
void	MPerfRpc.sendingDone(Address sender)
protected void	MPerf.sendNoException(Address target, Object payload, byte header, Message.Flag... flags)
protected void	UPerf.sendResults(Address dest, PerfUtil.Results results)
void	MPerfRpc.startSending(Address initiator)
void	UPerf.startTest(Address sender)

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

Modifier and Type	Method	Description
private void	ProgrammaticUPerf.Invoker.pickAnycastTargets(List<Address> anycast_targets)
private void	ProgrammaticUPerf2.Invoker.pickAnycastTargets(List<Address> anycast_targets)
private void	UPerf.Invoker.pickAnycastTargets(List<Address> anycast_targets)

Constructors in org.jgroups.tests.perf with parameters of type Address

Modifier	Constructor	Description
	Result(long time, long msgs, Address[] sources, long[] received)

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

Modifier	Constructor	Description
	Invoker(Collection<Address> dests, CountDownLatch latch)
	Invoker(Collection<Address> dests, CountDownLatch latch)
	Invoker(Collection<Address> dests, CountDownLatch latch)

Uses of Address in org.jgroups.tests.rt.transports

Methods in org.jgroups.tests.rt.transports that return Address

Modifier and Type	Method	Description
Address	JGroupsTransport.localAddress()

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

Modifier and Type	Method	Description
List<Address>	JGroupsTransport.clusterMembers()

Methods in org.jgroups.tests.rt.transports with parameters of type Address

Modifier and Type	Method	Description
void	ServerTransport.receive(Address sender, byte[] buf, int offset, int length)
void	ServerTransport.receive(Address sender, DataInput in, int length)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

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

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.
private Address	MergeId.initiator
protected final Address	Digest.Entry.member
protected Address[]	Digest.members
protected final Address	MaxOneThreadPerSender.Entry.sender
protected Address	MessageBatch.sender	The sender of the message batch

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

Modifier and Type	Field	Description
protected static final LazyRemovalCache<Address,String>	NameCache.cache	Keeps track of associations between addresses and logical names
protected final Map<Address,Long>	CreditMap.credits
protected static final Function<String,List<Address>>	Util.FUNC
protected final ConcurrentMap<Address,MaxOneThreadPerSender.Entry>	MaxOneThreadPerSender.MessageTable.map
protected final Map<Address,Queue<Message>>	MessageCache.map
protected final List<Address>	AckCollector.missing_acks	List of members from whom we haven't received an ACK yet
protected static final LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<String>>	NameCache.print_function
private final Map<Address,T>	ResponseCollector.responses
protected Map<Address,RpcStats.RTTStat>	RpcStats.rtt_stats
protected final Map<Address,AverageMinMax>	RTT.rtts
protected Map<Address,RpcStats.Result>	RpcStats.stats
protected final Map<Address,long[]>	RTT.times

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

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

Methods in org.jgroups.util that return Address

Modifier and Type	Method	Description
static Address	Util.addressFromString(String s)
static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(String name)
static Address[]	Util.createRandomAddresses(int num)	Returns an array of num random addresses, named A, B, C etc
static Address[]	Util.createRandomAddresses(int num, boolean use_numbers)
Address	MessageBatch.dest()
Address	MillisAddressGenerator.generateAddress()
Address	MillisAddressGenerator.generateAddress(String ignored)
Address	OneTimeAddressGenerator.generateAddress()
Address	Owner.getAddress()
Address	ThreadPool.getAddress()
Address	MessageBatch.getDest()
Address	Digest.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(DataInput in)
static Address[]	Util.readAddresses(DataInput in)
private static Address	Util.readOtherAddress(DataInput in)
Address	MessageBatch.sender()

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

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

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

Modifier and Type	Method	Description
void	AckCollector.ack(Address member)
void	AckCollector.ack(Address... members)
MessageCache	MessageCache.add(Address sender, Message msg)
static void	NameCache.add(Address uuid, 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(Collection<Address> members, Address... exclude)
protected void	AckCollector.addAll(Address... members)
static String	Util.addressToString(Address addr)
RspList<T>	RspList.addRsp(Address sender, T retval)
void	RpcStats.addRTTStats(Address sender, RTTHeader hdr)
protected void	RpcStats.addToResults(Address dest, boolean sync, long time)
static void	Util.bufferToArray(Address sender, ByteBuffer buf, Receiver target)
int	MillisAddress.compareTo(Address other)
int	UUID.compareTo(Address other)	Compares this UUID with the specified UUID.
boolean	Digest.contains(Address mbr)
(package private) boolean	RspList.contains(Address sender)
boolean	Digest.containsAll(Address... members)
boolean	Responses.containsResponseFrom(Address mbr)
static MergeId	MergeId.create(Address addr)
protected void	CreditMap.decrementAndAdd(Address member, long new_credits)	Decrements credits bytes from all elements and adds new_credits to member (if non null).
MessageBatch	MessageBatch.dest(Address dest)
Collection<Message>	MessageCache.drain(Address sender)
protected int	Digest.find(Address mbr)
PingData	Responses.findResponseFrom(Address mbr)
Long	CreditMap.get(Address member)
long[]	Digest.get(Address member)	Returns the highest delivered and received seqnos associated with a member.
protected MaxOneThreadPerSender.Entry	MaxOneThreadPerSender.MessageTable.get(Address sender, boolean multicast)
static String	NameCache.get(Address logical_addr)
static int	Util.getRank(Collection<Address> members, Address addr)
static int	Util.getRank(View view, Address addr)	Returns the rank of a member in a given view
protected void	RTT.handleRequest(Address sender, TpHeader hdr)
protected void	RTT.handleResponse(Address sender, int index)
boolean	Responses.isCoord(Address addr)
static boolean	Util.isCoordinator(View view, Address local_addr)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
MutableDigest	MutableDigest.merge(Address member, long highest_delivered_seqno, long highest_received_seqno)	Similar to set(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno)
Long	CreditMap.putIfAbsent(Address key)
Long	CreditMap.remove(Address key)
static void	NameCache.remove(Address addr)
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(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)
String	Digest.toString(Address[] order, boolean print_highest_received)
static void	Util.writeAddress(Address addr, DataOutput out)
static void	Util.writeAddresses(Address[] addrs, DataOutput out)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, List<Message> msgs, DataOutput dos, boolean multicast)	Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, Message[] msgs, int offset, int length, DataOutput dos, boolean multicast)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, FastArray<Message> msgs, DataOutput dos, boolean multicast)
static void	Util.writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, DataOutput dos, boolean multicast)
private static void	Util.writeOtherAddress(Address addr, DataOutput out)

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

Modifier and Type	Method	Description
void	AckCollector.ack(Collection<Address> members)
static void	NameCache.add(Map<Address,String> map)
protected void	AckCollector.addAll(Collection<Address> members)
protected void	AckCollector.addAll(Collection<Address> members, Collection<Address> exclude)
protected void	AckCollector.addAll(Collection<Address> members, Address... exclude)
void	RpcStats.addAnycast(boolean sync, long time, Collection<Address> dests)
static byte[]	Util.collectionToByteBuffer(Collection<Address> c)
protected void	Digest.createArrays(Map<Address,long[]> map)
static Collection<Address>	Util.determineActualMergeCoords(Map<Address,View> map)	Similar to Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual coord is when the sender of a view is the first member of that view
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs)	Returns all members that left between 2 views.
static Collection<Address>	Util.determineMergeCoords(Map<Address,View> map)	This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static Collection<Address>	Util.determineMergeParticipants(Map<Address,View> map)	Determines the members which take part in a merge.
static int	Util.getRank(Collection<Address> members, Address addr)
static List<Address>	Util.leftMembers(Collection<Address> old_list, Collection<Address> new_list)
static List<Address>	Util.newMembers(List<Address> old_list, List<Address> new_list)
void	ResponseCollector.remove(List<Address> members)
static void	NameCache.removeAll(Collection<Address> mbrs)
void	AckCollector.reset(Collection<Address> members)
AckCollector	AckCollector.reset(Collection<Address> expected_acks, Collection<Address> exclude)
AckCollector	AckCollector.reset(Collection<Address> expected_acks, Address... exclude)
void	ResponseCollector.reset(Collection<Address> members)
boolean	AckCollector.retainAll(Collection<Address> members)
static void	NameCache.retainAll(Collection<Address> logical_addrs)
boolean	ResponseCollector.retainAll(List<Address> members)
boolean	ResponseCollectorTask.retainAll(List<Address> members)
void	RpcStats.retainAll(Collection<Address> members)
static long	Util.size(Collection<? extends Address> addrs)	Returns the marshalled size of a Collection of Addresses.
static boolean	Util.startFlush(JChannel c, List<Address> flushParticipants)	Performs the flush of the given channel and the specified flush participants
static boolean	Util.startFlush(JChannel c, List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)	Performs the flush of the given channel for the specified flush participants and the given number of attempts along with random sleep time after each such attempt.
void	AckCollector.suspect(Collection<Address> members)
protected void	MaxOneThreadPerSender.MessageTable.viewChange(List<Address> mbrs)
void	MaxOneThreadPerSender.viewChange(List<Address> members)
static void	Util.writeAddresses(Collection<? extends Address> v, DataOutput out)	Writes a list of Addresses.

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

Modifier	Constructor	Description
	AckCollector(Address... members)
	Digest(Address[] members)	Only used internally, don't use !
	Digest(Address[] members, long[] seqnos)
	Digest(Address sender, long highest_delivered, long highest_received)
	Entry(Address member, long highest_delivered, long highest_received)
protected	Entry(Address sender, boolean mcast, AsciiString cluster_name)
private	MergeId(Address initiator, int id)
	MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, Collection<Message> msgs)
	MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, MessageBatch.Mode mode, int capacity)
	MutableDigest(Address[] members)
	Owner(Address address, long thread_id)
	ResponseCollector(Address... members)
	ResponseCollectorTask(Address... members)

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

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