Uses of Interface
org.javagroups.Address

Packages that use Address

org.javagroups
org.javagroups.blocks
org.javagroups.demos
org.javagroups.demos.wb
org.javagroups.ensemble
org.javagroups.protocols
org.javagroups.protocols.pbcast
org.javagroups.protocols.ring
org.javagroups.service
org.javagroups.service.lease
org.javagroups.stack
org.javagroups.util

Uses of Address in org.javagroups

Fields in org.javagroups declared as Address

protected Address	Message.dest_addr
protected Address	Message.src_addr

Methods in org.javagroups that return 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	JChannel.getLocalAddress() returns the local address of the channel returns null if the channel is closed
abstract Address	Channel.getLocalAddress() Returns the channel's own address.
Address	EnsChannel.getLocalAddress()
Address	Message.getSrc()

Methods in org.javagroups with parameters of type 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	JChannel.getState(Address target, long timeout) Retrieves the current group state.
abstract boolean	Channel.getState(Address target, long timeout) Retrieve the state of the group.
boolean	EnsChannel.getState(Address target, long timeout)
void	Membership.remove(Address old_member) removes an member from the membership.
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
abstract void	Channel.send(Address dst, Address src, java.io.Serializable obj) Helper method.
void	EnsChannel.send(Address dst, Address src, java.io.Serializable obj)
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	MembershipListener.suspect(Address suspected_mbr) Called when a member is suspected

Constructors in org.javagroups with parameters of type Address

MergeView(Address creator, long id, java.util.Vector members, java.util.Vector subgroups)
Creates a new view

Message(Address dest, Address src, byte[] buf)
Public constructor

Message(Address dest, Address src, java.io.Serializable obj)
Public constructor

View(Address creator, long id, java.util.Vector 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.

Uses of Address in org.javagroups.blocks

Fields in org.javagroups.blocks declared as Address

protected Address	Xid.creator
protected Address	TransactionalHashtable.local_addr
protected Address	RequestCorrelator.local_addr The address of this group member
protected Address	MessageDispatcher.local_addr

Methods in org.javagroups.blocks that return Address

Address	Xid.getCreator()
Address	ConnectionTable1_4.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	DistributedQueue.getLocalAddress()
Address	ReplicatedHashtable.getLocalAddress()
Address	NotificationBus.getLocalAddress()
Address	ConnectionTable.getLocalAddress()
Address	DistributedHashtable.getLocalAddress()

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

java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, int mode, long timeout) Deprecated. use callRemoteMethod(Address,MethodCall, int, long);
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, java.lang.String method_name, java.lang.Object arg1, int mode, long timeout) Deprecated. use callRemoteMethod(Address,MethodCall, int, long);
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, int mode, long timeout) Deprecated. use callRemoteMethod(Address,MethodCall, int, long);
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, int mode, long timeout) Deprecated. use callRemoteMethod(Address,MethodCall, int, long);
void	RpcDispatcher.channelReconnected(Address new_addr)
void	ConnectionTable1_4.ConnectionListener.connectionClosed(Address peer_addr)
void	ConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	ConnectionTable1_4.ConnectionListener.connectionOpened(Address peer_addr)
void	ConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
static Xid	Xid.create(Address creator)
static Xid	Xid.create(Address creator, int mode)
java.io.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)
protected void	PullPushAdapter.notifySuspect(Address suspected_mbr)
void	RequestCorrelator.receiveSuspect(Address mbr) Event.SUSPECT event received from a layer below
void	ConnectionTable1_4.remove(Address addr) Remove addrfrom connection table.
void	ConnectionTable.remove(Address addr) Remove addrfrom 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	ReplicatedTree.suspect(Address suspected_mbr) Called when a member is suspected
void	RspCollector.suspect(Address mbr)
void	DistributedQueue.suspect(Address suspected_mbr) Called when a member is suspected
void	ReplicatedHashtable.suspect(Address suspected_mbr) Called when a member is suspected
void	GroupRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
void	NotificationBus.suspect(Address suspected_mbr)
void	MembershipListenerAdapter.suspect(Address suspected_mbr) Notify membership listener that some node was suspected.
void	VotingAdapter.suspect(Address suspected) Callback for notification that one node is suspected
void	DistributedTree.suspect(Address suspected_mbr) Called when a member is suspected
void	DistributedHashtable.suspect(Address suspected_mbr) Called when a member is suspected

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

RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr)

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

Uses of Address in org.javagroups.demos

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

void	Gossip.channelReconnected(Address new_addr)
void	Draw.channelReconnected(Address addr)
void	NotificationBusDemo.memberJoined(Address mbr)
void	NotificationBusDemo.memberLeft(Address mbr)
void	QuoteClient.suspect(Address suspected_mbr)
void	Chat.suspect(Address suspected_mbr)
void	Topology.suspect(Address suspected_mbr)
void	QuoteServer.suspect(Address suspected_mbr)
void	ViewDemo.suspect(Address suspected_mbr) Called when a member is suspected

Uses of Address in org.javagroups.demos.wb

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

Address

Node.addr

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

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)

Uses of Address in org.javagroups.ensemble

Classes in org.javagroups.ensemble that implement Address

class

Hot_Endpoint

Uses of Address in org.javagroups.protocols

Classes in org.javagroups.protocols that implement Address

protected static class	JMS.JMSAddress Simple Address representing the JMS node ID or JMS topic group.
class	WanPipeAddress Logical address for a WAN pipe (logical link)

Fields in org.javagroups.protocols declared as Address

Address	PingRsp.coord_addr
Address	GMS.local_addr
Address	PingRsp.own_addr

Methods in org.javagroups.protocols that return Address

protected Address	GMS.determineCoordinator()
Address	PingRsp.getAddress()
Address	PingRsp.getCoordAddress()
protected Address	TOTAL_OLD.getLocalAddr() returns the Address of the local machine returns null if it is not known yet
protected Address	TOTAL_OLD.getSequencer() returns the address of the current sequencer of the group returns null if the list of members is empty

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

void	TCP.connectionClosed(Address peer_addr)
void	TCP.connectionOpened(Address peer_addr)
boolean	GMS.handleJoin(Address mbr)
boolean	ParticipantGmsImpl.handleJoin(Address mbr)
abstract boolean	GmsImpl.handleJoin(Address mbr)
boolean	CoordGmsImpl.handleJoin(Address mbr)
boolean	ClientGmsImpl.handleJoin(Address mbr)
void	GMS.handleLeave(Address mbr, boolean suspected)
void	ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
abstract void	GmsImpl.handleLeave(Address mbr, boolean suspected)
void	CoordGmsImpl.handleLeave(Address mbr, boolean suspected) Exclude mbr from the membership.
void	ClientGmsImpl.handleLeave(Address mbr, boolean suspected) Returns false.
void	GMS.handleSuspect(Address mbr)
void	ParticipantGmsImpl.handleSuspect(Address mbr)
abstract void	GmsImpl.handleSuspect(Address mbr)
void	CoordGmsImpl.handleSuspect(Address mbr)
void	ClientGmsImpl.handleSuspect(Address mbr) Returns immediately.
int	VectorTime.indexOf(Address member) Returns index of the given member represented by it's Address
void	GMS.join(Address mbr)
void	ParticipantGmsImpl.join(Address mbr)
abstract void	GmsImpl.join(Address mbr)
void	CoordGmsImpl.join(Address mbr)
void	ClientGmsImpl.join(Address mbr) Will generate a CONNECT_OK event.
void	GMS.leave(Address mbr)
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
abstract void	GmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	ClientGmsImpl.leave(Address mbr)
void	SMACK.retransmit(long seqno, Message msg, Address dest)
int	DEADLOCK.sendRequest(Address dest)
void	GMS.suspect(Address mbr)
void	ParticipantGmsImpl.suspect(Address mbr)
abstract void	GmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
void	ClientGmsImpl.suspect(Address mbr)

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

MERGEFAST.MergefastHeader(Address coord)

PingRsp(Address own_addr, Address coord_addr)

VectorTime(Address owner)
Constructs VectorTime given an adress of a owning group member

Uses of Address in org.javagroups.protocols.pbcast

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

Address

GMS.local_addr

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

protected Address	GMS.determineCoordinator()
Address	MergeData.getSender()
Address	Digest.senderAt(int index)

Methods in org.javagroups.protocols.pbcast with parameters of type 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	ParticipantGmsImpl.handleJoin(Address mbr)
abstract JoinRsp	GmsImpl.handleJoin(Address mbr)
JoinRsp	CoordGmsImpl.handleJoin(Address mbr) Computes the new view (including the newly joined member) and get the digest from PBCAST.
JoinRsp	ClientGmsImpl.handleJoin(Address mbr)
void	ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
abstract void	GmsImpl.handleLeave(Address mbr, boolean suspected)
void	CoordGmsImpl.handleLeave(Address mbr, boolean suspected) Exclude mbr from the membership.
void	ClientGmsImpl.handleLeave(Address mbr, boolean suspected) Returns false.
void	GmsImpl.handleMergeRequest(Address sender, java.lang.Object merge_id)
void	CoordGmsImpl.handleMergeRequest(Address sender, java.lang.Object merge_id) Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void	ParticipantGmsImpl.handleSuspect(Address mbr)
abstract void	GmsImpl.handleSuspect(Address mbr)
void	CoordGmsImpl.handleSuspect(Address mbr)
void	ClientGmsImpl.handleSuspect(Address mbr) Returns immediately.
long	Digest.highSeqnoAt(Address sender)
long	Digest.highSeqnoSeenAt(Address sender)
void	Digest.incrementHighSeqno(Address sender) Increment the sender's high_seqno by 1
void	ParticipantGmsImpl.join(Address mbr)
abstract void	GmsImpl.join(Address mbr)
void	CoordGmsImpl.join(Address mbr)
void	ClientGmsImpl.join(Address mbr) Joins this process to a group.
void	ParticipantGmsImpl.leave(Address mbr) Loop: determine coord.
abstract void	GmsImpl.leave(Address mbr)
void	CoordGmsImpl.leave(Address mbr) The coordinator itself wants to leave the group
void	ClientGmsImpl.leave(Address mbr)
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	ParticipantGmsImpl.suspect(Address mbr)
abstract void	GmsImpl.suspect(Address mbr)
void	CoordGmsImpl.suspect(Address mbr)
void	ClientGmsImpl.suspect(Address mbr)
void	ParticipantGmsImpl.unsuspect(Address mbr) Removes previously suspected member from list of currently suspected members
abstract void	GmsImpl.unsuspect(Address mbr)
void	CoordGmsImpl.unsuspect(Address mbr)
void	ClientGmsImpl.unsuspect(Address mbr)
protected boolean	GMS.wouldBeNewCoordinator(Address potential_new_coord) Checks whether the potential_new_coord would be the new coordinator (2nd in line)

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

GMS.GmsHeader(int 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)

STATE_TRANSFER.StateHeader(int type, Address sender, long id, Digest digest)

Uses of Address in org.javagroups.protocols.ring

Fields in org.javagroups.protocols.ring declared as Address

protected Address

TokenLostException.failedNode

Methods in org.javagroups.protocols.ring that return Address

Address	RingToken.getAruId()
Address	TokenLostException.getFailedNode()

Methods in org.javagroups.protocols.ring with parameters of type Address

void	RingToken.addRecoveredMember(Address member)
void	RingToken.setAruId(Address address)

Constructors in org.javagroups.protocols.ring with parameters of type Address

TcpRingNode(RpcProtocol owner, Address memberAddress)

TokenLostException(java.lang.String message, java.lang.Throwable cause, Address failedNode, int mode)

UdpRingNode(RpcProtocol owner, Address memberAddress)

Uses of Address in org.javagroups.service

Methods in org.javagroups.service that return Address

Address

AbstractService.getAddress() Get address of this service in service group.

Methods in org.javagroups.service with parameters of type Address

void	AbstractService.suspect(Address suspectedMember) This method is called when a member of service group is suspected to be failed.

Uses of Address in org.javagroups.service.lease

Methods in org.javagroups.service.lease that return Address

Address

LeaseFactoryClient.getAddress() Get address of this client in group.

Methods in org.javagroups.service.lease with parameters of type Address

protected void	LeaseFactoryService.denyLeaseRequest(int denialType, Address requester, java.lang.String reason, java.lang.Object leaseTarget, java.lang.Object tenant) Deny lease request.
protected void	LeaseFactoryService.processCancelLeaseRequest(LeaseRequestHeader header, java.lang.Object leaseTarget, Address requester) Process request to cancel lease.
protected void	LeaseFactoryService.processNewLeaseRequest(LeaseRequestHeader header, java.lang.Object leaseTarget, Address requester) Process new lease request.
protected void	LeaseFactoryService.processRenewLeaseRequest(LeaseRequestHeader header, java.lang.Object leaseTarget, Address requester) Process request to renew a lease.

Uses of Address in org.javagroups.stack

Classes in org.javagroups.stack that implement Address

class

IpAddress Network-dependent address (Internet).

Fields in org.javagroups.stack declared as Address

Address	StateTransferInfo.requester
Address	StateTransferInfo.target

Methods in org.javagroups.stack that return Address

Address	RouterStub.connect() Establishes a connection to the router.
Address	GossipData.getMbr()

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

void	AckMcastSenderWindow.ack(long seqno, Address sender) An ACK has been received from sender.
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, int mode, long timeout)
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, int mode, long timeout) Deprecated. this method results in an invalid method call if the argument is null
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, int mode, long timeout) Deprecated. this method results in an invalid method call if the argument is null
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, int mode, long timeout) Deprecated. this method results in an invalid method call if the argument is null
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, int mode, long timeout) Deprecated. this method results in an invalid method call if the argument is null
java.lang.Object	RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, int mode, long timeout) Deprecated. this method results in an invalid method call if the argument is null
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	Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender) Get the missing messages between sequence numbers first_seqno and last_seqno.
void	AckSenderWindow.retransmit(long first_seqno, long last_seqno, Address sender)
void	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.

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

GossipData(int type, java.lang.String group, Address mbr, java.util.Vector mbrs)

NakReceiverWindow(Address sender, long start_seqno)
Creates a new instance without a retransmission thread

NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno)
Creates a new instance with the given retransmit command

NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_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 requester, int type, Address target)

StateTransferInfo(int type, Address target)

Uses of Address in org.javagroups.util

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

void	RspList.addNotReceived(Address sender)
void	RspList.addRsp(Address sender, java.lang.Object retval)
void	RspList.addSuspect(Address sender)
java.lang.Object	RspList.get(Address sender)
boolean	RspList.isReceived(Address sender)
boolean	RspList.isSuspected(Address sender)
static boolean	Util.sameHost(Address one, Address two) Checks whether 2 Addresses are on the same host