Uses of Interface
org.jgroups.Address

Packages that use Address

org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.auth
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.mux
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
org.jgroups.protocols.relay
org.jgroups.protocols.rules
org.jgroups.protocols.tom
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

interface

PhysicalAddress Represents a physical (as opposed to logical) address

Classes in org.jgroups that implement Address

class

AnycastAddress This type of address represents a subset of the cluster members in which the total order properties must be applied, e.g.

Fields in org.jgroups declared as Address

protected Address	ViewId.creator
protected Address	Message.dest_addr
protected Address	JChannel.local_addr
protected Address	UnreachableException.member
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

protected java.util.Collection<Address>	AnycastAddress.destinations
protected java.util.List<Address>	View.members A list containing all the members of the view.This list is always ordered, with the coordinator being the first member.

Methods in org.jgroups that return Address

Address	Message.dest()
Address	Membership.elementAt(int index) Returns the component at the specified index
abstract Address	Channel.getAddress() Returns the channel's own address.
Address	JChannel.getAddress()
Address	ViewId.getCreator() Returns the address of the member that issued this view
Address	View.getCreator() Returns the creator of this view if this view was created with the empty constructur, null will be returned
Address	Message.getDest()
Address	Message.getSrc()
Address	Message.src()

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

java.util.Collection<Address>	AnycastAddress.getAddresses()
java.util.List<Address>	View.getMembers() Returns the member list
java.util.List<Address>	Membership.getMembers() Returns a copy (clone) of the members in this membership.
java.util.Iterator<Address>	View.iterator()

Methods in org.jgroups with parameters of type Address

protected void	AnycastAddress._add(Address address)
void	AnycastAddress.add(Address... addresses)
void	Membership.add(Address... mbrs)
void	Membership.add(Address new_member) Adds a new member to this membership.
int	AnycastAddress.compareTo(Address o)
abstract void	Channel.connect(java.lang.String cluster_name, Address target, long timeout) Connects this channel to a group and gets a state from a specified state provider.
void	JChannel.connect(java.lang.String cluster_name, Address target, long timeout)
void	JChannel.connect(java.lang.String cluster_name, Address target, long timeout, boolean useFlushIfPresent) Connects this channel to a group and gets a state from a specified state provider. This method invokes connect() and then getState. If the FLUSH protocol is in the channel's stack definition, only one flush round is executed for both connecting and fetching the state rather than two flushes if we invoke connect and getState in succession.
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
Message	Message.dest(Address new_dest)
abstract java.lang.String	Channel.getName(Address member) Returns the logical name of a given member.
java.lang.String	JChannel.getName(Address member)
abstract void	Channel.getState(Address target, long timeout) Retrieves the full state from the target member.
void	JChannel.getState(Address target, long timeout)
void	JChannel.getState(Address target, long timeout, boolean useFlushIfPresent) Retrieves state from the target member.
protected void	JChannel.getState(Address target, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
void	Membership.remove(Address old_member) Removes an member from the membership.
abstract void	Channel.send(Address dst, byte[] buf) Sends a message.
void	JChannel.send(Address dst, byte[] buf)
abstract void	Channel.send(Address dst, byte[] buf, int offset, int length) Sends a message to a destination.
void	JChannel.send(Address dst, byte[] buf, int offset, int length)
abstract void	Channel.send(Address dst, java.lang.Object obj) Helper method to create a Message with given parameters and invoke Channel.send(Message).
void	JChannel.send(Address dst, java.lang.Object obj)
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
Message	Message.src(Address new_src)
void	MembershipListener.suspect(Address suspected_mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReceiverAdapter.suspect(Address mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	Message.writeToNoAddrs(Address src, java.io.DataOutputStream out, short... excluded_headers) Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address

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

void	Membership.add(java.util.Collection<Address> v) Adds a list of members to this membership
void	AnycastAddress.addAll(java.util.Collection<Address> addresses)
void	Membership.merge(java.util.Collection<Address> new_mems, java.util.Collection<Address> suspects) Merges membership with the new members and removes suspects.
void	Membership.merge(java.util.Collection<Address> new_mems, java.util.Collection<Address> suspects) Merges membership with the new members and removes suspects.
void	Membership.remove(java.util.Collection<Address> v) Removes all the members contained in v from this membership
void	Membership.retainAll(java.util.Collection<Address> v)
void	Membership.set(java.util.Collection<Address> v) Clears the membership and adds all members of v This method will clear out all the old members of this membership by invoking the Clear method.
abstract void	Channel.startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume) Performs a partial flush in a cluster for flush participants.
void	JChannel.startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)
abstract void	Channel.stopFlush(java.util.List<Address> flushParticipants)
void	JChannel.stopFlush(java.util.List<Address> flushParticipants)

Constructors in org.jgroups with parameters of type Address

AnycastAddress(Address... addresses)

MergeView(Address creator, long id, java.util.List<Address> members, java.util.List<View> subgroups)
Creates a new view

Message(Address dest)
Constructs a Message given a destination Address

Message(Address dest, Address src, byte[] buf)
Constructs a Message given a destination Address, a source Address and the payload byte buffer

Message(Address dest, Address src, byte[] buf, int offset, int length)
Constructs a message.

Message(Address dest, Address src, java.lang.Object obj)
Constructs a Message given a destination Address, a source Address and the payload Object

Message(Address dest, byte[] buf)

Message(Address dest, byte[] buf, int offset, int length)

Message(Address dest, java.lang.Object obj)

UnreachableException(Address member)

UnreachableException(java.lang.String msg, Address member)

View(Address creator, long id, java.util.List<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

AnycastAddress(java.util.Collection<Address> addresses)

Membership(java.util.Collection<Address> initial_members)
Creates a Membership with a given initial members.

MergeView(Address creator, long id, java.util.List<Address> members, java.util.List<View> subgroups)
Creates a new view

MergeView(ViewId vid, java.util.List<Address> members, java.util.List<View> subgroups)
Creates a new view

View(Address creator, long id, java.util.List<Address> members)
Creates a new view

View(ViewId vid, java.util.List<Address> members)
Creates a new view

Uses of Address in org.jgroups.auth

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

protected java.util.Map<Address,DemoToken.Entry>

DemoToken.pending_requests

Uses of Address in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Address

protected Address	RequestCorrelator.local_addr The address of this group member
protected Address	MessageDispatcher.local_addr
protected Address	TCPConnectionMap.local_addr
protected Address	TCPConnectionMap.TCPConnection.peer_addr
protected Address	UnicastRequest.target

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

protected java.util.Map<Address,V>	AbstractConnectionMap.conns
java.util.Collection<? extends Address>	RequestCorrelator.MultiDestinationHeader.exclusion_list Contains a list of members who should not receive the request (others will drop).
protected java.util.Set<Address>	RequestOptions.exclusion_list A list of members which should be excluded from a call
protected java.util.Collection<Address>	MessageDispatcher.members

Methods in org.jgroups.blocks that return Address

Address	RequestCorrelator.getLocalAddress()
Address	BasicConnectionTable.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	TCPConnectionMap.getLocalAddress()
Address	ReplCache.getLocalAddress()
Address	PartitionedHashMap.getLocalAddress()
protected Address	TCPConnectionMap.TCPConnection.getPeerAddress()
Address	PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership) Defines a hash function to pick the right node from the list of cluster nodes.
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
protected Address	TCPConnectionMap.TCPConnection.readPeerAddress(java.net.Socket client_sock) Reads the peer's address.

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

java.util.Collection<Address>	RequestOptions.getExclusionList()
java.util.List<Address>	ReplicatedTree.getMembers()
java.util.List<Address>	ReplCache.HashFunction.hash(K key, short replication_count) Function that, given a key and a replication count, returns replication_count number of different addresses of nodes.
java.util.List<Address>	ReplCache.ConsistentHashFunction.hash(K key, short replication_count)

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

void	AbstractConnectionMap.addConnection(Address address, V conn)
<T> T	RpcDispatcher.callRemoteMethod(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> T	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options, FutureListener<T> listener) Invokes a method in a cluster member and - if blocking - returns the result
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	AbstractConnectionMap.ConnectionMapListener.connectionClosed(Address address)
boolean	TCPConnectionMap.connectionEstablishedTo(Address addr)
boolean	TCPConnectionMap.Mapper.connectionEstablishedTo(Address address)
void	BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
void	AbstractConnectionMap.ConnectionMapListener.connectionOpened(Address address, V conn)
protected RequestCorrelator	MessageDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)
TCPConnectionMap.TCPConnection	TCPConnectionMap.Mapper.getConnection(Address dest)
V	ConnectionMap.getConnection(Address dest)
boolean	AbstractConnectionMap.hasConnection(Address address)
boolean	RspFilter.isAcceptable(java.lang.Object response, Address sender) Determines whether a response from a given sender should be added to the response list of the request
protected void	AbstractConnectionMap.notifyConnectionClosed(Address address)
protected void	AbstractConnectionMap.notifyConnectionOpened(Address address, V conn)
void	BasicConnectionTable.receive(Address sender, byte[] data, int offset, int length) Calls the receiver callback.
void	BasicConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
void	TCPConnectionMap.receive(Address sender, byte[] data, int offset, int length) Calls the receiver callback.
void	TCPConnectionMap.Receiver.receive(Address sender, byte[] data, int offset, int length)
void	UnicastRequest.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
abstract void	Request.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)
void	GroupRequest.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
void	RspCollector.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)
void	RequestCorrelator.receiveSuspect(Address mbr) Event.SUSPECT event received from a layer below.
void	BasicConnectionTable.removeConnection(Address addr) Remove addrfrom connection table.
void	AbstractConnectionMap.removeConnectionIfPresent(Address address, V conn) Only removes the connection if conns.get(address) == conn
protected void	ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
void	BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
void	TCPConnectionMap.send(Address dest, byte[] data, int offset, int length)
protected void	TCPConnectionMap.TCPConnection.sendLocalAddress(Address local_addr) Send the cookie first, then the our port number.
void	RequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll) Sends a request to a single destination
RequestOptions	RequestOptions.setExclusionList(Address... mbrs)
void	RequestCorrelator.setLocalAddress(Address local_addr)
void	UnicastRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
void	ReplicatedHashMap.suspect(Address suspected_mbr) Called when a member is suspected
abstract void	Request.suspect(Address mbr)
void	ReplCache.suspect(Address suspected_mbr)
void	GroupRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
void	RspCollector.suspect(Address mbr)
void	PartitionedHashMap.suspect(Address suspected_mbr)
void	PartitionedHashMap.ConsistentHashFunction.suspect(Address suspected_mbr)

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

<T> RspList<T>	RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> RspList<T>	RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options, FutureListener<T> listener) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
protected <T> GroupRequest<T>	MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
protected <T> GroupRequest<T>	MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results, FutureListener<T> listener)
<T> RspList<T>	MessageDispatcher.castMessage(java.util.Collection<Address> dests, Message msg, RequestOptions options) Sends a message to all members and expects responses from members in dests (if non-null).
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options) Sends a message to all members and expects responses from members in dests (if non-null).
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options, FutureListener<T> listener) Sends a message to all members and expects responses from members in dests (if non-null).
Address	PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership) Defines a hash function to pick the right node from the list of cluster nodes.
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
void	ReplCache.HashFunction.installNodes(java.util.List<Address> nodes) When the topology changes, this method will be called.
void	ReplCache.ConsistentHashFunction.installNodes(java.util.List<Address> new_nodes)
void	BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs) Removes all connections from ConnectionTable which are not in current_mbrs
void	TCPConnectionMap.retainAll(java.util.Collection<Address> members)
void	AbstractConnectionMap.retainAll(java.util.Collection<Address> current_mbrs) Removes all connections which are not in current_mbrs
void	RequestCorrelator.sendRequest(long id, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options) Sends a request to a group.
void	RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)
protected void	MessageDispatcher.setMembers(java.util.List<Address> new_mbrs) If this dispatcher is using a user-provided PullPushAdapter, then need to set the members from the adapter initially since viewChange has most likely already been called in PullPushAdapter.
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)

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

GroupRequest(Message msg, RequestCorrelator corr, Address target, RequestOptions options)

RequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)

RequestCorrelator(short id, Protocol transport, RequestHandler handler, Address local_addr)
Constructor.

TCPConnectionMap.TCPConnection(Address peer_addr)
Creates a connection stub and binds it, use TCPConnectionMap.TCPConnection.connect(java.net.SocketAddress) to connect

UnicastRequest(Message msg, Address target, RequestOptions options)

UnicastRequest(Message msg, RequestCorrelator corr, Address target, RequestOptions options)

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

GroupRequest(Message msg, RequestCorrelator corr, java.util.Collection<Address> targets, RequestOptions options)

RequestCorrelator.MultiDestinationHeader(byte type, long id, boolean rsp_expected, short corr_id, java.util.Collection<Address> exclusion_list)

Uses of Address in org.jgroups.blocks.mux

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

protected RequestCorrelator	MuxMessageDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
protected RequestCorrelator	MuxRpcDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
boolean	NoMuxHandlerRspFilter.isAcceptable(java.lang.Object response, Address sender)
void	MuxRequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll)

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

protected <T> GroupRequest<T>	MuxMessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
protected <T> GroupRequest<T>	MuxRpcDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
protected <T> GroupRequest<T>	MuxMessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults, FutureListener<T> listener)
protected <T> GroupRequest<T>	MuxRpcDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults, FutureListener<T> listener)
void	MuxRequestCorrelator.sendRequest(long requestId, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)

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

MuxRequestCorrelator(short id, Protocol transport, RequestHandler handler, Address localAddr)

Uses of Address in org.jgroups.demos

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

void	ViewDemo.suspect(Address suspected_mbr) Called when a member is suspected
void	QuoteClient.suspect(Address suspected_mbr)

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

void	ReplicatedHashMapDemo.viewChange(View view, java.util.List<Address> new_mbrs, java.util.List<Address> old_mbrs)
void	ReplicatedHashMapDemo.viewChange(View view, java.util.List<Address> new_mbrs, java.util.List<Address> old_mbrs)

Uses of Address in org.jgroups.demos.wb

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

Address

Node.addr

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

void	Whiteboard.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	GraphPanel.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.suspect(Address obj)

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

void	GraphPanel.adjustNodes(java.util.List<Address> v)

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

protected Address	Executing.Owner.address
protected Address	FORWARD_TO_COORD.coord the address of the current coordinator, all msgs are forwarded to it
protected Address	SEQUENCER.coord
protected Address	CENTRAL_EXECUTOR.coord
protected Address	RELAY.coord
protected Address	CENTRAL_LOCK.coord
protected Address	COUNTER.coord The address of the cluster coordinator.
protected Address	Discovery.current_coord
protected Address	FD.FdHeader.from
protected Address	AUTH.local_addr
protected Address	FORWARD_TO_COORD.local_addr
protected Address	SIZE.local_addr
protected Address	UNICAST3.local_addr
protected Address	Locking.local_addr
protected Address	Executing.local_addr
protected Address	SEQUENCER.local_addr
protected Address	RSVP.local_addr
protected Address	UNICAST2.local_addr
protected Address	SCOPE.local_addr Deprecated.
protected Address	PDC.local_addr
protected Address	RELAY.local_addr
protected Address	STOMP.local_addr
protected Address	MERGE2.local_addr
protected Address	UNICAST.local_addr
protected Address	Discovery.local_addr
protected Address	TP.local_addr The address (host and port) of this member.
protected Address	DAISYCHAIN.local_addr
protected Address	VERIFY_SUSPECT.local_addr
protected Address	COUNTER.local_addr
protected Address	MERGE3.local_addr
protected Address	FD.local_addr
protected Address	FRAG2.local_addr
protected Address	DISCARD.localAddress
protected Address	PDC.Mapping.logical_addr
protected Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected Address	RELAY.RelayHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD.ping_dest
protected Address	PingData.sender
protected Address	VERIFY_SUSPECT.Entry.suspect
protected Address	RSVP.Entry.target

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

protected java.util.List<Address>	COUNTER.backup_coords Backup coordinators.
protected java.util.List<Address>	CENTRAL_EXECUTOR.backups
protected java.util.List<Address>	CENTRAL_LOCK.backups
protected AgeOutCache<Address>	UNICAST3.cache
protected AgeOutCache<Address>	UNICAST2.cache
protected java.util.concurrent.ConcurrentMap<Address,PhysicalAddress>	PDC.cache
protected AgeOutCache<Address>	UNICAST.cache
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	SEQUENCER.delivery_table
protected java.util.Map<Address,java.lang.String>	STOMP.endpoints
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Long,FRAG2.FragEntry>>	FRAG2.fragment_list
protected java.util.List<Address>	PEER_LOCK.PeerLock.grants
protected java.util.Set<Address>	DISCARD.ignoredMembers
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache Cache which maintains mappings between logical and physical addresses.
protected java.util.Collection<Address>	FD.FdHeader.mbrs
protected java.util.List<Address>	SIZE.members
protected java.util.List<Address>	UNICAST3.members
protected java.util.Collection<Address>	DISCARD.members
protected java.util.List<Address>	RSVP.members
protected java.util.List<Address>	UNICAST2.members
protected java.util.Set<Address>	MERGE2.members
protected java.util.List<Address>	UNICAST.members
protected java.util.List<Address>	Discovery.members
protected java.util.Set<Address>	TP.members The members of this group (updated when a member joins or leaves).
protected java.util.List<Address>	FD.members
protected java.util.List<Address>	FRAG2.members
protected java.util.Set<Address>	MERGE2.merge_candidates
protected java.util.List<Address>	FD.pingable_mbrs Members from which we select ping_dest.
protected static LazyRemovalCache.Printable<Address,PhysicalAddress>	TP.print_function
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Short,SCOPE.MessageQueue>>	SCOPE.queues Deprecated. Used to find the correct AckReceiverWindow on message reception and deliver it in the right order
protected java.util.Map<Address,FlowControl.Credit>	FlowControl.received Keeps track of credits per member at the receiver.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.ReceiverEntry>	UNICAST3.recv_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.ReceiverEntry>	UNICAST2.recv_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.ReceiverEntry>	UNICAST.recv_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.SenderEntry>	UNICAST3.send_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.SenderEntry>	UNICAST2.send_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.SenderEntry>	UNICAST.send_table
protected java.util.Map<Address,FlowControl.Credit>	UFC.sent Map: keys are members, values are credits left.
protected SuppressLog<Address>	TP.suppress_log_different_cluster Log to suppress identical warnings for messages from members in different clusters
protected SuppressLog<Address>	TP.suppress_log_different_version Log to suppress identical warnings for messages from members with different (incompatible) versions
protected BoundedList<Address>	FD.suspect_history
protected java.util.Set<Address>	FD_ALL.suspected_mbrs
protected java.util.Set<Address>	FD_SOCK.suspected_mbrs
protected java.util.List<Address>	FD.Broadcaster.suspected_mbrs
protected java.util.List<Address>	FD.BroadcastTask.suspected_members
protected java.util.Map<Address,java.lang.String>	RELAY.ViewData.uuids
protected java.util.concurrent.ConcurrentMap<ViewId,java.util.SortedSet<Address>>	MERGE3.views
protected ExpiryCache<Address>	TP.who_has_cache Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after who_has_cache_timeout ms
protected java.util.Map<Address,java.lang.Long>	UNICAST3.xmit_task_map Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)
protected java.util.Map<Address,java.lang.Long>	UNICAST2.xmit_task_map Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

Methods in org.jgroups.protocols that return Address

protected Address	FD_SOCK.determineCoordinator()
Address	AUTH.getAddress()
Address	Executing.Owner.getAddress()
Address	PingData.getAddress()
Address	TP.ProtocolAdapter.getAddress()
Address	CENTRAL_EXECUTOR.getCoord()
Address	CENTRAL_LOCK.getCoord()
Address	PingData.getCoordAddress()
Address	SEQUENCER.getCoordinator()
protected Address	ENCRYPT.getKeyServerAddr()
protected Address	ENCRYPT.getLocal_addr()
Address	SEQUENCER.getLocalAddress()
Address	PDC.Mapping.getLogicalAddr()
Address	PDC.Mapping.getPhysicalAddr()
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
Address	DISCARD.localAddress()

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

AgeOutCache<Address>	UNICAST3.getAgeOutCache()
AgeOutCache<Address>	UNICAST2.getAgeOutCache()
AgeOutCache<Address>	UNICAST.getAgeOutCache()
java.util.Collection<Address>	PingData.getMembers()
java.util.Set<Address>	TP.ProtocolAdapter.getMembers()
protected java.util.List<Address>	FD.Broadcaster.getSuspectedMembers()
java.util.Map<Address,View>	MERGE2.FindSubgroupsTask.getViews(java.util.List<PingData> initial_mbrs)

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

protected void	RSVP.Entry.ack(Address member)
void	COUNTER.ReconciliationTask.add(COUNTER.ReconcileResponse rsp, Address sender)
void	DISCARD.addIgnoreMember(Address sender) Messages from this sender will get dropped
protected void	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected static java.lang.String	FILE_PING.addressAsString(Address address)
protected static java.lang.String	PDC.addressAsString(Address address)
protected boolean	VERIFY_SUSPECT.addSuspect(Address suspect)
protected void	FD.Broadcaster.addSuspectedMember(Address mbr) Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
protected long	FlowControl.adjustCredit(java.util.Map<Address,FlowControl.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 boolean	SEQUENCER.canDeliver(Address sender, long seqno) Checks if seqno has already been received from sender.
void	FRAG2.clearFragmentsFor(Address mbr)
void	SCOPE.clearQueue(Address member) Deprecated.
void	UNICAST3.closeConnection(Address mbr) Removes and resets from connection table (which is already locked).
void	UNICAST3.closeReceiveConnection(Address mbr)
void	UNICAST3.closeSendConnection(Address mbr)
protected void	FD.computePingDest(Address remove) Computes pingable_mbrs (based on the current membership and the suspected members) and ping_dest
void	TUNNEL.TUNNELPolicy.connect(java.util.List<RouterStub> stubs, java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs)
protected void	TCPGOSSIP.connect(RouterStub stub, java.lang.String group, Address logical_addr)
protected void	TCPGOSSIP.connectAllStubs(java.lang.String group, Address logical_addr)
boolean	UNICAST2.connectionEstablished(Address target) Is the send connection to target established
static RELAY.RelayHeader	RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id)
void	TCPPING.discoveryRequestReceived(Address sender, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)
void	Discovery.discoveryRequestReceived(Address sender, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)
protected void	TP.doSend(Buffer buf, Address dest, boolean multicast)
void	UNICAST3.expired(Address key) Called by AgeOutCache, to removed expired connections
void	UNICAST2.expired(Address key) Called by AgeOutCache, to removed expired connections
void	UNICAST.expired(Address key) Called by AgeOutCache, to removed expired connections
protected void	SEQUENCER.flush(Address new_coord)
protected SCOPE.MessageQueue	SCOPE.getOrCreateQueue(Address sender, short scope) Deprecated.
protected UNICAST2.ReceiverEntry	UNICAST2.getOrCreateReceiverEntry(Address sender, long seqno, short conn_id)
protected UNICAST.ReceiverEntry	UNICAST.getOrCreateReceiverEntry(Address sender, long seqno, short conn_id)
protected PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
protected UNICAST3.ReceiverEntry	UNICAST3.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id)
protected UNICAST2.ReceiverEntry	UNICAST2.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id)
protected UNICAST.ReceiverEntry	UNICAST.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id)
protected void	UNICAST3.handleAckReceived(Address sender, long seqno, short conn_id) Add the ACK to hashtable.sender.sent_msgs
protected void	UNICAST.handleAckReceived(Address sender, long seqno, short conn_id)
protected void	UNICAST2.handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map)
protected void	UNICAST.handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map)
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, java.util.List<Tuple<java.lang.Long,Message>> msgs, boolean oob)
protected void	Executing.handleConsumerFoundResponse(long threadId, Address address)
protected void	Executing.handleConsumerReadyRequest(long requestId, Address address)
protected void	Executing.handleConsumerUnreadyRequest(long requestId, Address address)
protected void	MFC.handleCredit(Address sender, long increase)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	UNICAST3.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Check whether the hashtable contains an entry e for sender (create if not).
protected boolean	UNICAST2.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Check whether the hashmap contains an entry e for sender (create if not).
protected void	UNICAST.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Check whether the hashtable contains an entry e for sender (create if not).
protected java.lang.Object	MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected abstract java.lang.Object	FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected java.lang.Object	UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected void	Executing.handleExceptionResponse(Address source, long requestId, java.lang.Throwable throwable)
protected void	Executing.handleInterruptRequest(Address source, long requestId)
protected void	Locking.ClientLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	Locking.handleLockGrantedResponse(java.lang.String lock_name, Owner owner, Address sender)
protected void	COUNTER.handleRequest(COUNTER.Request req, Address sender)
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender) We need to resend the first message with our conn_id
protected void	UNICAST2.handleResendingOfFirstMessage(Address sender, long seqno) We need to resend our first message with our conn_id
protected void	UNICAST.handleResendingOfFirstMessage(Address sender, long seqno) We need to resend our first message with our conn_id
protected void	RSVP.handleResponse(Address member, short id)
protected void	COUNTER.handleResponse(COUNTER.Response rsp, Address sender)
protected void	Executing.handleTaskRejectedResponse(Address source, long requestId)
protected void	Executing.handleTaskRequest(long requestId, Address address)
protected void	Executing.handleTaskSubmittedRequest(java.lang.Runnable runnable, Address source, long requestId, long threadId)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UNICAST3.Header hdr)
protected void	UNICAST.handleUpEvent(Address sender, UNICAST.UnicastHeader hdr)
protected void	Executing.handleValueResponse(Address source, long requestId, java.lang.Object value)
protected void	UNICAST3.handleXmitRequest(Address sender, SeqnoList missing)
protected void	UNICAST2.handleXmitRequest(Address sender, SeqnoList missing)
boolean	UNICAST3.hasSendConnectionTo(Address dest) Used for testing only
boolean	UNICAST2.hasSendConnectionTo(Address dest) Used for testing only
boolean	UNICAST.hasSendConnectionTo(Address dest) Used for testing only
protected boolean	RELAY.isLocal(Address dest) Does the payload match the 'site' ID.
DISCARD	DISCARD.localAddress(Address addr)
void	BasicTCP.receive(Address sender, byte[] data, int offset, int length) ConnectionMap.Receiver interface
protected 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.
protected static void	SHARED_LOOPBACK.register(java.lang.String channel_name, 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	SWIFT_PING.remove(java.lang.String clustername, Address addr)
protected void	FILE_PING.remove(java.lang.String clustername, Address addr)
protected void	JDBC_PING.remove(java.lang.String clustername, Address addr)
protected void	S3_PING.remove(java.lang.String clustername, Address addr)
protected void	RACKSPACE_PING.remove(java.lang.String clustername, Address addr)
protected int	UNICAST3.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Try to remove as many messages as possible from the table as pass them up.
protected int	UNICAST.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Try to remove as many messages as possible from the table as pass them up.
protected void	UNICAST2.removeAndPassUp(Table<Message> win, Address sender) Try to remove as many messages as possible and pass them up.
void	UNICAST2.removeConnection(Address mbr) Removes and resets from connection table (which is already locked).
void	UNICAST.removeConnection(Address mbr) Removes and resets from connection table (which is already locked).
void	DISCARD.removeIgnoredMember(Address member)
protected void	TP.removeLogicalAddressFromCache(Address logical_addr)
protected void	PDC.removeNodeFromDisk(Address logical_addr)
protected void	UNICAST3.removeReceiveConnection(Address mbr)
void	UNICAST2.removeReceiveConnection(Address mbr)
void	UNICAST.removeReceiveConnection(Address mbr)
void	SCOPE.removeScope(Address member, short scope) Deprecated.
protected void	UNICAST3.removeSendConnection(Address mbr)
void	UNICAST2.removeSendConnection(Address mbr)
void	UNICAST.removeSendConnection(Address mbr)
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
protected void	UNICAST3.retransmit(SeqnoList missing, Address sender) Sends a retransmit request to the given sender
void	UNICAST2.retransmit(SeqnoList missing, Address sender)
protected void	COUNTER.send(Address dest, Buffer buffer)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length)
protected void	FORWARD_TO_COORD.send(Address target, long ack_id, byte type)
protected void	TUNNEL.send(Message msg, Address dest, boolean multicast)
protected void	TP.send(Message msg, Address dest, boolean multicast) Serializes and sends a message.
protected void	FORWARD_TO_COORD.sendAck(Address target, long ack_id)
protected void	UNICAST3.sendAck(Address dst, long seqno, short conn_id)
protected void	UNICAST2.sendAck(Address dest, long seqno, short conn_id)
protected void	UNICAST.sendAck(Address dst, long seqno, short conn_id)
void	UNICAST3.sendClose(Address dest, short conn_id)
protected void	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, java.lang.String counter_name)
protected void	CENTRAL_LOCK.sendCreateLockRequest(Address dest, java.lang.String lock_name, Owner owner)
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, java.lang.Long credits_needed) We cannot send this request as OOB message, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected void	CENTRAL_LOCK.sendDeleteLockRequest(Address dest, java.lang.String lock_name)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, java.util.List<PhysicalAddress> physical_addrs, boolean is_server, boolean return_view_only, java.lang.String logical_name, Address sender)
protected void	FD.sendHeartbeatResponse(Address dest)
protected void	AUTH.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	FORWARD_TO_COORD.sendNotCoord(Address target, long ack_id)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	Executing.sendRequest(Address dest, Executing.Type type, long requestId, java.lang.Object object)
protected void	Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, Owner owner, long timeout, boolean is_trylock)
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest)
protected void	UNICAST2.sendRequestForFirstSeqno(Address dest, long seqno_received)
protected void	UNICAST.sendRequestForFirstSeqno(Address dest, long seqno_received)
protected void	COUNTER.sendResponse(Address dest, COUNTER.Response rsp)
protected void	RSVP.sendResponse(Address dest, short id)
protected void	UNICAST2.sendStableMessage(Address dest, short conn_id, long hd, long hr)
protected void	Executing.sendThreadRequest(Address dest, long threadId, Executing.Type type, long requestId, java.lang.Object object)
protected abstract void	Executing.sendToCoordinator(Executing.Type type, long requestId, Address address)
protected void	CENTRAL_EXECUTOR.sendToCoordinator(Executing.Type type, long requestId, Address value)
protected void	TP.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
protected void	SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToSingleMember(java.util.List<RouterStub> stubs, java.lang.String group, Address dest, byte[] data, int offset, int length)
protected void	TP.setInAllThreadFactories(java.lang.String cluster_name, Address local_address, java.lang.String pattern)
protected void	ENCRYPT.setKeyServerAddr(Address keyServerAddr)
protected void	ENCRYPT.setLocal_addr(Address local_addr)
void	DISCARD.setLocalAddress(Address localAddress)
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender) Checks if a message should be passed up, or not
protected void	UNICAST2.stable(Address sender, short conn_id, long hd, long hr) Purge all messages in window for local_addr, which are <= low.
protected void	FD.Broadcaster.startBroadcastTask(Address suspect) Starts a new task, or - if already running - adds the argument to the running task.
protected void	SEQUENCER.startFlusher(Address new_coord)
protected static void	SHARED_LOOPBACK.unregister(java.lang.String channel_name, Address local_addr)
protected boolean	FD_ALL.unsuspect(Address mbr) Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack
void	VERIFY_SUSPECT.unsuspect(Address mbr)
protected void	FD.unsuspect(Address mbr)
protected void	FD.updateTimestamp(Address sender)
static void	TP.writeMessageList(Address dest, Address src, java.lang.String cluster_name, java.util.List<Message> msgs, java.io.DataOutputStream dos, boolean multicast, short transport_id) Write a list of messages with the *same* destination and src addresses.
protected void	PDC.writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr)
protected java.io.File	PDC.writeToTempFile(java.io.File dir, Address logical_addr, Address physical_addr, java.lang.String logical_name) Writes the data to a temporary file. The file is stored in the same directory as the other cluster files but is given the .tmp suffix

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

protected long	FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map, Address sender, int length) Check whether sender has enough credits left.
protected void	VERIFY_SUSPECT.adjustSuspectedMembers(java.util.List<Address> new_mbrship) Removes all elements from suspects that are not in the new membership
protected void	CENTRAL_LOCK.copyLocksTo(java.util.List<Address> new_joiners)
protected void	CENTRAL_EXECUTOR.copyQueueTo(java.util.List<Address> new_joiners)
static java.util.List<View>	MERGE3.detectDifferentViews(java.util.Map<Address,View> map)
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
protected void	FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	Locking.ServerLock.handleView(java.util.List<Address> members)
protected void	MFC.handleViewChange(java.util.List<Address> mbrs)
protected void	FlowControl.handleViewChange(java.util.List<Address> mbrs)
protected void	UFC.handleViewChange(java.util.List<Address> mbrs)
protected static java.lang.String	FlowControl.printMap(java.util.Map<Address,FlowControl.Credit> m)
abstract void	BasicTCP.retainAll(java.util.Collection<Address> members)
void	TCP.retainAll(java.util.Collection<Address> members)
protected boolean	RSVP.Entry.retainAll(java.util.Collection<Address> members)
void	TCP_NIO.retainAll(java.util.Collection<Address> members)
protected void	PEER_LOCK.PeerLock.retainAll(java.util.List<Address> members)
protected void	RELAY.sendViewOnLocalCluster(java.util.List<Address> destinations, byte[] buffer)
protected void	RELAY.sendViewOnLocalCluster(RELAY.ViewData data, boolean use_seperate_thread, java.util.List<Address> new_mbrs)
protected void	RELAY.sendViewOnLocalCluster(View remote_view, View global_view, boolean use_seperate_thread, java.util.List<Address> new_mbrs)
protected void	FD_ALL.suspect(java.util.List<Address> suspects)

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

Executing.Owner(Address address, long requestId)

FD_SOCK.FdHeader(byte type, Address mbr)

FD_SOCK.FdHeader(byte type, Address mbr, IpAddress sock_addr)

FD.FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)

PDC.Mapping(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name)

PingData(Address sender, View view, boolean is_server)

PingData(Address sender, View view, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)

PingData(Address sender, View view, ViewId view_id, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)

RSVP.Entry(Address member)
Unicast entry

SEQUENCER.Flusher(Address new_coord)

TP.ProtocolAdapter(java.lang.String cluster_name, Address local_addr, short transport_id, Protocol up, Protocol down, java.lang.String pattern)

VERIFY_SUSPECT.Entry(Address suspect, long target_time)

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

FD_SOCK.FdHeader(byte type, java.util.Map<Address,IpAddress> cachedAddrs)

FD_SOCK.FdHeader(byte type, java.util.Set<Address> mbrs)

FD.FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)

RSVP.Entry(java.util.Collection<Address> members)
Multicast entry

Uses of Address in org.jgroups.protocols.pbcast

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

protected Address	STABLE.coordinator
protected Address	StreamingStateTransfer.local_addr
protected Address	NAKACK2.local_addr
protected Address	GMS.local_addr
protected Address	STABLE.local_addr
protected Address	StreamingStateTransfer.StateGetter.requester
protected Address	MergeData.sender
protected Address	StreamingStateTransfer.state_provider
protected Address	STATE.StateOutputStream.stateRequester

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

protected java.util.Set<Address>	STABLE.mbrs
protected java.util.List<Address>	StreamingStateTransfer.members
protected java.util.List<Address>	NAKACK2.members
protected java.util.Map<Address,java.io.OutputStream>	StreamingStateTransfer.pending_state_transfers Whenever we get a state transfer request, we create an OutputStream and add the state requester's address and the OutputStream to this map.
protected SuppressLog<Address>	NAKACK2.suppress_log_non_member Log to suppress identical warnings for messages from non-members
protected SuppressLog<Address>	NAKACK.suppress_log_non_member Log to suppress identical warnings for messages from non-members
protected java.util.Set<Address>	STABLE.votes Keeps track of who we already heard from (STABLE_GOSSIP msgs).
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table Map to store sent and received messages (keyed by sender)
protected java.util.Map<Address,java.lang.Long>	NAKACK2.xmit_task_map Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

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

protected Address	StreamingStateTransfer.determineCoordinator()
protected Address	GMS.determineCoordinator()
Address	GMS.GmsHeader.getMember()
Address	NakAckHeader2.getSender()
Address	MergeData.getSender()
Address	NakAckHeader.getSender()

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

protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected boolean	STABLE.addVote(Address mbr) Adds mbr to votes and returns true if we have all the votes, otherwise false.
protected void	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract void	StreamingStateTransfer.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr) Creates an InputStream to the state provider to read the state
protected void	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	STATE_SOCK.createStreamToRequester(Address requester)
protected abstract void	StreamingStateTransfer.createStreamToRequester(Address requester) Creates an OutputStream to the state requester to write the state
protected void	STATE.createStreamToRequester(Address requester)
static NakAckHeader2	NakAckHeader2.createXmitRequestHeader(Address orginal_sender)
static NakAckHeader	NakAckHeader.createXmitRequestHeader(long low, long high, Address orginal_sender)
Digest	NAKACK2.getDigest(Address mbr)
Digest	NAKACK.getDigest(Address mbr)
protected void	STATE_TRANSFER.getStateFromApplication(Address requester, Digest digest)
protected void	StreamingStateTransfer.getStateFromApplication(Address requester, java.io.OutputStream out, boolean use_separate_thread)
Table<Message>	NAKACK2.getWindow(Address sender) Returns the receive window for sender; only used for testing.
NakReceiverWindow	NAKACK.getWindow(Address mbr) Please don't use this method; it is only provided for unit testing !
void	Merger.handleDigestResponse(Address sender, Digest digest)
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
protected void	StreamingStateTransfer.handleEOF(Address sender)
protected void	STATE.handleEOF(Address sender)
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected void	NAKACK2.handleMessages(Address sender, java.util.List<Tuple<java.lang.Long,Message>> msgs, boolean oob, java.lang.String cluster_name)
protected void	STABLE.handleStabilityMessage(Digest stable_digest, Address sender)
protected void	STABLE.handleStableMessage(Digest d, Address sender) Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
protected void	StreamingStateTransfer.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE_SOCK.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STABLE.handleUpEvent(STABLE.StableHeader hdr, Address sender)
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	CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	ClientGmsImpl.join(Address address, boolean useFlushIfPresent)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
abstract void	GmsImpl.leave(Address mbr)
void	ClientGmsImpl.leave(Address mbr)
protected void	NAKACK2.removeAndPassUp(Table<Message> buf, Address sender, boolean loopback, java.lang.String cluster_name) Efficient way of checking whether another thread is already processing messages from sender.
protected void	StreamingStateTransfer.removeRequester(Address requester)
protected void	NAKACK2.retransmit(long first_seqno, long last_seqno, Address sender)
void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender) Implementation of Retransmitter.RetransmitCommand.
protected void	NAKACK2.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	NAKACK2.retransmit(SeqnoList missing_msgs, Address sender, boolean multicast_xmit_request)
protected void	StreamingStateTransfer.sendEof(Address requester)
protected void	STATE_TRANSFER.sendException(Address requester, java.lang.Throwable exception)
protected void	StreamingStateTransfer.sendException(Address requester, java.lang.Throwable exception)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg) Sends a message msg to the requester.
protected void	StreamingStateTransfer.setStateInApplication(Address provider, java.io.InputStream in, Digest digest)
void	CoordGmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr) Removes previously suspected member from list of currently suspected members
void	GmsImpl.unsuspect(Address mbr)
protected boolean	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

protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected void	NAKACK2.adjustReceivers(java.util.List<Address> new_members) Remove old members from the retransmission buffers.
protected boolean	STABLE.allVotesReceived(java.util.Set<Address> votes) Votes is already locked and guaranteed to be non-null
void	GMS.castViewChange(View new_view, Digest digest, JoinRsp jr, java.util.Collection<Address> newMembers) Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
View	GMS.getNextView(java.util.Collection<Address> new_mbrs, java.util.Collection<Address> old_mbrs, java.util.Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(java.util.Collection<Address> new_mbrs, java.util.Collection<Address> old_mbrs, java.util.Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(java.util.Collection<Address> new_mbrs, java.util.Collection<Address> old_mbrs, java.util.Collection<Address> suspected_mbrs) Computes the next view.
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
void	Merger.merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	CoordGmsImpl.merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	GmsImpl.merge(java.util.Map<Address,View> views)
static void	Merger.sanitizeViews(java.util.Map<Address,View> map) Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061).

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

GMS.GmsHeader(byte type, Address mbr)

GMS.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)

STATE.StateOutputStream(Address stateRequester)

StreamingStateTransfer.StateGetter(Address requester, java.io.OutputStream output)

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

FLUSH.FlushHeader(byte type, long viewID, java.util.Collection<? extends Address> flushView)

GMS.GmsHeader(byte type, java.util.Collection<Address> mbrs)

Uses of Address in org.jgroups.protocols.relay

Subinterfaces of Address in org.jgroups.protocols.relay

interface

SiteAddress Address with a site suffix

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

class	CanBeSiteMaster Subclass of UUID which adds a boolean as payload.
class	CanBeSiteMasterTopology Subclass of TopologyUUID which adds a boolean as payload.
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

protected Address	RELAY2.coord
protected Address	RELAY2.Relay2Header.final_dest
protected Address	RELAY2.local_addr
protected Address	RELAY2.Relay2Header.original_sender

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

protected static Address	RELAY2.determineSiteMaster(View view) Gets the site master from view.
Address	RELAY2.getLocalAddress()
Address	Relayer.Route.siteMaster()

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

protected void	Relayer.Bridge.changeStatusToUp(short id, JChannel bridge, Address site_master)
int	SiteMaster.compareTo(Address other)
protected Message	Relayer.Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected void	RELAY2.forwardTo(Address next_dest, SiteAddress final_dest, Address original_sender, Message msg, boolean forward_to_current_coord)
void	Relayer.Route.send(short target_site, Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.sendSiteUnreachableTo(Address dest, short target_site) Sends a SITE-UNREACHABLE message to the sender of the message.
protected void	RELAY2.sendToBridges(Address sender, Message msg, short... excluded_sites) Sends the message via all bridges excluding the excluded_sites bridges
Relayer.Route	Relayer.Route.siteMaster(Address new_site_master)

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

RELAY2.Relay2Header(byte type, Address final_dest, Address original_sender)

Relayer.Route(Address site_master, JChannel bridge)

Relayer.Route(Address site_master, JChannel bridge, RELAY2.RouteStatus status)

Uses of Address in org.jgroups.protocols.rules

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

protected Address

SUPERVISOR.local_addr

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

Address

SUPERVISOR.getLocalAddress()

Uses of Address in org.jgroups.protocols.tom

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

Address	MessageID.getAddress()
Address	ToaHeader.getOrigin()

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

java.util.Set<Address>	SenderManager.getDestination(MessageID messageID) obtains the destination set of a message
java.util.Collection<Address>	ToaHeader.getDestinations()

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

long	SenderManager.addPropose(MessageID messageID, Address from, long sequenceNumber) Add a propose from a member in destination set

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

void	ToaHeader.addDestinations(java.util.Collection<Address> addresses)
void	SenderManager.addNewMessageToSend(MessageID messageID, java.util.Collection<Address> destinations, long initialSequenceNumber, boolean deliverToMyself) Add a new message sent
void	DeliveryManagerImpl.removeLeavers(java.util.Collection<Address> leavers)
long	SenderManager.removeLeavers(MessageID messageID, java.util.Collection<Address> leavers)

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

MessageID(Address address)

MessageID(Address address, long id)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

class

IpAddress Network-dependent address (Internet).

Fields in org.jgroups.stack declared as Address

protected Address	Retransmitter.Task.msg_sender
protected Address	Retransmitter.sender
Address	StateTransferInfo.target

Methods in org.jgroups.stack that return Address

Address	AddressGenerator.generateAddress()
Address	GossipData.getAddress()

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

java.util.List<Address>

GossipData.getMembers()

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

int	IpAddress.compareTo(Address o) implements the java.lang.Comparable interface
void	RouterStub.connect(java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs) Register this process with the router under group.
void	RouterStub.disconnect(java.lang.String group, Address addr)
void	NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
void	NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
void	Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender) Get the missing messages between sequence numbers first_seqno and last_seqno.
void	RouterStub.sendToMember(java.lang.String group, Address dest, byte[] data, int offset, int length)
void	ProtocolStack.startStack(java.lang.String cluster_name, Address local_addr) Start all layers.

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

void	GossipData.setMembers(java.util.List<Address> mbrs)

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

DefaultRetransmitter.SeqnoTask(long seqno, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)

DefaultRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
Create a new Retransmitter associated with the given sender address

GossipData(byte type, java.lang.String group, Address addr)

GossipData(byte type, java.lang.String group, Address addr, byte[] buffer)

GossipData(byte type, java.lang.String group, Address addr, byte[] buffer, int offset, int length)

GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs)

GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs, java.util.List<PhysicalAddress> physical_addrs)

GossipData(byte type, java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs)

NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched)
Creates a new instance with the given retransmit command

NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched, boolean use_range_based_retransmitter)

NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched, boolean use_range_based_retransmitter, int num_rows, int msgs_per_row, double resize_factor, long max_compaction_time, boolean automatic_purging)

RangeBasedRetransmitter.RangeTask(Seqno range, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)

RangeBasedRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
Create a new Retransmitter associated with the given sender address

Retransmitter.Task(Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)

Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
Create a new Retransmitter associated with the given sender address

RouterStubManager(Protocol owner, java.lang.String channelName, Address logicalAddress, long interval)

StateTransferInfo(Address target)

StateTransferInfo(Address target, long timeout)

StateTransferInfo(Address target, long timeout, byte[] state)

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

GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs)

GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs, java.util.List<PhysicalAddress> physical_addrs)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

class	AdditionalDataUUID Subclass of UUID which adds a string as payload.
class	PayloadUUID Subclass of UUID which adds a string as payload.
class	SingletonAddress Address with a cluster name.
class	TopologyUUID Subclass of UUID which adds 3 strings (siteId, rackId and machineId)as payload.
class	UUID Logical address which is unique over space and time.

Fields in org.jgroups.util declared as Address

protected Address	SingletonAddress.addr
protected Address	Owner.address
protected Address	MessageBatch.dest The destination address.
protected Address	ForwardQueue.local_addr
protected Address	Digest.DigestEntry.member
protected Address[]	Digest.members
protected Address	ForwardQueue.Flusher.new_coord
protected Address	Rsp.sender The sender of this response
protected Address	MessageBatch.sender The sender of the message batch

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

protected static LazyRemovalCache<Address,java.lang.String>	UUID.cache Keeps track of associations between logical addresses (UUIDs) and logical names
protected java.util.Map<Address,java.lang.Long>	CreditMap.credits
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	ForwardQueue.delivery_table
protected java.util.List<Address>	AckCollector.missing_acks List of members from whom we haven't received an ACK yet
protected static LazyRemovalCache.Printable<Address,java.lang.String>	UUID.print_function
protected java.util.List<Address>	AckCollector.suspected_mbrs

Methods in org.jgroups.util that return Address

static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(java.lang.String name)
Address	MessageBatch.dest()
Address	Owner.getAddress()
Address	SingletonAddress.getAddress()
static Address	Util.getCoordinator(View view)
Address	ForwardQueue.getLocalAddr()
Address	Digest.DigestEntry.getMember()
Address	Rsp.getSender()
static Address	Util.readAddress(java.io.DataInput in)
Address	MessageBatch.sender()

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

static java.util.Collection<Address>	Util.determineActualMergeCoords(java.util.Map<Address,View> map) Similar to Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual coord is when the sender of a view is the first member of that view
static java.util.List<Address>	Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs) Returns all members that left between 2 views.
static java.util.Collection<Address>	Util.determineMergeCoords(java.util.Map<Address,View> map) This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static java.util.Collection<Address>	Util.determineMergeParticipants(java.util.Map<Address,View> map) Determines the members which take part in a merge.
java.util.Set<java.util.Map.Entry<Address,Rsp<T>>>	RspList.entrySet()
static java.util.Map<Address,java.lang.String>	UUID.getContents() Returns a copy of the cache's contents
java.util.Set<Address>	Digest.getMembers()
java.util.List<Tuple<Address,java.lang.Long>>	CreditMap.getMembersWithCreditsLessThan(long min_credits)
java.util.List<Address>	CreditMap.getMembersWithInsufficientCredits(long credit_needed)
java.util.List<Address>	ResponseCollector.getMissing() Returns a list of members which didn't send a valid response
java.util.Map<Address,T>	ResponseCollector.getResults()
java.util.List<Address>	RspList.getSuspectedMembers()
java.util.List<Address>	ResponseCollector.getValidResults()
java.util.Set<Address>	CreditMap.keys()
java.util.Set<Address>	RspList.keySet()
static java.util.List<Address>	Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
static java.util.List<Address>	Util.leftMembers(View one, View two) Returns a list of members which left from view one to two
static java.util.List<Address>	Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
static java.util.List<Address>	Util.pickSubset(java.util.List<Address> members, double subset_percentage) Selects a random subset of members according to subset_percentage and returns them.
static java.util.Collection<? extends Address>	Util.readAddresses(java.io.DataInput in, java.lang.Class cl)

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

void	AckCollector.ack(Address member)
void	MutableDigest.add(Address member, long highest_delivered_seqno, long highest_received_seqno)
void	MutableDigest.add(Address member, long highest_delivered_seqno, long highest_received_seqno, boolean replace)
static void	UUID.add(Address uuid, java.lang.String logical_name)
void	ResponseCollector.add(Address member, T data)
protected void	AckCollector.addAll(Address... members)
void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, T retval)
protected boolean	ForwardQueue.canDeliver(Address sender, long seqno) Checks if seqno has already been received from sender.
int	UUID.compareTo(Address other) Compares this UUID with the specified UUID.
int	SingletonAddress.compareTo(Address o)
boolean	Digest.contains(Address member)
static MergeId	MergeId.create(Address addr)
static View	Util.createView(Address coord, long id, Address... members)
static View	Util.createView(Address coord, long id, Address... members)
protected void	CreditMap.decrementAndAdd(Address member, long new_credits) Decrements credits bytes from all elements and add new_credits to member (if non null).
MessageBatch	MessageBatch.dest(Address dest)
protected void	ForwardQueue.doFlush(Address new_target)
protected int	Digest.find(Address member)
void	ForwardQueue.flush(Address new_target, java.util.List<Address> mbrs)
protected void	ForwardQueue.flushMessagesInForwardTable(Address target) Sends all messages currently in forward_table to the new target (changing the dest field).
long[]	Digest.get(Address member) Returns the highest delivered and received seqnos associated with a member.
static java.lang.String	UUID.get(Address logical_addr)
java.lang.Long	CreditMap.get(Address member)
static int	Util.getRank(java.util.Collection<Address> members, Address addr)
static int	Util.getRank(View view, Address addr) Returns the rank of a member in a given view
long	Digest.highestDeliveredSeqnoAt(Address sender)
long	Digest.highestReceivedSeqnoAt(Address sender)
void	MutableDigest.incrementHighestDeliveredSeqno(Address member) Increments the sender's highest delivered seqno by 1
static boolean	Util.isCoordinator(View view, Address local_addr)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
void	MutableDigest.merge(Address member, long highest_delivered_seqno, long highest_received_seqno) Similar to add(), 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) If the member doesn not exist, a new entry will be added (provided there is enough space)
Rsp<T>	RspList.put(Address key, Rsp<T> value)
java.lang.Long	CreditMap.putIfAbsent(Address key)
static void	UUID.remove(Address addr)
java.lang.Long	CreditMap.remove(Address key)
void	ResponseCollector.remove(Address member)
void	CreditMap.replenish(Address sender, long new_credits)
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)
void	MutableDigest.setHighestDeliveredAndSeenSeqnos(Address member, long highest_delivered_seqno, long highest_received_seqno)
void	ForwardQueue.setLocalAddr(Address local_addr)
static int	Util.size(Address addr)
protected void	ForwardQueue.startFlusher(Address new_coord)
void	AckCollector.suspect(Address member)
void	ResponseCollector.suspect(Address member)
static void	Util.writeAddress(Address addr, java.io.DataOutput out)

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

static void	UUID.add(java.util.Map<Address,java.lang.String> map)
protected void	AckCollector.addAll(java.util.Collection<Address> members)
static byte[]	Util.collectionToByteBuffer(java.util.Collection<Address> c)
protected void	Digest.createArrays(java.util.Map<Address,long[]> map)
static java.util.List<View>	Util.detectDifferentViews(java.util.Map<Address,View> map)
static java.util.Collection<Address>	Util.determineActualMergeCoords(java.util.Map<Address,View> map) Similar to Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual coord is when the sender of a view is the first member of that view
static java.util.List<Address>	Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs) Returns all members that left between 2 views.
static java.util.List<Address>	Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs) Returns all members that left between 2 views.
static java.util.Collection<Address>	Util.determineMergeCoords(java.util.Map<Address,View> map) This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static java.util.Collection<Address>	Util.determineMergeParticipants(java.util.Map<Address,View> map) Determines the members which take part in a merge.
void	ForwardQueue.flush(Address new_target, java.util.List<Address> mbrs)
static int	Util.getRank(java.util.Collection<Address> members, Address addr)
static java.util.List<Address>	Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
static java.util.List<Address>	Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
static java.util.List<Address>	Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
static java.util.List<Address>	Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
static java.util.List<Address>	Util.pickSubset(java.util.List<Address> members, double subset_percentage) Selects a random subset of members according to subset_percentage and returns them.
void	RspList.putAll(java.util.Map<? extends Address,? extends Rsp<T>> m)
void	ResponseCollector.remove(java.util.List<Address> members)
static void	UUID.removeAll(java.util.Collection<Address> mbrs)
void	AckCollector.reset(java.util.Collection<Address> members)
void	ResponseCollector.reset(java.util.Collection<Address> members)
boolean	AckCollector.retainAll(java.util.Collection<Address> members)
static void	UUID.retainAll(java.util.Collection<Address> logical_addrs)
void	ResponseCollector.retainAll(java.util.List<Address> members)
static long	Util.size(java.util.Collection<? extends Address> addrs) Returns the marshalled size of a Collection of Addresses.
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants)
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)
static void	Util.writeAddresses(java.util.Collection<? extends Address> v, java.io.DataOutput out) Writes a Vector of Addresses.

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

AckCollector(Address... members)

Digest.DigestEntry(Address member, long highest_delivered, long highest_received)

Digest(Address[] members, long[] seqnos)

Digest(Address sender, long highest_delivered)

Digest(Address sender, long highest_delivered, long highest_received)

ForwardQueue.Flusher(Address new_coord)

MessageBatch(Address dest, Address sender, java.lang.String cluster_name, boolean multicast, java.util.Collection<Message> msgs)

MessageBatch(Address dest, Address sender, java.lang.String cluster_name, boolean multicast, MessageBatch.Mode mode, int capacity)

MutableDigest(Address[] members, long[] seqnos, int current_index)

Owner(Address address, long thread_id)

ResponseCollector(Address... members)

Rsp(Address sender)

Rsp(Address sender, T retval)

Rsp(Address sender, java.lang.Throwable t)

SingletonAddress(java.lang.String cluster_name, Address addr)

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

AckCollector(java.util.Collection<Address> members)

Digest(java.util.Map<Address,long[]> map)
Creates a new digest from an existing map by copying the keys and values from map

MutableDigest(java.util.Map<Address,long[]> map)

ResponseCollector(java.util.Collection<Address> members)