Uses of Interface org.jgroups.Address

Uses in package org.jgroups.blocks

Constructors with parameter type org.jgroups.Address
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, Address local_addr)

Fields of type org.jgroups.Address
Address	Xid.creator
Address	MessageDispatcher.local_addr
Address	RequestCorrelator.local_addr The address of this group member

Methods with parameter type org.jgroups.Address
Object	RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)
Object	RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)
Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
void	PullPushAdapter.channelReconnected(Address addr)
void	RpcDispatcher.channelReconnected(Address new_addr)
void	ConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	ConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
Xid	Xid.create(Address creator)
Xid	Xid.create(Address creator, int mode)
Serializable	NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries) Determines the coordinator and asks it for its cache.
void	NotificationBus.Consumer.memberJoined(Address mbr)
void	NotificationBus.Consumer.memberLeft(Address mbr)
void	PullPushAdapter.notifySuspect(Address suspected_mbr)
void	ConnectionTable.receive(Address sender, byte[] data, int offset, int length) Calls the receiver callback.
void	ConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
void	RequestCorrelator.receiveSuspect(Address mbr) `Event.SUSPECT` event received from a layer below.
void	ConnectionTable.remove(Address addr) Remove `addr`from connection table.
RspList	ReplicationManager.send(Address dest, byte[] data, boolean synchronous, long synchronous_timeout, Xid transaction, byte[] lock_info, long lock_acquisition_timeout, long lock_lease_timeout, boolean use_locks) Sends a request to all members of the group.
void	ConnectionTable.send(Address dest, byte[] data, int offset, int length)
void	GroupRequest.setCaller(Address caller)
void	RequestCorrelator.setLocalAddress(Address local_addr)
void	DistributedHashtable.suspect(Address suspected_mbr) Called when a member is suspected
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) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReplicatedHashtable.suspect(Address suspected_mbr) 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

Methods with return type org.jgroups.Address
Address	GroupRequest.getCaller()
Address	Xid.getCreator()
Address	ConnectionTable.getLocalAddress()
Address	DistributedHashtable.getLocalAddress()
Address	DistributedQueue.getLocalAddress()
Address	NotificationBus.getLocalAddress()
Address	ReplicatedHashtable.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	RequestCorrelator.getLocalAddress()

Uses in package org.jgroups.util

Constructors with parameter type org.jgroups.Address
Rsp.Rsp(Address sender)
Rsp.Rsp(Address sender, Object retval)
Rsp.Rsp(Address sender, boolean suspected)

Methods with parameter type org.jgroups.Address
void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, Object retval)
void	RspList.addSuspect(Address sender)
Object	RspList.get(Address sender)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
boolean	Util.sameHost(Address one, Address two) Checks whether 2 Addresses are on the same host
int	Util.size(Address addr)
void	Util.writeAddress(Address addr, DataOutputStream out)

Methods with return type org.jgroups.Address
Address	Rsp.getSender()
Address	Util.readAddress(DataInputStream in)

Uses in package org.jgroups.protocols.pbcast

Constructors with parameter type org.jgroups.Address
GMS.GmsHeader.GmsHeader(byte type, Address mbr) Used for JOIN_REQ or LEAVE_REQ header
Gossip.Gossip(Address obj, long id)
Gossip.Gossip(Address obj, long id, Digest d, Vector not_seen)
MergeData.MergeData(Address sender, View view, Digest digest)
NakAckHeader.NakAckHeader(byte type, long low, long high, Address sender)
STATE_TRANSFER.StateHeader.StateHeader(byte type, Address sender, long id, Digest digest)

Methods with parameter type org.jgroups.Address
void	Digest.add(Address sender, long low_seqno, long high_seqno)
void	Digest.add(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
void	Gossip.addToSeenList(Address mbr)
boolean	Digest.contains(Address sender)
Digest.Entry	Digest.get(Address sender)
void	ClientGmsImpl.handleJoin(Address mbr)
void	CoordGmsImpl.handleJoin(Address mbr) Computes the new view (including the newly joined member) and get the digest from PBCAST.
void	GmsImpl.handleJoin(Address mbr)
void	ParticipantGmsImpl.handleJoin(Address mbr)
void	ClientGmsImpl.handleLeave(Address mbr, boolean suspected) Returns false.
void	CoordGmsImpl.handleLeave(Address mbr, boolean suspected) Exclude `mbr` from the membership.
void	GmsImpl.handleLeave(Address mbr, boolean suspected)
void	ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
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.handleSuspect(Address mbr) Returns immediately.
void	CoordGmsImpl.handleSuspect(Address mbr)
void	GmsImpl.handleSuspect(Address mbr)
void	ParticipantGmsImpl.handleSuspect(Address mbr)
long	Digest.highSeqnoAt(Address sender)
long	Digest.highSeqnoSeenAt(Address sender)
void	Digest.incrementHighSeqno(Address sender) Increments the sender's high_seqno by 1.
void	ClientGmsImpl.join(Address mbr) Joins this process to a group.
void	CoordGmsImpl.join(Address mbr)
void	GmsImpl.join(Address mbr)
void	ParticipantGmsImpl.join(Address mbr)
void	ClientGmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	GmsImpl.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
long	Digest.lowSeqnoAt(Address sender)
void	Digest.merge(Address sender, long low_seqno, long high_seqno, long high_seqno_seen) 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.high_seqno=max(this.high_seqno, high_seqno) this.high_seqno_seen=max(this.high_seqno_seen, high_seqno_seen) If the sender doesn not exist, a new entry will be added (provided there is enough space)
void	Gossip.removeFromNotSeenList(Address mbr) Removes obj from not_seen list
void	Digest.resetAt(Address sender) Resets the seqnos for the sender at 'index' to 0.
void	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender) Implementation of Retransmitter.RetransmitCommand.
void	GmsImpl.sendMergeRejectedResponse(Address sender, ViewId merge_id)
boolean	Digest.set(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
void	Digest.setHighSeqnoAt(Address sender, long high_seqno)
void	Digest.setHighSeqnoSeenAt(Address sender, long high_seqno_seen)
void	Digest.setHighestDeliveredAndSeenSeqnos(Address sender, long high_seqno, long high_seqno_seen)
void	ClientGmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
void	ClientGmsImpl.unsuspect(Address mbr)
void	CoordGmsImpl.unsuspect(Address mbr)
void	GmsImpl.unsuspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr) Removes previously suspected member from list of currently suspected members
boolean	GMS.wouldBeNewCoordinator(Address potential_new_coord) Checks whether the potential_new_coord would be the new coordinator (2nd in line)

Methods with return type org.jgroups.Address
Address	GMS.determineCoordinator()
Address	GMS.GmsHeader.getMemeber()
Address	MergeData.getSender()

Uses in package org.jgroups.stack

Classes implementing org.jgroups.Address
class	IpAddress Network-dependent address (Internet).
class	LogicalAddress Logical address that spans the lifetime of a member.

Constructors with parameter type org.jgroups.Address
GossipData.GossipData(int type, String group, Address mbr, Vector mbrs)
NakReceiverWindow.NakReceiverWindow(Address sender, long start_seqno) Creates a new instance without a retransmission thread
NakReceiverWindow.NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno) Creates a new instance with the given retransmit command
NakReceiverWindow.NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno, TimeScheduler sched) Creates a new instance with the given retransmit command
Retransmitter.Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd) Create a new Retransmitter associated with the given sender address
Retransmitter.Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Create a new Retransmitter associated with the given sender address
StateTransferInfo.StateTransferInfo(int type, Address target)
StateTransferInfo.StateTransferInfo(Address requester, int type, Address target)

Fields of type org.jgroups.Address
Address	StateTransferInfo.requester
Address	StateTransferInfo.target

Methods with parameter type org.jgroups.Address
void	AckMcastSenderWindow.ack(long seqno, Address sender) An ACK has been received from `sender`.
Object	RpcProtocol.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)
Object	RpcProtocol.callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)
Object	RpcProtocol.callRemoteMethod(Address dest, String method_name, int mode, long timeout)
Object	RpcProtocol.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
void	GossipClient.register(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	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	AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest) Retranmit the given msg
void	AckMcastSenderWindow.suspect(Address suspected) Process with address `suspected` is suspected: remove it from all receiver sets.

Methods with return type org.jgroups.Address
Address	RouterStub.connect() Establishes a connection to the router.
Address	GossipData.getMbr()

Uses in package org.jgroups.protocols

Classes implementing org.jgroups.Address
class	JMS.JMSAddress Simple `Address` representing the JMS node ID or JMS topic group.
class	WanPipeAddress Logical address for a WAN pipe (logical link)

Constructors with parameter type org.jgroups.Address
MERGE3.CoordAnnouncement.CoordAnnouncement(Address coord)
FD.FdHeader.FdHeader(byte type, Vector mbrs, Address from)
FD_SOCK.FdHeader.FdHeader(byte type, Address mbr)
HTOTAL.HTotalHeader.HTotalHeader(Address dest, Address src)
MERGEFAST.MergefastHeader.MergefastHeader(Address coord)
PingRsp.PingRsp(Address own_addr, Address coord_addr, boolean is_server)
VectorTime.VectorTime(Address owner) Constructs VectorTime given an adress of a owning group member

Fields of type org.jgroups.Address
Address	PingRsp.coord_addr
Address	GMS.local_addr
Address	PingRsp.own_addr

Methods with parameter type org.jgroups.Address
boolean	ClientGmsImpl.handleJoin(Address mbr)
boolean	CoordGmsImpl.handleJoin(Address mbr)
boolean	GmsImpl.handleJoin(Address mbr)
boolean	GMS.handleJoin(Address mbr)
boolean	ParticipantGmsImpl.handleJoin(Address mbr)
void	ClientGmsImpl.handleLeave(Address mbr, boolean suspected) Returns false.
void	CoordGmsImpl.handleLeave(Address mbr, boolean suspected) Exclude `mbr` from the membership.
void	GmsImpl.handleLeave(Address mbr, boolean suspected)
void	GMS.handleLeave(Address mbr, boolean suspected)
void	ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
void	ClientGmsImpl.handleSuspect(Address mbr) Returns immediately.
void	CoordGmsImpl.handleSuspect(Address mbr)
void	GmsImpl.handleSuspect(Address mbr)
void	GMS.handleSuspect(Address mbr)
void	ParticipantGmsImpl.handleSuspect(Address mbr)
int	VectorTime.indexOf(Address member) Returns index of the given member represented by it's Address
void	ClientGmsImpl.join(Address mbr) Will generate a CONNECT_OK event.
void	CoordGmsImpl.join(Address mbr)
void	GmsImpl.join(Address mbr)
void	GMS.join(Address mbr)
void	ParticipantGmsImpl.join(Address mbr)
void	ClientGmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	GmsImpl.leave(Address mbr)
void	GMS.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
void	Discovery.localAddressSet(Address addr) Called after local_addr was set
void	PING.localAddressSet(Address addr)
void	TCPPING.localAddressSet(Address addr) Called after local_addr was set
void	TCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	TCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	TCP.receive(Address sender, byte[] data, int offset, int length) ConnectionTable.Receiver interface
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.
void	SMACK.retransmit(long seqno, Message msg, Address dest) Retranmit the given msg
int	DEADLOCK.sendRequest(Address dest)
void	TCP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	TP.sendToSingleMember(Address dest, byte[] data, int offset, int length) Send to all members in the group.
void	UDP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	ENCRYPT.setKeyServerAddr(Address keyServerAddr)
void	ENCRYPT.setLocal_addr(Address local_addr)
void	ClientGmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
void	GmsImpl.suspect(Address mbr)
void	GMS.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)

Methods with return type org.jgroups.Address
Address	GMS.determineCoordinator()
Address	PingRsp.getAddress()
Address	PingRsp.getCoordAddress()
Address	ENCRYPT.getKeyServerAddr()
Address	TOTAL_OLD.getLocalAddr() returns the Address of the local machine returns null if it is not known yet
Address	TP.getLocalAddress()
Address	ENCRYPT.getLocal_addr()
Address	TOTAL_OLD.getSequencer() returns the address of the current sequencer of the group returns null if the list of members is empty

Uses in package org.jgroups.jmx.protocols

Methods with return type org.jgroups.Address
Address	TP.getLocalAddress()
Address	TPMBean.getLocalAddress()

Uses in package org.jgroups.jmx

Methods with parameter type org.jgroups.Address
boolean	JChannel.getState(Address target, long timeout)
boolean	JChannelMBean.getState(Address target, long timeout)
void	JChannel.send(Address dst, Address src, Serializable obj)
void	JChannelMBean.send(Address dst, Address src, Serializable obj)

Methods with return type org.jgroups.Address
Address	JChannel.getLocalAddress()
Address	JChannelMBean.getLocalAddress()

Uses in package org.jgroups.demos.wb

Fields of type org.jgroups.Address
Address	Node.addr

Methods with parameter type org.jgroups.Address
void	GraphPanel.addNode(String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.addNode(String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.suspect(Address obj) Called whenever a member is suspected of having crashed, but has not yet been excluded.

Uses in package org.jgroups.protocols.ring

Constructors with parameter type org.jgroups.Address
TcpRingNode.TcpRingNode(RpcProtocol owner, Address memberAddress)
TokenLostException.TokenLostException(String message, Throwable cause, Address failedNode, int mode)
UdpRingNode.UdpRingNode(RpcProtocol owner, Address memberAddress)

Fields of type org.jgroups.Address
Address	TokenLostException.failedNode

Methods with parameter type org.jgroups.Address
void	RingToken.addRecoveredMember(Address member)
void	RingToken.setAruId(Address address)

Methods with return type org.jgroups.Address
Address	RingToken.getAruId()
Address	TokenLostException.getFailedNode()

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Address
void	Draw.channelReconnected(Address addr)
void	Gossip.channelReconnected(Address new_addr)
void	NotificationBusDemo.memberJoined(Address mbr)
void	NotificationBusDemo.memberLeft(Address mbr)
void	Chat.suspect(Address suspected_mbr)
void	QuoteClient.suspect(Address suspected_mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	QuoteServer.suspect(Address suspected_mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	Topology.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr) Called when a member is suspected

Uses in package org.jgroups.debug

Methods with parameter type org.jgroups.Address
void	Simulator.addMember(Address addr)
void	Simulator.addMember(Address addr, Simulator s)
void	Simulator.setLocalAddress(Address addr)

Uses in package org.jgroups

Constructors with parameter type org.jgroups.Address
MergeView.MergeView(Address creator, long id, Vector members, Vector subgroups) Creates a new view
Message.Message(Address dest, Address src, Serializable obj) Public constructor
Message.Message(Address dest, Address src, byte[] buf) Public constructor
Message.Message(Address dest, Address src, byte[] buf, int offset, int length) Constructs a message.
View.View(Address creator, long id, Vector members) Creates a new view
ViewId.ViewId(Address coord_addr) Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
ViewId.ViewId(Address coord_addr, long id) Creates a ViewID with the coordinator address and the given Lamport timestamp.

Fields of type org.jgroups.Address
Address	Message.dest_addr
Address	Message.src_addr

Methods with parameter type org.jgroups.Address
void	Membership.add(Address new_member) Adds a new member to this membership.
void	ChannelListener.channelReconnected(Address addr)
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	Channel.getState(Address target, long timeout) Retrieve the state of the group.
boolean	JChannel.getState(Address target, long timeout) Retrieves the current group state.
void	Channel.notifyChannelReconnected(Address addr)
void	Membership.remove(Address old_member) removes an member from the membership.
void	Channel.send(Address dst, Address src, Serializable obj) Helper method.
void	JChannel.send(Address dst, Address src, Serializable obj) creates a new message with the destination address, and the source address and the object as the message value
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	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) Called whenever a member is suspected of having crashed, but has not yet been excluded.

Methods with return type org.jgroups.Address
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()
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()

Overview Package Class Use Tree Index Deprecated About
	Frames \| No Frames

Uses of Interface org.jgroups.Address

Uses in package org.jgroups.blocks

Constructors with parameter type org.jgroups.Address

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.util

Constructors with parameter type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.protocols.pbcast

Constructors with parameter type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.stack

Classes implementing org.jgroups.Address

Constructors with parameter type org.jgroups.Address

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.protocols

Classes implementing org.jgroups.Address

Constructors with parameter type org.jgroups.Address

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.jmx.protocols

Methods with return type org.jgroups.Address

Uses in package org.jgroups.jmx

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.demos.wb

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Uses in package org.jgroups.protocols.ring

Constructors with parameter type org.jgroups.Address

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Address

Uses in package org.jgroups.debug

Methods with parameter type org.jgroups.Address

Uses in package org.jgroups

Constructors with parameter type org.jgroups.Address

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Methods with return type org.jgroups.Address