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.protocols.ring Supports protocols in ring networks. 
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
           
 

Methods in org.jgroups that return Address
 Address ViewId.getCoordAddress()
          returns the address of the member that issued this view
 Address View.getCreator()
          returns the creator of this view if this view was created with the empty constructur, null will be returned
 Address Message.getDest()
           
abstract  Address Channel.getLocalAddress()
          Returns the channel's own address.
 Address JChannel.getLocalAddress()
          returns the local address of the channel returns null if the channel is closed
 Address Message.getSrc()
           
 

Methods in org.jgroups with parameters of type Address
 void Membership.add(Address new_member)
          Adds a new member to this membership.
 void ChannelListener.channelReconnected(Address addr)
           
abstract  boolean 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 JChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
           
 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
abstract  boolean Channel.getState(Address target, long timeout)
          Retrieve the state of the group.
 boolean JChannel.getState(Address target, long timeout)
          Retrieves the current group state.
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)
          Retrieves a substate (or partial state) from the target.
protected  void Channel.notifyChannelReconnected(Address addr)
           
 void Membership.remove(Address old_member)
          removes an member from the membership.
abstract  void Channel.send(Address dst, Address src, java.io.Serializable obj)
          Helper method.
 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
 void Message.setDest(Address new_dest)
           
 void Message.setSrc(Address new_src)
           
 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)
           
 void ReceiverAdapter.suspect(Address suspected_mbr)
           
 

Constructors in org.jgroups with parameters of type Address
MergeView(Address creator, long id, java.util.Vector members, java.util.Vector subgroups)
          Creates a new view
Message(Address dest)
          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 members)
          Creates a new view
ViewId(Address coord_addr)
          Creates a ViewID with the coordinator address and a Lamport timestamp of 0.
ViewId(Address coord_addr, long id)
          Creates a ViewID with the coordinator address and the given Lamport timestamp.
 

Uses of Address in org.jgroups.blocks
 

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

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

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, 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)
           
 void RpcDispatcher.channelReconnected(Address new_addr)
           
 void BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
           
 void BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
           
static Xid Xid.create(Address creator)
           
static Xid Xid.create(Address creator, int mode)
           
 java.io.Serializable NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)
          Determines the coordinator and asks it for its cache.
 void NotificationBus.Consumer.memberJoined(Address mbr)
           
 void NotificationBus.Consumer.memberLeft(Address mbr)
           
protected  void PullPushAdapter.notifySuspect(Address suspected_mbr)
           
 void 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 RspCollector.receiveResponse(java.lang.Object response_value, Address sende)
           
 void GroupRequest.receiveResponse(java.lang.Object response_value, Address sender)
          Callback (called by RequestCorrelator or Transport).
 void RequestCorrelator.receiveSuspect(Address mbr)
          Event.SUSPECT event received from a layer below.
 void BasicConnectionTable.remove(Address addr)
          Remove addrfrom connection table.
protected  void ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
           
 RspList ReplicationManager.send(Address dest, byte[] data, boolean synchronous, long synchronous_timeout, Xid transaction, byte[] lock_info, long lock_acquisition_timeout, long lock_lease_timeout, boolean use_locks)
          Sends a request to all members of the group.
 void 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 DistributedHashtable.suspect(Address suspected_mbr)
          Called when a member is suspected
 void RspCollector.suspect(Address mbr)
           
 void VotingAdapter.suspect(Address suspected)
          Callback for notification that one node is suspected
 void DistributedLockManager.suspect(Address suspected_mbr)
           
 void DistributedQueue.suspect(Address suspected_mbr)
          Called when a member is suspected
 void DistributedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 void GroupRequest.suspect(Address suspected_member)
          Callback (called by RequestCorrelator or Transport).
 void MembershipListenerAdapter.suspect(Address suspected_mbr)
          Notify membership listener that some node was suspected.
 void NotificationBus.suspect(Address suspected_mbr)
           
 void ReplicatedHashtable.suspect(Address suspected_mbr)
          Called when a member is suspected
 void ReplicatedTree.suspect(Address suspected_mbr)
          Called when a member is suspected
 

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)
           
 

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

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 GraphPanel.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
           
 void Whiteboard.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 TP.getLocalAddress()
           
 Address TPMBean.getLocalAddress()
           
 

Uses of Address in org.jgroups.mux
 

Methods in org.jgroups.mux that return Address
 Address MuxChannel.getLocalAddress()
           
 Address Multiplexer.getStateProvider(Address preferredTarget, java.lang.String service_id)
          Returns an Address of a state provider for a given service_id.
 

Methods in org.jgroups.mux with parameters of type Address
 boolean MuxChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
           
 boolean MuxChannel.getState(Address target, long timeout)
           
 boolean MuxChannel.getState(Address target, java.lang.String state_id, long timeout)
           
 boolean Multiplexer.getState(Address target, java.lang.String id, long timeout)
           
 Address Multiplexer.getStateProvider(Address preferredTarget, java.lang.String service_id)
          Returns an Address of a state provider for a given service_id.
 void MuxChannel.send(Address dst, Address src, java.io.Serializable obj)
           
 void Multiplexer.sendServiceDownMessage(java.lang.String service, Address host, boolean bypassFlush)
           
 void Multiplexer.sendServiceUpMessage(java.lang.String service, Address host, boolean bypassFlush)
           
 

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.
 class WanPipeAddress
          Logical address for a WAN pipe (logical link)
 

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

Methods in org.jgroups.protocols that return Address
protected  Address GMS.determineCoordinator()
           
 Address PingRsp.getAddress()
           
 Address PingRsp.getCoordAddress()
           
 Address SEQUENCER.getCoordinator()
           
protected  Address ENCRYPT.getKeyServerAddr()
           
protected  Address ENCRYPT.getLocal_addr()
           
protected  Address TOTAL_OLD.getLocalAddr()
          returns the Address of the local machine returns null if it is not known yet
 Address SEQUENCER.getLocalAddress()
           
 Address TP.getLocalAddress()
           
 Address SEQUENCER.SequencerHeader.getOriginalSender()
           
protected  Address TOTAL_OLD.getSequencer()
          returns the address of the current sequencer of the group returns null if the list of members is empty
 

Methods in org.jgroups.protocols with parameters of type Address
protected  void FD.Broadcaster.addSuspectedMember(Address mbr)
          Adds a suspected member.
 void FD.BroadcastTask.addSuspectedMember(Address suspect)
           
abstract  boolean GmsImpl.handleJoin(Address mbr)
           
 boolean CoordGmsImpl.handleJoin(Address mbr)
           
 boolean ParticipantGmsImpl.handleJoin(Address mbr)
           
 boolean ClientGmsImpl.handleJoin(Address mbr)
           
 boolean GMS.handleJoin(Address mbr)
           
abstract  void GmsImpl.handleLeave(Address mbr, boolean suspected)
           
 void CoordGmsImpl.handleLeave(Address mbr, boolean suspected)
          Exclude mbr from the membership.
 void ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
           
 void ClientGmsImpl.handleLeave(Address mbr, boolean suspected)
          Returns false.
 void GMS.handleLeave(Address mbr, boolean suspected)
           
abstract  void GmsImpl.handleSuspect(Address mbr)
           
 void CoordGmsImpl.handleSuspect(Address mbr)
           
 void ParticipantGmsImpl.handleSuspect(Address mbr)
           
 void ClientGmsImpl.handleSuspect(Address mbr)
          Returns immediately.
 void GMS.handleSuspect(Address mbr)
           
 int VectorTime.indexOf(Address member)
          Returns index of the given member represented by it's Address
abstract  void GmsImpl.join(Address mbr)
           
 void CoordGmsImpl.join(Address mbr)
           
 void ParticipantGmsImpl.join(Address mbr)
           
 void ClientGmsImpl.join(Address mbr)
          Will generate a CONNECT_OK event.
 void GMS.join(Address mbr)
           
abstract  void GmsImpl.leave(Address mbr)
           
 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)
           
 void GMS.leave(Address mbr)
           
 void Discovery.localAddressSet(Address addr)
          Called after local_addr was set
 void PING.localAddressSet(Address addr)
           
 void TCPPING.localAddressSet(Address addr)
           
abstract  void TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
           
 void UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
           
 void BasicTCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
           
abstract  void TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
           
 void UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
           
 void BasicTCP.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
 void SMACK.retransmit(long seqno, Message msg, Address dest)
           
 void TCP.send(Address dest, byte[] data, int offset, int length)
           
abstract  void BasicTCP.send(Address dest, byte[] data, int offset, int length)
           
 void TCP_NIO.send(Address dest, byte[] data, int offset, int length)
           
 int DEADLOCK.sendRequest(Address dest)
           
abstract  void TP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
          Send to all members in the group.
 void UDP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
           
 void BasicTCP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
           
protected  void ENCRYPT.setKeyServerAddr(Address keyServerAddr)
           
protected  void ENCRYPT.setLocal_addr(Address local_addr)
           
abstract  void GmsImpl.suspect(Address mbr)
           
 void CoordGmsImpl.suspect(Address mbr)
           
 void ParticipantGmsImpl.suspect(Address mbr)
           
 void ClientGmsImpl.suspect(Address mbr)
           
 void GMS.suspect(Address mbr)
           
 

Constructors in org.jgroups.protocols with parameters of type Address
FD_SOCK.FdHeader(byte type, Address mbr)
           
FD.FdHeader(byte type, java.util.Vector 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)
           
VectorTime(Address owner)
          Constructs VectorTime given an adress of a owning group member
 

Uses of Address in org.jgroups.protocols.pbcast
 

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

Methods in org.jgroups.protocols.pbcast with parameters of type Address
 void Digest.add(Address sender, long low_seqno, long high_seqno)
           
 void Digest.add(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
           
 void Gossip.addToSeenList(Address mbr)
           
 boolean Digest.contains(Address sender)
           
 Digest.Entry Digest.get(Address sender)
           
 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)
           
 long Digest.highSeqnoAt(Address sender)
           
 long Digest.highSeqnoSeenAt(Address sender)
           
 void Digest.incrementHighSeqno(Address sender)
          Increments the sender's high_seqno by 1.
abstract  void GmsImpl.join(Address mbr)
           
 void ClientGmsImpl.join(Address mbr)
          Joins this process to a group.
 void CoordGmsImpl.join(Address mbr)
           
 void ParticipantGmsImpl.join(Address mbr)
           
abstract  void GmsImpl.leave(Address mbr)
           
 void ClientGmsImpl.leave(Address mbr)
           
 void CoordGmsImpl.leave(Address mbr)
          The coordinator itself wants to leave the group
 void ParticipantGmsImpl.leave(Address mbr)
          Loop: determine coord.
 long Digest.lowSeqnoAt(Address sender)
           
 void Digest.merge(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
          Similar to add(), but if the sender already exists, its seqnos will be modified (no new entry) as follows: this.low_seqno=min(this.low_seqno, low_seqno) this.high_seqno=max(this.high_seqno, high_seqno) this.high_seqno_seen=max(this.high_seqno_seen, high_seqno_seen) If the sender doesn not exist, a new entry will be added (provided there is enough space)
 void Gossip.removeFromNotSeenList(Address mbr)
          Removes obj from not_seen list
 void Digest.resetAt(Address sender)
          Resets the seqnos for the sender at 'index' to 0.
 void NAKACK.retransmit(long first_seqno, long last_seqno, Address sender)
          Implementation of Retransmitter.RetransmitCommand.
protected  void GmsImpl.sendMergeRejectedResponse(Address sender, ViewId merge_id)
           
 boolean Digest.set(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
           
 void Digest.setHighestDeliveredAndSeenSeqnos(Address sender, long high_seqno, long high_seqno_seen)
           
 void Digest.setHighSeqnoAt(Address sender, long high_seqno)
           
 void Digest.setHighSeqnoSeenAt(Address sender, long high_seqno_seen)
           
abstract  void GmsImpl.suspect(Address mbr)
           
 void ClientGmsImpl.suspect(Address mbr)
           
 void CoordGmsImpl.suspect(Address mbr)
           
 void ParticipantGmsImpl.suspect(Address mbr)
           
abstract  void GmsImpl.unsuspect(Address mbr)
           
 void ClientGmsImpl.unsuspect(Address mbr)
           
 void CoordGmsImpl.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)
 

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)
           
 

Uses of Address in org.jgroups.protocols.ring
 

Fields in org.jgroups.protocols.ring declared as Address
protected  Address TokenLostException.failedNode
           
 

Methods in org.jgroups.protocols.ring that return Address
 Address RingToken.getAruId()
           
 Address TokenLostException.getFailedNode()
           
 

Methods in org.jgroups.protocols.ring with parameters of type Address
 void RingToken.addRecoveredMember(Address member)
           
 void RingToken.setAruId(Address address)
           
 

Constructors in org.jgroups.protocols.ring with parameters of type Address
TcpRingNode(RpcProtocol owner, Address memberAddress)
           
TokenLostException(java.lang.String message, java.lang.Throwable cause, Address failedNode, int mode)
           
UdpRingNode(RpcProtocol owner, Address memberAddress)
           
 

Uses of Address in org.jgroups.stack
 

Classes in org.jgroups.stack that implement Address
 class IpAddress
          Network-dependent address (Internet).
 class LogicalAddress
          Logical address that spans the lifetime of a member.
 

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 with parameters of type Address
 void AckMcastSenderWindow.ack(long seqno, Address sender)
          An ACK has been received from sender.
 java.lang.Object RpcProtocol.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
           
 java.lang.Object RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, int mode, long timeout)
           
 java.lang.Object RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
           
 java.lang.Object RpcProtocol.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
           
 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 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, long[] interval, TimeScheduler sched, Address sender)
           
GossipData(byte type, java.lang.String group, Address addr, java.util.List mbrs)
           
NakReceiverWindow(Address sender, long start_seqno)
          Creates a new instance without a retransmission thread
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno)
          Creates a new instance with the given retransmit command
NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno, TimeScheduler sched)
          Creates a new instance with the given retransmit command
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd)
          Create a new Retransmitter associated with the given sender address
Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched)
          Create a new Retransmitter associated with the given sender address
StateTransferInfo(Address 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
 

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

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

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



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