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.locking
org.jgroups.blocks.mux
org.jgroups.debug	Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
org.jgroups.mux
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.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

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

Fields in org.jgroups declared as Address

Modifier and Type	Field	Description
protected Address	Message.dest_addr
protected Address	JChannel.local_addr
static final Address	Global.NULL_ADDR
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

Modifier and Type	Field	Description
protected Vector<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

Modifier and Type	Method	Description
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()	Returns the local address of the channel (null if the channel is closed)
Address	ViewId.getCoordAddress()	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()
abstract Address	Channel.getLocalAddress()	Deprecated. Use Channel.getAddress() instead
Address	JChannel.getLocalAddress()	Deprecated.
Address	Message.getSrc()

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

Modifier and Type	Method	Description
Vector<Address>	Membership.getMembers()	returns a copy (clone) of the members in this membership.
Vector<Address>	View.getMembers()	Returns a reference to the List of members (ordered) Do NOT change this list, hence your will invalidate the view Make a copy if you have to modify it.

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method	Description
void	Membership.add(Address new_member)	Adds a new member to this membership.
void	Membership.add(Address... mbrs)
void	ChannelListener.channelReconnected(Address addr)	Deprecated.
void	ChannelListenerAdapter.channelReconnected(Address addr)
abstract void	Channel.connect(String cluster_name, Address target, String state_id, long timeout)	Connects the channel to a group and fetches the state
void	JChannel.connect(String cluster_name, Address target, String state_id, long timeout)	Connects this channel to a group and gets a state from a specified state provider.
void	JChannel.connect(String cluster_name, Address target, String state_id, long timeout, boolean useFlushIfPresent)	Connects this channel to a group and gets a state from a specified state provider.
boolean	Membership.contains(Address member)	Returns true if the provided member belongs to this membership
boolean	View.containsMember(Address mbr)	returns true, if this view contains a certain member
abstract String	Channel.getName(Address member)	Returns the logical name of a given member.
String	JChannel.getName(Address member)
abstract boolean	Channel.getState(Address target, long timeout)	Retrieve the state of the group.
abstract boolean	Channel.getState(Address target, String state_id, long timeout)	Fetches a partial state identified by state_id.
boolean	JChannel.getState(Address target, long timeout)	Retrieves a full state from the target member.
boolean	JChannel.getState(Address target, String state_id, long timeout)	Retrieves a substate (or partial state) indicated by state_id from the target member.
boolean	JChannel.getState(Address target, String state_id, long timeout, boolean useFlushIfPresent)	Retrieves a substate (or partial state) indicated by state_id from the target member.
protected boolean	JChannel.getState(Address target, String state_id, long timeout, Callable<Boolean> flushInvoker)	Retrieves a substate (or partial state) indicated by state_id from the target member.
void	Membership.remove(Address old_member)	removes an member from the membership.
abstract void	Channel.send(Address dst, Address src, byte[] buf)
abstract void	Channel.send(Address dst, Address src, byte[] buf, int offset, int length)
abstract void	Channel.send(Address dst, Address src, Serializable obj)	Helper method.
void	JChannel.send(Address dst, Address src, byte[] buf)
void	JChannel.send(Address dst, Address src, byte[] buf, int offset, int length)
void	JChannel.send(Address dst, Address src, Serializable obj)	creates a new message with the destination address, and the source address and the object as the message value
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	ExtendedReceiverAdapter.suspect(Address suspected_mbr)
void	MembershipListener.suspect(Address suspected_mbr)	Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReceiverAdapter.suspect(Address mbr)
void	Message.writeToNoAddrs(Address src, DataOutputStream out)	Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address

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

Modifier and Type	Method	Description
final void	Membership.add(Collection<Address> v)	Adds a list of members to this membership
void	Membership.merge(Collection<Address> new_mems, Collection<Address> suspects)	merges membership with the new members and removes suspects The Merge method will remove all the suspects and add in the new members.
void	Membership.remove(Collection<Address> v)	removes all the members contained in v from this membership
void	Membership.set(Collection<Address> v)	Clear 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 boolean	Channel.startFlush(List<Address> flushParticipants, boolean automatic_resume)
boolean	JChannel.startFlush(List<Address> flushParticipants, boolean automatic_resume)	Performs a partial flush in a cluster for flush participants.
abstract void	Channel.stopFlush(List<Address> flushParticipants)
void	JChannel.stopFlush(List<Address> flushParticipants)

Constructors in org.jgroups with parameters of type Address

Modifier	Constructor	Description
	MergeView(Address creator, long id, Vector<Address> members, Vector<View> subgroups)	Creates a new view
	Message(Address dest)	Public constructor
	Message(Address dest, Address src, byte[] buf)	Public constructor
	Message(Address dest, Address src, byte[] buf, int offset, int length)	Constructs a message.
	Message(Address dest, Address src, Object obj)	Public constructor
	View(Address creator, long id, Collection<Address> members)	Creates a new view
	ViewId(Address coord_addr)	Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
	ViewId(Address coord_addr, 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 member ship object with the initial members.
	MergeView(Address creator, long id, Vector<Address> members, Vector<View> subgroups)	Creates a new view
	MergeView(ViewId vid, Vector<Address> members, Vector<View> subgroups)	Creates a new view
	View(Address creator, long id, Collection<Address> members)	Creates a new view
	View(ViewId vid, Collection<Address> members)
	View(ViewId vid, Vector<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
protected Address	MessageDispatcher.local_addr
protected Address	RequestCorrelator.local_addr	The address of this group member
protected final Address	UnicastRequest.target

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

Modifier and Type	Field	Description
protected final Map<Address,V>	AbstractConnectionMap.conns
Collection<? extends Address>	RequestCorrelator.MultiDestinationHeader.exclusion_list	Contains a list of members who should not receive the request (others will drop).
protected final Collection<Address>	MessageDispatcher.members

Methods in org.jgroups.blocks that return Address

Modifier and Type	Method	Description
Address	BasicConnectionTable.getLocalAddress()
Address	DistributedQueue.getLocalAddress()
Address	NotificationBus.getLocalAddress()	Deprecated.
Address	PartitionedHashMap.getLocalAddress()
Address	ReplCache.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()
Address	TCPConnectionMap.getLocalAddress()
Address	PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key, List<Address> members)
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, List<Address> members)
Address	PartitionedHashMap.HashFunction.hash(K key, List<Address> membership)	Defines a hash function to pick the right node from the list of cluster nodes.

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

Modifier and Type	Method	Description
Collection<Address>	RequestOptions.getExclusionList()
Vector<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
void	AbstractConnectionMap.addConnection(Address address, V conn)
Object	RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)	Deprecated.
Object	RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, RequestOptions options)
Object	RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)	Deprecated.
Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall call)	Deprecated.
Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)	Deprecated.
Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)	Deprecated.
Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall call, RequestOptions options)
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call)	Deprecated.
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)	Deprecated.
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options)
void	RpcDispatcher.channelReconnected(Address new_addr)
void	AbstractConnectionMap.ConnectionMapListener.connectionClosed(Address address)
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
boolean	TCPConnectionMap.connectionEstablishedTo(Address addr)
void	AbstractConnectionMap.ConnectionMapListener.connectionOpened(Address address, V conn)
void	BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
protected RequestCorrelator	MessageDispatcher.createRequestCorrelator(Object transport, RequestHandler handler, Address local_addr)
Serializable	NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)	Deprecated. Determines the coordinator and asks it for its cache.
V	ConnectionMap.getConnection(Address dest)
boolean	AbstractConnectionMap.hasConnection(Address address)
boolean	AbstractConnectionMap.hasOpenConnection(Address address)
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	NotificationBus.Consumer.memberJoined(Address mbr)
void	NotificationBus.Consumer.memberLeft(Address mbr)
protected void	AbstractConnectionMap.notifyConnectionClosed(Address address)
protected void	AbstractConnectionMap.notifyConnectionOpened(Address address, V conn)
protected void	PullPushAdapter.notifySuspect(Address suspected_mbr)	Deprecated.
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	GroupRequest.receiveResponse(Object response_value, Address sender)	Callback (called by RequestCorrelator or Transport).
void	MultiRequest.receiveResponse(Object response_value, Address sender)	Callback (called by RequestCorrelator or Transport).
abstract void	Request.receiveResponse(Object response_value, Address sender)
void	RspCollector.receiveResponse(Object response_value, Address sender)
void	UnicastRequest.receiveResponse(Object response_value, Address sender)	Callback (called by RequestCorrelator or Transport).
void	RequestCorrelator.receiveSuspect(Address mbr)	Event.SUSPECT event received from a layer below.
void	AbstractConnectionMap.removeConnection(Address address)
void	BasicConnectionTable.removeConnection(Address addr)	Remove addrfrom connection table.
protected void	ConnectionTableNIO.runRequest(Address addr, ByteBuffer buf)
void	BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
void	TCPConnectionMap.send(Address dest, byte[] data, int offset, int length)
void	NotificationBus.sendNotification(Address dest, Serializable n)	Deprecated. Pack the argument in a Info, serialize that one into the message buffer and send the message
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	DistributedLockManager.suspect(Address suspected_mbr)	Deprecated.
void	DistributedQueue.suspect(Address suspected_mbr)	Called when a member is suspected
void	DistributedTree.suspect(Address suspected_mbr)	Called when a member is suspected
void	GroupRequest.suspect(Address suspected_member)	Callback (called by RequestCorrelator or Transport).
void	MembershipListenerAdapter.suspect(Address suspected_mbr)	Notify membership listener that some node was suspected.
void	MultiRequest.suspect(Address suspected_member)	Callback (called by RequestCorrelator or Transport).
void	NotificationBus.suspect(Address suspected_mbr)	Deprecated.
void	PartitionedHashMap.ArrayBasedConsistentHashFunction.suspect(Address suspected_mbr)
void	PartitionedHashMap.suspect(Address suspected_mbr)
void	ReplCache.suspect(Address suspected_mbr)
void	ReplicatedHashMap.suspect(Address suspected_mbr)	Called when a member is suspected
abstract void	Request.suspect(Address mbr)
void	RspCollector.suspect(Address mbr)
void	UnicastRequest.suspect(Address suspected_member)	Callback (called by RequestCorrelator or Transport).
void	VotingAdapter.suspect(Address suspected)	Callback for notification that one node is suspected

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

Modifier and Type	Method	Description
RspList	RpcDispatcher.callRemoteMethods(Collection<Address> dests, String method_name, Object[] args, Class[] types, RequestOptions options)
RspList	RpcDispatcher.callRemoteMethods(Collection<Address> dests, MethodCall method_call, RequestOptions options)	Invokes a method in all members contained in dests (or all members if dests is null).
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout)	Deprecated.
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting)	Deprecated.
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting, RspFilter filter)	Deprecated.
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, String[] signature, int mode, long timeout)	Deprecated.
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, String[] signature, int mode, long timeout, boolean use_anycasting)	Deprecated.
RspList	RpcDispatcher.callRemoteMethods(Vector<Address> dests, MethodCall method_call, int mode, long timeout)	Deprecated.
NotifyingFuture<RspList>	RpcDispatcher.callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall method_call, RequestOptions options)
NotifyingFuture<RspList>	RpcDispatcher.callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call)	Deprecated.
NotifyingFuture<RspList>	RpcDispatcher.callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob, RspFilter filter)	Deprecated.
protected GroupRequest	MessageDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
RspList	MessageDispatcher.castMessage(Collection<Address> dests, Message msg, RequestOptions options)	Sends a message to the members listed in dests.
NotifyingFuture<RspList>	MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions options)
Address	PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key, List<Address> members)
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, List<Address> members)
Address	PartitionedHashMap.HashFunction.hash(K key, List<Address> membership)	Defines a hash function to pick the right node from the list of cluster nodes.
void	ReplCache.ConsistentHashFunction.installNodes(List<Address> new_nodes)
void	ReplCache.HashFunction.installNodes(List<Address> nodes)	When the topology changes, this method will be called.
void	AbstractConnectionMap.retainAll(Collection<Address> current_mbrs)	Removes all connections which are not in current_mbrs
void	BasicConnectionTable.retainAll(Collection<Address> current_mbrs)	Removes all connections from ConnectionTable which are not in current_mbrs
void	TCPConnectionMap.retainAll(Collection<Address> members)
void	RequestCorrelator.sendRequest(long id, Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)	Sends a request to a group.
void	RequestCorrelator.sendRequest(long id, List<Address> dest_mbrs, Message msg, RspCollector coll)
void	ReplicatedHashMap.Notification.viewChange(View view, Vector<Address> new_mbrs, Vector<Address> old_mbrs)

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

Modifier	Constructor	Description
	GroupRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)
	MultiRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options, int expected_mbrs)
	RequestCorrelator(short id, Object transport, RequestHandler handler, Address local_addr)
	RequestCorrelator(Object transport, RequestHandler handler, Address local_addr)
	RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)	Deprecated.
	RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)	Deprecated.
	RequestCorrelator(String name, Object transport, RequestHandler handler, Address local_addr)	Deprecated.
	RequestCorrelator(String name, Object transport, RequestHandler handler, Address local_addr, boolean concurrent_processing)	Deprecated.
	UnicastRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)
	UnicastRequest(Message m, Transport transport, Address target, RequestOptions options)

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

Modifier	Constructor	Description
	GroupRequest(Message msg, RequestCorrelator corr, Collection<Address> targets, RequestOptions options)
	GroupRequest(Message m, Transport transport, Collection<Address> mbrs, RequestOptions options)
	MultiDestinationHeader(byte type, long id, boolean rsp_expected, short corr_id, Collection<Address> exclusion_list)
	MultiRequest(Message m, RequestCorrelator corr, Collection<Address> mbrs, RequestOptions options, int expected_mbrs)
	MultiRequest(Message m, Transport transport, Collection<Address> mbrs, RequestOptions options, int expected_mbrs)

Uses of Address in org.jgroups.blocks.locking

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

Modifier and Type	Field	Description
protected Address	Owner.address

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

Modifier and Type	Method	Description
Address	Owner.getAddress()

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

Modifier	Constructor	Description
	Owner(Address address, long thread_id)

Uses of Address in org.jgroups.blocks.mux

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

Modifier and Type	Method	Description
protected RequestCorrelator	MuxMessageDispatcher.createRequestCorrelator(Object transport, RequestHandler handler, Address localAddr)
protected RequestCorrelator	MuxRpcDispatcher.createRequestCorrelator(Object transport, RequestHandler handler, Address localAddr)
boolean	NoMuxHandlerRspFilter.isAcceptable(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

Modifier and Type	Method	Description
protected GroupRequest	MuxMessageDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
protected GroupRequest	MuxRpcDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
void	MuxRequestCorrelator.sendRequest(long requestId, Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)

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

Modifier	Constructor	Description
	MuxRequestCorrelator(short id, Object transport, RequestHandler handler, Address localAddr)

Uses of Address in org.jgroups.debug

Methods in org.jgroups.debug that return Address

Modifier and Type	Method	Description
Address	Simulator.getLocalAddress()

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

Modifier and Type	Method	Description
void	Simulator.addMember(Address addr)
void	Simulator.addMember(Address addr, Simulator s)
boolean	Simulator.checkForDropMessage(Message msg, Address dest)
boolean	Simulator.DropMessage.drop(Message msg, Address dest)
boolean	Simulator.receiverDropFault(Message msg, Address src)
boolean	Simulator.senderDropFault(Message msg, Address dest)
void	Simulator.setLocalAddress(Address addr)
void	Simulator.simulatePartition(Address[] partition)

Uses of Address in org.jgroups.demos

Fields in org.jgroups.demos declared as Address

Modifier and Type	Field	Description
protected Address	RelayDemoRpc.local_addr

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

Modifier and Type	Method	Description
void	Draw.channelReconnected(Address addr)
static String	RelayDemoRpc.handleMessage(String msg, Address sender)
void	NotificationBusDemo.memberJoined(Address mbr)
void	NotificationBusDemo.memberLeft(Address mbr)
void	QuoteClient.suspect(Address suspected_mbr)
void	QuoteServer.suspect(Address suspected_mbr)
void	Topology.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr)	Called when a member is suspected

Uses of Address in org.jgroups.demos.wb

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

Modifier and Type	Field	Description
Address	Node.addr

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

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

Uses of Address in org.jgroups.mux

Methods in org.jgroups.mux that return Address

Modifier and Type	Method	Description
Address	MuxChannel.getAddress()	Deprecated.

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

Modifier and Type	Method	Description
void	MuxChannel.connect(String cluster_name, Address target, String state_id, long timeout)	Deprecated.
boolean	MuxChannel.getState(Address target, String state_id, long timeout, boolean useFlushIfPresent)	Deprecated.
void	MuxChannel.send(Address dst, Address src, Serializable obj)	Deprecated.

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

Modifier	Constructor	Description
	ServiceInfo(byte type, String service, Address host, byte[] state)

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
protected final Address	Executing.Owner.address
protected Address	CENTRAL_EXECUTOR.coord
protected Address	CENTRAL_LOCK.coord
protected Address	RELAY.coord
protected Address	DAISYCHAIN.local_addr
protected Address	Discovery.local_addr
protected Address	Executing.local_addr
protected Address	FD.local_addr
protected Address	Locking.local_addr
protected Address	RELAY.local_addr
protected Address	SCOPE.local_addr
protected Address	STOMP.local_addr
protected Address	TP.local_addr	The address (host and port) of this member.
protected Address	DAISYCHAIN.next
protected Address	RELAY.RelayHeader.original_sender
protected Address	FD.ping_dest

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

Modifier and Type	Field	Description
protected Queue<Address>	Executing._consumersAvailable	This is stored on the coordinator side.
protected Queue<Address>	Executing._runRequests	This is stored on the coordinator side.
protected final List<Address>	CENTRAL_EXECUTOR.backups
protected final List<Address>	CENTRAL_LOCK.backups
protected final Map<Address,String>	STOMP.endpoints
protected final List<Address>	PEER_LOCK.PeerLock.grants
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache	Cache which maintains mappings between logical and physical addresses.
protected final Vector<Address>	Discovery.members
protected final List<Address>	FD.members
protected final Set<Address>	TP.members	The members of this group (updated when a member joins or leaves).
protected final List<Address>	FD.pingable_mbrs	Members from which we select ping_dest.
protected static final LazyRemovalCache.Printable<Address,PhysicalAddress>	TP.print_function
protected final ConcurrentMap<Address,ConcurrentMap<Short,SCOPE.MessageQueue>>	SCOPE.queues	Used to find the correct AckReceiverWindow on message reception and deliver it in the right order
protected final Map<Address,FlowControl.Credit>	FlowControl.received	Keeps track of credits per member at the receiver.
protected final Map<Address,FlowControl.Credit>	UFC.sent	Mapinvalid input: '<'Address,Long>: keys are members, values are credits left.
protected final BoundedList<Address>	FD.suspect_history
protected final Set<Address>	FD_ALL.suspected_mbrs
protected final Set<Address>	FD_SOCK.suspected_mbrs
protected Map<Address,String>	RELAY.ViewData.uuids
protected AgeOutCache<Address>	TP.who_has_cache	Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after 5000ms

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method	Description
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	SEQUENCER.SequencerHeader.getOriginalSender()

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

Modifier and Type	Method	Description
AgeOutCache<Address>	UNICAST.getAgeOutCache()
AgeOutCache<Address>	UNICAST2.getAgeOutCache()
Collection<Address>	PingData.getMembers()
Set<Address>	TP.ProtocolAdapter.getMembers()

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

Modifier and Type	Method	Description
void	DISCARD.addIgnoreMember(Address sender)	Messages from this sender will get dropped
protected void	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected String	FILE_PING.addressAsString(Address address)
protected void	FD.Broadcaster.addSuspectedMember(Address mbr)	Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
protected long	FlowControl.adjustCredit(Map<Address,FlowControl.Credit> map, Address sender, int length)	Check whether sender has enough credits left.
void	FRAG2.clearFragmentsFor(Address mbr)
void	SCOPE.clearQueue(Address member)
protected void	TCPGOSSIP.connect(RouterStub stub, String group, Address logical_addr)
void	TUNNEL.TUNNELPolicy.connect(List<RouterStub> stubs, String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs)
protected void	TCPGOSSIP.connectAllStubs(String group, Address logical_addr)
static RELAY.RelayHeader	RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
void	Discovery.discoveryRequestReceived(Address sender, String logical_name, Collection<PhysicalAddress> physical_addrs)
void	TCPPING.discoveryRequestReceived(Address sender, String logical_name, Collection<PhysicalAddress> physical_addrs)
protected void	TP.dispatchToThreadPool(Executor pool, Address sender, byte[] data, int offset, int length)
protected void	TP.doSend(Buffer buf, Address dest, boolean multicast)
void	UNICAST.expired(Address key)	Called by AgeOutCache, to removed expired connections
void	UNICAST2.expired(Address key)	Called by AgeOutCache, to removed expired connections
protected SCOPE.MessageQueue	SCOPE.getOrCreateQueue(Address sender, short scope)
protected PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
protected void	Executing.handleConsumerFoundResponse(Address consumer)
protected void	Executing.handleConsumerReadyRequest(Address source)
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,FlowControl.Credit> map, Address sender, long requested_credits)
protected abstract Object	FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected Object	MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected Object	UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected void	Executing.handleExceptionResponse(Address source, Executing.Request req)
protected void	Executing.handleInterruptRequest(Address source, short requestId)
protected void	Locking.ClientLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	Locking.handleLockGrantedResponse(String lock_name, Owner owner, Address sender)
protected void	PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	Executing.handleNewConsumer(Address sender)
protected void	Executing.handleNewRunRequest(Address sender)
protected void	Executing.handleRemoveConsumer(Address sender)
protected void	Executing.handleRemoveRunRequest(Address sender)
protected void	Executing.handleTaskRejectedResponse(Address source, short requestId)
protected void	Executing.handleTaskRequest(Address source)
protected void	Executing.handleTaskSubmittedRequest(Runnable runnable, Address source, short requestId)
protected void	Executing.handleValueResponse(Address source, Executing.Request req)
protected boolean	RELAY.isLocal(Address dest)	Does the payload match the 'site' ID.
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 void	TP.registerLocalAddress(Address addr)	Associates the address with the physical address fetched from the cache
protected void	FILE_PING.remove(String clustername, Address addr)
protected void	JDBC_PING.remove(String clustername, Address addr)
protected void	S3_PING.remove(String clustername, Address addr)
void	UNICAST.removeConnection(Address mbr)	Removes and resets from connection table (which is already locked).
void	UNICAST2.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)
void	SCOPE.removeScope(Address member, short scope)
void	SMACK.retransmit(long seqno, Message msg, Address dest)
void	UNICAST2.retransmit(long first_seqno, long last_seqno, Address sender)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
protected void	TP.send(Message msg, Address dest, boolean multicast)	Serializes and sends a message.
protected void	TUNNEL.send(Message msg, Address dest, boolean multicast)
protected void	CENTRAL_LOCK.sendCreateLockRequest(Address dest, String lock_name, Owner owner)
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, Long credits_needed)	We cannot send this request as OOB messages, 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)
protected void	AUTH.sendJoinRejectionMessage(Address dest, String error_msg)
protected void	AUTH.sendMergeRejectionMessage(Address dest, String error_msg)
protected void	CENTRAL_EXECUTOR.sendNewConsumerRequest(Address sender)
protected abstract void	Executing.sendNewConsumerRequest(Address source)
protected void	CENTRAL_EXECUTOR.sendNewRunRequest(Address sender)
protected abstract void	Executing.sendNewRunRequest(Address source)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, String error_msg)
protected void	CENTRAL_EXECUTOR.sendRemoveConsumerRequest(Address sender)
protected abstract void	Executing.sendRemoveConsumerRequest(Address source)
protected void	CENTRAL_EXECUTOR.sendRemoveRunRequest(Address sender)
protected abstract void	Executing.sendRemoveRunRequest(Address source)
protected void	Executing.sendRequest(Address dest, Executing.Type type, short requestId, Object object)
protected void	Locking.sendRequest(Address dest, Locking.Type type, String lock_name, Owner owner, long timeout, boolean is_trylock)
protected void	UNICAST2.sendStableMessage(Address dest, long low, long high)
protected void	SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
protected void	TP.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
void	TUNNEL.TUNNELPolicy.sendToSingleMember(List<RouterStub> stubs, String group, Address dest, byte[] data, int offset, int length)
protected void	RELAY.sendViewOnLocalCluster(Address dest, RELAY.ViewData data, boolean use_seperate_thread)
protected void	RELAY.sendViewOnLocalCluster(Address dest, View remote_view, View global_view, boolean use_seperate_thread)
protected void	TP.setInAllThreadFactories(String cluster_name, Address local_address, String pattern)
protected void	ENCRYPT.setKeyServerAddr(Address keyServerAddr)
protected void	ENCRYPT.setLocal_addr(Address local_addr)
void	DISCARD.setLocalAddress(Address localAddress)
protected void	UNICAST2.stable(Address sender, long highest_delivered, long highest_seen)	Purge all messages in window for local_addr, which are invalid input: '<'= low.
protected static void	TP.writeMessageList(Address dest, Address src, List<Message> msgs, DataOutputStream dos, boolean multicast)	Write a lits of messages with the same destination and *mostly* the same src addresses.

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

Modifier and Type	Method	Description
protected long	FlowControl.adjustCredit(Map<Address,FlowControl.Credit> map, Address sender, int length)	Check whether sender has enough credits left.
protected void	CENTRAL_LOCK.copyLocksTo(List<Address> new_joiners)
protected void	CENTRAL_EXECUTOR.copyQueueTo(List<Address> new_joiners)
protected void	FlowControl.handleCreditRequest(Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	Locking.ServerLock.handleView(List<Address> members)
protected void	FlowControl.handleViewChange(Vector<Address> mbrs)
protected void	MFC.handleViewChange(Vector<Address> mbrs)
protected void	UFC.handleViewChange(Vector<Address> mbrs)
protected final View	Discovery.makeView(Vector<Address> mbrs)
protected static String	FlowControl.printMap(Map<Address,FlowControl.Credit> m)
abstract void	BasicTCP.retainAll(Collection<Address> members)
protected void	PEER_LOCK.PeerLock.retainAll(List<Address> members)
void	TCP_NIO.retainAll(Collection<Address> members)
void	TCP.retainAll(Collection<Address> members)

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

Modifier	Constructor	Description
	FdHeader(byte type, Address mbr)
	FdHeader(byte type, Address mbr, IpAddress sock_addr)
	FdHeader(byte type, Collection<Address> mbrs, Address from)
	HTotalHeader(Address dest, Address src)
	Owner(Address address, short requestId)
	PingData(Address own_addr, View view, boolean is_server)
	PingData(Address own_addr, View view, boolean is_server, String logical_name, Collection<PhysicalAddress> physical_addrs)
	ProtocolAdapter(String cluster_name, Address local_addr, short transport_id, Protocol up, Protocol down, String pattern)
	SequencerHeader(byte type, Address original_sender, long seqno)

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

Modifier	Constructor	Description
	DiscardHeader(Set<Address> ignoredAddresses)
	FdHeader(byte type, Map<Address,IpAddress> cachedAddrs)
	FdHeader(byte type, Set<Address> mbrs)
	FdHeader(byte type, Collection<Address> mbrs, Address from)

Uses of Address in org.jgroups.protocols.pbcast

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

Modifier and Type	Field	Description
protected Address	GMS.local_addr

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

Modifier and Type	Method	Description
protected Address	GMS.determineCoordinator()
Address	GMS.GmsHeader.getMember()
Address	MergeData.getSender()
Address	NakAckHeader.getSender()

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

Modifier and Type	Method	Description
static NakAckHeader	NakAckHeader.createXmitRequestHeader(long low, long high, Address orginal_sender)
double	NAKACK.getSmoothedAverageRetransmissionTime(Address sender)	Returns the smoothed average retransmission time for a given sender
NakReceiverWindow	NAKACK.getWindow(Address mbr)	Please don't use this method; it is only provided for unit testing !
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
void	Merger.handleDigestResponse(Address sender, Digest digest)
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
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.
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)
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)
void	ClientGmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr)	The coordinator itself wants to leave the group
abstract void	GmsImpl.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr)	Loop: determine coord.
void	NAKACK.messageGapDetected(long from, long to, Address src)	Called when a message gap is detected
void	NAKACK.missingMessageReceived(long seqno, Address original_sender)
void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender)	Implementation of Retransmitter.RetransmitCommand.
protected void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
void	GmsImpl.unsuspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr)	Removes previously suspected member from list of currently suspected members
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
void	GMS.castViewChangeWithDest(View new_view, Digest digest, JoinRsp jr, Collection<Address> newMembers)	Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
protected boolean	GMS.checkSelfInclusion(Vector<Address> mbrs)	Returns true if local_addr is member of mbrs, else false
View	GMS.getNextView(Collection<Address> new_mbrs, Collection<Address> old_mbrs, 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 boolean	GmsImpl.iWouldBeCoordinator(Vector<Address> new_mbrs)	Returns potential coordinator based on lexicographic ordering of member addresses.
View	GMS.makeView(Vector<Address> mbrs)
static View	GMS.makeView(Vector<Address> mbrs, ViewId vid)
void	CoordGmsImpl.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
void	GmsImpl.merge(Map<Address,View> views)
void	Merger.merge(Map<Address,View> views)	Invoked upon receiving a MERGE event from the MERGE layer.
static void	Merger.sanitizeViews(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

Modifier	Constructor	Description
	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)
	StateHeader(byte type, Address sender, long id, Digest digest)
	StateHeader(byte type, Address sender, long id, Digest digest, String state_id)
	StateHeader(byte type, Address sender, long id, Digest digest)
	StateHeader(byte type, Address sender, String state_id)
	StateHeader(byte type, Address sender, IpAddress bind_addr, Digest digest, String state_id)

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

Modifier	Constructor	Description
	FlushHeader(byte type, long viewID, Collection<? extends Address> flushView)
	GmsHeader(byte type, Collection<Address> mbrs)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

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

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
protected Address	Retransmitter.Task.msg_sender
protected final Address	Retransmitter.sender
Address	StateTransferInfo.target

Methods in org.jgroups.stack that return Address

Modifier and Type	Method	Description
Address	AddressGenerator.generateAddress()
Address	GossipData.getAddress()

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

Modifier and Type	Method	Description
List<Address>	GossipData.getMembers()

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

Modifier and Type	Method	Description
void	AckMcastSenderWindow.ack(long seqno, Address sender)	An ACK has been received from sender.
final int	IpAddress.compareTo(Address o)	implements the java.lang.Comparable interface
void	RouterStub.connect(String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs)	Register this process with the router under group.
void	RouterStub.disconnect(String group, Address addr)
void	NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
void	NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
void	AckMcastSenderWindow.remove(Address obj)	Remove obj from all receiver sets and wake up retransmission thread.
void	AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)	Retranmit the given msg
void	AckSenderWindow.retransmit(long first_seqno, long last_seqno, Address 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(String group, Address dest, byte[] data, int offset, int length)
void	ProtocolStack.startStack(String cluster_name, Address local_addr)	Start all layers.
void	AckMcastSenderWindow.suspect(Address suspected)	Process with address suspected is suspected: remove it from all receiver sets.

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

Modifier and Type	Method	Description
void	GossipData.setMembers(List<Address> mbrs)

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

Modifier	Constructor	Description
	AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
	DefaultRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)	Create a new Retransmitter associated with the given sender address
	GossipData(byte type, String group, Address addr)
	GossipData(byte type, String group, Address addr, byte[] buffer)
	GossipData(byte type, String group, Address addr, byte[] buffer, int offset, int length)
	GossipData(byte type, String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs)
	GossipData(byte type, String group, Address addr, List<Address> mbrs)
	GossipData(byte type, String group, Address addr, List<Address> mbrs, List<PhysicalAddress> physical_addrs)
	NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched)	Creates a new instance with the given retransmit command
	NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched, boolean use_range_based_retransmitter)
	NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_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)
	NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched)	Creates a new instance with the given retransmit command
	RangeBasedRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)	Create a new Retransmitter associated with the given sender address
protected	RangeTask(Seqno range, 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, String channelName, Address logicalAddress, long interval)
protected	SeqnoTask(long seqno, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
	StateTransferInfo(Address target)
	StateTransferInfo(Address target, long timeout)
	StateTransferInfo(Address target, InputStream is, String state_id)
	StateTransferInfo(Address target, OutputStream os, String state_id)
	StateTransferInfo(Address target, String state_id, long timeout)
	StateTransferInfo(Address target, String state_id, long timeout, byte[] state)
protected	Task(Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)

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

Modifier	Constructor	Description
	GossipData(byte type, String group, Address addr, List<Address> mbrs)
	GossipData(byte type, String group, Address addr, List<Address> mbrs, List<PhysicalAddress> physical_addrs)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

Modifier and Type	Class	Description
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

Modifier and Type	Field	Description
protected final Address	SingletonAddress.addr

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

Modifier and Type	Field	Description
protected static LazyRemovalCache<Address,String>	UUID.cache	Keeps track of associations between logical addresses (UUIDs) and logical names
protected final Map<Address,Long>	CreditMap.credits
protected static final LazyRemovalCache.Printable<Address,String>	UUID.print_function
protected final Map<Address,Digest.Entry>	Digest.senders	Map<Address, Entry>

Methods in org.jgroups.util that return Address

Modifier and Type	Method	Description
static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(String name)
Address	SingletonAddress.getAddress()
Address	Rsp.getSender()
static Address	Util.readAddress(DataInputStream in)

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

Modifier and Type	Method	Description
static Vector<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 List<Address>	Util.determineNewMembers(List<Address> old_mbrs, List<Address> new_mbrs)	Returns the members which joined between 2 subsequent views
Set<Map.Entry<Address,Rsp>>	RspList.entrySet()
static Map<Address,String>	UUID.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)
Map<Address,T>	ResponseCollector.getResults()
Map<Address,Digest.Entry>	Digest.getSenders()	Returns an unmodifiable map, so modifications will result in exceptions
Map<Address,Digest.Entry>	MutableDigest.getSenders()
Vector<Address>	RspList.getSuspectedMembers()
Set<Address>	CreditMap.keys()
Set<Address>	RspList.keySet()
static List<Address>	Util.leftMembers(Collection<Address> old_list, Collection<Address> new_list)
static List<Address>	Util.leftMembers(View one, View two)	Returns a list of members which left from view one to two
static List<Address>	Util.newMembers(List<Address> old_list, List<Address> new_list)
static Vector<Address>	Util.pickSubset(Vector<Address> members, double subset_percentage)	Selects a random subset of members according to subset_percentage and returns them.
static Collection<? extends Address>	Util.readAddresses(DataInputStream in, Class cl)

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

Modifier and Type	Method	Description
void	MutableDigest.add(Address sender, long low_seqno, long highest_delivered_seqno)
void	MutableDigest.add(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
void	ResponseCollector.add(Address member, T data)
boolean	SeqnoTable.add(Address member, long seqno)
static void	UUID.add(Address uuid, String logical_name)
void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, Object retval)
void	RspList.addSuspect(Address sender)
int	SingletonAddress.compareTo(Address o)
int	UUID.compareTo(Address other)	Compares this UUID with the specified UUID.
boolean	Digest.contains(Address sender)
static MergeId	MergeId.create(Address addr)
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).
void	FIFOMessageQueue.done(Address sender, K dest)	Deprecated.
Long	CreditMap.get(Address member)
Digest.Entry	Digest.get(Address sender)	Returns the Entry for the given sender.
static String	UUID.get(Address logical_addr)
long	SeqnoTable.getHighestReceived(Address member)
long	SeqnoTable.getNextToReceive(Address member)
static int	Util.getRank(View view, Address addr)
long	Digest.highestDeliveredSeqnoAt(Address sender)
long	Digest.highestReceivedSeqnoAt(Address sender)
void	MutableDigest.incrementHighestDeliveredSeqno(Address sender)	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)
long	Digest.lowSeqnoAt(Address sender)
void	MutableDigest.merge(Address sender, long low_seqno, 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.low_seqno=min(this.low_seqno, low_seqno) 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 sender doesn not exist, a new entry will be added (provided there is enough space)
void	FIFOMessageQueue.put(Address sender, K dest, V el)	Deprecated.
Rsp	RspList.put(Address key, Rsp value)
Long	CreditMap.putIfAbsent(Address key)
Long	CreditMap.remove(Address key)
void	ResponseCollector.remove(Address member)
void	SeqnoTable.remove(Address member)
static void	UUID.remove(Address addr)
void	CreditMap.replenish(Address sender, long new_credits)
void	ResponseCollector.reset(Address... members)
void	MutableDigest.resetAt(Address sender)	Resets the seqnos for the sender at 'index' to 0.
static boolean	Util.sameHost(Address one, Address two)	Checks whether 2 Addresses are on the same host
boolean	MutableDigest.set(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
void	MutableDigest.setHighestDeliveredAndSeenSeqnos(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
static int	Util.size(Address addr)
void	AckCollector.suspect(Address member)
void	ResponseCollector.suspect(Address member)
void	AckCollector.unsuspect(Address member)
static void	Util.writeAddress(Address addr, DataOutputStream out)

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

Modifier and Type	Method	Description
static void	UUID.add(Map<Address,String> map)
static byte[]	Util.collectionToByteBuffer(Collection<Address> c)
static Vector<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 List<Address>	Util.determineNewMembers(List<Address> old_mbrs, List<Address> new_mbrs)	Returns the members which joined between 2 subsequent views
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)
static Vector<Address>	Util.pickSubset(Vector<Address> members, double subset_percentage)	Selects a random subset of members according to subset_percentage and returns them.
void	RspList.putAll(Map<? extends Address,? extends Rsp> m)
static void	UUID.removeAll(Collection<Address> mbrs)
void	AckCollector.reset(Collection<Address> members)
void	ResponseCollector.reset(Collection<Address> members)
boolean	SeqnoTable.retainAll(Collection<Address> members)
static void	UUID.retainAll(Collection<Address> logical_addrs)
static long	Util.size(Collection<? extends Address> addrs)	Returns the marshalled size of a Collection of Addresses.
static boolean	Util.startFlush(Channel c, List<Address> flushParticipants)
static boolean	Util.startFlush(Channel c, List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)
static void	Util.writeAddresses(Collection<? extends Address> v, DataOutputStream out)	Writes a Vector of Addresses.

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

Modifier	Constructor	Description
	Digest(Address sender, long low, long highest_delivered)
	Digest(Address sender, long low, long highest_delivered, long highest_received)
	ResponseCollector(Address... members)
	Rsp(Address sender)
	Rsp(Address sender, boolean suspected)
	Rsp(Address sender, T retval)
	SingletonAddress(String cluster_name, Address addr)

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

Modifier	Constructor	Description
	Digest(Map<Address,Digest.Entry> map)	Creates a new digest from an existing map by copying the keys and values from map
	MutableDigest(Map<Address,Digest.Entry> map)
	ResponseCollector(Collection<Address> members)