Uses of Interface org.jgroups.Address

Uses in package org.jgroups.demos.wb

Fields of type org.jgroups.Address

Address

Methods with parameter type org.jgroups.Address

void
GraphPanel.addNode(String lbl, Address addr, int xloc, int yloc)
void
Whiteboard.addNode(String lbl, Address addr, int xloc, int yloc)
void
Called whenever a member is suspected of having crashed, but has not yet been excluded.

Uses in package org.jgroups.protocols

Classes implementing org.jgroups.Address

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

Constructors with parameter type org.jgroups.Address

FD.FdHeader.FdHeader(byte type, Vector mbrs, Address from)
PingRsp.PingRsp(Address own_addr, Address coord_addr, boolean is_server)
Constructs VectorTime given an adress of a owning group member

Fields of type org.jgroups.Address

Address
Address
Address

Methods with parameter type org.jgroups.Address

boolean
boolean
boolean
boolean
boolean
void
ClientGmsImpl.handleLeave(Address mbr, boolean suspected)
Returns false.
void
CoordGmsImpl.handleLeave(Address mbr, boolean suspected)
Exclude mbr from the membership.
void
GmsImpl.handleLeave(Address mbr, boolean suspected)
void
GMS.handleLeave(Address mbr, boolean suspected)
void
ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
void
Returns immediately.
void
void
void
void
int
Returns index of the given member represented by it's Address
void
Will generate a CONNECT_OK event.
void
void
void
void
void
void
The coordinator itself wants to leave the group
void
void
void
Loop: determine coord.
void
Called after local_addr was set
void
void
Called after local_addr was set
void
TCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
TCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void
TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void
UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void
TCP.receive(Address sender, byte[] data, int offset, int length)
ConnectionTable.Receiver interface
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
SMACK.retransmit(long seqno, Message msg, Address dest)
Retranmit the given msg
int
void
TCP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
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
void
void
void
void
void
void

Methods with return type org.jgroups.Address

Address
Address
Address
Address
Address
returns the Address of the local machine returns null if it is not known yet
Address
Address
Address
returns the address of the current sequencer of the group returns null if the list of members is empty

Uses in package org.jgroups.jmx.protocols

Methods with return type org.jgroups.Address

Address
Address

Uses in package org.jgroups

Constructors with parameter type org.jgroups.Address

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

Fields of type org.jgroups.Address

Address
Address

Methods with parameter type org.jgroups.Address

void
Membership.add(Address new_member)
Adds a new member to this membership.
void
boolean
Returns true if the provided member belongs to this membership
boolean
returns true, if this view contains a certain member
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.
void
void
removes an member from the membership.
void
Channel.send(Address dst, Address src, Serializable obj)
Helper method.
void
JChannel.send(Address dst, Address src, Serializable obj)
creates a new message with the destination address, and the source address and the object as the message value
void
void
void
Called whenever a member is suspected of having crashed, but has not yet been excluded.
void
Called whenever a member is suspected of having crashed, but has not yet been excluded.

Methods with return type org.jgroups.Address

Address
returns the address of the member that issued this view
Address
returns the creator of this view if this view was created with the empty constructur, null will be returned
Address
Address
Returns the channel's own address.
Address
returns the local address of the channel returns null if the channel is closed
Address

Uses in package org.jgroups.blocks

Constructors with parameter type org.jgroups.Address

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

Fields of type org.jgroups.Address

Address
Address
Address
The address of this group member

Methods with parameter type org.jgroups.Address

Object
RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)
Object
RpcDispatcher.callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)
Object
RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
void
void
void
void
Xid
Xid.create(Address creator)
Xid
Xid.create(Address creator, int mode)
Serializable
NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries)
Determines the coordinator and asks it for its cache.
void
void
void
void
ConnectionTable.receive(Address sender, byte[] data, int offset, int length)
Calls the receiver callback.
void
ConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
void
Event.SUSPECT event received from a layer below.
void
Remove addrfrom connection table.
RspList
ReplicationManager.send(Address dest, byte[] data, boolean synchronous, long synchronous_timeout, Xid transaction, byte[] lock_info, long lock_acquisition_timeout, long lock_lease_timeout, boolean use_locks)
Sends a request to all members of the group.
void
ConnectionTable.send(Address dest, byte[] data, int offset, int length)
void
void
void
Called when a member is suspected
void
Called when a member is suspected
void
Called when a member is suspected
void
GroupRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport).
void
Notify membership listener that some node was suspected.
void
Called whenever a member is suspected of having crashed, but has not yet been excluded.
void
Called when a member is suspected
void
Called when a member is suspected
void
void
Callback for notification that one node is suspected

Methods with return type org.jgroups.Address

Address
Address
Address
Address
Address
Address
Address
Address
Address

Uses in package org.jgroups.util

Constructors with parameter type org.jgroups.Address

Rsp.Rsp(Address sender)
Rsp.Rsp(Address sender, Object retval)
Rsp.Rsp(Address sender, boolean suspected)

Methods with parameter type org.jgroups.Address

void
void
RspList.addRsp(Address sender, Object retval)
void
Object
boolean
boolean
boolean
Checks whether 2 Addresses are on the same host
int
void
Util.writeAddress(Address addr, DataOutputStream out)

Methods with return type org.jgroups.Address

Address
Address
Util.readAddress(DataInputStream in)

Uses in package org.jgroups.debug

Methods with parameter type org.jgroups.Address

void
void
void

Uses in package org.jgroups.protocols.pbcast

Constructors with parameter type org.jgroups.Address

GMS.GmsHeader.GmsHeader(byte type, Address mbr)
Used for JOIN_REQ or LEAVE_REQ header
Gossip.Gossip(Address obj, long id)
Gossip.Gossip(Address obj, long id, Digest d, Vector not_seen)
MergeData.MergeData(Address sender, View view, Digest digest)
NakAckHeader.NakAckHeader(byte type, long low, long high, Address sender)
STATE_TRANSFER.StateHeader.StateHeader(byte type, Address sender, long id, Digest digest)

Methods with parameter type org.jgroups.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
boolean
Digest.Entry
Digest.get(Address sender)
void
void
Computes the new view (including the newly joined member) and get the digest from PBCAST.
void
void
void
ClientGmsImpl.handleLeave(Address mbr, boolean suspected)
Returns false.
void
CoordGmsImpl.handleLeave(Address mbr, boolean suspected)
Exclude mbr from the membership.
void
GmsImpl.handleLeave(Address mbr, boolean suspected)
void
ParticipantGmsImpl.handleLeave(Address mbr, boolean suspected)
void
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
void
void
void
Returns immediately.
void
void
void
long
long
void
Increments the sender's high_seqno by 1.
void
Joins this process to a group.
void
void
void
void
void
The coordinator itself wants to leave the group
void
void
Loop: determine coord.
long
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:
  1. this.low_seqno=min(this.low_seqno, low_seqno)
  2. this.high_seqno=max(this.high_seqno, high_seqno)
  3. 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
Removes obj from not_seen list
void
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.
void
boolean
Digest.set(Address sender, long low_seqno, long high_seqno, long high_seqno_seen)
void
Digest.setHighSeqnoAt(Address sender, long high_seqno)
void
Digest.setHighSeqnoSeenAt(Address sender, long high_seqno_seen)
void
Digest.setHighestDeliveredAndSeenSeqnos(Address sender, long high_seqno, long high_seqno_seen)
void
void
void
void
void
void
void
void
Removes previously suspected member from list of currently suspected members
boolean
GMS.wouldBeNewCoordinator(Address potential_new_coord)
Checks whether the potential_new_coord would be the new coordinator (2nd in line)

Methods with return type org.jgroups.Address

Address
Address
Address

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Address

void
void
void
void
void
Chat.suspect(Address suspected_mbr)
void
QuoteClient.suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed, but has not yet been excluded.
void
QuoteServer.suspect(Address suspected_mbr)
Called whenever a member is suspected of having crashed, but has not yet been excluded.
void
Topology.suspect(Address suspected_mbr)
void
ViewDemo.suspect(Address suspected_mbr)
Called when a member is suspected

Uses in package org.jgroups.stack

Classes implementing org.jgroups.Address

class
Network-dependent address (Internet).
class
Logical address that spans the lifetime of a member.

Constructors with parameter type org.jgroups.Address

GossipData.GossipData(int type, String group, Address mbr, Vector mbrs)
NakReceiverWindow.NakReceiverWindow(Address sender, long start_seqno)
Creates a new instance without a retransmission thread
Creates a new instance with the given retransmit command
Creates a new instance with the given retransmit command
Create a new Retransmitter associated with the given sender address
Create a new Retransmitter associated with the given sender address
StateTransferInfo.StateTransferInfo(Address requester, int type, Address target)

Fields of type org.jgroups.Address

Address
Address

Methods with parameter type org.jgroups.Address

void
AckMcastSenderWindow.ack(long seqno, Address sender)
An ACK has been received from sender.
Object
RpcProtocol.callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)
Object
RpcProtocol.callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)
Object
RpcProtocol.callRemoteMethod(Address dest, String method_name, int mode, long timeout)
Object
RpcProtocol.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
void
GossipClient.register(String group, Address mbr)
Adds the member to the given group.
void
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
Retranmit the given msg
void
Process with address suspected is suspected: remove it from all receiver sets.

Methods with return type org.jgroups.Address

Address
Establishes a connection to the router.
Address

Uses in package org.jgroups.jmx

Methods with parameter type org.jgroups.Address

boolean
JChannel.getState(Address target, long timeout)
boolean
JChannelMBean.getState(Address target, long timeout)
void
JChannel.send(Address dst, Address src, Serializable obj)
void
JChannelMBean.send(Address dst, Address src, Serializable obj)

Methods with return type org.jgroups.Address

Address
Address

Uses in package org.jgroups.protocols.ring

Constructors with parameter type org.jgroups.Address

TcpRingNode.TcpRingNode(RpcProtocol owner, Address memberAddress)
TokenLostException.TokenLostException(String message, Throwable cause, Address failedNode, int mode)
UdpRingNode.UdpRingNode(RpcProtocol owner, Address memberAddress)

Fields of type org.jgroups.Address

Address

Methods with parameter type org.jgroups.Address

void
void

Methods with return type org.jgroups.Address

Address
Address

Copyright B) 1998-2005 Bela Ban. All Rights Reserved.