Uses of Interface
org.jgroups.Address

Packages that use Address

Package	Description
org.infinispan.remoting.transport.jgroups	A transport implementation based on JGroups.
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.mux
org.jgroups.conf	Provides ways to configure a protocol stack.
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.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.infinispan.remoting.transport.jgroups

Fields in org.infinispan.remoting.transport.jgroups declared as Address

Modifier and Type	Field and Description
protected Address	JGroupsAddress.address

Methods in org.infinispan.remoting.transport.jgroups that return Address

Modifier and Type	Method and Description
Address	JGroupsAddress.getJGroupsAddress()
protected static Address	JGroupsTransport.toJGroupsAddress(Address a)

Methods in org.infinispan.remoting.transport.jgroups with parameters of type Address

Modifier and Type	Method and Description
Response	CommandAwareRpcDispatcher.invokeRemoteCommand(Address recipient, ReplicableCommand command, ResponseMode mode, long timeout, boolean oob, boolean asyncMarshalling)
boolean	JGroupsResponseFilterAdapter.isAcceptable(Object response, Address sender)
void	JGroupsTransport.suspect(Address suspected_mbr)

Method parameters in org.infinispan.remoting.transport.jgroups with type arguments of type Address

Modifier and Type	Method and Description
RspList<Object>	CommandAwareRpcDispatcher.invokeRemoteCommands(List<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, boolean anycasting, boolean oob, RspFilter filter, boolean asyncMarshalling)

Constructors in org.infinispan.remoting.transport.jgroups with parameters of type Address

Constructor and Description
JGroupsAddress(Address address)

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

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

Fields in org.jgroups declared as Address

Modifier and Type	Field and Description
protected Address	ViewId.creator
protected Address	Message.dest_addr
protected Address	JChannel.local_addr
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

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

Modifier and Type	Method and Description
Address	Membership.elementAt(int index) Returns the component at the specified index
Address	JChannel.getAddress()
abstract Address	Channel.getAddress() Returns the channel's own address.
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()

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

Modifier and Type	Method and Description
List<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.
List<Address>	Membership.getMembers() Returns a copy (clone) of the members in this membership.
Iterator<Address>	View.iterator()

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method and Description
void	Membership.add(Address... mbrs)
void	Membership.add(Address new_member) Adds a new member to this membership.
void	JChannel.connect(String cluster_name, Address target, long timeout)
abstract void	Channel.connect(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(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
String	JChannel.getName(Address member)
abstract String	Channel.getName(Address member) Returns the logical name of a given member.
void	JChannel.getState(Address target, long timeout)
abstract void	Channel.getState(Address target, long timeout) Retrieves the full state from the target member.
void	JChannel.getState(Address target, long timeout, boolean useFlushIfPresent) Retrieves state from the target member.
protected void	JChannel.getState(Address target, long timeout, Callable<Boolean> flushInvoker)
void	Membership.remove(Address old_member) Removes an member from the membership.
void	JChannel.send(Address dst, byte[] buf)
abstract void	Channel.send(Address dst, byte[] buf) Sends a message.
void	JChannel.send(Address dst, byte[] buf, int offset, int length)
abstract void	Channel.send(Address dst, byte[] buf, int offset, int length) Sends a message to a destination.
void	JChannel.send(Address dst, Object obj)
abstract void	Channel.send(Address dst, Object obj) Helper method to create a Message with given parameters and invoke Channel.send(Message).
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	ReceiverAdapter.suspect(Address mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	MembershipListener.suspect(Address suspected_mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
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 and Description
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.
void	Membership.merge(Collection<Address> new_mems, Collection<Address> suspects) Merges membership with the new members and removes suspects.
void	Membership.remove(Collection<Address> v) Removes all the members contained in v from this membership
void	Membership.retainAll(Collection<Address> v)
void	Membership.set(Collection<Address> v) Clears the membership and adds all members of v This method will clear out all the old members of this membership by invoking the Clear method.
void	JChannel.startFlush(List<Address> flushParticipants, boolean automatic_resume)
abstract void	Channel.startFlush(List<Address> flushParticipants, boolean automatic_resume) Performs a partial flush in a cluster for flush participants.
void	JChannel.stopFlush(List<Address> flushParticipants)
abstract void	Channel.stopFlush(List<Address> flushParticipants)

Constructors in org.jgroups with parameters of type Address

Constructor and Description
MergeView(Address creator, long id, List<Address> members, 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, 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, Object obj)
View(Address creator, long id, 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

Constructor and Description
Membership(Collection<Address> initial_members) Creates a Membership with a given initial members.
MergeView(Address creator, long id, List<Address> members, List<View> subgroups) Creates a new view
MergeView(ViewId vid, List<Address> members, List<View> subgroups) Creates a new view
View(Address creator, long id, List<Address> members) Creates a new view
View(ViewId vid, List<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 and Description
protected Address	RequestCorrelator.local_addr The address of this group member
protected Address	MessageDispatcher.local_addr
protected Address	UnicastRequest.target

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

Modifier and Type	Field and Description
protected 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 Collection<Address>	MessageDispatcher.members

Methods in org.jgroups.blocks that return Address

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

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

Modifier and Type	Method and Description
Collection<Address>	RequestOptions.getExclusionList()
List<Address>	ReplicatedTree.getMembers()
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.
List<Address>	ReplCache.ConsistentHashFunction.hash(K key, short replication_count)

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

Modifier and Type	Method and Description
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, String method_name, Object[] args, 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
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	AbstractConnectionMap.ConnectionMapListener.connectionClosed(Address address)
boolean	TCPConnectionMap.connectionEstablishedTo(Address addr)
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)
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
protected void	AbstractConnectionMap.notifyConnectionClosed(Address address)
protected void	AbstractConnectionMap.notifyConnectionOpened(Address address, V conn)
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	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	UnicastRequest.receiveResponse(Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
void	RspCollector.receiveResponse(Object response_value, Address sender, boolean is_exception)
abstract void	Request.receiveResponse(Object response_value, Address sender, boolean is_exception)
void	GroupRequest.receiveResponse(Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
void	RequestCorrelator.receiveSuspect(Address mbr) Event.SUSPECT event received from a layer below.
void	BasicConnectionTable.removeConnection(Address addr) Remove addrfrom connection table.
void	AbstractConnectionMap.removeConnection(Address address)
protected void	ConnectionTableNIO.runRequest(Address addr, ByteBuffer buf)
void	TCPConnectionMap.send(Address dest, byte[] data, int offset, int length)
void	BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
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	RspCollector.suspect(Address mbr)
abstract void	Request.suspect(Address mbr)
void	ReplicatedHashMap.suspect(Address suspected_mbr) Called when a member is suspected
void	ReplCache.suspect(Address suspected_mbr)
void	PartitionedHashMap.suspect(Address suspected_mbr)
void	PartitionedHashMap.ConsistentHashFunction.suspect(Address suspected_mbr)
void	GroupRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).

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

Modifier and Type	Method and Description
<T> RspList<T>	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).
<T> RspList<T>	RpcDispatcher.callRemoteMethods(Collection<Address> dests, String method_name, Object[] args, Class[] types, RequestOptions options) Invokes a method in all members contained in dests (or all members if dests is null).
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members contained in dests (or all members if dests is null).
protected <T> GroupRequest<T>	MessageDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
<T> RspList<T>	MessageDispatcher.castMessage(Collection<Address> dests, Message msg, RequestOptions options) Sends a message to the members listed in dests.
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions options) Sends a message to the members listed in dests.
Address	PartitionedHashMap.HashFunction.hash(K key, List<Address> membership) Defines a hash function to pick the right node from the list of cluster nodes.
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, List<Address> members)
void	ReplCache.HashFunction.installNodes(List<Address> nodes) When the topology changes, this method will be called.
void	ReplCache.ConsistentHashFunction.installNodes(List<Address> new_nodes)
void	TCPConnectionMap.retainAll(Collection<Address> members)
void	BasicConnectionTable.retainAll(Collection<Address> current_mbrs) Removes all connections from ConnectionTable which are not in current_mbrs
void	AbstractConnectionMap.retainAll(Collection<Address> current_mbrs) Removes all connections which are not in current_mbrs
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)
protected void	MessageDispatcher.setMembers(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, List<Address> mbrs_joined, List<Address> mbrs_left)
void	ReplicatedHashMap.Notification.viewChange(View view, List<Address> mbrs_joined, List<Address> mbrs_left)

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

Constructor and Description
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.
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

Constructor and Description
GroupRequest(Message msg, RequestCorrelator corr, Collection<Address> targets, RequestOptions options)
RequestCorrelator.MultiDestinationHeader(byte type, long id, boolean rsp_expected, short corr_id, Collection<Address> exclusion_list)

Uses of Address in org.jgroups.blocks.mux

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

Modifier and Type	Method and Description
protected RequestCorrelator	MuxRpcDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
protected RequestCorrelator	MuxMessageDispatcher.createRequestCorrelator(Protocol 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 and Description
protected <T> GroupRequest<T>	MuxRpcDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
protected <T> GroupRequest<T>	MuxMessageDispatcher.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

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

Uses of Address in org.jgroups.conf

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

Modifier and Type	Method and Description
static Class<Address>	ClassConfigurator.get(short magic) Returns a class for a magic number.

Uses of Address in org.jgroups.demos

Fields in org.jgroups.demos declared as Address

Modifier and Type	Field and Description
protected Address	RelayDemoRpc.local_addr

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

Modifier and Type	Method and Description
static String	RelayDemoRpc.handleMessage(String msg, Address sender)
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

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

Uses of Address in org.jgroups.demos.wb

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

Modifier and Type	Field and Description
Address	Node.addr

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

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

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

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

Uses of Address in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field and Description
protected Address	Executing.Owner.address
protected Address	RELAY.coord
protected Address	COUNTER.coord The address of the cluster coordinator.
protected Address	CENTRAL_LOCK.coord
protected Address	CENTRAL_EXECUTOR.coord
protected Address	Discovery.current_coord
protected Address	VERIFY_SUSPECT.local_addr
protected Address	TP.local_addr The address (host and port) of this member.
protected Address	STOMP.local_addr
protected Address	SCOPE.local_addr
protected Address	RSVP.local_addr
protected Address	RELAY.local_addr
protected Address	MERGE2.local_addr
protected Address	Locking.local_addr
protected Address	FD.local_addr
protected Address	Executing.local_addr
protected Address	Discovery.local_addr
protected Address	DAISYCHAIN.local_addr
protected Address	COUNTER.local_addr
protected Address	DAISYCHAIN.next
protected Address	RELAY.RelayHeader.original_sender
protected Address	PingData.own_addr
protected Address	FD.ping_dest
protected Address	VERIFY_SUSPECT.Entry.suspect
protected Address	RSVP.Entry.target

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

Modifier and Type	Field and Description
protected List<Address>	COUNTER.backup_coords Backup coordinators.
protected List<Address>	CENTRAL_LOCK.backups
protected List<Address>	CENTRAL_EXECUTOR.backups
protected Map<Address,String>	STOMP.endpoints
protected List<Address>	PEER_LOCK.PeerLock.grants
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache Cache which maintains mappings between logical and physical addresses.
protected Set<Address>	TP.members The members of this group (updated when a member joins or leaves).
protected List<Address>	RSVP.members
protected Set<Address>	MERGE2.members
protected List<Address>	FD.members
protected List<Address>	Discovery.members
protected Set<Address>	MERGE2.merge_candidates
protected List<Address>	FD.pingable_mbrs Members from which we select ping_dest.
protected static LazyRemovalCache.Printable<Address,PhysicalAddress>	TP.print_function
protected 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 Map<Address,FlowControl.Credit>	FlowControl.received Keeps track of credits per member at the receiver.
protected Map<Address,FlowControl.Credit>	UFC.sent Map: keys are members, values are credits left.
protected BoundedList<Address>	FD.suspect_history
protected Set<Address>	FD_SOCK.suspected_mbrs
protected Set<Address>	FD_ALL.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 and Description
protected Address	FD_SOCK.determineCoordinator()
Address	TP.ProtocolAdapter.getAddress()
Address	PingData.getAddress()
Address	Executing.Owner.getAddress()
Address	CENTRAL_LOCK.getCoord()
Address	CENTRAL_EXECUTOR.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 and Description
AgeOutCache<Address>	UNICAST2.getAgeOutCache()
AgeOutCache<Address>	UNICAST.getAgeOutCache()
Set<Address>	TP.ProtocolAdapter.getMembers()
Collection<Address>	PingData.getMembers()
Map<Address,View>	MERGE2.FindSubgroupsTask.getViews(List<PingData> initial_mbrs)

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

Modifier and Type	Method and Description
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 String	FILE_PING.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(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)
void	TUNNEL.TUNNELPolicy.connect(List<RouterStub> stubs, String group, Address addr, String logical_name, List<PhysicalAddress> phys_addrs)
protected void	TCPGOSSIP.connect(RouterStub stub, String group, Address logical_addr)
protected void	TCPGOSSIP.connectAllStubs(String group, Address logical_addr)
static RELAY.RelayHeader	RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
void	TCPPING.discoveryRequestReceived(Address sender, String logical_name, Collection<PhysicalAddress> physical_addrs)
void	Discovery.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	UNICAST2.expired(Address key) Called by AgeOutCache, to removed expired connections
void	UNICAST.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(long request, Address address)
protected void	Executing.handleConsumerReadyRequest(long requestId, Address address)
protected void	Executing.handleConsumerUnreadyRequest(long requestId, Address address)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	MFC.handleCredit(Address sender, long increase)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	UNICAST.handleDataReceived(Address sender, long seqno, long conn_id, boolean first, Message msg, Event evt) Check whether the hashtable contains an entry e for sender (create if not).
protected void	UNICAST2.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 Object	UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected Object	MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected abstract Object	FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected void	Executing.handleExceptionResponse(Address source, long requestId, Throwable throwable)
protected void	Executing.handleInterruptRequest(Address source, long requestId)
protected void	PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	Locking.ClientLock.handleLockGrantedResponse(Owner owner, Address sender)
protected void	Locking.handleLockGrantedResponse(String lock_name, Owner owner, Address sender)
protected void	COUNTER.handleRequest(COUNTER.Request req, Address sender)
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(Runnable runnable, Address source, long requestId)
protected void	Executing.handleValueResponse(Address source, long requestId, Object value)
protected boolean	RELAY.isLocal(Address dest) Does the payload match the 'site' ID.
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.
void	BasicTCP.receive(Address sender, byte[] data, int offset, int length) ConnectionMap.Receiver interface
protected static void	SHARED_LOOPBACK.register(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	S3_PING.remove(String clustername, Address addr)
protected void	JDBC_PING.remove(String clustername, Address addr)
protected void	FILE_PING.remove(String clustername, Address addr)
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)
void	UNICAST2.removeReceiveConnection(Address mbr)
void	UNICAST.removeReceiveConnection(Address mbr)
void	SCOPE.removeScope(Address member, short scope)
void	UNICAST2.removeSendConnection(Address mbr)
void	UNICAST.removeSendConnection(Address mbr)
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
void	UNICAST2.retransmit(long first_seqno, long last_seqno, Address sender)
protected void	COUNTER.send(Address dest, Buffer buffer)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
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	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, String counter_name)
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	Discovery.sendDiscoveryResponse(Address logical_addr, List<PhysicalAddress> physical_addrs, boolean is_server, boolean return_view_only, String logical_name, Address sender)
protected void	AUTH.sendJoinRejectionMessage(Address dest, String error_msg)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	Executing.sendRequest(Address dest, Executing.Type type, long requestId, Object object)
protected void	Locking.sendRequest(Address dest, Locking.Type type, String lock_name, Owner owner, long timeout, boolean is_trylock)
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 low, long high)
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(List<RouterStub> stubs, String group, Address dest, byte[] data, int offset, int length)
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, short conn_id, long highest_delivered, long highest_seen) Purge all messages in window for local_addr, which are <= low.
protected static void	SHARED_LOOPBACK.unregister(String channel_name, Address local_addr)
void	VERIFY_SUSPECT.unsuspect(Address mbr)
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 and Description
protected long	FlowControl.adjustCredit(Map<Address,FlowControl.Credit> map, Address sender, int length) Check whether sender has enough credits left.
protected void	VERIFY_SUSPECT.adjustSuspectedMembers(List<Address> new_mbrship) Removes all elements from suspects that are not in the new membership
protected void	CENTRAL_LOCK.copyLocksTo(List<Address> new_joiners)
protected void	CENTRAL_EXECUTOR.copyQueueTo(List<Address> new_joiners)
List<View>	MERGE2.FindSubgroupsTask.detectDifferentViews(Map<Address,View> map)
protected void	FlowControl.handleCreditRequest(Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	Locking.ServerLock.handleView(List<Address> members)
protected void	UFC.handleViewChange(List<Address> mbrs)
protected void	MFC.handleViewChange(List<Address> mbrs)
protected void	FlowControl.handleViewChange(List<Address> mbrs)
protected static String	FlowControl.printMap(Map<Address,FlowControl.Credit> m)
void	TCP_NIO.retainAll(Collection<Address> members)
void	TCP.retainAll(Collection<Address> members)
protected boolean	RSVP.Entry.retainAll(Collection<Address> members)
abstract void	BasicTCP.retainAll(Collection<Address> members)
protected void	PEER_LOCK.PeerLock.retainAll(List<Address> members)
protected void	RELAY.sendViewOnLocalCluster(List<Address> destinations, byte[] buffer)
protected void	RELAY.sendViewOnLocalCluster(RELAY.ViewData data, boolean use_seperate_thread, List<Address> new_mbrs)
protected void	RELAY.sendViewOnLocalCluster(View remote_view, View global_view, boolean use_seperate_thread, List<Address> new_mbrs)

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

Constructor and Description
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, Collection<Address> mbrs, Address from)
HTOTAL.HTotalHeader(Address dest, Address src)
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)
PingData(Address own_addr, View view, ViewId view_id, boolean is_server, String logical_name, Collection<PhysicalAddress> physical_addrs)
RSVP.Entry(Address member) Unicast entry
SEQUENCER.SequencerHeader(byte type, Address original_sender, long seqno)
TP.ProtocolAdapter(String cluster_name, Address local_addr, short transport_id, Protocol up, Protocol down, String pattern)
VERIFY_SUSPECT.Entry(Address suspect, long target_time)

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

Constructor and Description
DISCARD.DiscardHeader(Set<Address> ignoredAddresses)
FD_SOCK.FdHeader(byte type, Map<Address,IpAddress> cachedAddrs)
FD_SOCK.FdHeader(byte type, Set<Address> mbrs)
FD.FdHeader(byte type, Collection<Address> mbrs, Address from)
RSVP.Entry(Collection<Address> members) Multicast entry

Uses of Address in org.jgroups.protocols.pbcast

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

Modifier and Type	Field and Description
protected Address	StreamingStateTransfer.local_addr
protected Address	GMS.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

Modifier and Type	Field and Description
protected List<Address>	StreamingStateTransfer.members
protected Map<Address,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.

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

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

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

Modifier and Type	Method and Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
protected abstract void	StreamingStateTransfer.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr) Creates an InputStream to the state provider to read the state
protected void	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract void	StreamingStateTransfer.createStreamToRequester(Address requester) Creates an OutputStream to the state requester to write the state
protected void	STATE_SOCK.createStreamToRequester(Address requester)
protected void	STATE.createStreamToRequester(Address requester)
static NakAckHeader	NakAckHeader.createXmitRequestHeader(long low, long high, Address orginal_sender)
Digest	NAKACK.getDigest(Address mbr)
protected void	STATE_TRANSFER.getStateFromApplication(Address requester, Digest digest)
protected void	StreamingStateTransfer.getStateFromApplication(Address requester, OutputStream out, boolean use_separate_thread)
NakReceiverWindow	NAKACK.getWindow(Address mbr) Please don't use this method; it is only provided for unit testing !
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
void	Merger.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	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	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	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
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	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STATE_SOCK.handleStateReq(Address requester)
void	ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	ClientGmsImpl.join(Address address, boolean useFlushIfPresent)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
abstract void	GmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	ClientGmsImpl.leave(Address mbr)
protected void	StreamingStateTransfer.removeRequester(Address requester)
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)
protected void	StreamingStateTransfer.sendEof(Address requester)
protected void	StreamingStateTransfer.sendException(Address requester, Throwable exception)
protected void	STATE_TRANSFER.sendException(Address requester, 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	StreamingStateTransfer.setStateInApplication(Address provider, InputStream in, Digest digest)
void	ParticipantGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	CoordGmsImpl.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	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 and Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
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.
View	GMS.getNextView(Collection<Address> new_mbrs, Collection<Address> old_mbrs, Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(Collection<Address> new_mbrs, Collection<Address> old_mbrs, Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(Collection<Address> new_mbrs, Collection<Address> old_mbrs, Collection<Address> suspected_mbrs) Computes the next view.
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	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	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, Collection<? extends Address> mbrs)
void	Merger.merge(Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	GmsImpl.merge(Map<Address,View> views)
void	CoordGmsImpl.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

Constructor and Description
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, OutputStream output)

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

Constructor and Description
FLUSH.FlushHeader(byte type, long viewID, Collection<? extends Address> flushView)
GMS.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 and Description
class	IpAddress Network-dependent address (Internet).

Fields in org.jgroups.stack declared as Address

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

Methods in org.jgroups.stack that return Address

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

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

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

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

Modifier and Type	Method and Description
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	Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender) Get the missing messages between sequence numbers first_seqno and last_seqno.
void	AckSenderWindow.retransmit(long first_seqno, long last_seqno, Address sender)
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.

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

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

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

Constructor and Description
AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
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, 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, List<Address> mbrs)
GossipData(byte type, String group, Address addr, List<Address> mbrs, List<PhysicalAddress> physical_addrs)
GossipData(byte type, String group, Address addr, String logical_name, 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, 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

Constructor and 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 and 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 and Description
protected Address	SingletonAddress.addr
protected Address	Owner.address
protected Address	Digest.DigestEntry.member
protected Address[]	Digest.members
protected Address	Rsp.sender The sender of this response

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

Modifier and Type	Field and Description
protected static LazyRemovalCache<Address,String>	UUID.cache Keeps track of associations between logical addresses (UUIDs) and logical names
protected Map<Address,Long>	CreditMap.credits
protected List<Address>	AckCollector.missing_acks List of members from whom we haven't received an ACK yet
protected static LazyRemovalCache.Printable<Address,String>	UUID.print_function
protected List<Address>	AckCollector.suspected_mbrs

Methods in org.jgroups.util that return Address

Modifier and Type	Method and Description
static Address	Util.createRandomAddress()
static Address	Util.createRandomAddress(String name)
Address	SingletonAddress.getAddress()
Address	Owner.getAddress()
Address	Digest.DigestEntry.getMember()
Address	Rsp.getSender()
static Address	Util.readAddress(DataInput in)

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

Modifier and Type	Method and Description
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs) Returns all members that left between 2 views.
static Collection<Address>	Util.determineMergeCoords(Map<Address,View> map) This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static Collection<Address>	Util.determineMergeParticipants(Map<Address,View> map) Determines the members which take part in a merge.
Set<Map.Entry<Address,Rsp<T>>>	RspList.entrySet()
static Map<Address,String>	UUID.getContents() Returns a copy of the cache's contents
Set<Address>	Digest.getMembers()
List<Tuple<Address,Long>>	CreditMap.getMembersWithCreditsLessThan(long min_credits)
List<Address>	CreditMap.getMembersWithInsufficientCredits(long credit_needed)
List<Address>	ResponseCollector.getMissing() Returns a list of members which didn't send a valid response
Map<Address,T>	ResponseCollector.getResults()
List<Address>	RspList.getSuspectedMembers()
List<Address>	ResponseCollector.getValidResults()
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 List<Address>	Util.pickSubset(List<Address> members, double subset_percentage) Selects a random subset of members according to subset_percentage and returns them.
static Collection<? extends Address>	Util.readAddresses(DataInput in, Class cl)

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

Modifier and Type	Method and Description
void	AckCollector.ack(Address member)
boolean	SeqnoTable.add(Address member, long seqno)
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, 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)
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).
protected int	Digest.find(Address member)
static String	UUID.get(Address logical_addr)
long[]	Digest.get(Address member) Returns the highest delivered and received seqnos associated with a member.
Long	CreditMap.get(Address member)
long	SeqnoTable.getHighestReceived(Address member)
long	SeqnoTable.getNextToReceive(Address member)
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)
Long	CreditMap.putIfAbsent(Address key)
static void	UUID.remove(Address addr)
void	SeqnoTable.remove(Address member)
void	ResponseCollector.remove(Address member)
Long	CreditMap.remove(Address key)
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
void	MutableDigest.setHighestDeliveredAndSeenSeqnos(Address member, long highest_delivered_seqno, long highest_received_seqno)
static int	Util.size(Address addr)
void	ResponseCollector.suspect(Address member)
void	AckCollector.suspect(Address member)
static void	Util.writeAddress(Address addr, DataOutput out)

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

Modifier and Type	Method and Description
static void	UUID.add(Map<Address,String> map)
protected void	AckCollector.addAll(Collection<Address> members)
static byte[]	Util.collectionToByteBuffer(Collection<Address> c)
protected void	Digest.createArrays(Map<Address,long[]> map)
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs) Returns all members that left between 2 views.
static List<Address>	Util.determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs) Returns all members that left between 2 views.
static Collection<Address>	Util.determineMergeCoords(Map<Address,View> map) This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static Collection<Address>	Util.determineMergeParticipants(Map<Address,View> map) Determines the members which take part in a merge.
static List<Address>	Util.leftMembers(Collection<Address> old_list, Collection<Address> new_list)
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 List<Address>	Util.newMembers(List<Address> old_list, List<Address> new_list)
static List<Address>	Util.pickSubset(List<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<T>> m)
void	ResponseCollector.remove(List<Address> members)
static void	UUID.removeAll(Collection<Address> mbrs)
void	ResponseCollector.reset(Collection<Address> members)
void	AckCollector.reset(Collection<Address> members)
static void	UUID.retainAll(Collection<Address> logical_addrs)
boolean	SeqnoTable.retainAll(Collection<Address> members)
boolean	AckCollector.retainAll(Collection<Address> members)
static long	Util.size(Collection<? extends Address> addrs) Returns the marshalled size of a Collection of Addresses.
static boolean	Util.startFlush(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, DataOutput out) Writes a Vector of Addresses.

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

Constructor and Description
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)
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, Throwable t)
SingletonAddress(String cluster_name, Address addr)

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

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