Uses of Interface
org.jgroups.Address

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

Uses of Address in org.jgroups
 

Fields in org.jgroups declared as Address
protected  Address Message.dest_addr
           
protected  Address Message.src_addr
           
 

Fields in org.jgroups with type parameters of type Address
protected  java.util.Vector<Address> View.members
          A list containing all the members of the view This list is always ordered, with the coordinator being the first member.
 

Methods in org.jgroups that return Address
 Address Membership.elementAt(int index)
          Returns the component at the specified index
 Address ViewId.getCoordAddress()
          returns the address of the member that issued this view
 Address View.getCreator()
          returns the creator of this view if this view was created with the empty constructur, null will be returned
 Address Message.getDest()
           
 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 Message.getSrc()
           
 

Methods in org.jgroups that return types with arguments of type Address
 java.util.Vector<Address> Membership.getMembers()
          returns a copy (clone) of the members in this membership.
 java.util.Vector<Address> View.getMembers()
          Returns a reference to the List of members (ordered) Do NOT change this list, hence your will invalidate the view Make a copy if you have to modify it.
 

Methods in org.jgroups with parameters of type Address
 void Membership.add(Address new_member)
          Adds a new member to this membership.
 void ChannelListenerAdapter.channelReconnected(Address addr)
           
 void ChannelListener.channelReconnected(Address addr)
           
 void JChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
          Connects this channel to a group and gets a state from a specified state provider.
abstract  void Channel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
          Connects the channel to a group and fetches the state
 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 a full state from the target member.
abstract  boolean Channel.getState(Address target, long timeout)
          Retrieve the state of the group.
 boolean JChannel.getState(Address target, java.lang.String state_id, long timeout)
          Retrieves a substate (or partial state) indicated by state_id from the target member.
abstract  boolean Channel.getState(Address target, java.lang.String state_id, long timeout)
          Fetches a partial state identified by state_id.
 boolean JChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
          Retrieves a substate (or partial state) indicated by state_id from the target member.
protected  boolean JChannel.getState(Address target, java.lang.String state_id, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
          Retrieves a substate (or partial state) indicated by state_id from the target member.
protected  void Channel.notifyChannelReconnected(Address addr)
           
 void Membership.remove(Address old_member)
          removes an member from the membership.
 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 Message.setDest(Address new_dest)
           
 void Message.setSrc(Address new_src)
           
 void ReceiverAdapter.suspect(Address suspected_mbr)
           
 void MembershipListener.suspect(Address suspected_mbr)
          Called whenever a member is suspected of having crashed, but has not yet been excluded.
 void ExtendedReceiverAdapter.suspect(Address suspected_mbr)
           
 

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

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

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

Uses of Address in org.jgroups.blocks
 

Fields in org.jgroups.blocks declared as Address
protected  Address MessageDispatcher.local_addr
           
protected  Address RequestCorrelator.local_addr
          The address of this group member
 

Fields in org.jgroups.blocks with type parameters of type Address
protected  java.util.Stack<Address> RequestCorrelator.call_stack
          This field is used only if deadlock detection is enabled.
 java.util.Stack<Address> RequestCorrelator.Header.callStack
          Stack<Address>.
 java.util.List<Address> RequestCorrelator.Header.dest_mbrs
          Contains a list of members who should receive the request (others will drop).
 

Methods in org.jgroups.blocks that return Address
 Address GroupRequest.getCaller()
           
 Address ReplicatedTree.getLocalAddress()
           
 Address ReplicatedHashMap.getLocalAddress()
           
 Address DistributedQueue.getLocalAddress()
           
 Address NotificationBus.getLocalAddress()
           
 Address RequestCorrelator.getLocalAddress()
           
 Address ReplicatedHashtable.getLocalAddress()
          Deprecated.  
 Address DistributedHashtable.getLocalAddress()
          Deprecated.  
 Address BasicConnectionTable.getLocalAddress()
           
 

Methods in org.jgroups.blocks that return types with arguments of type Address
 java.util.Vector<Address> GroupRequest.getSuspects()
          Returns the list of suspected members.
 

Methods in org.jgroups.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, MethodCall method_call, int mode, long timeout, boolean oob)
           
 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)
           
 void PullPushAdapter.channelReconnected(Address addr)
          Deprecated.  
 void RpcDispatcher.channelReconnected(Address new_addr)
           
 void BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
           
 void BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
           
 java.io.Serializable NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)
          Determines the coordinator and asks it for its cache.
 boolean RspFilter.isAcceptable(java.lang.Object response, Address sender)
          Determines whether a response from a given sender should be added to the response list of the request
 void NotificationBus.Consumer.memberJoined(Address mbr)
           
 void NotificationBus.Consumer.memberLeft(Address mbr)
           
protected  void PullPushAdapter.notifySuspect(Address suspected_mbr)
          Deprecated.  
 void BasicConnectionTable.receive(Address sender, byte[] data, int offset, int length)
          Calls the receiver callback.
 void BasicConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
           
 void GroupRequest.receiveResponse(java.lang.Object response_value, Address sender)
          Callback (called by RequestCorrelator or Transport).
 void RspCollector.receiveResponse(java.lang.Object response_value, Address sender)
           
 void RequestCorrelator.receiveSuspect(Address mbr)
          Event.SUSPECT event received from a layer below.
 void BasicConnectionTable.removeConnection(Address addr)
          Remove addrfrom connection table.
protected  void ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
           
 void BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
           
 void NotificationBus.sendNotification(Address dest, java.io.Serializable n)
          Pack the argument in a Info, serialize that one into the message buffer and send the message
 void GroupRequest.setCaller(Address caller)
           
 void RequestCorrelator.setLocalAddress(Address local_addr)
           
 void ReplicatedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 void GroupRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void ReplicatedHashMap.suspect(Address suspected_mbr)
          Called when a member is suspected
 void DistributedQueue.suspect(Address suspected_mbr)
          Called when a member is suspected
 void MembershipListenerAdapter.suspect(Address suspected_mbr)
          Notify membership listener that some node was suspected.
 void DistributedLockManager.suspect(Address suspected_mbr)
           
 void NotificationBus.suspect(Address suspected_mbr)
           
 void RspCollector.suspect(Address mbr)
           
 void ReplicatedHashtable.suspect(Address suspected_mbr)
          Deprecated. Called when a member is suspected
 void DistributedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 void DistributedHashtable.suspect(Address suspected_mbr)
          Deprecated. Called when a member is suspected
 void VotingAdapter.suspect(Address suspected)
          Callback for notification that one node is suspected
 

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

Constructors in org.jgroups.blocks with parameters of type Address
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)
           
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)
           
 

Constructor parameters in org.jgroups.blocks with type arguments of type Address
GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode)
           
GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)
           
GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode)
           
GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)
           
 

Uses of Address in org.jgroups.debug
 

Methods in org.jgroups.debug with parameters of type Address
 void Simulator.addMember(Address addr)
           
 void Simulator.addMember(Address addr, Simulator s)
           
 void Simulator.setLocalAddress(Address addr)
           
 

Uses of Address in org.jgroups.demos
 

Methods in org.jgroups.demos with parameters of type Address
 void Gossip.channelReconnected(Address new_addr)
           
 void Draw.channelReconnected(Address addr)
           
 void NotificationBusDemo.memberJoined(Address mbr)
           
 void NotificationBusDemo.memberLeft(Address mbr)
           
 void ChatCore.suspect(Address suspected_mbr)
           
 void Topology.suspect(Address suspected_mbr)
           
 void ViewDemo.suspect(Address suspected_mbr)
          Called when a member is suspected
 void QuoteServer.suspect(Address suspected_mbr)
           
 void QuoteClient.suspect(Address suspected_mbr)
           
 

Uses of Address in org.jgroups.demos.wb
 

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

Methods in org.jgroups.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.jgroups.jmx
 

Methods in org.jgroups.jmx that return Address
 Address JChannel.getLocalAddress()
           
 Address JChannelMBean.getLocalAddress()
           
 

Methods in org.jgroups.jmx with parameters of type Address
 boolean JChannel.getState(Address target, long timeout)
           
 boolean JChannelMBean.getState(Address target, long timeout)
           
 void JChannel.send(Address dst, Address src, java.io.Serializable obj)
           
 void JChannelMBean.send(Address dst, Address src, java.io.Serializable obj)
           
 

Uses of Address in org.jgroups.jmx.protocols
 

Methods in org.jgroups.jmx.protocols that return Address
 Address TPMBean.getLocalAddress()
           
 Address TP.getLocalAddress()
           
 

Uses of Address in org.jgroups.mux
 

Methods in org.jgroups.mux that return Address
 Address MuxChannel.getLocalAddress()
           
 

Methods in org.jgroups.mux with parameters of type Address
 void MuxChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
           
 boolean MuxChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
           
 void MuxChannel.send(Address dst, Address src, java.io.Serializable obj)
           
 

Constructors in org.jgroups.mux with parameters of type Address
ServiceInfo(byte type, java.lang.String service, Address host, byte[] state)
           
 

Uses of Address in org.jgroups.protocols
 

Classes in org.jgroups.protocols that implement Address
static class JMS.JMSAddress
          Simple Address representing the JMS node ID or JMS topic group.
 

Fields in org.jgroups.protocols declared as Address
 Address PingRsp.coord_addr
           
protected  Address TP.local_addr
          The address (host and port) of this member
protected  Address PARTITION.local_address
           
 Address PingRsp.own_addr
           
 

Fields in org.jgroups.protocols with type parameters of type Address
protected  java.util.HashSet<Address> TP.members
          The members of this group (updated when a member joins or leaves)
 

Methods in org.jgroups.protocols that return Address
protected  Address UDP.createLocalAddress()
           
 Address PingRsp.getAddress()
           
 Address PingRsp.getCoordAddress()
           
 Address SEQUENCER.getCoordinator()
           
protected  Address ENCRYPT.getKeyServerAddr()
           
protected  Address ENCRYPT.getLocal_addr()
           
 Address SEQUENCER.getLocalAddress()
           
 Address TP.getLocalAddress()
           
 Address SEQUENCER.SequencerHeader.getOriginalSender()
           
 

Methods in org.jgroups.protocols that return types with arguments of type Address
 java.util.List<Address> TCPPING.getInitialHosts()
          Returns the list of initial hosts as configured by the user via XML.
 java.util.List<Address> TP.ProtocolAdapter.getMembers()
           
 

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

Method parameters in org.jgroups.protocols with type arguments of type Address
abstract  void BasicTCP.retainAll(java.util.Collection<Address> members)
           
 void TCP.retainAll(java.util.Collection<Address> members)
           
 void TCP_NIO.retainAll(java.util.Collection<Address> members)
           
 

Constructors in org.jgroups.protocols with parameters of type Address
FD_ALL.Header(byte type, Address suspect)
           
FD_SOCK.FdHeader(byte type, Address mbr)
           
FD_SOCK.FdHeader(byte type, Address mbr, IpAddress sock_addr)
           
FD.FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)
           
HTOTAL.HTotalHeader(Address dest, Address src)
           
MERGE3.CoordAnnouncement(Address coord)
           
MERGEFAST.MergefastHeader(Address coord)
           
PingRsp(Address own_addr, Address coord_addr, boolean is_server)
           
SEQUENCER.SequencerHeader(byte type, Address original_sender, long seqno)
           
TP.ProtocolAdapter(java.lang.String cluster_name, java.lang.String transport_name, Protocol up, Protocol down, java.lang.String pattern, Address addr)
           
 

Constructor parameters in org.jgroups.protocols with type arguments of type Address
DISCARD.DiscardHeader(java.util.Set<Address> ignoredAddresses)
           
FD_SOCK.FdHeader(byte type, java.util.Map<Address,IpAddress> cachedAddrs)
           
FD_SOCK.FdHeader(byte type, java.util.Set<Address> mbrs)
           
FD.FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)
           
 

Uses of Address in org.jgroups.protocols.pbcast
 

Methods in org.jgroups.protocols.pbcast that return Address
protected  Address GMS.determineCoordinator()
           
 Address GMS.GmsHeader.getMember()
           
 Address MergeData.getSender()
           
 

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

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

Constructors in org.jgroups.protocols.pbcast with parameters of type Address
GMS.GmsHeader(byte type, Address mbr)
          Used for JOIN_REQ or LEAVE_REQ header
Gossip(Address obj, long id)
           
Gossip(Address obj, long id, Digest d, java.util.Vector not_seen)
           
MergeData(Address sender, View view, Digest digest)
           
NakAckHeader(byte type, long low, long high, Address sender)
           
STATE_TRANSFER.StateHeader(byte type, Address sender, long id, Digest digest)
           
STATE_TRANSFER.StateHeader(byte type, Address sender, long id, Digest digest, java.lang.String state_id)
           
STREAMING_STATE_TRANSFER.StateHeader(byte type, Address sender, IpAddress bind_addr, Digest digest, java.lang.String state_id)
           
STREAMING_STATE_TRANSFER.StateHeader(byte type, Address sender, long id, Digest digest)
           
STREAMING_STATE_TRANSFER.StateHeader(byte type, Address sender, java.lang.String state_id)
           
 

Constructor parameters in org.jgroups.protocols.pbcast with type arguments of type Address
FLUSH.FlushHeader(byte type, long viewID, java.util.Collection<Address> flushView)
           
 

Uses of Address in org.jgroups.stack
 

Classes in org.jgroups.stack that implement Address
 class IpAddress
          Network-dependent address (Internet).
 

Fields in org.jgroups.stack declared as Address
 Address StateTransferInfo.target
           
 

Methods in org.jgroups.stack that return Address
 Address GossipData.getAddress()
           
 Address RouterStub.getLocalAddress()
           
 

Methods in org.jgroups.stack that return types with arguments of type Address
 java.util.List<Address> GossipClient.getMembers(java.lang.String group)
          Returns all members of a given group
 

Methods in org.jgroups.stack with parameters of type Address
 void AckMcastSenderWindow.ack(long seqno, Address sender)
          An ACK has been received from sender.
 void NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
           
 void NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
           
 void GossipClient.register(java.lang.String group, Address mbr)
          Adds the member to the given group.
 void AckMcastSenderWindow.remove(Address obj)
          Remove obj from all receiver sets and wake up retransmission thread.
 void 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 RouterStub.sendToSingleMember(Address dest, byte[] data, int offset, int length)
           
 void AckMcastSenderWindow.suspect(Address suspected)
          Process with address suspected is suspected: remove it from all receiver sets.
 void GossipClient.unregister(java.lang.String group, Address mbr)
           
 

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

Uses of Address in org.jgroups.util
 

Fields in org.jgroups.util with type parameters of type Address
protected  java.util.Map<Address,Digest.Entry> Digest.senders
          Map<Address, Entry>
 

Methods in org.jgroups.util that return Address
 Address Rsp.getSender()
           
static Address Util.readAddress(java.io.DataInputStream in)
           
 

Methods in org.jgroups.util that return types with arguments of type Address
static java.util.Vector<Address> Util.determineLeftMembers(java.util.Vector<Address> old_mbrs, java.util.Vector<Address> new_mbrs)
          Returns all members that left between 2 views.
 java.util.Set<java.util.Map.Entry<Address,Rsp>> RspList.entrySet()
           
 java.util.Map<Address,T> ResponseCollector.getResults()
           
 java.util.Map<Address,Digest.Entry> Digest.getSenders()
          Returns an unmodifiable map, so modifications will result in exceptions
 java.util.Map<Address,Digest.Entry> MutableDigest.getSenders()
           
 java.util.Vector<Address> RspList.getSuspectedMembers()
           
 java.util.Set<Address> RspList.keySet()
           
static java.util.Collection<Address> Util.readAddresses(java.io.DataInputStream in, java.lang.Class cl)
           
 

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

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

Constructors in org.jgroups.util with parameters of type Address
Digest(Address sender, long low, long highest_delivered)
           
Digest(Address sender, long low, long highest_delivered, long highest_received)
           
Rsp(Address sender)
           
Rsp(Address sender, boolean suspected)
           
Rsp(Address sender, java.lang.Object retval)
           
 

Constructor parameters in org.jgroups.util with type arguments of type Address
Digest(java.util.Map<Address,Digest.Entry> map)
          Creates a new digest from an existing map by copying the keys and values from map
MutableDigest(java.util.Map<Address,Digest.Entry> map)
           
ResponseCollector(java.util.Collection<Address> members)
           
 



Copyright ? 1998-2008 Bela Ban. All Rights Reserved.