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

Methods in org.javagroups with parameters of type Address
 void MembershipListener.suspect(Address suspected_mbr)
          Called when a member is suspected
 void Membership.add(Address new_member)
          Adds a new member to this membership.
 void Membership.remove(Address old_member)
          removes an member from the membership.
 boolean Membership.contains(Address member)
          Returns true if the provided member belongs to this 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
 boolean JChannel.getState(Address target, long timeout)
          Retrieves the current group state.
 void EnsChannel.send(Address dst, Address src, java.io.Serializable obj)
           
 boolean EnsChannel.getState(Address target, long timeout)
           
 boolean View.containsMember(Address mbr)
          returns true, if this view contains a certain member
 void Message.setDest(Address new_dest)
           
 void Message.setSrc(Address new_src)
           
 void ChannelListener.channelReconnected(Address addr)
           
abstract  void Channel.send(Address dst, Address src, java.io.Serializable obj)
          Helper method.
abstract  boolean Channel.getState(Address target, long timeout)
          Retrieve the state of the group.
 

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
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.
View(Address creator, long id, java.util.Vector members)
          Creates a new view
Message(Address dest, Address src, byte[] buf)
          Public constructor
Message(Address dest, Address src, java.io.Serializable obj)
          Public constructor
 

Uses of Address in org.javagroups.blocks
 

Fields in org.javagroups.blocks declared as Address
protected  Address TransactionalHashtable.local_addr
           
protected  Address Xid.creator
           
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 ConnectionTable1_4.getLocalAddress()
           
 Address Xid.getCreator()
           
 Address ReplicatedTree.getLocalAddress()
           
 Address ReplicatedHashtable.getLocalAddress()
           
 Address NotificationBus.getLocalAddress()
           
 Address DistributedQueue.getLocalAddress()
           
 Address DistributedHashtable.getLocalAddress()
           
 Address ConnectionTable.getLocalAddress()
           
 

Methods in org.javagroups.blocks with parameters of type Address
 void ConnectionTable1_4.remove(Address addr)
          Remove addrfrom connection table.
 void ConnectionTable1_4.ConnectionListener.connectionOpened(Address peer_addr)
           
 void ConnectionTable1_4.ConnectionListener.connectionClosed(Address peer_addr)
           
 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.
static Xid Xid.create(Address creator)
           
static Xid Xid.create(Address creator, int mode)
           
 void ReplicatedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 void ReplicatedHashtable.suspect(Address suspected_mbr)
          Called when a member is suspected
 java.io.Serializable NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)
          Determines the coordinator and asks it for its cache.
 void NotificationBus.suspect(Address suspected_mbr)
           
 void NotificationBus.Consumer.memberJoined(Address mbr)
           
 void NotificationBus.Consumer.memberLeft(Address mbr)
           
 void MembershipListenerAdapter.suspect(Address suspected_mbr)
          Notify membership listener that some node was suspected.
 void GroupRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void DistributedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 void DistributedQueue.suspect(Address suspected_mbr)
          Called when a member is suspected
 void VotingAdapter.suspect(Address suspected)
          Callback for notification that one node is suspected
 void RspCollector.suspect(Address mbr)
           
 void RequestCorrelator.receiveSuspect(Address mbr)
          Event.SUSPECT event received from a layer below
 void RequestCorrelator.setLocalAddress(Address local_addr)
           
protected  void PullPushAdapter.notifySuspect(Address suspected_mbr)
           
 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 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);
 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)
           
 void RpcDispatcher.channelReconnected(Address new_addr)
           
 void DistributedHashtable.suspect(Address suspected_mbr)
          Called when a member is suspected
 void ConnectionTable.remove(Address addr)
          Remove addrfrom connection table.
 void ConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
           
 void ConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
           
 

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 ViewDemo.suspect(Address suspected_mbr)
          Called when a member is suspected
 void Topology.suspect(Address suspected_mbr)
           
 void QuoteServer.suspect(Address suspected_mbr)
           
 void QuoteClient.suspect(Address suspected_mbr)
           
 void NotificationBusDemo.memberJoined(Address mbr)
           
 void NotificationBusDemo.memberLeft(Address mbr)
           
 void Gossip.channelReconnected(Address new_addr)
           
 void Draw.channelReconnected(Address addr)
           
 void Chat.suspect(Address suspected_mbr)
           
 

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.suspect(Address obj)
           
 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)
           
 

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.own_addr
           
 Address PingRsp.coord_addr
           
 Address GMS.local_addr
           
 

Methods in org.javagroups.protocols that return Address
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
 Address PingRsp.getAddress()
           
 Address PingRsp.getCoordAddress()
           
protected  Address GMS.determineCoordinator()
           
 

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

Constructors in org.javagroups.protocols with parameters of type Address
PingRsp(Address own_addr, Address coord_addr)
           
MERGEFAST.MergefastHeader(Address coord)
           
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
 Address MergeData.getSender()
           
 Address Digest.senderAt(int index)
           
protected  Address GMS.determineCoordinator()
           
 

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

Constructors in org.javagroups.protocols.pbcast with parameters of type Address
STATE_TRANSFER.StateHeader(int type, Address sender, long id, Digest digest)
           
Gossip(Address obj, long id)
           
Gossip(Address obj, long id, Digest d, java.util.Vector not_seen)
           
MergeData(Address sender, View view, Digest digest)
           
GMS.GmsHeader(int type, Address mbr)
          Used for JOIN_REQ or LEAVE_REQ header
 

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.setAruId(Address address)
           
 void RingToken.addRecoveredMember(Address member)
           
 

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.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.
protected  void LeaseFactoryService.processCancelLeaseRequest(LeaseRequestHeader header, java.lang.Object leaseTarget, Address requester)
          Process request to cancel 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 GossipData.getMbr()
           
 Address RouterStub.connect()
          Establishes a connection to the router.
 

Methods in org.javagroups.stack with parameters of type Address
 void AckSenderWindow.retransmit(long first_seqno, long last_seqno, Address sender)
           
 void GossipClient.register(java.lang.String group, Address mbr)
          Adds the member to the given group.
 void AckMcastSenderWindow.ack(long seqno, Address sender)
          An ACK has been received from sender.
 void AckMcastSenderWindow.remove(Address obj)
          Remove obj from all receiver sets and wake up retransmission thread.
 void AckMcastSenderWindow.suspect(Address suspected)
          Process with address suspected is suspected: remove it from all receiver sets.
 void AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)
          Retranmit the given msg
 void Retransmitter.RetransmitCommand.retransmit(long first_seqno, long last_seqno, Address sender)
          Get the missing messages between sequence numbers first_seqno and last_seqno.
 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 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
 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, MethodCall method_call, int mode, long timeout)
           
 

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

Uses of Address in org.javagroups.util
 

Methods in org.javagroups.util with parameters of type Address
static boolean Util.sameHost(Address one, Address two)
          Checks whether 2 Addresses are on the same host
 void RspList.addRsp(Address sender, java.lang.Object retval)
           
 void RspList.addNotReceived(Address sender)
           
 void RspList.addSuspect(Address sender)
           
 boolean RspList.isReceived(Address sender)
           
 boolean RspList.isSuspected(Address sender)
           
 java.lang.Object RspList.get(Address sender)
           
 



Copyright © 2001,2002 www.javagroups.com . All Rights Reserved.