Uses of Interface org.jgroups.Address

Uses in package org.jgroups.service

Methods with parameter type org.jgroups.Address
void	AbstractService.suspect(Address suspectedMember) This method is called when a member of service group is suspected to be failed.

Methods with return type org.jgroups.Address
Address	AbstractService.getAddress() Get address of this service in service group.

Uses in package org.jgroups.protocols.pbcast

Constructors with parameter type org.jgroups.Address
GMS.GmsHeader.GmsHeader(int 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)
STATE_TRANSFER.StateHeader.StateHeader(int type, Address sender, long id, Digest digest)

Fields of type org.jgroups.Address
Address	GMS.local_addr

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)
int	Digest.getIndex(Address sender)
JoinRsp	ClientGmsImpl.handleJoin(Address mbr)
JoinRsp	CoordGmsImpl.handleJoin(Address mbr) Computes the new view (including the newly joined member) and get the digest from PBCAST.
JoinRsp	GmsImpl.handleJoin(Address mbr)
JoinRsp	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, Object 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, Object 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) Increment 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.
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	NAKACK.retransmit(long first_seqno, long last_seqno, Address sender) Implementation of Retransmitter.RetransmitCommand.
void	Digest.setHighSeqnoAt(Address sender, long high_seqno)
void	Digest.setHighSeqnoSeenAt(Address sender, 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	MergeData.getSender()
Address	Digest.senderAt(int index)

Uses in package org.jgroups.util

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

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.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 when a member is suspected

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 when a member is suspected
void	QuoteServer.suspect(Address suspected_mbr) Called when a member is suspected
void	Topology.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr) Called when a member is suspected

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
Address	TransactionalHashtable.local_addr

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	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	RequestCorrelator.receiveSuspect(Address mbr) `Event.SUSPECT` event received from a layer below All response collectors currently registered will be notified that `mbr` may have crashed, so they won't wait for its response.
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	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 when a member is suspected
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	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.service.lease

Methods with parameter type org.jgroups.Address
void	LeaseFactoryService.denyLeaseRequest(int denialType, Address requester, String reason, Object leaseTarget, Object tenant) Deny lease request.
void	LeaseFactoryService.processCancelLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process request to cancel lease.
void	LeaseFactoryService.processNewLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process new lease request.
void	LeaseFactoryService.processRenewLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process request to renew a lease.

Methods with return type org.jgroups.Address
Address	LeaseFactoryClient.getAddress() Get address of this client in group.

Uses in package org.jgroups.stack

Classes implementing org.jgroups.Address
class	IpAddress Network-dependent address (Internet).
class	LogicalAddress1_4 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.ensemble

Classes implementing org.jgroups.Address
class	Hot_Endpoint

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	EnsChannel.getState(Address target, long timeout)
boolean	JChannel.getState(Address target, long timeout) Retrieves the current group state.
void	Membership.remove(Address old_member) removes an member from the membership.
void	Channel.send(Address dst, Address src, Serializable obj) Helper method.
void	EnsChannel.send(Address dst, Address src, Serializable obj)
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 when a member is suspected

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	EnsChannel.getLocalAddress()
Address	JChannel.getLocalAddress() returns the local address of the channel returns null if the channel is closed
Address	Message.getSrc()

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
MERGEFAST.MergefastHeader.MergefastHeader(Address coord)
PingRsp.PingRsp(Address own_addr, Address coord_addr)
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
void	TCP.connectionClosed(Address peer_addr)
void	TCP.connectionOpened(Address peer_addr)
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	SMACK.retransmit(long seqno, Message msg, Address dest) Retranmit the given msg
int	DEADLOCK.sendRequest(Address dest)
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	TOTAL_OLD.getLocalAddr() returns the Address of the local machine returns null if it is not known yet
Address	TOTAL_OLD.getSequencer() returns the address of the current sequencer of the group returns null if the list of members is empty

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

Uses of Interface org.jgroups.Address

Uses in package org.jgroups.service

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

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

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.wb

Fields of type org.jgroups.Address

Methods with parameter type org.jgroups.Address

Uses in package org.jgroups.demos

Methods with parameter type 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.service.lease

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.ensemble

Classes implementing 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

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