Uses of Interface org.jgroups.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
EnsChannel.getState(Address target, long timeout)
boolean
JChannel.getState(Address target, long timeout)
Retrieves the current group state.
void
removes an member from the membership.
void
Channel.send(Address dst, Address src, Serializable obj)
Helper method.
void
EnsChannel.send(Address dst, Address src, Serializable obj)
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 when a member is suspected

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
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
Address

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
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
Event.SUSPECT event received from a layer below

All response collectors currently registered will be notified that mbr may have crashed, so they won't wait for its response.

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
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 when a member is suspected
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

Uses in package org.jgroups.ensemble

Classes implementing org.jgroups.Address

class

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 when a member is suspected

Uses in package org.jgroups.service.lease

Methods with parameter type org.jgroups.Address

void
LeaseFactoryService.denyLeaseRequest(int denialType, Address requester, String reason, Object leaseTarget, Object tenant)
Deny lease request.
void
Process request to cancel lease.
void
LeaseFactoryService.processNewLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester)
Process new lease request.
void
Process request to renew a lease.

Methods with return type org.jgroups.Address

Address
Get address of this client in group.

Uses in package org.jgroups.protocols.pbcast

Constructors with parameter type org.jgroups.Address

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)
STATE_TRANSFER.StateHeader.StateHeader(int type, Address sender, long id, Digest digest)

Fields of type org.jgroups.Address

Address

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
int
JoinRsp
JoinRsp
Computes the new view (including the newly joined member) and get the digest from PBCAST.
JoinRsp
JoinRsp
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
CoordGmsImpl.handleMergeRequest(Address sender, Object merge_id)
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, Object merge_id)
void
Returns immediately.
void
void
void
long
long
void
Increment 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.
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
NAKACK.retransmit(long first_seqno, long last_seqno, Address sender)
Implementation of Retransmitter.RetransmitCommand.
void
Digest.setHighSeqnoAt(Address sender, long high_seqno)
void
Digest.setHighSeqnoSeenAt(Address sender, 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
Digest.senderAt(int index)

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

Uses in package org.jgroups.service

Methods with parameter type org.jgroups.Address

void
AbstractService.suspect(Address suspectedMember)
This method is called when a member of service group is suspected to be failed.

Methods with return type org.jgroups.Address

Address
Get address of this service in service group.

Uses in package org.jgroups.util

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

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

PingRsp.PingRsp(Address own_addr, Address coord_addr)
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

void
void
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
SMACK.retransmit(long seqno, Message msg, Address dest)
Retranmit the given msg
int
void
void
void
void
void

Methods with return type org.jgroups.Address

Address
Address
Address
Address
returns the Address of the local machine returns null if it is not known yet
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.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.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 when a member is suspected
void
QuoteServer.suspect(Address suspected_mbr)
Called when a member is suspected
void
Topology.suspect(Address suspected_mbr)
void
ViewDemo.suspect(Address suspected_mbr)
Called when a member is suspected

Copyright B) 2001,2002 www.jgroups.com . All Rights Reserved.