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.blocks.locking   
org.jgroups.blocks.mux   
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.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
 

Subinterfaces of Address in org.jgroups
 interface PhysicalAddress
          Represents a physical (as opposed to logical) address
 

Fields in org.jgroups declared as Address
protected  Address Message.dest_addr
           
protected  Address JChannel.local_addr
           
static Address Global.NULL_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 JChannel.getAddress()
          Returns the local address of the channel (null if the channel is closed)
abstract  Address Channel.getAddress()
          Returns the channel's own 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()
          Deprecated. 
abstract  Address Channel.getLocalAddress()
          Deprecated. Use Channel.getAddress() instead
 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... mbrs)
           
 void Membership.add(Address new_member)
          Adds a new member to this membership.
 void ChannelListenerAdapter.channelReconnected(Address addr)
           
 void ChannelListener.channelReconnected(Address addr)
          Deprecated. 
 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
 void JChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
          Connects this channel to a group and gets a state from a specified state provider.
 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
 java.lang.String JChannel.getName(Address member)
           
abstract  java.lang.String Channel.getName(Address member)
          Returns the logical name of a given 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.
 void Membership.remove(Address old_member)
          removes an member from the membership.
 void JChannel.send(Address dst, Address src, byte[] buf)
           
abstract  void Channel.send(Address dst, Address src, byte[] buf)
           
 void JChannel.send(Address dst, Address src, byte[] buf, int offset, int length)
           
abstract  void Channel.send(Address dst, Address src, byte[] buf, int offset, int length)
           
 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 mbr)
           
 void ExtendedReceiverAdapter.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 Message.writeToNoAddrs(Address src, java.io.DataOutputStream out)
          Writes the message to the output stream, but excludes the dest and src addresses unless the src address given as argument is different from the message's src address
 

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.lang.Object obj)
          Public constructor
View(Address creator, long id, java.util.Collection<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.Collection<Address> members)
          Creates a new view
View(ViewId vid, java.util.Collection<Address> members)
           
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 RequestCorrelator.local_addr
          The address of this group member
protected  Address MessageDispatcher.local_addr
           
protected  Address UnicastRequest.target
           
 

Fields in org.jgroups.blocks with type parameters of type Address
protected  java.util.Map<Address,V> AbstractConnectionMap.conns
           
 java.util.Collection<? extends Address> RequestCorrelator.MultiDestinationHeader.exclusion_list
          Contains a list of members who should not receive the request (others will drop).
protected  java.util.Collection<Address> MessageDispatcher.members
           
 

Methods in org.jgroups.blocks that return Address
 Address TCPConnectionMap.getLocalAddress()
           
 Address ReplicatedTree.getLocalAddress()
           
 Address ReplicatedHashMap.getLocalAddress()
           
 Address NotificationBus.getLocalAddress()
          Deprecated.  
 Address PartitionedHashMap.getLocalAddress()
           
 Address ReplCache.getLocalAddress()
           
 Address DistributedQueue.getLocalAddress()
           
 Address RequestCorrelator.getLocalAddress()
           
 Address BasicConnectionTable.getLocalAddress()
           
 Address PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership)
          Defines a hash function to pick the right node from the list of cluster nodes.
 Address PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
           
 Address PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key, java.util.List<Address> members)
           
 

Methods in org.jgroups.blocks that return types with arguments of type Address
 java.util.Collection<Address> RequestOptions.getExclusionList()
           
 java.util.Vector<Address> ReplicatedTree.getMembers()
           
 java.util.List<Address> ReplCache.HashFunction.hash(K key, short replication_count)
          Function that, given a key and a replication count, returns replication_count number of different addresses of nodes.
 java.util.List<Address> ReplCache.ConsistentHashFunction.hash(K key, short replication_count)
           
 

Methods in org.jgroups.blocks with parameters of type Address
 void AbstractConnectionMap.addConnection(Address address, V conn)
           
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, MethodCall call)
          Deprecated. 
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
          Deprecated. 
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)
          Deprecated. 
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, MethodCall call, RequestOptions options)
           
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
          Deprecated. 
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options)
           
 java.lang.Object RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
          Deprecated. 
<T> NotifyingFuture<T>
RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call)
          Deprecated. 
<T> NotifyingFuture<T>
RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)
          Deprecated. 
<T> NotifyingFuture<T>
RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options)
           
 void RpcDispatcher.channelReconnected(Address new_addr)
           
 void BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
           
 void AbstractConnectionMap.ConnectionMapListener.connectionClosed(Address address)
           
 boolean TCPConnectionMap.connectionEstablishedTo(Address addr)
           
 void BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
           
 void AbstractConnectionMap.ConnectionMapListener.connectionOpened(Address address, V conn)
           
protected  RequestCorrelator MessageDispatcher.createRequestCorrelator(java.lang.Object transport, RequestHandler handler, Address local_addr)
           
 java.io.Serializable NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)
          Deprecated. Determines the coordinator and asks it for its cache.
 V ConnectionMap.getConnection(Address dest)
           
 boolean AbstractConnectionMap.hasConnection(Address address)
           
 boolean AbstractConnectionMap.hasOpenConnection(Address address)
           
 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 AbstractConnectionMap.notifyConnectionClosed(Address address)
           
protected  void AbstractConnectionMap.notifyConnectionOpened(Address address, V conn)
           
protected  void PullPushAdapter.notifySuspect(Address suspected_mbr)
          Deprecated.  
 void TCPConnectionMap.receive(Address sender, byte[] data, int offset, int length)
          Calls the receiver callback.
 void TCPConnectionMap.Receiver.receive(Address sender, byte[] data, int offset, int length)
           
 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 UnicastRequest.receiveResponse(java.lang.Object response_value, Address sender)
          Callback (called by RequestCorrelator or Transport).
 void MultiRequest.receiveResponse(java.lang.Object response_value, Address sender)
          Callback (called by RequestCorrelator or Transport).
 void RspCollector.receiveResponse(java.lang.Object response_value, Address sender)
           
abstract  void Request.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.
 void AbstractConnectionMap.removeConnection(Address address)
           
protected  void ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
           
 void TCPConnectionMap.send(Address dest, byte[] data, int offset, int length)
           
 void BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
           
 void NotificationBus.sendNotification(Address dest, java.io.Serializable n)
          Deprecated. Pack the argument in a Info, serialize that one into the message buffer and send the message
 void RequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll)
          Sends a request to a single destination
 RequestOptions RequestOptions.setExclusionList(Address... mbrs)
           
 void RequestCorrelator.setLocalAddress(Address local_addr)
           
 void GroupRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void UnicastRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void ReplicatedHashMap.suspect(Address suspected_mbr)
          Called when a member is suspected
 void NotificationBus.suspect(Address suspected_mbr)
          Deprecated.  
 void MultiRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void PartitionedHashMap.suspect(Address suspected_mbr)
           
 void PartitionedHashMap.ArrayBasedConsistentHashFunction.suspect(Address suspected_mbr)
           
 void MembershipListenerAdapter.suspect(Address suspected_mbr)
          Notify membership listener that some node was suspected.
 void ReplCache.suspect(Address suspected_mbr)
           
 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 RspCollector.suspect(Address mbr)
           
abstract  void Request.suspect(Address mbr)
           
 void DistributedLockManager.suspect(Address suspected_mbr)
          Deprecated.  
 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
 RspList RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options)
          Invokes a method in all members contained in dests (or all members if dests is null).
 RspList RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, RequestOptions options)
           
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, MethodCall method_call, int mode, long timeout)
          Deprecated. 
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
          Deprecated. 
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout, boolean use_anycasting)
          Deprecated. 
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout, boolean use_anycasting, RspFilter filter)
          Deprecated. 
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
          Deprecated. 
 RspList RpcDispatcher.callRemoteMethods(java.util.Vector<Address> dests, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout, boolean use_anycasting)
          Deprecated. 
 NotifyingFuture<RspList> RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options)
           
 NotifyingFuture<RspList> RpcDispatcher.callRemoteMethodsWithFuture(java.util.Vector<Address> dests, MethodCall method_call)
          Deprecated. 
 NotifyingFuture<RspList> RpcDispatcher.callRemoteMethodsWithFuture(java.util.Vector<Address> dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob, RspFilter filter)
          Deprecated. 
protected  GroupRequest MessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
           
 RspList MessageDispatcher.castMessage(java.util.Collection<Address> dests, Message msg, RequestOptions options)
          Sends a message to the members listed in dests.
 NotifyingFuture<RspList> MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options)
           
 Address PartitionedHashMap.HashFunction.hash(K key, java.util.List<Address> membership)
          Defines a hash function to pick the right node from the list of cluster nodes.
 Address PartitionedHashMap.ConsistentHashFunction.hash(K key, java.util.List<Address> members)
           
 Address PartitionedHashMap.ArrayBasedConsistentHashFunction.hash(K key, java.util.List<Address> members)
           
 void ReplCache.HashFunction.installNodes(java.util.List<Address> nodes)
          When the topology changes, this method will be called.
 void ReplCache.ConsistentHashFunction.installNodes(java.util.List<Address> new_nodes)
           
 void TCPConnectionMap.retainAll(java.util.Collection<Address> members)
           
 void BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs)
          Removes all connections from ConnectionTable which are not in current_mbrs
 void AbstractConnectionMap.retainAll(java.util.Collection<Address> current_mbrs)
          Removes all connections which are not in current_mbrs
 void RequestCorrelator.sendRequest(long id, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)
          Sends a request to a group.
 void RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)
           
 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
GroupRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)
           
MultiRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options, int expected_mbrs)
           
RequestCorrelator(java.lang.Object transport, RequestHandler handler, Address local_addr)
           
RequestCorrelator(short id, java.lang.Object transport, RequestHandler handler, Address local_addr)
           
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr)
          Deprecated. 
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr, boolean concurrent_processing)
          Deprecated. 
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)
          Deprecated. 
RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)
          Deprecated. 
UnicastRequest(Message m, RequestCorrelator corr, Address target, RequestOptions options)
           
UnicastRequest(Message m, Transport transport, Address target, RequestOptions options)
           
 

Constructor parameters in org.jgroups.blocks with type arguments of type Address
GroupRequest(Message msg, RequestCorrelator corr, java.util.Collection<Address> targets, RequestOptions options)
           
GroupRequest(Message m, Transport transport, java.util.Collection<Address> mbrs, RequestOptions options)
           
MultiRequest(Message m, RequestCorrelator corr, java.util.Collection<Address> mbrs, RequestOptions options, int expected_mbrs)
           
MultiRequest(Message m, Transport transport, java.util.Collection<Address> mbrs, RequestOptions options, int expected_mbrs)
           
RequestCorrelator.MultiDestinationHeader(byte type, long id, boolean rsp_expected, short corr_id, java.util.Collection<Address> exclusion_list)
           
 

Uses of Address in org.jgroups.blocks.locking
 

Fields in org.jgroups.blocks.locking declared as Address
protected  Address Owner.address
           
 

Methods in org.jgroups.blocks.locking that return Address
 Address Owner.getAddress()
           
 

Constructors in org.jgroups.blocks.locking with parameters of type Address
Owner(Address address, long thread_id)
           
 

Uses of Address in org.jgroups.blocks.mux
 

Methods in org.jgroups.blocks.mux with parameters of type Address
protected  RequestCorrelator MuxRpcDispatcher.createRequestCorrelator(java.lang.Object transport, RequestHandler handler, Address localAddr)
           
protected  RequestCorrelator MuxMessageDispatcher.createRequestCorrelator(java.lang.Object transport, RequestHandler handler, Address localAddr)
           
 boolean NoMuxHandlerRspFilter.isAcceptable(java.lang.Object response, Address sender)
           
 void MuxRequestCorrelator.sendUnicastRequest(long id, Address target, Message msg, RspCollector coll)
           
 

Method parameters in org.jgroups.blocks.mux with type arguments of type Address
protected  GroupRequest MuxRpcDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
           
protected  GroupRequest MuxMessageDispatcher.cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
           
 void MuxRequestCorrelator.sendRequest(long requestId, java.util.Collection<Address> dest_mbrs, Message msg, RspCollector coll, RequestOptions options)
           
 

Constructors in org.jgroups.blocks.mux with parameters of type Address
MuxRequestCorrelator(short id, java.lang.Object transport, RequestHandler handler, Address localAddr)
           
 

Uses of Address in org.jgroups.debug
 

Methods in org.jgroups.debug that return Address
 Address Simulator.getLocalAddress()
           
 

Methods in org.jgroups.debug with parameters of type Address
 void Simulator.addMember(Address addr)
           
 void Simulator.addMember(Address addr, Simulator s)
           
 boolean Simulator.checkForDropMessage(Message msg, Address dest)
           
 boolean Simulator.DropMessage.drop(Message msg, Address dest)
           
 boolean Simulator.receiverDropFault(Message msg, Address src)
           
 boolean Simulator.senderDropFault(Message msg, Address dest)
           
 void Simulator.setLocalAddress(Address addr)
           
 void Simulator.simulatePartition(Address[] partition)
           
 

Uses of Address in org.jgroups.demos
 

Fields in org.jgroups.demos declared as Address
protected  Address RelayDemoRpc.local_addr
           
 

Methods in org.jgroups.demos with parameters of type Address
 void Draw.channelReconnected(Address addr)
           
static java.lang.String RelayDemoRpc.handleMessage(java.lang.String msg, Address sender)
           
 void NotificationBusDemo.memberJoined(Address mbr)
           
 void NotificationBusDemo.memberLeft(Address mbr)
           
 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)
           
 

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

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

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)
          Deprecated.  
 boolean MuxChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
          Deprecated.  
 void MuxChannel.send(Address dst, Address src, java.io.Serializable obj)
          Deprecated.  
 

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
 

Fields in org.jgroups.protocols declared as Address
protected  Address Executing.Owner.address
           
protected  Address RELAY.coord
           
protected  Address CENTRAL_LOCK.coord
           
protected  Address CENTRAL_EXECUTOR.coord
           
protected  Address STOMP.local_addr
           
protected  Address SCOPE.local_addr
           
protected  Address RELAY.local_addr
           
protected  Address FD.local_addr
           
protected  Address DAISYCHAIN.local_addr
           
protected  Address Discovery.local_addr
           
protected  Address Locking.local_addr
           
protected  Address Executing.local_addr
           
protected  Address TP.local_addr
          The address (host and port) of this member.
protected  Address DAISYCHAIN.next
           
protected  Address RELAY.RelayHeader.original_sender
           
protected  Address FD.ping_dest
           
 

Fields in org.jgroups.protocols with type parameters of type Address
protected  java.util.Queue<Address> Executing._consumersAvailable
          This is stored on the coordinator side.
protected  java.util.Queue<Address> Executing._runRequests
          This is stored on the coordinator side.
protected  java.util.List<Address> CENTRAL_LOCK.backups
           
protected  java.util.List<Address> CENTRAL_EXECUTOR.backups
           
protected  java.util.Map<Address,java.lang.String> STOMP.endpoints
           
protected  java.util.List<Address> PEER_LOCK.PeerLock.grants
           
protected  LazyRemovalCache<Address,PhysicalAddress> TP.logical_addr_cache
          Cache which maintains mappings between logical and physical addresses.
protected  java.util.List<Address> FD.members
           
protected  java.util.Vector<Address> Discovery.members
           
protected  java.util.Set<Address> TP.members
          The members of this group (updated when a member joins or leaves).
protected  java.util.List<Address> FD.pingable_mbrs
          Members from which we select ping_dest.
protected static LazyRemovalCache.Printable<Address,PhysicalAddress> TP.print_function
           
protected  java.util.concurrent.ConcurrentMap<Address,java.util.concurrent.ConcurrentMap<java.lang.Short,SCOPE.MessageQueue>> SCOPE.queues
          Used to find the correct AckReceiverWindow on message reception and deliver it in the right order
protected  java.util.Map<Address,FlowControl.Credit> FlowControl.received
          Keeps track of credits per member at the receiver.
protected  java.util.Map<Address,FlowControl.Credit> UFC.sent
          Map: keys are members, values are credits left.
protected  BoundedList<Address> FD.suspect_history
           
protected  java.util.Set<Address> FD_SOCK.suspected_mbrs
           
protected  java.util.Set<Address> FD_ALL.suspected_mbrs
           
protected  java.util.Map<Address,java.lang.String> RELAY.ViewData.uuids
           
protected  AgeOutCache<Address> TP.who_has_cache
          Cache keeping track of WHO_HAS requests for physical addresses (given a logical address) and expiring them after 5000ms
 

Methods in org.jgroups.protocols that return Address
 Address PingData.getAddress()
           
 Address Executing.Owner.getAddress()
           
 Address TP.ProtocolAdapter.getAddress()
           
 Address CENTRAL_LOCK.getCoord()
           
 Address CENTRAL_EXECUTOR.getCoord()
           
 Address PingData.getCoordAddress()
           
 Address SEQUENCER.getCoordinator()
           
protected  Address ENCRYPT.getKeyServerAddr()
           
protected  Address ENCRYPT.getLocal_addr()
           
 Address SEQUENCER.getLocalAddress()
           
 Address SEQUENCER.SequencerHeader.getOriginalSender()
           
 

Methods in org.jgroups.protocols that return types with arguments of type Address
 AgeOutCache<Address> UNICAST2.getAgeOutCache()
           
 AgeOutCache<Address> UNICAST.getAgeOutCache()
           
 java.util.Collection<Address> PingData.getMembers()
           
 java.util.Set<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 TP.addPhysicalAddressToCache(Address logical_addr, PhysicalAddress physical_addr)
           
protected  java.lang.String FILE_PING.addressAsString(Address address)
           
protected  void FD.Broadcaster.addSuspectedMember(Address mbr)
          Adds a suspected member.
 void FD.BroadcastTask.addSuspectedMember(Address suspect)
           
protected  long FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map, Address sender, int length)
          Check whether sender has enough credits left.
 void FRAG2.clearFragmentsFor(Address mbr)
           
 void SCOPE.clearQueue(Address member)
           
 void TUNNEL.TUNNELPolicy.connect(java.util.List<RouterStub> stubs, java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs)
           
protected  void TCPGOSSIP.connect(RouterStub stub, java.lang.String group, Address logical_addr)
           
protected  void TCPGOSSIP.connectAllStubs(java.lang.String group, Address logical_addr)
           
static RELAY.RelayHeader RELAY.RelayHeader.createDisseminateHeader(Address original_sender)
           
 void TCPPING.discoveryRequestReceived(Address sender, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)
           
 void Discovery.discoveryRequestReceived(Address sender, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)
           
protected  void TP.dispatchToThreadPool(java.util.concurrent.Executor pool, Address sender, byte[] data, int offset, int length)
           
protected  void TP.doSend(Buffer buf, Address dest, boolean multicast)
           
 void UNICAST2.expired(Address key)
          Called by AgeOutCache, to removed expired connections
 void UNICAST.expired(Address key)
          Called by AgeOutCache, to removed expired connections
protected  SCOPE.MessageQueue SCOPE.getOrCreateQueue(Address sender, short scope)
           
protected  PhysicalAddress TP.getPhysicalAddressFromCache(Address logical_addr)
           
protected  void Executing.handleConsumerFoundResponse(Address consumer)
           
protected  void Executing.handleConsumerReadyRequest(Address source)
           
protected  void UFC.handleCredit(Address sender, long increase)
           
protected  void MFC.handleCredit(Address sender, long increase)
           
protected abstract  void FlowControl.handleCredit(Address sender, long increase)
           
protected  void FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
           
protected  java.lang.Object UFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
           
protected  java.lang.Object MFC.handleDownMessage(Event evt, Message msg, Address dest, int length)
           
protected abstract  java.lang.Object FlowControl.handleDownMessage(Event evt, Message msg, Address dest, int length)
           
protected  void Executing.handleExceptionResponse(Address source, Executing.Request req)
           
protected  void Executing.handleInterruptRequest(Address source, short requestId)
           
protected  void PEER_LOCK.PeerLock.handleLockGrantedResponse(Owner owner, Address sender)
           
protected  void Locking.ClientLock.handleLockGrantedResponse(Owner owner, Address sender)
           
protected  void Locking.handleLockGrantedResponse(java.lang.String lock_name, Owner owner, Address sender)
           
protected  void Executing.handleNewConsumer(Address sender)
           
protected  void Executing.handleNewRunRequest(Address sender)
           
protected  void Executing.handleRemoveConsumer(Address sender)
           
protected  void Executing.handleRemoveRunRequest(Address sender)
           
protected  void Executing.handleTaskRejectedResponse(Address source, short requestId)
           
protected  void Executing.handleTaskRequest(Address source)
           
protected  void Executing.handleTaskSubmittedRequest(java.lang.Runnable runnable, Address source, short requestId)
           
protected  void Executing.handleValueResponse(Address source, Executing.Request req)
           
protected  boolean RELAY.isLocal(Address dest)
          Does the payload match the 'site' ID.
 void BasicTCP.receive(Address sender, byte[] data, int offset, int length)
          ConnectionMap.Receiver interface
protected  void TP.receive(Address sender, byte[] data, int offset, int length)
          Subclasses must call this method when a unicast or multicast message has been received.
protected  void TP.registerLocalAddress(Address addr)
          Associates the address with the physical address fetched from the cache
protected  void S3_PING.remove(java.lang.String clustername, Address addr)
           
protected  void JDBC_PING.remove(java.lang.String clustername, Address addr)
           
protected  void FILE_PING.remove(java.lang.String clustername, Address addr)
           
 void UNICAST2.removeConnection(Address mbr)
          Removes and resets from connection table (which is already locked).
 void UNICAST.removeConnection(Address mbr)
          Removes and resets from connection table (which is already locked).
 void DISCARD.removeIgnoredMember(Address member)
           
protected  void TP.removeLogicalAddressFromCache(Address logical_addr)
           
 void SCOPE.removeScope(Address member, short scope)
           
 void UNICAST2.retransmit(long first_seqno, long last_seqno, Address sender)
           
 void SMACK.retransmit(long seqno, Message msg, Address dest)
           
 void TCP_NIO.send(Address dest, byte[] data, int offset, int length)
           
 void TCP.send(Address dest, byte[] data, int offset, int length)
           
abstract  void BasicTCP.send(Address dest, byte[] data, int offset, int length)
           
protected  void TUNNEL.send(Message msg, Address dest, boolean multicast)
           
protected  void TP.send(Message msg, Address dest, boolean multicast)
          Serializes and sends a message.
protected  void CENTRAL_LOCK.sendCreateLockRequest(Address dest, java.lang.String lock_name, Owner owner)
           
protected  void FlowControl.sendCredit(Address dest, long credits)
           
protected  void FlowControl.sendCreditRequest(Address dest, java.lang.Long credits_needed)
          We cannot send this request as OOB messages, as the credit request needs to queue up behind the regular messages; if a receiver cannot process the regular messages, that is a sign that the sender should be throttled !
protected  void CENTRAL_LOCK.sendDeleteLockRequest(Address dest, java.lang.String lock_name)
           
protected  void AUTH.sendJoinRejectionMessage(Address dest, java.lang.String error_msg)
           
protected  void AUTH.sendMergeRejectionMessage(Address dest, java.lang.String error_msg)
           
protected  void CENTRAL_EXECUTOR.sendNewConsumerRequest(Address sender)
           
protected abstract  void Executing.sendNewConsumerRequest(Address source)
           
protected  void CENTRAL_EXECUTOR.sendNewRunRequest(Address sender)
           
protected abstract  void Executing.sendNewRunRequest(Address source)
           
protected  void AUTH.sendRejectionMessage(byte type, Address dest, java.lang.String error_msg)
           
protected  void CENTRAL_EXECUTOR.sendRemoveConsumerRequest(Address sender)
           
protected abstract  void Executing.sendRemoveConsumerRequest(Address source)
           
protected  void CENTRAL_EXECUTOR.sendRemoveRunRequest(Address sender)
           
protected abstract  void Executing.sendRemoveRunRequest(Address source)
           
protected  void Executing.sendRequest(Address dest, Executing.Type type, short requestId, java.lang.Object object)
           
protected  void Locking.sendRequest(Address dest, Locking.Type type, java.lang.String lock_name, Owner owner, long timeout, boolean is_trylock)
           
protected  void UNICAST2.sendStableMessage(Address dest, long low, long high)
           
protected  void SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
           
protected  void TP.sendToSingleMember(Address dest, byte[] buf, int offset, int length)
           
 void TUNNEL.TUNNELPolicy.sendToSingleMember(java.util.List<RouterStub> stubs, java.lang.String group, Address dest, byte[] data, int offset, int length)
           
protected  void RELAY.sendViewOnLocalCluster(Address dest, RELAY.ViewData data, boolean use_seperate_thread)
           
protected  void RELAY.sendViewOnLocalCluster(Address dest, View remote_view, View global_view, boolean use_seperate_thread)
           
protected  void TP.setInAllThreadFactories(java.lang.String cluster_name, Address local_address, java.lang.String pattern)
           
protected  void ENCRYPT.setKeyServerAddr(Address keyServerAddr)
           
protected  void ENCRYPT.setLocal_addr(Address local_addr)
           
 void DISCARD.setLocalAddress(Address localAddress)
           
protected  void UNICAST2.stable(Address sender, long highest_delivered, long highest_seen)
          Purge all messages in window for local_addr, which are <= low.
protected static void TP.writeMessageList(Address dest, Address src, java.util.List<Message> msgs, java.io.DataOutputStream dos, boolean multicast)
          Write a lits of messages with the same destination and *mostly* the same src addresses.
 

Method parameters in org.jgroups.protocols with type arguments of type Address
protected  long FlowControl.adjustCredit(java.util.Map<Address,FlowControl.Credit> map, Address sender, int length)
          Check whether sender has enough credits left.
protected  void CENTRAL_LOCK.copyLocksTo(java.util.List<Address> new_joiners)
           
protected  void CENTRAL_EXECUTOR.copyQueueTo(java.util.List<Address> new_joiners)
           
protected  void FlowControl.handleCreditRequest(java.util.Map<Address,FlowControl.Credit> map, Address sender, long requested_credits)
           
protected  void Locking.ServerLock.handleView(java.util.List<Address> members)
           
protected  void UFC.handleViewChange(java.util.Vector<Address> mbrs)
           
protected  void MFC.handleViewChange(java.util.Vector<Address> mbrs)
           
protected  void FlowControl.handleViewChange(java.util.Vector<Address> mbrs)
           
protected  View Discovery.makeView(java.util.Vector<Address> mbrs)
           
protected static java.lang.String FlowControl.printMap(java.util.Map<Address,FlowControl.Credit> m)
           
 void TCP_NIO.retainAll(java.util.Collection<Address> members)
           
 void TCP.retainAll(java.util.Collection<Address> members)
           
abstract  void BasicTCP.retainAll(java.util.Collection<Address> members)
           
protected  void PEER_LOCK.PeerLock.retainAll(java.util.List<Address> members)
           
 

Constructors in org.jgroups.protocols with parameters of type Address
Executing.Owner(Address address, short requestId)
           
FD_SOCK.FdHeader(byte type, Address mbr)
           
FD_SOCK.FdHeader(byte type, Address mbr, IpAddress sock_addr)
           
FD.FdHeader(byte type, java.util.Collection<Address> mbrs, Address from)
           
HTOTAL.HTotalHeader(Address dest, Address src)
           
PingData(Address own_addr, View view, boolean is_server)
           
PingData(Address own_addr, View view, boolean is_server, java.lang.String logical_name, java.util.Collection<PhysicalAddress> physical_addrs)
           
SEQUENCER.SequencerHeader(byte type, Address original_sender, long seqno)
           
TP.ProtocolAdapter(java.lang.String cluster_name, Address local_addr, short transport_id, Protocol up, Protocol down, java.lang.String pattern)
           
 

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.Collection<Address> mbrs, Address from)
           
 

Uses of Address in org.jgroups.protocols.pbcast
 

Fields in org.jgroups.protocols.pbcast declared as Address
protected  Address GMS.local_addr
           
 

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

Methods in org.jgroups.protocols.pbcast with parameters of type Address
static NakAckHeader NakAckHeader.createXmitRequestHeader(long low, long high, Address orginal_sender)
           
 double NAKACK.getSmoothedAverageRetransmissionTime(Address sender)
          Returns the smoothed average retransmission time for a given sender
 NakReceiverWindow NAKACK.getWindow(Address mbr)
          Please don't use this method; it is only provided for unit testing !
 void ServerGmsImpl.handleDigestResponse(Address sender, Digest digest)
           
 void Merger.handleDigestResponse(Address sender, Digest digest)
           
 void GmsImpl.handleDigestResponse(Address sender, Digest digest)
           
 void ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
          Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
 void Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
          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, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
           
 void CoordGmsImpl.join(Address mbr, boolean useFlushIfPresent)
           
 void ParticipantGmsImpl.join(Address mbr, boolean useFlushIfPresent)
           
 void ClientGmsImpl.join(Address address, boolean useFlushIfPresent)
           
abstract  void GmsImpl.join(Address mbr, boolean useFlushIfPresent)
           
 void CoordGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
           
 void ParticipantGmsImpl.joinWithStateTransfer(Address mbr, boolean useFlushIfPresent)
           
 void ClientGmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
           
abstract  void GmsImpl.joinWithStateTransfer(Address local_addr, boolean useFlushIfPresent)
           
 void CoordGmsImpl.leave(Address mbr)
          The coordinator itself wants to leave the group
 void ParticipantGmsImpl.leave(Address mbr)
          Loop: determine coord.
 void ClientGmsImpl.leave(Address mbr)
           
abstract  void GmsImpl.leave(Address mbr)
           
 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 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 Merger.sendMergeRejectedResponse(Address sender, MergeId merge_id)
           
protected  void GmsImpl.sendMergeRejectedResponse(Address sender, MergeId merge_id)
           
 void CoordGmsImpl.suspect(Address mbr)
           
 void ParticipantGmsImpl.suspect(Address mbr)
           
 void GmsImpl.suspect(Address mbr)
           
 void ParticipantGmsImpl.unsuspect(Address mbr)
          Removes previously suspected member from list of currently suspected members
 void GmsImpl.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)
 

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.
 void ServerGmsImpl.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
          Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
 void Merger.handleMergeRequest(Address sender, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
          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, MergeId merge_id, java.util.Collection<? extends Address> mbrs)
           
protected  boolean GmsImpl.iWouldBeCoordinator(java.util.Vector<Address> new_mbrs)
          Returns potential coordinator based on lexicographic ordering of member addresses.
 View GMS.makeView(java.util.Vector<Address> mbrs)
           
static View GMS.makeView(java.util.Vector<Address> mbrs, ViewId vid)
           
 void CoordGmsImpl.merge(java.util.Map<Address,View> views)
          Invoked upon receiving a MERGE event from the MERGE layer.
 void Merger.merge(java.util.Map<Address,View> views)
          Invoked upon receiving a MERGE event from the MERGE layer.
 void GmsImpl.merge(java.util.Map<Address,View> views)
           
static void Merger.sanitizeViews(java.util.Map<Address,View> map)
          Removes all members from a given view which don't have us in their view (https://jira.jboss.org/browse/JGRP-1061).
 

Constructors in org.jgroups.protocols.pbcast with parameters of type Address
GMS.GmsHeader(byte type, Address mbr)
           
GMS.GmsHeader(byte type, Address mbr, boolean useFlushIfPresent)
          Used for JOIN_REQ or LEAVE_REQ header
MergeData(Address sender, View view, Digest digest)
           
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<? extends Address> flushView)
           
GMS.GmsHeader(byte type, java.util.Collection<Address> mbrs)
           
 

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
protected  Address Retransmitter.Task.msg_sender
           
protected  Address Retransmitter.sender
           
 Address StateTransferInfo.target
           
 

Methods in org.jgroups.stack that return Address
 Address AddressGenerator.generateAddress()
           
 Address GossipData.getAddress()
           
 

Methods in org.jgroups.stack that return types with arguments of type Address
 java.util.List<Address> GossipData.getMembers()
           
 

Methods in org.jgroups.stack with parameters of type Address
 void AckMcastSenderWindow.ack(long seqno, Address sender)
          An ACK has been received from sender.
 int IpAddress.compareTo(Address o)
          implements the java.lang.Comparable interface
 void RouterStub.connect(java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs)
          Register this process with the router under group.
 void RouterStub.disconnect(java.lang.String group, Address addr)
           
 void NakReceiverWindow.Listener.messageGapDetected(long from, long to, Address src)
           
 void NakReceiverWindow.Listener.missingMessageReceived(long seqno, Address original_sender)
           
 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 RouterStub.sendToMember(java.lang.String group, Address dest, byte[] data, int offset, int length)
           
 void ProtocolStack.startStack(java.lang.String cluster_name, Address local_addr)
          Start all layers.
 void AckMcastSenderWindow.suspect(Address suspected)
          Process with address suspected is suspected: remove it from all receiver sets.
 

Method parameters in org.jgroups.stack with type arguments of type Address
 void GossipData.setMembers(java.util.List<Address> mbrs)
           
 

Constructors in org.jgroups.stack with parameters of type Address
AckSenderWindow(AckSenderWindow.RetransmitCommand com, Interval interval, TimeScheduler sched, Address sender)
           
DefaultRetransmitter.SeqnoTask(long seqno, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
           
DefaultRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
          Create a new Retransmitter associated with the given sender address
GossipData(byte type, java.lang.String group, Address addr)
           
GossipData(byte type, java.lang.String group, Address addr, byte[] buffer)
           
GossipData(byte type, java.lang.String group, Address addr, byte[] buffer, int offset, int length)
           
GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs)
           
GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs, java.util.List<PhysicalAddress> physical_addrs)
           
GossipData(byte type, java.lang.String group, Address addr, java.lang.String logical_name, java.util.List<PhysicalAddress> phys_addrs)
           
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, long lowest_seqno, TimeScheduler sched, boolean use_range_based_retransmitter)
           
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched, boolean use_range_based_retransmitter, int num_rows, int msgs_per_row, double resize_factor, long max_compaction_time, boolean automatic_purging)
           
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long highest_delivered_seqno, TimeScheduler sched)
          Creates a new instance with the given retransmit command
RangeBasedRetransmitter.RangeTask(Seqno range, Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
           
RangeBasedRetransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
          Create a new Retransmitter associated with the given sender address
Retransmitter.Task(Interval intervals, Retransmitter.RetransmitCommand cmd, Address msg_sender)
           
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
          Create a new Retransmitter associated with the given sender address
RouterStubManager(Protocol owner, java.lang.String channelName, Address logicalAddress, long interval)
           
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)
           
 

Constructor parameters in org.jgroups.stack with type arguments of type Address
GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs)
           
GossipData(byte type, java.lang.String group, Address addr, java.util.List<Address> mbrs, java.util.List<PhysicalAddress> physical_addrs)
           
 

Uses of Address in org.jgroups.util
 

Classes in org.jgroups.util that implement Address
 class AdditionalDataUUID
          Subclass of UUID which adds a string as payload.
 class PayloadUUID
          Subclass of UUID which adds a string as payload.
 class SingletonAddress
          Address with a cluster name.
 class TopologyUUID
          Subclass of UUID which adds 3 strings (siteId, rackId and machineId)as payload.
 class UUID
          Logical address which is unique over space and time.
 

Fields in org.jgroups.util declared as Address
protected  Address SingletonAddress.addr
           
 

Fields in org.jgroups.util with type parameters of type Address
protected static LazyRemovalCache<Address,java.lang.String> UUID.cache
          Keeps track of associations between logical addresses (UUIDs) and logical names
protected  java.util.Map<Address,java.lang.Long> CreditMap.credits
           
protected static LazyRemovalCache.Printable<Address,java.lang.String> UUID.print_function
           
protected  java.util.Map<Address,Digest.Entry> Digest.senders
          Map<Address, Entry>
 

Methods in org.jgroups.util that return Address
static Address Util.createRandomAddress()
           
static Address Util.createRandomAddress(java.lang.String name)
           
 Address SingletonAddress.getAddress()
           
 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.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns all members that left between 2 views.
static java.util.Collection<Address> Util.determineMergeCoords(java.util.Map<Address,View> map)
          This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static java.util.Collection<Address> Util.determineMergeParticipants(java.util.Map<Address,View> map)
          Determines the members which take part in a merge.
static java.util.List<Address> Util.determineNewMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns the members which joined between 2 subsequent views
 java.util.Set<java.util.Map.Entry<Address,Rsp>> RspList.entrySet()
           
static java.util.Map<Address,java.lang.String> UUID.getContents()
          Returns a copy of the cache's contents
 java.util.List<Tuple<Address,java.lang.Long>> CreditMap.getMembersWithCreditsLessThan(long min_credits)
           
 java.util.List<Address> CreditMap.getMembersWithInsufficientCredits(long credit_needed)
           
 java.util.Map<Address,T> ResponseCollector.getResults()
           
 java.util.Map<Address,Digest.Entry> MutableDigest.getSenders()
           
 java.util.Map<Address,Digest.Entry> Digest.getSenders()
          Returns an unmodifiable map, so modifications will result in exceptions
 java.util.Vector<Address> RspList.getSuspectedMembers()
           
 java.util.Set<Address> CreditMap.keys()
           
 java.util.Set<Address> RspList.keySet()
           
static java.util.List<Address> Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
           
static java.util.List<Address> Util.leftMembers(View one, View two)
          Returns a list of members which left from view one to two
static java.util.List<Address> Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
           
static java.util.Vector<Address> Util.pickSubset(java.util.Vector<Address> members, double subset_percentage)
          Selects a random subset of members according to subset_percentage and returns them.
static java.util.Collection<? extends 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)
           
static void UUID.add(Address uuid, java.lang.String logical_name)
           
 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)
           
 int SingletonAddress.compareTo(Address o)
           
 int UUID.compareTo(Address other)
          Compares this UUID with the specified UUID.
 boolean Digest.contains(Address sender)
           
static MergeId MergeId.create(Address addr)
           
static View Util.createView(Address coord, long id, Address... members)
           
static View Util.createView(Address coord, long id, Address... members)
           
protected  void CreditMap.decrementAndAdd(Address member, long new_credits)
          Decrements credits bytes from all elements and add new_credits to member (if non null).
 void FIFOMessageQueue.done(Address sender, K dest)
          Deprecated.  
static java.lang.String UUID.get(Address logical_addr)
           
 java.lang.Long CreditMap.get(Address member)
           
 Digest.Entry Digest.get(Address sender)
          Returns the Entry for the given sender.
 long SeqnoTable.getHighestReceived(Address member)
           
 long SeqnoTable.getNextToReceive(Address member)
           
static int Util.getRank(View view, Address addr)
           
 long Digest.highestDeliveredSeqnoAt(Address sender)
           
 long Digest.highestReceivedSeqnoAt(Address sender)
           
 void MutableDigest.incrementHighestDeliveredSeqno(Address sender)
          Increments the sender's highest delivered seqno by 1
static boolean Util.isCoordinator(View view, Address local_addr)
           
 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)
          Deprecated.  
 Rsp RspList.put(Address key, Rsp value)
           
 java.lang.Long CreditMap.putIfAbsent(Address key)
           
static void UUID.remove(Address addr)
           
 void SeqnoTable.remove(Address member)
           
 java.lang.Long CreditMap.remove(Address key)
           
 void ResponseCollector.remove(Address member)
           
 void CreditMap.replenish(Address sender, long new_credits)
           
 void ResponseCollector.reset(Address... members)
           
 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 void UUID.add(java.util.Map<Address,java.lang.String> map)
           
static byte[] Util.collectionToByteBuffer(java.util.Collection<Address> c)
           
static java.util.Vector<Address> Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns all members that left between 2 views.
static java.util.Vector<Address> Util.determineLeftMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns all members that left between 2 views.
static java.util.Collection<Address> Util.determineMergeCoords(java.util.Map<Address,View> map)
          This is the same or a subset of Util.determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.
static java.util.Collection<Address> Util.determineMergeParticipants(java.util.Map<Address,View> map)
          Determines the members which take part in a merge.
static java.util.List<Address> Util.determineNewMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns the members which joined between 2 subsequent views
static java.util.List<Address> Util.determineNewMembers(java.util.List<Address> old_mbrs, java.util.List<Address> new_mbrs)
          Returns the members which joined between 2 subsequent views
static java.util.List<Address> Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
           
static java.util.List<Address> Util.leftMembers(java.util.Collection<Address> old_list, java.util.Collection<Address> new_list)
           
static java.util.List<Address> Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
           
static java.util.List<Address> Util.newMembers(java.util.List<Address> old_list, java.util.List<Address> new_list)
           
static java.util.Vector<Address> Util.pickSubset(java.util.Vector<Address> members, double subset_percentage)
          Selects a random subset of members according to subset_percentage and returns them.
 void RspList.putAll(java.util.Map<? extends Address,? extends Rsp> m)
           
static void UUID.removeAll(java.util.Collection<Address> mbrs)
           
 void ResponseCollector.reset(java.util.Collection<Address> members)
           
 void AckCollector.reset(java.util.Collection<Address> members)
           
static void UUID.retainAll(java.util.Collection<Address> logical_addrs)
           
 boolean SeqnoTable.retainAll(java.util.Collection<Address> members)
           
static long Util.size(java.util.Collection<? extends Address> addrs)
          Returns the marshalled size of a Collection of Addresses.
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)
           
static void Util.writeAddresses(java.util.Collection<? extends Address> v, java.io.DataOutputStream out)
          Writes a Vector of Addresses.
 

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)
           
ResponseCollector(Address... members)
           
Rsp(Address sender)
           
Rsp(Address sender, boolean suspected)
           
Rsp(Address sender, T retval)
           
SingletonAddress(java.lang.String cluster_name, Address addr)
           
 

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-2009 Bela Ban / Red Hat. All Rights Reserved.