Uses of Interface
org.jgroups.Address

Packages that use Address

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

Uses of Address in org.jgroups

Fields in org.jgroups declared as Address

Modifier and Type	Field	Description
protected Address	Message.dest_addr
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

Modifier and Type	Field	Description
protected java.util.Vector<Address>	View.members	A list containing all the members of the view This list is always ordered, with the coordinator being the first member.

Methods in org.jgroups that return Address

Modifier and Type	Method	Description
Address	Membership.elementAt(int index)	Returns the component at the specified index
Address	ViewId.getCoordAddress()	returns the address of the member that issued this view
Address	View.getCreator()	returns the creator of this view if this view was created with the empty constructur, null will be returned
Address	Message.getDest()
abstract Address	Channel.getLocalAddress()	Returns the channel's own address.
Address	JChannel.getLocalAddress()	returns the local address of the channel returns null if the channel is closed
Address	Message.getSrc()

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

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

Methods in org.jgroups with parameters of type Address

Modifier and Type	Method	Description
void	Membership.add(Address new_member)	Adds a new member to this membership.
void	ChannelListener.channelReconnected(Address addr)
void	ChannelListenerAdapter.channelReconnected(Address addr)
abstract void	Channel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)	Connects the channel to a group and fetches the state
void	JChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)	Connects this channel to a group and gets a state from a specified state provider.
boolean	Membership.contains(Address member)	Returns true if the provided member belongs to this membership
boolean	View.containsMember(Address mbr)	returns true, if this view contains a certain member
abstract boolean	Channel.getState(Address target, long timeout)	Retrieve the state of the group.
abstract boolean	Channel.getState(Address target, java.lang.String state_id, long timeout)	Fetches a partial state identified by state_id.
boolean	JChannel.getState(Address target, long timeout)	Retrieves a full state from the target member.
boolean	JChannel.getState(Address target, java.lang.String state_id, long timeout)	Retrieves a substate (or partial state) indicated by state_id from the target member.
boolean	JChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)	Retrieves a substate (or partial state) indicated by state_id from the target member.
protected boolean	JChannel.getState(Address target, java.lang.String state_id, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)	Retrieves a substate (or partial state) indicated by state_id from the target member.
protected void	Channel.notifyChannelReconnected(Address addr)
void	Membership.remove(Address old_member)	removes an member from the membership.
abstract void	Channel.send(Address dst, Address src, java.io.Serializable obj)	Helper method.
void	JChannel.send(Address dst, Address src, java.io.Serializable obj)	creates a new message with the destination address, and the source address and the object as the message value
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	ExtendedReceiverAdapter.suspect(Address suspected_mbr)
void	MembershipListener.suspect(Address suspected_mbr)	Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReceiverAdapter.suspect(Address suspected_mbr)

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

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

Constructors in org.jgroups with parameters of type Address

Constructor	Description
MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)	Creates a new view
Message(Address dest)	Public constructor
Message(Address dest, Address src, byte[] buf)	Public constructor
Message(Address dest, Address src, byte[] buf, int offset, int length)	Constructs a message.
Message(Address dest, Address src, java.io.Serializable obj)	Public constructor
View(Address creator, long id, java.util.Vector<Address> members)	Creates a new view
ViewId(Address coord_addr)	Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
ViewId(Address coord_addr, long id)	Creates a ViewID with the coordinator address and the given Lamport timestamp.

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

Constructor	Description
Membership(java.util.Collection<Address> initial_members)	Creates a member ship object with the initial members.
MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)	Creates a new view
MergeView(ViewId vid, java.util.Vector<Address> members, java.util.Vector<View> subgroups)	Creates a new view
View(Address creator, long id, java.util.Vector<Address> members)	Creates a new view
View(ViewId vid, java.util.Vector<Address> members)	Creates a new view

Uses of Address in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Address

Modifier and Type	Field	Description
protected Address	MessageDispatcher.local_addr
protected Address	RequestCorrelator.local_addr	The address of this group member

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

Modifier and Type	Field	Description
protected java.util.Stack<Address>	RequestCorrelator.call_stack	This field is used only if deadlock detection is enabled.
java.util.Stack<Address>	RequestCorrelator.Header.callStack	Stack<Address>.
java.util.List<Address>	RequestCorrelator.Header.dest_mbrs	Contains a list of members who should receive the request (others will drop).

Methods in org.jgroups.blocks that return Address

Modifier and Type	Method	Description
Address	GroupRequest.getCaller()
Address	BasicConnectionTable.getLocalAddress()
Address	DistributedHashtable.getLocalAddress()	Deprecated.
Address	DistributedQueue.getLocalAddress()
Address	NotificationBus.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedHashtable.getLocalAddress()	Deprecated.
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()

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

Modifier and Type	Method	Description
java.util.Vector<Address>	GroupRequest.getSuspects()	Returns the list of suspected members.

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

Modifier and Type	Method	Description
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)
void	PullPushAdapter.channelReconnected(Address addr)	Deprecated.
void	RpcDispatcher.channelReconnected(Address new_addr)
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
java.io.Serializable	NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)	Determines the coordinator and asks it for its cache.
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	NotificationBus.Consumer.memberJoined(Address mbr)
void	NotificationBus.Consumer.memberLeft(Address mbr)
protected void	PullPushAdapter.notifySuspect(Address suspected_mbr)	Deprecated.
void	BasicConnectionTable.receive(Address sender, byte[] data, int offset, int length)	Calls the receiver callback.
void	BasicConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
void	GroupRequest.receiveResponse(java.lang.Object response_value, Address sender)	Callback (called by RequestCorrelator or Transport).
void	RspCollector.receiveResponse(java.lang.Object response_value, Address sender)
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	NotificationBus.sendNotification(Address dest, java.io.Serializable n)	Pack the argument in a Info, serialize that one into the message buffer and send the message
void	GroupRequest.setCaller(Address caller)
void	RequestCorrelator.setLocalAddress(Address local_addr)
void	DistributedHashtable.suspect(Address suspected_mbr)	Deprecated. Called when a member is suspected
void	DistributedLockManager.suspect(Address suspected_mbr)
void	DistributedQueue.suspect(Address suspected_mbr)	Called when a member is suspected
void	DistributedTree.suspect(Address suspected_mbr)	Called when a member is suspected
void	GroupRequest.suspect(Address suspected_member)	Callback (called by RequestCorrelator or Transport).
void	MembershipListenerAdapter.suspect(Address suspected_mbr)	Notify membership listener that some node was suspected.
void	NotificationBus.suspect(Address suspected_mbr)
void	ReplicatedHashMap.suspect(Address suspected_mbr)	Called when a member is suspected
void	ReplicatedHashtable.suspect(Address suspected_mbr)	Deprecated. Called when a member is suspected
void	ReplicatedTree.suspect(Address suspected_mbr)	Called when a member is suspected
void	RspCollector.suspect(Address mbr)
void	VotingAdapter.suspect(Address suspected)	Callback for notification that one node is suspected

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

Modifier and Type	Method	Description
void	GroupRequest.reset(java.util.Vector<Address> mbrs)	This method sets the membership variable to the value of members.
void	BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs)	Removes all connections from ConnectionTable which are not in current_mbrs
void	RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)
void	RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll, boolean use_anycasting)	Send a request to a group.
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.Vector<Address> new_mbrs, java.util.Vector<Address> old_mbrs)

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

Constructor	Description
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr)

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

Constructor	Description
GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode)
GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)
GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode)
GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)

Uses of Address in org.jgroups.debug

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

Modifier and Type	Method	Description
void	Simulator.addMember(Address addr)
void	Simulator.addMember(Address addr, Simulator s)
void	Simulator.setLocalAddress(Address addr)

Uses of Address in org.jgroups.demos

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

Modifier and Type	Method	Description
void	Draw.channelReconnected(Address addr)
void	Gossip.channelReconnected(Address new_addr)
void	NotificationBusDemo.memberJoined(Address mbr)
void	NotificationBusDemo.memberLeft(Address mbr)
void	ChatCore.suspect(Address suspected_mbr)
void	QuoteClient.suspect(Address suspected_mbr)
void	QuoteServer.suspect(Address suspected_mbr)
void	Topology.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr)	Called when a member is suspected

Uses of Address in org.jgroups.demos.wb

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

Modifier and Type	Field	Description
Address	Node.addr

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

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

Uses of Address in org.jgroups.jmx

Methods in org.jgroups.jmx that return Address

Modifier and Type	Method	Description
Address	JChannel.getLocalAddress()
Address	JChannelMBean.getLocalAddress()

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

Modifier and Type	Method	Description
boolean	JChannel.getState(Address target, long timeout)
boolean	JChannelMBean.getState(Address target, long timeout)
void	JChannel.send(Address dst, Address src, java.io.Serializable obj)
void	JChannelMBean.send(Address dst, Address src, java.io.Serializable obj)

Uses of Address in org.jgroups.jmx.protocols

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

Modifier and Type	Method	Description
Address	TP.getLocalAddress()
Address	TPMBean.getLocalAddress()

Uses of Address in org.jgroups.mux

Methods in org.jgroups.mux that return Address

Modifier and Type	Method	Description
Address	MuxChannel.getLocalAddress()

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

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

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

Constructor	Description
ServiceInfo(byte type, java.lang.String service, Address host, byte[] state)

Uses of Address in org.jgroups.protocols

Classes in org.jgroups.protocols that implement Address

Modifier and Type	Class	Description
static class	JMS.JMSAddress	Simple Address representing the JMS node ID or JMS topic group.

Fields in org.jgroups.protocols declared as Address

Modifier and Type	Field	Description
Address	PingRsp.coord_addr
protected Address	TP.local_addr	The address (host and port) of this member
protected Address	PARTITION.local_address
Address	PingRsp.own_addr

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

Modifier and Type	Field	Description
protected java.util.HashSet<Address>	TP.members	The members of this group (updated when a member joins or leaves)

Methods in org.jgroups.protocols that return Address

Modifier and Type	Method	Description
protected Address	UDP.createLocalAddress()
Address	PingRsp.getAddress()
Address	PingRsp.getCoordAddress()
Address	SEQUENCER.getCoordinator()
protected Address	ENCRYPT.getKeyServerAddr()
protected Address	ENCRYPT.getLocal_addr()
Address	SEQUENCER.getLocalAddress()
Address	TP.getLocalAddress()
Address	SEQUENCER.SequencerHeader.getOriginalSender()

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

Modifier and Type	Method	Description
java.util.List<Address>	TCPPING.getInitialHosts()	Returns the list of initial hosts as configured by the user via XML.
java.util.List<Address>	TP.ProtocolAdapter.getMembers()

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

Modifier and Type	Method	Description
void	DISCARD.addIgnoreMember(Address sender)	Messages from this sender will get dropped
protected void	FD.Broadcaster.addSuspectedMember(Address mbr)	Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
void	UNICAST.expired(Address key)	Called by AgeOutCache, to removed expired connections
void	Discovery.localAddressSet(Address addr)	Called after local_addr was set
void	PING.localAddressSet(Address addr)
void	TCPPING.localAddressSet(Address addr)
void	BasicTCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	LOOPBACK.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	SHARED_LOOPBACK.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
abstract void	TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	TUNNEL.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	BasicTCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	LOOPBACK.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	SHARED_LOOPBACK.postUnmarshallingList(Message msg, Address dest, boolean multicast)
abstract void	TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	TUNNEL.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	BasicTCP.receive(Address sender, byte[] data, int offset, int length)	ConnectionTable.Receiver interface
protected void	TP.receive(Address dest, Address sender, byte[] data, int offset, int length)	Subclasses must call this method when a unicast or multicast message has been received.
boolean	UNICAST.removeConnection(Address mbr)	Removes and resets from connection table (which is already locked).
void	DISCARD.removeIgnoredMember(Address member)
void	SMACK.retransmit(long seqno, Message msg, Address dest)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length)
void	TCP.send(Address dest, byte[] data, int offset, int length)
void	BasicTCP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	LOOPBACK.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] data, int offset, int length)
abstract void	TP.sendToSingleMember(Address dest, byte[] data, int offset, int length)	Send to all members in the group.
void	TUNNEL.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	UDP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
protected void	ENCRYPT.setKeyServerAddr(Address keyServerAddr)
protected void	ENCRYPT.setLocal_addr(Address local_addr)
void	DISCARD.setLocalAddress(Address localAddress)

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

Modifier and Type	Method	Description
abstract void	BasicTCP.retainAll(java.util.Collection<Address> members)
void	TCP_NIO.retainAll(java.util.Collection<Address> members)
void	TCP.retainAll(java.util.Collection<Address> members)

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

Constructor	Description
CoordAnnouncement(Address coord)
FdHeader(byte type, Address mbr)
FdHeader(byte type, Address mbr, IpAddress sock_addr)
FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)
Header(byte type, Address suspect)
HTotalHeader(Address dest, Address src)
MergefastHeader(Address coord)
PingRsp(Address own_addr, Address coord_addr, boolean is_server)
ProtocolAdapter(java.lang.String cluster_name, java.lang.String transport_name, Protocol up, Protocol down, java.lang.String pattern, Address addr)
SequencerHeader(byte type, Address original_sender, long seqno)

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

Constructor	Description
DiscardHeader(java.util.Set<Address> ignoredAddresses)
FdHeader(byte type, java.util.Map<Address,IpAddress> cachedAddrs)
FdHeader(byte type, java.util.Set<Address> mbrs)
FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)

Uses of Address in org.jgroups.protocols.pbcast

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

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

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

Modifier and Type	Method	Description
void	Gossip.addToSeenList(Address mbr)
double	NAKACK.getSmoothedAverageRetransmissionTime(Address sender)	Returns the smoothed average retransmission time for a given sender
void	CoordGmsImpl.handleDigestResponse(Address sender, Digest digest)
void	GmsImpl.handleDigestResponse(Address sender, Digest digest)
void	CoordGmsImpl.handleMergeRequest(Address sender, ViewId merge_id)	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, ViewId merge_id)
void	ParticipantGmsImpl.handleMergeRequest(Address sender, ViewId merge_id)
void	ClientGmsImpl.join(Address address)
void	CoordGmsImpl.join(Address mbr)
abstract void	GmsImpl.join(Address mbr)
void	ParticipantGmsImpl.join(Address mbr)
void	ClientGmsImpl.joinWithStateTransfer(Address address)
void	CoordGmsImpl.joinWithStateTransfer(Address mbr)
abstract void	GmsImpl.joinWithStateTransfer(Address local_addr)
void	ParticipantGmsImpl.joinWithStateTransfer(Address mbr)
void	ClientGmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr)	The coordinator itself wants to leave the group
abstract void	GmsImpl.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr)	Loop: determine coord.
void	NAKACK.messageGapDetected(long from, long to, Address src)	Called when a message gap is detected
void	NAKACK.missingMessageReceived(long seqno, Address original_sender)
void	Gossip.removeFromNotSeenList(Address mbr)	Removes obj from not_seen list
void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender)	Implementation of Retransmitter.RetransmitCommand.
protected void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender, boolean multicast_xmit_request)
void	GMS.sendJoinResponse(JoinRsp rsp, Address dest)
protected void	GmsImpl.sendMergeRejectedResponse(Address sender, ViewId merge_id)
void	ClientGmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
abstract void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
void	ClientGmsImpl.unsuspect(Address mbr)
void	CoordGmsImpl.unsuspect(Address mbr)
abstract void	GmsImpl.unsuspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr)	Removes previously suspected member from list of currently suspected members
protected boolean	GMS.wouldBeNewCoordinator(Address potential_new_coord)	Checks whether the potential_new_coord would be the new coordinator (2nd in line)

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

Modifier and Type	Method	Description
void	GMS.castViewChangeWithDest(View new_view, Digest digest, JoinRsp jr, java.util.Collection<Address> newMembers)	Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
protected boolean	GMS.checkSelfInclusion(java.util.Vector<Address> mbrs)	Returns true if local_addr is member of mbrs, else false
View	GMS.getNextView(java.util.Collection<Address> new_mbrs, java.util.Collection<Address> old_mbrs, java.util.Collection<Address> suspected_mbrs)	Computes the next view.
View	GMS.makeView(java.util.Vector<Address> mbrs)
static View	GMS.makeView(java.util.Vector<Address> mbrs, ViewId vid)
void	CoordGmsImpl.merge(java.util.Vector<Address> other_coords)	Invoked upon receiving a MERGE event from the MERGE layer.
void	GmsImpl.merge(java.util.Vector<Address> other_coords)

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

Constructor	Description
GmsHeader(byte type, Address mbr)	Used for JOIN_REQ or LEAVE_REQ header
Gossip(Address obj, long id)
Gossip(Address obj, long id, Digest d, java.util.Vector not_seen)
MergeData(Address sender, View view, Digest digest)
NakAckHeader(byte type, long low, long high, Address sender)
StateHeader(byte type, Address sender, long id, Digest digest)
StateHeader(byte type, Address sender, long id, Digest digest, java.lang.String state_id)
StateHeader(byte type, Address sender, long id, Digest digest)
StateHeader(byte type, Address sender, java.lang.String state_id)
StateHeader(byte type, Address sender, IpAddress bind_addr, Digest digest, java.lang.String state_id)

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

Constructor	Description
FlushHeader(byte type, long viewID, java.util.Collection<Address> flushView)

Uses of Address in org.jgroups.stack

Classes in org.jgroups.stack that implement Address

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

Fields in org.jgroups.stack declared as Address

Modifier and Type	Field	Description
Address	StateTransferInfo.target

Methods in org.jgroups.stack that return Address

Modifier and Type	Method	Description
Address	GossipData.getAddress()
Address	RouterStub.getLocalAddress()

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

Modifier and Type	Method	Description
java.util.List<Address>	GossipClient.getMembers(java.lang.String group)	Returns all members of a given group

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

Modifier and Type	Method	Description
void	AckMcastSenderWindow.ack(long seqno, Address sender)	An ACK has been received from sender.
void	NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
void	NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
void	GossipClient.register(java.lang.String group, Address mbr)	Adds the member to the given group.
void	AckMcastSenderWindow.remove(Address obj)	Remove obj from all receiver sets and wake up retransmission thread.
void	AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)	Retranmit the given msg
void	AckSenderWindow.retransmit(long first_seqno, long last_seqno, Address sender)
void	Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender)	Get the missing messages between sequence numbers first_seqno and last_seqno.
void	RouterStub.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	AckMcastSenderWindow.suspect(Address suspected)	Process with address suspected is suspected: remove it from all receiver sets.
void	GossipClient.unregister(java.lang.String group, Address mbr)

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

Constructor	Description
AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
GossipData(byte type, java.lang.String group, Address addr, java.util.List mbrs)
NakReceiverWindow(Address local_addr, Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched)
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno)	Creates a new instance with the given retransmit command
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched)	Creates a new instance with the given retransmit command
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched)	Creates a new instance with the given retransmit command
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd)	Create a new Retransmitter associated with the given sender address
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)	Create a new Retransmitter associated with the given sender address
StateTransferInfo(Address target)
StateTransferInfo(Address target, long timeout)
StateTransferInfo(Address target, java.io.InputStream is, java.lang.String state_id)
StateTransferInfo(Address target, java.io.OutputStream os, java.lang.String state_id)
StateTransferInfo(Address target, java.lang.String state_id, long timeout)
StateTransferInfo(Address target, java.lang.String state_id, long timeout, byte[] state)

Uses of Address in org.jgroups.util

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

Modifier and Type	Field	Description
protected java.util.Map<Address,Digest.Entry>	Digest.senders	Map<Address, Entry>

Methods in org.jgroups.util that return Address

Modifier and Type	Method	Description
Address	Rsp.getSender()
static Address	Util.readAddress(java.io.DataInputStream in)

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

Modifier and Type	Method	Description
static java.util.Vector<Address>	Util.determineLeftMembers(java.util.Vector<Address> old_mbrs, java.util.Vector<Address> new_mbrs)	Returns all members that left between 2 views.
java.util.Set<java.util.Map.Entry<Address,Rsp>>	RspList.entrySet()
java.util.Map<Address,T>	ResponseCollector.getResults()
java.util.Map<Address,Digest.Entry>	Digest.getSenders()	Returns an unmodifiable map, so modifications will result in exceptions
java.util.Map<Address,Digest.Entry>	MutableDigest.getSenders()
java.util.Vector<Address>	RspList.getSuspectedMembers()
java.util.Set<Address>	RspList.keySet()
static java.util.Collection<Address>	Util.readAddresses(java.io.DataInputStream in, java.lang.Class cl)

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

Modifier and Type	Method	Description
void	MutableDigest.add(Address sender, long low_seqno, long highest_delivered_seqno)
void	MutableDigest.add(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
void	ResponseCollector.add(Address member, T data)
boolean	SeqnoTable.add(Address member, long seqno)
void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, java.lang.Object retval)
void	RspList.addSuspect(Address sender)
boolean	Digest.contains(Address sender)
static View	Util.createView(Address coord, long id, Address... members)
void	FIFOMessageQueue.done(Address sender, K dest)
Digest.Entry	Digest.get(Address sender)	Returns the Entry for the given sender.
long	SeqnoTable.getHighestReceived(Address member)
long	SeqnoTable.getNextToReceive(Address member)
long	Digest.highestDeliveredSeqnoAt(Address sender)
long	Digest.highestReceivedSeqnoAt(Address sender)
void	MutableDigest.incrementHighestDeliveredSeqno(Address sender)	Increments the sender's high_seqno by 1.
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
long	Digest.lowSeqnoAt(Address sender)
void	MutableDigest.merge(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)	Similar to add(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.low_seqno=min(this.low_seqno, low_seqno) this.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno) this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno) If the sender doesn not exist, a new entry will be added (provided there is enough space)
void	FIFOMessageQueue.put(Address sender, K dest, V el)
Rsp	RspList.put(Address key, Rsp value)
void	ResponseCollector.remove(Address member)
void	SeqnoTable.remove(Address member)
void	MutableDigest.resetAt(Address sender)	Resets the seqnos for the sender at 'index' to 0.
static boolean	Util.sameHost(Address one, Address two)	Checks whether 2 Addresses are on the same host
boolean	MutableDigest.set(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
void	MutableDigest.setHighestDeliveredAndSeenSeqnos(Address sender, long low_seqno, long highest_delivered_seqno, long highest_received_seqno)
static int	Util.size(Address addr)
void	AckCollector.suspect(Address member)
void	ResponseCollector.suspect(Address member)
void	AckCollector.unsuspect(Address member)
static void	Util.writeAddress(Address addr, java.io.DataOutputStream out)

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

Modifier and Type	Method	Description
static java.util.Vector<Address>	Util.determineLeftMembers(java.util.Vector<Address> old_mbrs, java.util.Vector<Address> new_mbrs)	Returns all members that left between 2 views.
void	RspList.putAll(java.util.Map<? extends Address,? extends Rsp> m)
void	AckCollector.reset(ViewId v, java.util.List<Address> members)
void	ResponseCollector.reset(java.util.Collection<Address> members)
boolean	SeqnoTable.retainAll(java.util.Collection<Address> members)
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants)
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)

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

Constructor	Description
Digest(Address sender, long low, long highest_delivered)
Digest(Address sender, long low, long highest_delivered, long highest_received)
Rsp(Address sender)
Rsp(Address sender, boolean suspected)
Rsp(Address sender, java.lang.Object retval)

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

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