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.auth
org.jgroups.auth.sasl
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.cs	This package contains all client-server related interfaces and classes
org.jgroups.blocks.mux
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
org.jgroups.fork
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
org.jgroups.protocols.relay
org.jgroups.protocols.rules
org.jgroups.protocols.tom
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Subinterfaces of Address in org.jgroups

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

Classes in org.jgroups that implement Address

Modifier and Type	Class and Description
class	AnycastAddress This type of address represents a subset of the cluster members in which the total order properties must be applied, e.g.

Fields in org.jgroups declared as Address

Modifier and Type	Field and Description
protected Address	ViewId.creator
protected Address	Message.dest_addr
protected Address	JChannel.local_addr
protected Address	UnreachableException.member
protected Address[]	View.members An array containing all the members of the view.
static Address	Global.NULL_ADDRESS
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

Modifier and Type	Field and Description
protected java.util.Collection<Address>	AnycastAddress.destinations

Methods in org.jgroups that return Address

Modifier and Type	Method and Description
Address	Message.dest()
static Address[][]	View.diff(View from, View to) Returns the difference between 2 views from and to.
Address	Membership.elementAt(int index) Returns the component at the specified index
protected Address	JChannel.generateAddress()
Address	View.get(int index)
Address	JChannel.getAddress()
abstract Address	Channel.getAddress() Returns the channel's own address.
Address	View.getCoord()
Address	View.getCreator() Returns the creator of this view if this view was created with the empty constructur, null will be returned
Address	ViewId.getCreator() Returns the address of the member that issued this view
Address	Message.getDest()
Address[]	View.getMembersRaw() Returns the underlying array.
Address	Message.getSrc()
Address	Message.src()

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

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

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method and Description
Membership	Membership.add(Address... mbrs)
void	AnycastAddress.add(Address... addresses)
Membership	Membership.add(Address new_member) Adds a new member to this membership.
int	AnycastAddress.compareTo(Address o)
void	JChannel.connect(java.lang.String cluster_name, Address target, long timeout)
abstract void	Channel.connect(java.lang.String cluster_name, Address target, long timeout) Connects this channel to a group and gets a state from a specified state provider.
void	JChannel.connect(java.lang.String cluster_name, Address target, long timeout, 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
boolean	View.containsMembers(Address... mbrs) Returns true if all mbrs are elements of this view, false otherwise
static View	View.create(Address coord, long id, Address... members)
static View	View.create(Address coord, long id, Address... members)
static View	View.create(Address coord, long id, java.util.Collection<Address> members)
Message	Message.dest(Address new_dest)
protected int	MergeView.get(Address member)
java.lang.String	JChannel.getName(Address member)
abstract java.lang.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, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
protected void	AnycastAddress.internalAdd(Address address)
Membership	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, java.lang.Object obj)
abstract void	Channel.send(Address dst, java.lang.Object obj) Helper method to create a Message with given parameters and invoke Channel.send(Message).
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
Message	Message.src(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, java.io.DataOutput out, short... excluded_headers) Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address

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

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

Constructors in org.jgroups with parameters of type Address

Constructor and Description
AnycastAddress(Address... addresses)
MergeView(Address creator, long id, java.util.List<Address> members, java.util.List<View> subgroups) Creates a new view
MergeView(ViewId view_id, Address[] members, java.util.List<View> subgroups)
Message(Address dest) Constructs a Message given a destination Address
Message(Address dest, Address src, byte[] buf) Constructs a Message given a destination Address, a source Address and the payload byte buffer
Message(Address dest, Address src, byte[] buf, int offset, int length) Constructs a message.
Message(Address dest, Address src, java.lang.Object obj) Constructs a Message given a destination Address, a source Address and the payload Object
Message(Address dest, byte[] buf)
Message(Address dest, byte[] buf, int offset, int length)
Message(Address dest, java.lang.Object obj)
UnreachableException(Address member)
UnreachableException(java.lang.String msg, Address member)
View(Address creator, long id, java.util.List<Address> members) Creates a new view
View(ViewId view_id, Address[] members) Creates a new view.
ViewId(Address creator) Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
ViewId(Address creator, long id) Creates a ViewID with the coordinator address and the given Lamport timestamp.

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

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

Uses of Address in org.jgroups.auth

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

Modifier and Type	Field and Description
protected java.util.Map<Address,DemoToken.Entry>	DemoToken.pending_requests

Uses of Address in org.jgroups.auth.sasl

Methods in org.jgroups.auth.sasl with parameters of type Address

Modifier and Type	Method and Description
Message	SaslClientContext.nextMessage(Address address, SaslHeader header)
Message	SaslServerContext.nextMessage(Address address, SaslHeader header)
Message	SaslContext.nextMessage(Address address, SaslHeader saslHeader)

Uses of Address in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Address

Modifier and Type	Field and Description
Address[]	RequestCorrelator.MultiDestinationHeader.exclusion_list Contains a list of members who should not receive the request (others will drop).
protected Address[]	RequestOptions.exclusion_list A list of members which should be excluded from a call
protected Address	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 java.util.Collection<Address>	MessageDispatcher.members
protected java.util.Map<Address,Rsp<T>>	GroupRequest.requests Correlates requests and responses

Methods in org.jgroups.blocks that return Address

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

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

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

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

Modifier and Type	Method and Description
<T> T	RpcDispatcher.callRemoteMethod(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> T	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options, FutureListener<T> listener) Invokes a method in a cluster member and - if blocking - returns the result
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
protected RequestCorrelator	MessageDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)
boolean	RspFilter.isAcceptable(java.lang.Object response, Address sender) Determines whether a response from a given sender should be added to the response list of the request
void	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)
abstract void	Request.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)
void	UnicastRequest.receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception) Callback (called by RequestCorrelator or Transport).
void	GroupRequest.receiveResponse(java.lang.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.
protected void	ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
void	BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
void	RequestCorrelator.sendUnicastRequest(Address target, Message msg, Request req) Sends a request to a single destination
RequestOptions	RequestOptions.setExclusionList(Address... mbrs)
void	RequestCorrelator.setLocalAddress(Address a)
void	ReplCache.suspect(Address suspected_mbr)
abstract void	Request.suspect(Address mbr)
void	ReplicatedHashMap.suspect(Address suspected_mbr) Called when a member is suspected
void	UnicastRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
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(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> RspList<T>	RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options, FutureListener<RspList<T>> listener) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
protected <T> GroupRequest<T>	MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
protected <T> GroupRequest<T>	MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results, FutureListener<RspList<T>> listener)
<T> RspList<T>	MessageDispatcher.castMessage(java.util.Collection<Address> dests, Message msg, RequestOptions options) Sends a message to all members and expects responses from members in dests (if non-null).
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options) Sends a message to all members and expects responses from members in dests (if non-null).
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options, FutureListener<RspList<T>> listener) Sends a message to all members and expects responses from members in dests (if non-null).
Address	PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership) Defines a hash function to pick the right node from the list of cluster nodes.
Address	PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
void	ReplCache.HashFunction.installNodes(java.util.List<Address> nodes) When the topology changes, this method will be called.
void	ReplCache.ConsistentHashFunction.installNodes(java.util.List<Address> new_nodes)
void	BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs) Removes all connections from ConnectionTable which are not in current_mbrs
void	RequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs, Message msg, Request req, RequestOptions options) Sends a request to a group.
void	RequestCorrelator.sendRequest(java.util.List<Address> dest_mbrs, Message msg, Request req)
protected void	MessageDispatcher.setMembers(java.util.List<Address> new_mbrs) If this dispatcher is using a user-provided PullPushAdapter, then need to set the members from the adapter initially since viewChange has most likely already been called in PullPushAdapter.
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.List<Address> mbrs_joined, java.util.List<Address> mbrs_left)

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

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

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

Constructor and Description
GroupRequest(RequestCorrelator corr, java.util.Collection<Address> targets, RequestOptions options)

Uses of Address in org.jgroups.blocks.cs

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

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

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

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

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

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

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

Modifier and Type	Method and Description
void	BaseServer.addConnection(Address peer_addr, Connection conn)
void	TcpConnection.connect(Address dest)
void	NioConnection.connect(Address dest)
abstract void	Connection.connect(Address dest)
protected void	TcpConnection.connect(Address dest, boolean send_local_addr)
protected void	NioConnection.connect(Address dest, boolean send_local_addr)
boolean	BaseServer.connectionEstablishedTo(Address address)
protected TcpConnection	TcpBaseServer.createConnection(Address dest)
protected abstract Connection	BaseServer.createConnection(Address dest) Creates a new connection object to target dest, but doesn't yet connect it
protected NioConnection	NioBaseServer.createConnection(Address dest)
Connection	BaseServer.getConnection(Address dest) Creates a new connection to dest, or returns an existing one
boolean	BaseServer.hasConnection(Address address)
void	ReceiverAdapter.receive(Address sender, byte[] buf, int offset, int length)
void	BaseServer.receive(Address sender, byte[] data, int offset, int length) Called by a Connection implementation when a message has been received.
void	Receiver.receive(Address sender, byte[] buf, int offset, int length) Delivers a message from a given sender to the application
void	ReceiverAdapter.receive(Address sender, java.nio.ByteBuffer buf) The default implementation assumes that Buffer.flip() or Buffer.rewind() was called on buf before invoking this callback
void	BaseServer.receive(Address sender, java.nio.ByteBuffer buf) Called by a Connection implementation when a message has been received
void	Receiver.receive(Address sender, java.nio.ByteBuffer buf) Delivers a message from a given sender to the application
void	BaseServer.removeConnectionIfPresent(Address address, Connection conn) Only removes the connection if conns.get(address) == conn
void	BaseServer.replaceConnection(Address address, Connection conn)
void	NioClient.send(Address dest, byte[] data, int offset, int length)
void	BaseServer.send(Address dest, byte[] data, int offset, int length)
void	TcpClient.send(Address dest, byte[] data, int offset, int length)
void	NioClient.send(Address dest, java.nio.ByteBuffer data)
void	BaseServer.send(Address dest, java.nio.ByteBuffer data)
void	TcpClient.send(Address dest, java.nio.ByteBuffer data)
protected void	TcpConnection.sendLocalAddress(Address local_addr) Send the cookie first, then the our port number.
protected void	NioConnection.sendLocalAddress(Address local_addr)
protected <T> boolean	BaseServer.validateArgs(Address dest, T buffer)

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

Modifier and Type	Method and Description
void	BaseServer.retainAll(java.util.Collection<Address> current_mbrs) Removes all connections which are not in current_mbrs

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

Constructor and Description
NioConnection(Address peer_addr, NioBaseServer server) Creates a connection stub and binds it, use NioConnection.connect(Address) to connect
TcpConnection(Address peer_addr, TcpBaseServer server) Creates a connection stub and binds it, use TcpConnection.connect(Address) to connect

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	MuxMessageDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
protected RequestCorrelator	MuxRpcDispatcher.createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
boolean	NoMuxHandlerRspFilter.isAcceptable(java.lang.Object response, Address sender)
void	MuxRequestCorrelator.sendUnicastRequest(Address target, Message msg, Request req)

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

Modifier and Type	Method and Description
protected <T> GroupRequest<T>	MuxMessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults, FutureListener<RspList<T>> listener)
protected <T> GroupRequest<T>	MuxRpcDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults, FutureListener<RspList<T>> listener)
void	MuxRequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs, Message msg, Request req, 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.demos

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

Modifier and Type	Method and Description
void	Topology.addNode(Address member)
void	PubServer.receive(Address sender, byte[] buf, int offset, int length)
void	PubClient.receive(Address sender, byte[] buf, int offset, int length)
void	PubServer.receive(Address sender, java.nio.ByteBuffer buf)
void	PubClient.receive(Address sender, java.nio.ByteBuffer buf)
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, java.util.List<Address> new_mbrs, java.util.List<Address> old_mbrs)
void	ReplicatedHashMapDemo.viewChange(View view, java.util.List<Address> new_mbrs, java.util.List<Address> old_mbrs)

Uses of Address in org.jgroups.demos.wb

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

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(java.lang.String lbl, Address addr, int xloc, int yloc)
void	GraphPanel.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.suspect(Address obj)

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

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

Uses of Address in org.jgroups.fork

Fields in org.jgroups.fork declared as Address

Modifier and Type	Field and Description
protected Address	ForkProtocolStack.local_addr

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

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

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

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

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	CENTRAL_EXECUTOR.coord
protected Address	RELAY.coord
protected Address	FORWARD_TO_COORD.coord the address of the current coordinator, all msgs are forwarded to it
protected Address	COUNTER.coord The address of the cluster coordinator.
protected Address	SEQUENCER2.coord
protected Address	SEQUENCER.coord
protected Address	CENTRAL_LOCK.coord
protected Address	MERGE2.current_coord Deprecated.
protected Address	Discovery.current_coord
protected Address	FD.FdHeader.from
protected Address	ASYM_ENCRYPT.key_server_addr
protected Address	RELAY.local_addr
protected Address	FORWARD_TO_COORD.local_addr
protected Address	PERF.local_addr
protected Address	Locking.local_addr
protected Address	SASL.local_addr
protected Address	MAKE_BATCH.local_addr
protected Address	RSVP.local_addr
protected Address	PDC.local_addr
protected Address	UNICAST.local_addr Deprecated.
protected Address	MERGE3.local_addr
protected Address	FD_SOCK.local_addr
protected Address	COUNTER.local_addr
protected Address	FD.local_addr
protected Address	FORK.local_addr
protected Address	ABP.local_addr
protected Address	MERGE2.local_addr Deprecated.
protected Address	SIZE.local_addr
protected Address	SEQUENCER2.local_addr
protected Address	Discovery.local_addr
protected Address	STOMP.local_addr
protected Address	FlowControl.local_addr
protected Address	UNICAST3.local_addr
protected Address	SEQUENCER.local_addr
protected Address	AUTH.local_addr
protected Address	TP.local_addr The address (host and port) of this member.
protected Address	VERIFY_SUSPECT.local_addr
protected Address	BARRIER.local_addr
protected Address	FD_ALL.local_addr
protected Address	EncryptBase.local_addr
protected Address	FD_ALL2.local_addr
protected Address	FRAG2.local_addr
protected Address	Executing.local_addr
protected Address	KeyExchange.local_addr
protected Address	UNICAST2.local_addr Deprecated.
protected Address	SCOPE.local_addr Deprecated.
protected Address	FD_HOST.local_addr
protected Address	DAISYCHAIN.local_addr
protected Address	DISCARD.localAddress
protected Address	PDC.Mapping.logical_addr
protected Address	FD_SOCK.FdHeader.mbr
protected Address	SEQUENCER.Flusher.new_coord
protected Address	DAISYCHAIN.next
protected Address	RELAY.RelayHeader.original_sender
protected Address	PDC.Mapping.physical_addr
protected Address	FD_SOCK.ping_dest
protected Address	FD.ping_dest
protected Address	PingData.sender
protected Address	VERIFY_SUSPECT.Entry.suspect
protected Address	RSVP.Entry.target

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

Modifier and Type	Field and Description
protected java.util.List<Address>	COUNTER.backup_coords Backup coordinators.
protected java.util.List<Address>	CENTRAL_EXECUTOR.backups
protected java.util.List<Address>	CENTRAL_LOCK.backups
protected java.util.concurrent.ConcurrentMap<Address,PhysicalAddress>	PDC.cache
protected AgeOutCache<Address>	UNICAST.cache Deprecated.
protected LazyRemovalCache<Address,IpAddress>	FD_SOCK.cache Cache of member addresses and their ServerSocket addresses
protected AgeOutCache<Address>	UNICAST3.cache
protected AgeOutCache<Address>	UNICAST2.cache Deprecated.
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.curr_mbrs
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	SEQUENCER.delivery_table
protected java.util.Map<Address,java.lang.String>	STOMP.endpoints
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Long,FRAG2.FragEntry>>	FRAG2.fragment_list
protected Promise<java.util.Map<Address,IpAddress>>	FD_SOCK.get_cache_promise Used to rendezvous on GET_CACHE and GET_CACHE_RSP
protected java.util.List<Address>	PEER_LOCK.PeerLock.grants
protected java.util.Set<Address>	BARRIER.holes
protected java.util.Map<java.net.InetAddress,java.util.List<Address>>	FD_HOST.hosts Map of hosts and their cluster members, updated on view changes.
protected java.util.Set<Address>	DISCARD.ignoredMembers
protected ExpiryCache<Address>	UNICAST3.last_sync_sent Keep track of when a SEND_FIRST_SEQNO message was sent to a given sender
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.left_mbrs
protected LazyRemovalCache<Address,PhysicalAddress>	TP.logical_addr_cache Cache which maintains mappings between logical and physical addresses.
protected java.util.Set<Address>	FD_SOCK.FdHeader.mbrs
protected java.util.Collection<Address>	FD.FdHeader.mbrs
protected java.util.Collection<? extends Address>	PingData.mbrs
protected java.util.Map<Address,Message>	BARRIER.mcast_queue
protected java.util.Collection<Address>	DISCARD.members
protected java.util.List<Address>	RSVP.members
protected java.util.List<Address>	UNICAST.members Deprecated.
protected java.util.List<Address>	FD_SOCK.members
protected java.util.List<Address>	FD.members
protected java.util.Set<Address>	MERGE2.members Deprecated.
protected java.util.List<Address>	SIZE.members
protected java.util.List<Address>	Discovery.members
protected java.util.List<Address>	UNICAST3.members
protected java.util.Set<Address>	TP.members The members of this group (updated when a member joins or leaves).
protected java.util.List<Address>	FD_ALL.members
protected java.util.List<Address>	FD_ALL2.members
protected java.util.List<Address>	FRAG2.members
protected java.util.List<Address>	UNICAST2.members Deprecated.
protected java.util.List<Address>	FD_HOST.members
protected java.util.Set<Address>	MERGE2.merge_candidates Deprecated.
protected java.util.List<Address>	Discovery.DiscoveryCacheDisseminationTask.new_mbrs
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_ucast
protected java.util.List<Address>	FD_SOCK.pingable_mbrs
protected java.util.List<Address>	FD.pingable_mbrs Members from which we select ping_dest.
protected static LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<PhysicalAddress>>	TP.print_function
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Short,SCOPE.MessageQueue>>	SCOPE.queues Deprecated. Used to find the correct AckReceiverWindow on message reception and deliver it in the right order
protected java.util.Map<Address,FlowControl.Credit>	FlowControl.received Keeps track of credits per member at the receiver.
protected java.util.concurrent.ConcurrentHashMap<Address,ABP.Entry>	ABP.recv_map
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.ReceiverEntry>	UNICAST.recv_table Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.ReceiverEntry>	UNICAST3.recv_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.ReceiverEntry>	UNICAST2.recv_table Deprecated.
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_ucast
protected java.util.Map<Address,SaslContext>	SASL.sasl_context
protected java.util.concurrent.ConcurrentHashMap<Address,ABP.Entry>	ABP.send_map
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.SenderEntry>	UNICAST.send_table Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST3.SenderEntry>	UNICAST3.send_table
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.SenderEntry>	UNICAST2.send_table Deprecated.
protected java.util.Map<Address,FlowControl.Credit>	UFC.sent Map: keys are members, values are credits left.
protected SuppressLog<Address>	TP.suppress_log_different_cluster Log to suppress identical warnings for messages from members in different clusters
protected SuppressLog<Address>	TP.suppress_log_different_version Log to suppress identical warnings for messages from members with different (incompatible) versions
protected BoundedList<Tuple<Address,java.lang.Long>>	FD_ALL.suspect_history
protected BoundedList<Tuple<Address,java.lang.Long>>	FD_ALL2.suspect_history
protected java.util.Set<Address>	FD_SOCK.suspected_mbrs
protected java.util.List<Address>	FD.Broadcaster.suspected_mbrs
protected java.util.Set<Address>	FD_ALL.suspected_mbrs
protected java.util.Set<Address>	FD_ALL2.suspected_mbrs
protected java.util.Set<Address>	FD_HOST.suspected_mbrs
protected java.util.List<Address>	FD.BroadcastTask.suspected_members
protected java.util.concurrent.ConcurrentMap<Address,java.lang.Long>	FD_ALL.timestamps
protected java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.atomic.AtomicBoolean>	FD_ALL2.timestamps
protected java.util.Map<Address,Message>	BARRIER.ucast_queue
protected java.util.Map<Address,java.lang.String>	RELAY.ViewData.uuids
protected java.util.Map<Address,ViewId>	MERGE3.views
protected java.util.Map<Address,View>	MERGE2.views Deprecated.
protected ExpiryCache<Address>	TP.who_has_cache Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after who_has_cache_timeout ms
protected java.util.Map<Address,java.lang.Long>	UNICAST3.xmit_task_map Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)
protected java.util.Map<Address,java.lang.Long>	UNICAST2.xmit_task_map Deprecated. Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method and Description
protected Address	FD_SOCK.determineCoordinator()
protected Address	FD_SOCK.determinePingDest()
Address	SASL.getAddress()
Address	PingData.getAddress()
Address	AUTH.getAddress()
Address	TP.ProtocolAdapter.getAddress()
Address	Executing.Owner.getAddress()
Address	CENTRAL_EXECUTOR.getCoord()
Address	CENTRAL_LOCK.getCoord()
Address	SEQUENCER2.getCoordinator()
Address	SEQUENCER.getCoordinator()
protected Address	ASYM_ENCRYPT.getCoordinator(Message msg, GMS.GmsHeader hdr) Tries to find out if this is a JOIN_RSP or INSTALL_MERGE_VIEW message and returns the coordinator of the view
Address	ENCRYPT.getKeyServerAddr() Deprecated.
Address	SEQUENCER2.getLocalAddress()
Address	SEQUENCER.getLocalAddress()
Address	PDC.Mapping.getLogicalAddr()
Address	PDC.Mapping.getPhysicalAddr()
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
Address	ASYM_ENCRYPT.keyServerAddr()
Address	DISCARD.localAddress()
Address	TP.localAddress()

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

Modifier and Type	Method and Description
protected java.util.Map<ViewId,java.util.Set<Address>>	MERGE3.convertViews()
AgeOutCache<Address>	UNICAST.getAgeOutCache() Deprecated.
AgeOutCache<Address>	UNICAST3.getAgeOutCache()
AgeOutCache<Address>	UNICAST2.getAgeOutCache() Deprecated.
java.util.Set<Address>	TP.ProtocolAdapter.getMembers()
protected java.util.List<Address>	FD.Broadcaster.getSuspectedMembers()
java.util.Collection<? extends Address>	PingData.mbrs()
protected java.util.Map<Address,IpAddress>	FD_SOCK.unmarshal(byte[] buffer, int offset, int length)

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

Modifier and Type	Method and Description
protected void	TP._send(Message msg, Address dest)
protected void	RSVP.Entry.ack(Address member)
void	COUNTER.ReconciliationTask.add(COUNTER.ReconcileResponse rsp, Address sender)
protected boolean	Discovery.addDiscoveryResponseToCaches(Address mbr, java.lang.String logical_name, PhysicalAddress physical_addr)
protected boolean	FILE_PING.addDiscoveryResponseToCaches(Address mbr, java.lang.String logical_name, PhysicalAddress physical_addr) Only add the discovery response if the logical address is not present or the physical addrs are different
protected void	FD_ALL.addIfAbsent(Address mbr)
DISCARD	DISCARD.addIgnoreMember(Address sender) Messages from this sender will get dropped
protected void	MERGE3.addInfo(Address sender, ViewId view_id, java.lang.String logical_name, PhysicalAddress physical_addr) Adds received INFO to views hashmap
protected boolean	TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
protected static java.lang.String	PDC.addressAsString(Address address)
protected static java.lang.String	Discovery.addressAsString(Address address)
protected static java.lang.String	FILE_PING.addressToFilename(Address mbr)
protected boolean	VERIFY_SUSPECT.addSuspect(Address suspect)
protected void	FD_SOCK.BroadcastTask.addSuspectedMember(Address mbr) Adds a suspected member.
protected void	FD.Broadcaster.addSuspectedMember(Address mbr) Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
protected long	FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map, Address sender, int length) Check whether sender has enough credits left.
protected void	SEQUENCER.broadcast(Message msg, boolean copy, Address original_sender, long seqno, boolean resend)
protected void	FD_SOCK.broadcastSuspectMessage(Address suspected_mbr) Sends a SUSPECT message to all group members.
protected void	FD_SOCK.broadcastUnuspectMessage(Address mbr)
protected boolean	SEQUENCER.canDeliver(Address sender, long seqno) Checks if seqno has already been received from sender.
void	FRAG2.clearFragmentsFor(Address mbr)
void	SCOPE.clearQueue(Address member) Deprecated.
void	UNICAST3.closeConnection(Address mbr) Removes and resets from connection table (which is already locked).
void	UNICAST3.closeReceiveConnection(Address mbr)
void	UNICAST3.closeSendConnection(Address mbr)
protected void	FD.computePingDest(Address remove) Computes pingable_mbrs (based on the current membership and the suspected members) and ping_dest
boolean	UNICAST2.connectionEstablished(Address target) Deprecated. Is the send connection to target established
protected boolean	JDBC_PING.contains(java.lang.String cluster_name, Address addr)
static RELAY.RelayHeader	RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
protected UNICAST3.ReceiverEntry	UNICAST3.createReceiverEntry(Address sender, long seqno, short conn_id)
protected javax.net.ssl.SSLSocket	SSL_KEY_EXCHANGE.createSocketTo(Address target)
protected void	UNICAST3.deliverMessage(Event evt, Address sender, long seqno)
void	Discovery.discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
void	TCPPING.discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
protected void	TP.doSend(AsciiString cluster_name, byte[] buf, int offset, int length, Address dest)
void	UNICAST.expired(Address key) Deprecated. Called by AgeOutCache, to removed expired connections
void	UNICAST3.expired(Address key) Called by AgeOutCache, to removed expired connections
void	UNICAST2.expired(Address key) Deprecated. Called by AgeOutCache, to removed expired connections
protected IpAddress	FD_SOCK.fetchPingAddress(Address mbr) Attempts to obtain the ping_addr first from the cache, then by unicasting q request to mbr, then by multicasting a request to all members.
void	SSL_KEY_EXCHANGE.fetchSecretKeyFrom(Address target)
abstract void	KeyExchange.fetchSecretKeyFrom(Address target) Needs to fetch the secret key from a given destination (usually the key server).
protected void	SEQUENCER.flush(Address new_coord)
protected ABP.Entry	ABP.getEntry(java.util.concurrent.ConcurrentMap<Address,ABP.Entry> map, Address dest)
protected java.net.InetAddress	FD_HOST.getHostFor(Address mbr)
protected SCOPE.MessageQueue	SCOPE.getOrCreateQueue(Address sender, short scope) Deprecated.
protected UNICAST.ReceiverEntry	UNICAST.getOrCreateReceiverEntry(Address sender, long seqno, short conn_id) Deprecated.
protected UNICAST2.ReceiverEntry	UNICAST2.getOrCreateReceiverEntry(Address sender, long seqno, short conn_id) Deprecated.
protected PhysicalAddress	FD_HOST.getPhysicalAddress(Address logical_addr)
protected PhysicalAddress	TP.getPhysicalAddressFromCache(Address logical_addr)
protected UNICAST.ReceiverEntry	UNICAST.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id) Deprecated.
protected UNICAST3.ReceiverEntry	UNICAST3.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id)
protected UNICAST2.ReceiverEntry	UNICAST2.getReceiverEntry(Address sender, long seqno, boolean first, short conn_id) Deprecated.
protected UNICAST3.SenderEntry	UNICAST3.getSenderEntry(Address dst)
protected void	MERGE2.handle(MERGE2.MergeHeader hdr, Address sender) Deprecated.
protected void	UNICAST.handleAckReceived(Address sender, long seqno, short conn_id) Deprecated.
protected void	UNICAST3.handleAckReceived(Address sender, long seqno, short conn_id, long timestamp) Add the ACK to hashtable.sender.sent_msgs
protected void	UNICAST.handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map) Deprecated.
protected void	UNICAST2.handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map) Deprecated.
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, java.util.List<Tuple<java.lang.Long,Message>> msgs, boolean oob)
protected void	Executing.handleConsumerFoundResponse(long threadId, Address address)
protected void	Executing.handleConsumerReadyRequest(long requestId, Address address)
protected void	Executing.handleConsumerUnreadyRequest(long requestId, Address address)
protected void	MFC.handleCredit(Address sender, long increase)
protected abstract void	FlowControl.handleCredit(Address sender, long increase)
protected void	UFC.handleCredit(Address sender, long increase)
protected void	FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected void	UNICAST.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Deprecated. Check whether the hashtable contains an entry e for sender (create if not).
protected void	UNICAST3.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Check whether the hashtable contains an entry e for sender (create if not).
protected boolean	UNICAST2.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Deprecated. Check whether the hashmap contains an entry e for sender (create if not).
protected void	UNICAST3.handleDataReceivedFromSelf(Address sender, long seqno, Message msg) Called when the sender of a message is the local member.
protected void	Discovery.handleDiscoveryResponse(PingData data, Address sender)
protected java.lang.Object	MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected abstract java.lang.Object	FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected java.lang.Object	UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
protected void	Executing.handleExceptionResponse(Address source, long requestId, java.lang.Throwable throwable)
protected void	Executing.handleInterruptRequest(Address source, long requestId)
protected void	PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner, Address sender)
protected boolean	ABP.Entry.handleMessage(Address sender, byte msg_bit)
protected void	TP.handleMessageBatch(Address sender, byte[] data, int offset, int length)
protected void	ASYM_ENCRYPT.handleNewKeyServer(Address old_key_server, boolean merge_view, boolean left_mbrs) If the keyserver changed, send a request for the secret key to the keyserver
protected void	COUNTER.handleRequest(COUNTER.Request req, Address sender)
protected void	UNICAST.handleResendingOfFirstMessage(Address sender, long seqno) Deprecated. We need to resend our first message with our conn_id
protected void	UNICAST3.handleResendingOfFirstMessage(Address sender, long timestamp) We need to resend the first message with our conn_id
protected void	UNICAST2.handleResendingOfFirstMessage(Address sender, long seqno) Deprecated. We need to resend our first message with our conn_id
protected void	RSVP.handleResponse(Address member, short id)
protected void	COUNTER.handleResponse(COUNTER.Response rsp, Address sender)
protected void	TP.handleSingleMessage(Address sender, byte[] data, int offset, int length)
protected void	Executing.handleTaskRejectedResponse(Address source, long requestId)
protected void	Executing.handleTaskRequest(long requestId, Address address)
protected void	Executing.handleTaskSubmittedRequest(java.lang.Runnable runnable, Address source, long requestId, long threadId)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UNICAST3.Header hdr)
protected void	UNICAST.handleUpEvent(Address sender, UNICAST.UnicastHeader hdr) Deprecated.
protected void	Executing.handleValueResponse(Address source, long requestId, java.lang.Object value)
protected void	UNICAST3.handleXmitRequest(Address sender, SeqnoList missing)
protected void	UNICAST2.handleXmitRequest(Address sender, SeqnoList missing) Deprecated.
boolean	UNICAST.hasSendConnectionTo(Address dest) Deprecated. Used for testing only
boolean	UNICAST3.hasSendConnectionTo(Address dest) Used for testing only
boolean	UNICAST2.hasSendConnectionTo(Address dest) Deprecated. Used for testing only
protected boolean	EncryptBase.inView(Address sender, java.lang.String error_msg)
protected boolean	Discovery.isCoord(Address member)
protected boolean	RELAY.isLocal(Address dest) Does the payload match the 'site' ID.
protected boolean	FD_HOST.isPinger(Address mbr)
ASYM_ENCRYPT	ASYM_ENCRYPT.keyServerAddr(Address key_srv)
protected boolean	ASYM_ENCRYPT.keyServerChanged(Address old_keyserver)
DISCARD	DISCARD.localAddress(Address addr)
<T extends EncryptBase> T	EncryptBase.localAddress(Address addr)
protected int	RingBufferBundlerLockless2.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
protected int	RingBufferBundler.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
protected int	RingBufferBundlerLockless.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int available_msgs, int max_bundle_size)
protected void	MERGE2.mergeFast(Address dest, Address sender) Deprecated.
protected void	UNICAST3.processInternalMessage(Table<Message> win, Address sender)
void	BasicTCP.receive(Address sender, byte[] data, int offset, int length) BaseServer.Receiver interface
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, java.nio.ByteBuffer buf)
protected static void	SHARED_LOOPBACK.register(AsciiString 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	JDBC_PING.remove(java.lang.String clustername, Address addr)
protected void	SWIFT_PING.remove(java.lang.String clustername, Address addr)
protected void	RACKSPACE_PING.remove(java.lang.String clustername, Address addr)
protected void	FILE_PING.remove(java.lang.String clustername, Address addr)
protected void	S3_PING.remove(java.lang.String clustername, Address addr)
protected int	UNICAST.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Deprecated. Try to remove as many messages as possible from the table as pass them up.
protected void	SEQUENCER2.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Try to remove as many messages as possible from the table as pass them up.
protected void	UNICAST2.removeAndPassUp(Table<Message> win, Address sender) Deprecated. Try to remove as many messages as possible and pass them up.
void	UNICAST.removeConnection(Address mbr) Deprecated. Removes and resets from connection table (which is already locked).
void	UNICAST2.removeConnection(Address mbr) Deprecated. Removes and resets from connection table (which is already locked).
DISCARD	DISCARD.removeIgnoredMember(Address member)
protected void	TP.removeLogicalAddressFromCache(Address logical_addr)
protected void	PDC.removeNodeFromDisk(Address logical_addr)
void	UNICAST.removeReceiveConnection(Address mbr) Deprecated.
protected void	UNICAST3.removeReceiveConnection(Address mbr)
void	UNICAST2.removeReceiveConnection(Address mbr) Deprecated.
void	SCOPE.removeScope(Address member, short scope) Deprecated.
void	UNICAST.removeSendConnection(Address mbr) Deprecated.
protected void	UNICAST3.removeSendConnection(Address mbr)
void	UNICAST2.removeSendConnection(Address mbr) Deprecated.
protected boolean	VERIFY_SUSPECT.removeSuspect(Address suspect)
protected void	FD_SOCK.BroadcastTask.removeSuspectedMember(Address suspected_mbr)
protected void	UNICAST3.retransmit(SeqnoList missing, Address sender) Sends a retransmit request to the given sender
void	UNICAST2.retransmit(SeqnoList missing, Address sender) Deprecated.
protected void	COUNTER.send(Address dest, Buffer buffer)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length) Deprecated.
void	TCP_NIO2.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
protected void	Locking.send(Address dest, Locking.Request req)
protected void	FORWARD_TO_COORD.send(Address target, long ack_id, byte type)
protected void	TUNNEL.send(Message msg, Address dest)
protected void	TP.send(Message msg, Address dest) Serializes and sends a message.
protected void	FORWARD_TO_COORD.sendAck(Address target, long ack_id)
protected void	UNICAST.sendAck(Address dst, long seqno, short conn_id) Deprecated.
protected void	UNICAST3.sendAck(Address dst, long seqno, short conn_id)
protected void	UNICAST2.sendAck(Address dest, long seqno, short conn_id) Deprecated.
void	UNICAST3.sendClose(Address dest, short conn_id)
protected void	COUNTER.sendCounterNotFoundExceptionResponse(Address dest, Owner owner, java.lang.String counter_name)
protected void	CENTRAL_LOCK.sendCreateLockRequest(Address dest, java.lang.String lock_name, Owner owner)
protected void	FlowControl.sendCredit(Address dest, long credits)
protected void	FlowControl.sendCreditRequest(Address dest, long credits_needed) We cannot send this request as OOB message, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected void	CENTRAL_LOCK.sendDeleteLockRequest(Address dest, java.lang.String lock_name)
protected void	Discovery.sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name, Address sender, boolean coord)
protected void	FD.sendHeartbeatResponse(Address dest)
protected void	FD_SOCK.sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr) Sends or broadcasts a I_HAVE_SOCK response.
protected void	SASL.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)
protected void	AUTH.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)
protected void	ASYM_ENCRYPT.sendKeyRequest(Address key_server) send client's public key to server and request server's public key
protected void	SASL.sendMergeRejectionMessage(Address dest)
protected void	AUTH.sendMergeRejectionMessage(Address dest)
protected void	BaseBundler.sendMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> list)
protected void	ASYM_ENCRYPT.sendNewKeyserverAck(Address dest)
protected void	FORWARD_TO_COORD.sendNotCoord(Address target, long ack_id)
protected void	SASL.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
protected void	AUTH.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
protected void	COUNTER.sendRequest(Address dest, COUNTER.Request req)
protected void	Executing.sendRequest(Address dest, Executing.Type type, long requestId, java.lang.Object object)
protected void	Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, int lock_id, Owner owner, long timeout, boolean is_trylock)
protected void	Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, Owner owner, long timeout, boolean is_trylock)
protected void	UNICAST3.sendRequestForFirstSeqno(Address dest)
protected void	UNICAST.sendRequestForFirstSeqno(Address dest, long seqno_received) Deprecated.
protected void	UNICAST2.sendRequestForFirstSeqno(Address dest, long seqno_received) Deprecated.
protected void	COUNTER.sendResponse(Address dest, COUNTER.Response rsp)
protected void	RSVP.sendResponse(Address dest, short id)
protected void	ASYM_ENCRYPT.sendSecretKey(java.security.Key secret_key, java.security.PublicKey public_key, Address source)
protected void	SEQUENCER2.sendSeqnoResponse(Address original_sender, long seqno, int num_seqnos)
protected void	UNICAST2.sendStableMessage(Address dest, short conn_id, long hd, long hr) Deprecated.
protected void	Executing.sendThreadRequest(Address dest, long threadId, Executing.Type type, long requestId, java.lang.Object object)
protected void	CENTRAL_EXECUTOR.sendToCoordinator(Executing.Type type, long requestId, Address value)
protected abstract void	Executing.sendToCoordinator(Executing.Type type, long requestId, Address address)
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(java.lang.String group, Address dest, byte[] data, int offset, int length)
protected void	TP.setInAllThreadFactories(java.lang.String cluster_name, Address local_address, java.lang.String pattern)
protected void	ENCRYPT.setKeyServerAddr(Address keyServerAddr) Deprecated.
DISCARD	DISCARD.setLocalAddress(Address localAddress)
protected void	ENCRYPT.setLocalAddress(Address local_addr) Deprecated.
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender) Checks if a message should be passed up, or not
protected void	UNICAST2.stable(Address sender, short conn_id, long hd, long hr) Deprecated. Purge all messages in window for local_addr, which are <= low.
protected void	FD.Broadcaster.startBroadcastTask(Address suspect) Starts a new task, or - if already running - adds the argument to the running task.
protected void	SEQUENCER.startFlusher(Address new_coord)
protected static void	SHARED_LOOPBACK.unregister(AsciiString channel_name, Address local_addr)
protected void	FD_SOCK.unsuspect(Address mbr)
protected void	FD.unsuspect(Address mbr)
void	VERIFY_SUSPECT.unsuspect(Address mbr)
protected boolean	FD_ALL.unsuspect(Address mbr) Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack
protected boolean	FD_ALL2.unsuspect(Address mbr) Removes mbr from suspected_mbrs and sends a UNSUSPECT event up and down the stack
protected boolean	FD_HOST.unsuspect(Address mbr)
protected void	FD_ALL.update(Address sender)
protected void	FD_ALL2.update(Address sender)
protected void	FD.updateTimestamp(Address sender)
protected boolean	TP.versionMatch(short version, Address sender)
static void	TP.writeMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> msgs, java.io.DataOutput dos, boolean multicast, short transport_id) Write a list of messages with the *same* destination and src addresses.
static void	TP.writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, java.io.DataOutput dos, boolean multicast)
protected void	PDC.writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr)
protected java.io.File	PDC.writeToTempFile(java.io.File dir, Address logical_addr, Address physical_addr, java.lang.String logical_name) Writes the data to a temporary file. The file is stored in the same directory as the other cluster files but is given the .tmp suffix

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

Modifier and Type	Method and Description
protected long	FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map, Address sender, int length) Check whether sender has enough credits left.
protected void	FD_SOCK.BroadcastTask.adjustSuspectedMembers(java.util.List<Address> new_mbrship) Removes all elements from suspected_mbrs that are not in the new membership
protected void	VERIFY_SUSPECT.adjustSuspectedMembers(java.util.List<Address> new_mbrship) Removes all elements from suspects that are not in the new membership
protected void	CENTRAL_LOCK.copyLocksTo(java.util.List<Address> new_joiners)
protected void	CENTRAL_EXECUTOR.copyQueueTo(java.util.List<Address> new_joiners)
static java.util.List<View>	MERGE3.detectDifferentViews(java.util.Map<Address,View> map)
protected void	Discovery.disseminateDiscoveryInformation(java.util.List current_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs) Disseminates cache information (UUID/IP adddress/port/name) to the given members
protected void	Discovery.disseminateDiscoveryInformation(java.util.List current_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs) Disseminates cache information (UUID/IP adddress/port/name) to the given members
protected void	TP.fetchPhysicalAddrs(java.util.List<Address> missing)
protected Responses	TP.fetchResponsesFromDiscoveryProtocol(java.util.List<Address> missing)
Responses	Discovery.findMembers(java.util.List<Address> members, boolean initial_discovery, boolean async)
void	JDBC_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
protected abstract void	Discovery.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses) Fetches information (e.g.
void	SHARED_LOOPBACK_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	TCPPING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	TCPGOSSIP.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	FILE_PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
void	PING.findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
protected void	BARRIER.flushQueue(java.util.Map<Address,Message> queue)
protected ABP.Entry	ABP.getEntry(java.util.concurrent.ConcurrentMap<Address,ABP.Entry> map, Address dest)
protected Address	FD.getPingDest(java.util.List<Address> mbrs)
protected void	FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
protected Locking.Response	Locking.ServerLock.handleView(java.util.List<Address> members)
protected void	MFC.handleViewChange(java.util.List<Address> mbrs)
protected void	FlowControl.handleViewChange(java.util.List<Address> mbrs)
protected void	UFC.handleViewChange(java.util.List<Address> mbrs)
static Buffer	FD_SOCK.marshal(LazyRemovalCache<Address,IpAddress> addrs)
PingData	PingData.mbrs(java.util.Collection<? extends Address> mbrs)
protected static java.lang.String	FlowControl.printMap(java.util.Map<Address,FlowControl.Credit> m)
protected void	JDBC_PING.readAll(java.sql.Connection connection, java.util.List<Address> members, java.lang.String clustername, Responses rsps)
protected void	JDBC_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	SWIFT_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	RACKSPACE_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	FILE_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	S3_PING.readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	S3_PING.readResponse(org.jgroups.protocols.S3_PING.GetResponse rsp, java.util.List<Address> mbrs, Responses responses)
protected boolean	RSVP.Entry.retainAll(java.util.Collection<Address> members)
abstract void	BasicTCP.retainAll(java.util.Collection<Address> members)
void	TCP_NIO.retainAll(java.util.Collection<Address> members) Deprecated.
void	TCP_NIO2.retainAll(java.util.Collection<Address> members)
void	TCP.retainAll(java.util.Collection<Address> members)
protected void	PEER_LOCK.PeerLock.retainAll(java.util.List<Address> members)
protected void	PING.sendDiscoveryRequest(java.lang.String cluster_name, java.util.List<Address> members_to_find)
protected void	TP.sendToMembers(java.util.Collection<Address> mbrs, byte[] buf, int offset, int length) Fetches the physical addrs for mbrs and sends the msg to each physical address.
protected void	RELAY.sendViewOnLocalCluster(java.util.List<Address> destinations, byte[] buffer)
protected void	RELAY.sendViewOnLocalCluster(RELAY.ViewData data, boolean use_seperate_thread, java.util.List<Address> new_mbrs)
protected void	RELAY.sendViewOnLocalCluster(View remote_view, View global_view, boolean use_seperate_thread, java.util.List<Address> new_mbrs)
protected void	Discovery.startCacheDissemination(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
protected void	Discovery.startCacheDissemination(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
protected void	Discovery.startCacheDissemination(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
protected void	FD_ALL.suspect(java.util.List<Address> suspects)
protected void	FD_ALL2.suspect(java.util.List<Address> suspects)
protected void	FD_HOST.suspect(java.util.List<Address> suspects)
protected void	FD_SOCK.suspect(java.util.Set<Address> suspects)

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

Constructor and Description
Entry(Address member) Unicast entry
Entry(Address suspect, long target_time)
FdHeader(byte type, Address mbr)
FdHeader(byte type, Address mbr, IpAddress sock_addr)
FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)
Flusher(Address new_coord)
Mapping(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name)
Owner(Address address, long requestId)
PingData(Address sender, boolean is_server)
PingData(Address sender, boolean is_server, java.lang.String logical_name, PhysicalAddress physical_addr)
PingData(Address sender, View view, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs) Deprecated. Use the constructor wityh a single PhysicalAddress instead
PingData(Address sender, View view, ViewId view_id, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs) Deprecated. Use the constructor with a single PhysicalAddress instead
ProtocolAdapter(AsciiString cluster_name, Address local_addr, short transport_id, Protocol up, Protocol down, java.lang.String pattern)

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

Constructor and Description
DiscoveryCacheDisseminationTask(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
DiscoveryCacheDisseminationTask(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
DiscoveryCacheDisseminationTask(java.util.List<Address> curr_mbrs, java.util.List<Address> left_mbrs, java.util.List<Address> new_mbrs)
Entry(java.util.Collection<Address> members) Multicast entry
FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)
FdHeader(byte type, java.util.Set<Address> mbrs)

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	STABLE.coordinator
protected Address[]	DeltaView.left_members Members which left the view corresponding to ref_view_id
protected Address	GMS.local_addr
protected Address	STABLE.local_addr
protected Address	StreamingStateTransfer.local_addr
protected Address	NAKACK2.local_addr
protected Address	STATE_TRANSFER.local_addr
protected Address	GMS.GmsHeader.mbr
protected Address[]	DeltaView.new_members Members which joined the view corresponding to ref_view_id
protected Address	StreamingStateTransfer.StateGetter.requester
protected Address	MergeData.sender
protected Address	StreamingStateTransfer.state_provider
protected Address	STATE.StateOutputStream.stateRequester

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

Modifier and Type	Field and Description
protected java.util.concurrent.ConcurrentMap<Address,java.util.Collection<Address>>	Merger.MergeTask.coords List of all subpartition coordinators and their members
protected java.util.concurrent.ConcurrentMap<Address,java.util.Collection<Address>>	Merger.MergeTask.coords List of all subpartition coordinators and their members
protected java.util.List<Address>	GMS.joining Members joined but for which no view has been received yet
protected java.util.List<Address>	GMS.leaving Members excluded from group, but for which no view has been received yet
protected java.util.List<Address>	StreamingStateTransfer.members
protected java.util.List<Address>	NAKACK2.members
protected java.util.List<Address>	STATE_TRANSFER.members
protected BoundedList<Address>	GMS.prev_members Keeps track of old members (up to num_prev_mbrs)
protected ProcessingQueue<Address>	StreamingStateTransfer.state_requesters List of members requesting state.
protected ProcessingQueue<Address>	STATE_TRANSFER.state_requesters List of members requesting state
protected SuppressLog<Address>	NAKACK.suppress_log_non_member Deprecated. Log to suppress identical warnings for messages from non-members
protected SuppressLog<Address>	NAKACK2.suppress_log_non_member Log to suppress identical warnings for messages from non-members
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table Map to store sent and received messages (keyed by sender)
protected java.util.Map<Address,java.lang.Long>	NAKACK2.xmit_task_map Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

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

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

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

Modifier and Type	Method and Description
protected java.util.List<Address>	GMS.computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Computes a merge membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes the regular membership
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.Map<Address,View> views) Needs to return a map of all subview coordinators and their views (as a collection of members).
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.Map<Address,View> views) Needs to return a map of all subview coordinators and their views (as a collection of members).
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Default implementation for a merge.
static java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(java.util.Collection<java.util.Collection<Address>> subviews) Old default implementation for a merge.
java.util.Iterator<Address>	DeltaView.iterator()
protected java.util.Collection<? extends Address>	GMS.readMembers(byte[] buffer, int offset, int length)
protected Tuple<java.util.Collection<? extends Address>,Digest>	FLUSH.readParticipantsAndDigest(byte[] buffer, int offset, int length)

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, java.util.Collection<? extends Address> mbrs)
protected void	StreamingStateTransfer.closeHoleFor(Address member)
protected void	STATE_TRANSFER.closeHoleFor(Address member)
protected Tuple<java.io.InputStream,java.lang.Object>	STATE_SOCK.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected Tuple<java.io.InputStream,java.lang.Object>	STATE.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr)
protected abstract Tuple<java.io.InputStream,java.lang.Object>	StreamingStateTransfer.createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr) Creates an InputStream to the state provider to read the state.
protected void	STATE.createStreamToRequester(Address requester)
protected void	StreamingStateTransfer.createStreamToRequester(Address requester) Creates an OutputStream to the state requester to write the state
static NakAckHeader2	NakAckHeader2.createXmitRequestHeader(Address orginal_sender)
static NakAckHeader	NakAckHeader.createXmitRequestHeader(long low, long high, Address orginal_sender)
protected void	NAKACK2.deliver(Message msg, Address sender, long seqno, java.lang.String error_msg)
protected boolean	ClientGmsImpl.firstOfAllClients(Address joiner, Responses rsps) Handles the case where no coord responses were received.
Digest	NAKACK.getDigest(Address mbr) Deprecated.
Digest	NAKACK2.getDigest(Address mbr)
protected static int	STABLE.getRank(Address member, View v)
protected void	STATE_TRANSFER.getStateFromApplication(Address requester, Digest digest)
protected void	StreamingStateTransfer.getStateFromApplication(Address requester, java.io.OutputStream out, boolean use_separate_thread)
NakReceiverWindow	NAKACK.getWindow(Address mbr) Deprecated. Please don't use this method; it is only provided for unit testing !
Table<Message>	NAKACK2.getWindow(Address sender) Returns the receive window for sender; only used for testing.
void	StreamingStateTransfer.handle(Address state_requester)
void	STATE_TRANSFER.handle(Address state_requester)
void	ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
void	Merger.handleDigestResponse(Address sender, Digest digest)
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
protected void	STATE.handleEOF(Address sender)
protected void	StreamingStateTransfer.handleEOF(Address sender)
protected void	NAKACK2.handleHighestSeqno(Address sender, long seqno) Compares the sender's highest seqno with my highest seqno: if the sender's is higher, ask sender for retransmission
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected void	NAKACK2.handleMessages(Address dest, Address sender, java.util.List<Tuple<java.lang.Long,Message>> msgs, boolean oob, AsciiString cluster_name)
protected void	STABLE.handleStabilityMessage(Digest stable_digest, Address sender, ViewId view_id)
protected void	STABLE.handleStableMessage(Digest d, Address sender, ViewId view_id) Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
protected void	STATE.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	StreamingStateTransfer.handleStateChunk(Address sender, byte[] buffer, int offset, int length)
protected void	STATE_SOCK.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateReq(Address requester)
protected void	STATE_TRANSFER.handleStateReq(Address requester)
protected void	StreamingStateTransfer.handleStateRsp(Address provider, StreamingStateTransfer.StateHeader hdr)
protected void	STATE_TRANSFER.handleStateRsp(Digest digest, Address sender, byte[] state) Set the digest and the send the state up to the application
protected void	STABLE.handleUpEvent(STABLE.StableHeader hdr, Address sender, Digest digest)
protected void	NAKACK2.handleXmitReq(Address xmit_requester, SeqnoList missing_msgs, Address original_sender) Retransmits messsages first_seqno to last_seqno from original_sender from xmit_table to xmit_requester, called when XMIT_REQ is received.
void	ClientGmsImpl.join(Address address, boolean useFlushIfPresent)
void	ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
void	CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.join(Address mbr, boolean useFlushIfPresent)
protected void	ClientGmsImpl.joinInternal(Address mbr, boolean joinWithStateTransfer, boolean useFlushIfPresent) Joins this process to a group.
void	ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
void	ClientGmsImpl.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
abstract void	GmsImpl.leave(Address mbr)
GMS.GmsHeader	GMS.GmsHeader.mbr(Address mbr)
protected void	StreamingStateTransfer.punchHoleFor(Address member)
protected void	STATE_TRANSFER.punchHoleFor(Address member)
protected void	NAKACK2.removeAndPassUp(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster_name) Efficient way of checking whether another thread is already processing messages from sender.
void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender) Deprecated. Implementation of Retransmitter.RetransmitCommand.
protected void	NAKACK2.retransmit(long first_seqno, long last_seqno, Address sender)
protected void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request) Deprecated.
protected void	NAKACK2.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
protected void	NAKACK2.retransmit(SeqnoList missing_msgs, Address sender, boolean multicast_xmit_request)
protected void	StreamingStateTransfer.sendEof(Address requester)
protected void	StreamingStateTransfer.sendException(Address requester, java.lang.Throwable exception)
protected void	STATE_TRANSFER.sendException(Address requester, java.lang.Throwable exception)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
protected void	Merger.sendMergeResponse(Address sender, View view, Digest digest, MergeId merge_id) Send back a response containing view and digest to sender
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg) Sends a message msg to the requester.
protected void	StreamingStateTransfer.setStateInApplication(java.io.InputStream in, java.lang.Object resource, Address provider)
void	ParticipantGmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
protected void	NAKACK2.unknownMember(Address sender, java.lang.Object message)
void	ParticipantGmsImpl.unsuspect(Address mbr) Removes previously suspected member from list of currently suspected members
void	GmsImpl.unsuspect(Address mbr)
protected void	STABLE.updateLocalDigest(Digest d, Address sender) Update my own digest from a digest received by somebody else.
protected boolean	GMS.wouldBeNewCoordinator(Address potential_new_coord) Checks whether the potential_new_coord would be the new coordinator (2nd in line)

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

Modifier and Type	Method and Description
protected void	Merger._handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected void	Merger.MergeTask._run(MergeId new_merge_id, java.util.Collection<Address> coordsCopy) Runs the merge protocol as a leader
protected void	NAKACK2.adjustReceivers(java.util.List<Address> members) Removes old members from xmit-table and adds new members to xmit-table (at seqnos hd=0, hr=0).
void	GMS.castViewChange(View new_view, Digest digest, java.util.Collection<Address> newMembers) Broadcasts the new view and digest as a VIEW message and waits for acks from existing members
protected java.util.List<Address>	GMS.computeNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Computes a merge membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes the regular membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes the regular membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes the regular membership
protected java.util.List<Address>	GMS.computeNewMembership(java.util.List<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes the regular membership
protected static java.util.Map<Address,java.util.Collection<Address>>	Merger.determineMergeCoords(java.util.Map<Address,View> views) Needs to return a map of all subview coordinators and their views (as a collection of members).
protected Address	Merger.determineMergeLeader(java.util.Map<Address,View> views) Returns the address of the merge leader
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(java.util.Map<Address,java.util.Collection<Address>> coords, MergeId new_merge_id, long timeout) Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
protected boolean	Merger.MergeTask.getMergeDataFromSubgroupCoordinators(java.util.Map<Address,java.util.Collection<Address>> coords, MergeId new_merge_id, long timeout) Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Takes the existing membership list and removes suspected and left members, then adds new members to the end of the list
java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Default implementation for a merge.
static java.util.List<Address>	GMS.DefaultMembershipPolicy.getNewMembershipOld(java.util.Collection<java.util.Collection<Address>> subviews) Old default implementation for a merge.
View	GMS.getNextView(java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspected_mbrs) Computes the next view.
View	GMS.getNextView(java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspected_mbrs) Computes the next view.
void	ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	GmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
protected static Buffer	GMS.marshal(java.util.Collection<? extends Address> mbrs)
protected static Buffer	FLUSH.marshal(java.util.Collection<? extends Address> participants, Digest digest)
void	ServerGmsImpl.merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	Merger.merge(java.util.Map<Address,View> views) Invoked upon receiving a MERGE event from the MERGE layer.
void	GmsImpl.merge(java.util.Map<Address,View> views)
protected void	Merger.MergeTask.removeRejectedMergeRequests(java.util.Collection<Address> coords) Removed rejected merge requests from merge_rsps and coords.
static void	Merger.sanitizeViews(java.util.Map<Address,View> map) Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061).
void	GMS.sendJoinResponses(JoinRsp jr, java.util.Collection<Address> newMembers)
protected void	Merger.sendMergeCancelledMessage(java.util.Collection<Address> coords, MergeId merge_id)
protected void	Merger.sendMergeView(java.util.Collection<Address> coords, MergeData combined_merge_data, MergeId merge_id) Sends the new view and digest to all subgroup coordinors in coords.
void	Merger.MergeTask.start(java.util.Map<Address,View> views)

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

Constructor and Description
DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)
DeltaView(ViewId view_id, ViewId ref_view_id, Address[] left_members, Address[] new_members)
GmsHeader(byte type, Address mbr)
GmsHeader(byte type, Address mbr, boolean useFlushIfPresent) Used for JOIN_REQ or LEAVE_REQ header
MergeData(Address sender, View view, Digest digest)
MergeData(Address sender, View view, Digest digest, boolean merge_rejected)
StateGetter(Address requester, java.io.OutputStream output)
StateOutputStream(Address stateRequester)

Uses of Address in org.jgroups.protocols.relay

Subinterfaces of Address in org.jgroups.protocols.relay

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

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

Modifier and Type	Class and Description
class	CanBeSiteMaster Deprecated. Use ExtendedUUID directly. This class will get dropped in 4.0.
class	CanBeSiteMasterTopology Deprecated. Use ExtendedUUID instead. This class will get dropped in 4.0.
class	SiteMaster Special address with the UUID part being 0: identifies the current (relay) coordinator of a given site.
class	SiteUUID Implementation of SiteAddress

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

Modifier and Type	Field and Description
protected Address	RELAY2.Relay2Header.final_dest
protected Address	RELAY2.local_addr
protected Address	RELAY2.Relay2Header.original_sender
protected Address	Route.site_master SiteUUID: address of the site master

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

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

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

Modifier and Type	Method and Description
Address	RELAY2.getLocalAddress()
protected Address	RELAY2.pickSiteMaster(Address sender) Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender) Needs to pick a member from a list of addresses of site masters
Address	Route.siteMaster()

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

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

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

Modifier and Type	Method and Description
int	SiteUUID.compareTo(Address other)
int	SiteMaster.compareTo(Address other)
protected boolean	Relayer.Bridge.contains(java.util.List<Route> routes, Address addr)
protected Message	Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected void	RELAY2.forwardTo(Address next_dest, SiteAddress final_dest, Address original_sender, Message msg, boolean forward_to_current_coord)
protected Route	Relayer.getRoute(java.lang.String site, Address sender)
Route	SiteMasterPicker.pickRoute(java.lang.String site, java.util.List<Route> routes, Address original_sender) Picks a route to a given remote site from a list of routes.
protected Address	RELAY2.pickSiteMaster(Address sender) Returns a site master from site_masters
Address	SiteMasterPicker.pickSiteMaster(java.util.List<Address> site_masters, Address original_sender) Needs to pick a member from a list of addresses of site masters
void	Route.send(Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.sendSiteUnreachableTo(Address dest, java.lang.String target_site) Sends a SITE-UNREACHABLE message to the sender of the message.
protected void	RELAY2.sendToBridges(Address sender, Message msg, java.lang.String... excluded_sites) Sends the message via all bridges excluding the excluded_sites bridges

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

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

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

Constructor and Description
Relay2Header(byte type, Address final_dest, Address original_sender)
Route(Address site_master, JChannel bridge, RELAY2 relay, Log log)

Uses of Address in org.jgroups.protocols.rules

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

Modifier and Type	Field and Description
protected Address	SUPERVISOR.local_addr

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

Modifier and Type	Method and Description
Address	SUPERVISOR.getLocalAddress()

Uses of Address in org.jgroups.protocols.tom

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

Modifier and Type	Method and Description
Address	MessageID.getAddress()

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

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

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

Modifier and Type	Method and Description
long	SenderManager.addPropose(MessageID messageID, Address from, long sequenceNumber) Add a propose from a member in destination set

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

Modifier and Type	Method and Description
void	SenderManager.addNewMessageToSend(MessageID messageID, java.util.Collection<Address> destinations, long initialSequenceNumber, boolean deliverToMyself) Add a new message sent
static ToaHeader	ToaHeader.newDataMessageHeader(MessageID messageID, java.util.Collection<Address> destinations)
void	DeliveryManagerImpl.removeLeavers(java.util.Collection<Address> leavers)
long	SenderManager.removeLeavers(MessageID messageID, java.util.Collection<Address> leavers)

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

Constructor and Description
MessageID(Address address, long id)

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	GossipRouter.Entry.client_addr
protected Address	RouterStubManager.local_addr
protected Address	Retransmitter.Task.msg_sender
protected Address	Retransmitter.sender Deprecated.
Address	StateTransferInfo.target

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

Modifier and Type	Field and Description
protected java.util.concurrent.ConcurrentMap<java.lang.String,java.util.concurrent.ConcurrentMap<Address,GossipRouter.Entry>>	GossipRouter.address_mappings

Methods in org.jgroups.stack that return Address

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

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

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

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

Modifier and Type	Method and Description
protected void	GossipRouter.addAddressMapping(Address sender, java.lang.String group, Address addr, PhysicalAddress phys_addr, java.lang.String logical_name)
int	IpAddress.compareTo(Address o) implements the java.lang.Comparable interface
void	RouterStub.connect(java.lang.String group, Address addr, java.lang.String logical_name, PhysicalAddress phys_addr) Registers mbr with the GossipRouter under the given group, with the given logical name and physical address.
void	RouterStub.disconnect(java.lang.String group, Address addr)
protected void	GossipRouter.handleRegister(Address sender, GossipData request)
void	NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
void	NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
void	GossipRouter.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, byte[] buf, int offset, int length)
void	RouterStub.receive(Address sender, java.nio.ByteBuffer buf)
protected void	GossipRouter.removeAddressMapping(java.lang.String group, Address addr)
protected void	GossipRouter.removeFromAddressMappings(Address client_addr)
void	Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender) Get the missing messages between sequence numbers first_seqno and last_seqno.
protected void	GossipRouter.route(java.lang.String group, Address dest, byte[] msg, int offset, int length)
protected void	GossipRouter.sendToMember(Address dest, byte[] buf, int offset, int len)
protected void	GossipRouter.sendToMember(Address dest, GossipData request)
void	RouterStub.sendToMember(java.lang.String group, Address dest, byte[] data, int offset, int length)
void	ProtocolStack.startStack(java.lang.String cluster, Address local_addr) Start all layers.

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

Modifier and Type	Method and Description
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes a new membership based on existing, joining, leaving and suspected members.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes a new membership based on existing, joining, leaving and suspected members.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes a new membership based on existing, joining, leaving and suspected members.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<Address> current_members, java.util.Collection<Address> joiners, java.util.Collection<Address> leavers, java.util.Collection<Address> suspects) Computes a new membership based on existing, joining, leaving and suspected members.
java.util.List<Address>	LargestWinningPolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Called when a merge happened.
java.util.List<Address>	MembershipChangePolicy.getNewMembership(java.util.Collection<java.util.Collection<Address>> subviews) Compute a new membership based on a number of subviews
protected void	GossipRouter.sendToAllMembersInGroup(java.util.Set<java.util.Map.Entry<Address,GossipRouter.Entry>> dests, byte[] buf, int offset, int len)
protected void	GossipRouter.sendToAllMembersInGroup(java.util.Set<java.util.Map.Entry<Address,GossipRouter.Entry>> dests, GossipData request)

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

Constructor and Description
DefaultRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Create a new Retransmitter associated with the given sender address
Entry(Address client_addr, PhysicalAddress phys_addr, java.lang.String logical_name)
GossipData(GossipType type, java.lang.String group, Address addr)
GossipData(GossipType type, java.lang.String group, Address addr, byte[] buffer)
GossipData(GossipType type, java.lang.String group, Address addr, byte[] buffer, int offset, int length)
GossipData(GossipType type, java.lang.String group, Address addr, java.util.List<PingData> ping_data)
GossipData(GossipType type, java.lang.String group, Address addr, java.util.List<PingData> ping_data, PhysicalAddress physical_addr)
GossipData(GossipType type, java.lang.String group, Address addr, java.lang.String logical_name, PhysicalAddress physical_addr)
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched) Deprecated. 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) Deprecated.
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) Deprecated.
RangeBasedRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Create a new Retransmitter associated with the given sender address
RangeTask(Seqno range, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Deprecated. Create a new Retransmitter associated with the given sender address
RouterStubManager(Protocol owner, java.lang.String cluster_name, Address local_addr, java.lang.String logical_name, PhysicalAddress phys_addr, long interval)
SeqnoTask(long seqno, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
StateTransferInfo(Address target)
StateTransferInfo(Address target, long timeout)
StateTransferInfo(Address target, long timeout, byte[] state)
Task(Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)

Uses of Address in org.jgroups.util

Classes in org.jgroups.util that implement Address

Modifier and Type	Class and Description
class	AdditionalDataUUID Deprecated. Use ExtendedUUID instead. Will get dropped in 4.0.
class	ExtendedUUID Subclass of UUID accommodating additional data such as a flag and a small hashmap.
class	PayloadUUID Deprecated. Use ExtendedUUID instead. Will get dropped in 4.0.
class	SingletonAddress Address with a cluster name.
class	TopologyUUID Deprecated. Use ExtendedUUID instead. This class will be dropped in 4.0.
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	MessageBatch.dest The destination address.
protected Address	ForwardQueue.local_addr
protected Address	Digest.Entry.member
protected Address[]	Digest.members
protected Address	ForwardQueue.Flusher.new_coord
protected Address	MessageBatch.sender The sender of the message batch
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,java.lang.String>	UUID.cache Keeps track of associations between logical addresses (UUIDs) and logical names
protected java.util.Map<Address,java.lang.Long>	CreditMap.credits
protected java.util.concurrent.ConcurrentMap<Address,BoundedHashMap<java.lang.Long,java.lang.Long>>	ForwardQueue.delivery_table
protected java.util.List<Address>	AckCollector.missing_acks List of members from whom we haven't received an ACK yet
protected static LazyRemovalCache.Printable<Address,LazyRemovalCache.Entry<java.lang.String>>	UUID.print_function
protected java.util.concurrent.ConcurrentMap<Address,RpcStats.Result>	RpcStats.stats
protected java.util.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(java.lang.String name)
static Address[]	Util.createRandomAddresses(int num) Returns an array of num random addresses, named A, B, C etc
static Address[]	Util.createRandomAddresses(int num, boolean use_numbers)
Address	MessageBatch.dest()
Address	OneTimeAddressGenerator.generateAddress()
Address	Owner.getAddress()
Address	SingletonAddress.getAddress()
static Address	UUID.getByName(java.lang.String logical_name)
static Address	Util.getCoordinator(View view)
Address	ForwardQueue.getLocalAddr()
Address	Digest.Entry.getMember()
Address[]	Digest.getMembersRaw() Don't use, this method is reserved for Bela ! :-)
Address[]	MutableDigest.getNonSetMembers() Returns an array of members whose seqno is not set.
Address	Rsp.getSender()
static Address	Util.readAddress(java.io.DataInput in)
static Address[]	Util.readAddresses(java.io.DataInput in)
Address	MessageBatch.sender()

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

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

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

Modifier and Type	Method and Description
void	AckCollector.ack(Address member)
static void	UUID.add(Address uuid, java.lang.String logical_name)
boolean	ResponseCollector.add(Address member, T data)
boolean	ResponseCollectorTask.add(Address member, T data)
void	RpcStats.add(RpcStats.Type type, Address dest, boolean sync, long time)
protected void	AckCollector.addAll(Address... members)
void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, T retval)
protected void	RpcStats.addToResults(Address dest, boolean sync, long time)
static void	Util.bufferToArray(Address sender, java.nio.ByteBuffer buf, Receiver target)
protected boolean	ForwardQueue.canDeliver(Address sender, long seqno) Checks if seqno has already been received from sender.
int	UUID.compareTo(Address other) Compares this UUID with the specified UUID.
int	SingletonAddress.compareTo(Address o)
boolean	Digest.contains(Address mbr)
boolean	Digest.containsAll(Address... members)
boolean	Responses.containsResponseFrom(Address mbr)
static MergeId	MergeId.create(Address addr)
protected void	CreditMap.decrementAndAdd(Address member, long new_credits) Decrements credits bytes from all elements and add new_credits to member (if non null).
MessageBatch	MessageBatch.dest(Address dest)
protected void	ForwardQueue.doFlush(Address new_target)
protected int	Digest.find(Address mbr)
PingData	Responses.findResponseFrom(Address mbr)
void	ForwardQueue.flush(Address new_target, java.util.List<Address> mbrs)
protected void	ForwardQueue.flushMessagesInForwardTable(Address target) Sends all messages currently in forward_table to the new target (changing the dest field).
java.lang.Long	CreditMap.get(Address member)
static java.lang.String	UUID.get(Address logical_addr)
long[]	Digest.get(Address member) Returns the highest delivered and received seqnos associated with a member.
static int	Util.getRank(java.util.Collection<Address> members, Address addr)
static int	Util.getRank(View view, Address addr) Returns the rank of a member in a given view
static boolean	Util.isCoordinator(View view, Address local_addr)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
MutableDigest	MutableDigest.merge(Address member, long highest_delivered_seqno, long highest_received_seqno) Similar to set(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno)
Rsp<T>	RspList.put(Address key, Rsp<T> value)
java.lang.Long	CreditMap.putIfAbsent(Address key)
java.lang.Long	CreditMap.remove(Address key)
void	ResponseCollector.remove(Address member)
static void	UUID.remove(Address addr)
void	CreditMap.replenish(Address sender, long new_credits)
void	ResponseCollector.reset(Address... members)
static boolean	Util.sameHost(Address one, Address two) Checks whether 2 Addresses are on the same host
MessageBatch	MessageBatch.sender(Address sender)
MutableDigest	MutableDigest.set(Address member, long highest_delivered_seqno, long highest_received_seqno)
void	ForwardQueue.setLocalAddr(Address local_addr)
static int	Util.size(Address addr)
static long	Util.size(Address[] addrs)
protected void	ForwardQueue.startFlusher(Address new_coord)
void	ResponseCollector.suspect(Address member)
void	AckCollector.suspect(Address member)
java.lang.String	Digest.toString(Address[] order, boolean print_highest_received)
static void	Util.writeAddress(Address addr, java.io.DataOutput out)
static void	Util.writeAddresses(Address[] addrs, java.io.DataOutput out)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> msgs, java.io.DataOutput dos, boolean multicast, short transport_id) Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, java.io.DataOutput dos, boolean multicast)

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

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

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

Constructor and Description
AckCollector(Address... members)
Digest(Address[] members) Only used internally, don't use !
Digest(Address[] members, long[] seqnos)
Digest(Address sender, long highest_delivered, long highest_received)
Entry(Address member, long highest_delivered, long highest_received)
Flusher(Address new_coord)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs, Filter<Message> filter)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, MessageBatch.Mode mode, int capacity)
MutableDigest(Address[] members)
Owner(Address address, long thread_id)
ResponseCollector(Address... members)
ResponseCollectorTask(Address... members)
Rsp(Address sender)
Rsp(Address sender, T retval)
Rsp(Address sender, java.lang.Throwable t)
SingletonAddress(byte[] cluster_name, Address addr)

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

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