|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
JChannel.getLocalAddress()
returns the local address of the channel returns null if the channel is closed |
Address |
EnsChannel.getLocalAddress()
|
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 |
Message.getSrc()
|
abstract Address |
Channel.getLocalAddress()
Returns the channel's own address. |
Methods in org.jgroups with parameters of type Address | |
void |
MembershipListener.suspect(Address suspected_mbr)
Called when a member is suspected |
void |
Membership.add(Address new_member)
Adds a new member to this membership. |
void |
Membership.remove(Address old_member)
removes an member from the membership. |
boolean |
Membership.contains(Address member)
Returns true if the provided member belongs to this membership |
void |
JChannel.send(Address dst,
Address src,
java.io.Serializable obj)
creates a new message with the destination address, and the source address and the object as the message value |
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves the current group state. |
void |
EnsChannel.send(Address dst,
Address src,
java.io.Serializable obj)
|
boolean |
EnsChannel.getState(Address target,
long timeout)
|
boolean |
View.containsMember(Address mbr)
returns true, if this view contains a certain member |
void |
Message.setDest(Address new_dest)
|
void |
Message.setSrc(Address new_src)
|
void |
ChannelListener.channelReconnected(Address addr)
|
abstract void |
Channel.send(Address dst,
Address src,
java.io.Serializable obj)
Helper method. |
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group. |
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 |
|
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. |
|
View(Address creator,
long id,
java.util.Vector members)
Creates a new view |
|
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 |
Uses of Address in org.jgroups.blocks |
Fields in org.jgroups.blocks declared as Address | |
protected Address |
TransactionalHashtable.local_addr
|
protected Address |
Xid.creator
|
protected Address |
RequestCorrelator.local_addr
The address of this group member |
protected Address |
MessageDispatcher.local_addr
|
Methods in org.jgroups.blocks that return Address | |
Address |
Xid.getCreator()
|
Address |
ReplicatedTree.getLocalAddress()
|
Address |
ReplicatedHashtable.getLocalAddress()
|
Address |
NotificationBus.getLocalAddress()
|
Address |
DistributedQueue.getLocalAddress()
|
Address |
RequestCorrelator.getLocalAddress()
|
Address |
DistributedHashtable.getLocalAddress()
|
Address |
ConnectionTable.getLocalAddress()
|
Methods in org.jgroups.blocks with parameters of type Address | |
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. |
static Xid |
Xid.create(Address creator)
|
static Xid |
Xid.create(Address creator,
int mode)
|
void |
ReplicatedTree.suspect(Address suspected_mbr)
Called when a member is suspected |
void |
ReplicatedHashtable.suspect(Address suspected_mbr)
Called when a member is suspected |
java.io.Serializable |
NotificationBus.getCacheFromMember(Address mbr,
long timeout,
int max_tries)
Determines the coordinator and asks it for its cache. |
void |
NotificationBus.suspect(Address suspected_mbr)
|
void |
NotificationBus.Consumer.memberJoined(Address mbr)
|
void |
NotificationBus.Consumer.memberLeft(Address mbr)
|
void |
MembershipListenerAdapter.suspect(Address suspected_mbr)
Notify membership listener that some node was suspected. |
void |
GroupRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport). |
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 |
VotingAdapter.suspect(Address suspected)
Callback for notification that one node is suspected |
void |
RspCollector.suspect(Address mbr)
|
void |
RequestCorrelator.receiveSuspect(Address mbr)
Event.SUSPECT event received from a layer below |
void |
RequestCorrelator.setLocalAddress(Address local_addr)
|
protected void |
PullPushAdapter.notifySuspect(Address suspected_mbr)
|
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)
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout)
|
void |
RpcDispatcher.channelReconnected(Address new_addr)
|
void |
DistributedHashtable.suspect(Address suspected_mbr)
Called when a member is suspected |
void |
ConnectionTable.remove(Address addr)
Remove addr from connection table. |
void |
ConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
|
void |
ConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
|
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.demos |
Methods in org.jgroups.demos with parameters of type Address | |
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)
|
void |
NotificationBusDemo.memberJoined(Address mbr)
|
void |
NotificationBusDemo.memberLeft(Address mbr)
|
void |
Gossip.channelReconnected(Address new_addr)
|
void |
Draw.channelReconnected(Address addr)
|
void |
Chat.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.suspect(Address obj)
|
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)
|
Uses of Address in org.jgroups.ensemble |
Classes in org.jgroups.ensemble that implement Address | |
class |
Hot_Endpoint
|
Uses of Address in org.jgroups.protocols |
Classes in org.jgroups.protocols that implement Address | |
protected 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.own_addr
|
Address |
PingRsp.coord_addr
|
Address |
GMS.local_addr
|
Methods in org.jgroups.protocols that return Address | |
protected Address |
TOTAL_OLD.getLocalAddr()
returns the Address of the local machine returns null if it is not known yet |
protected Address |
TOTAL_OLD.getSequencer()
returns the address of the current sequencer of the group returns null if the list of members is empty |
Address |
PingRsp.getAddress()
|
Address |
PingRsp.getCoordAddress()
|
protected Address |
GMS.determineCoordinator()
|
Methods in org.jgroups.protocols with parameters of type Address | |
void |
TCP.connectionOpened(Address peer_addr)
|
void |
TCP.connectionClosed(Address peer_addr)
|
void |
SMACK.retransmit(long seqno,
Message msg,
Address dest)
|
void |
ParticipantGmsImpl.join(Address mbr)
|
void |
ParticipantGmsImpl.leave(Address mbr)
Loop: determine coord. |
void |
ParticipantGmsImpl.suspect(Address mbr)
|
boolean |
ParticipantGmsImpl.handleJoin(Address mbr)
|
void |
ParticipantGmsImpl.handleLeave(Address mbr,
boolean suspected)
|
void |
ParticipantGmsImpl.handleSuspect(Address mbr)
|
int |
DEADLOCK.sendRequest(Address dest)
|
void |
CoordGmsImpl.join(Address mbr)
|
void |
CoordGmsImpl.leave(Address mbr)
The coordinator itself wants to leave the group |
void |
CoordGmsImpl.suspect(Address mbr)
|
boolean |
CoordGmsImpl.handleJoin(Address mbr)
|
void |
CoordGmsImpl.handleLeave(Address mbr,
boolean suspected)
Exclude mbr from the membership. |
void |
CoordGmsImpl.handleSuspect(Address mbr)
|
void |
GMS.join(Address mbr)
|
void |
GMS.leave(Address mbr)
|
void |
GMS.suspect(Address mbr)
|
boolean |
GMS.handleJoin(Address mbr)
|
void |
GMS.handleLeave(Address mbr,
boolean suspected)
|
void |
GMS.handleSuspect(Address mbr)
|
abstract void |
GmsImpl.join(Address mbr)
|
abstract void |
GmsImpl.leave(Address mbr)
|
abstract void |
GmsImpl.suspect(Address mbr)
|
abstract boolean |
GmsImpl.handleJoin(Address mbr)
|
abstract void |
GmsImpl.handleLeave(Address mbr,
boolean suspected)
|
abstract void |
GmsImpl.handleSuspect(Address mbr)
|
void |
ClientGmsImpl.join(Address mbr)
Will generate a CONNECT_OK event. |
void |
ClientGmsImpl.leave(Address mbr)
|
void |
ClientGmsImpl.suspect(Address mbr)
|
boolean |
ClientGmsImpl.handleJoin(Address mbr)
|
void |
ClientGmsImpl.handleLeave(Address mbr,
boolean suspected)
Returns false. |
void |
ClientGmsImpl.handleSuspect(Address mbr)
Returns immediately. |
int |
VectorTime.indexOf(Address member)
Returns index of the given member represented by it's Address |
Constructors in org.jgroups.protocols with parameters of type Address | |
PingRsp(Address own_addr,
Address coord_addr)
|
|
MERGEFAST.MergefastHeader(Address coord)
|
|
VectorTime(Address owner)
Constructs VectorTime given an adress of a owning group member |
Uses of Address in org.jgroups.protocols.pbcast |
Fields in org.jgroups.protocols.pbcast declared as Address | |
Address |
GMS.local_addr
|
Methods in org.jgroups.protocols.pbcast that return Address | |
Address |
MergeData.getSender()
|
Address |
Digest.senderAt(int index)
|
protected Address |
GMS.determineCoordinator()
|
Methods in org.jgroups.protocols.pbcast with parameters of type Address | |
void |
ParticipantGmsImpl.join(Address mbr)
|
void |
ParticipantGmsImpl.leave(Address mbr)
Loop: determine coord. |
void |
ParticipantGmsImpl.suspect(Address mbr)
|
void |
ParticipantGmsImpl.unsuspect(Address mbr)
Removes previously suspected member from list of currently suspected members |
JoinRsp |
ParticipantGmsImpl.handleJoin(Address mbr)
|
void |
ParticipantGmsImpl.handleLeave(Address mbr,
boolean suspected)
|
void |
ParticipantGmsImpl.handleSuspect(Address mbr)
|
void |
NAKACK.retransmit(long first_seqno,
long last_seqno,
Address sender)
Implementation of Retransmitter.RetransmitCommand. |
void |
Gossip.removeFromNotSeenList(Address mbr)
Removes obj from not_seen list |
void |
Gossip.addToSeenList(Address mbr)
|
void |
CoordGmsImpl.join(Address mbr)
|
void |
CoordGmsImpl.leave(Address mbr)
The coordinator itself wants to leave the group |
void |
CoordGmsImpl.suspect(Address mbr)
|
void |
CoordGmsImpl.unsuspect(Address mbr)
|
void |
CoordGmsImpl.handleMergeRequest(Address sender,
java.lang.Object merge_id)
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. |
JoinRsp |
CoordGmsImpl.handleJoin(Address mbr)
Computes the new view (including the newly joined member) and get the digest from PBCAST. |
void |
CoordGmsImpl.handleLeave(Address mbr,
boolean suspected)
Exclude mbr from the membership. |
void |
CoordGmsImpl.handleSuspect(Address mbr)
|
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 |
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) |
int |
Digest.getIndex(Address sender)
|
boolean |
Digest.contains(Address sender)
|
void |
Digest.incrementHighSeqno(Address sender)
Increment the sender's high_seqno by 1 |
long |
Digest.highSeqnoAt(Address sender)
|
long |
Digest.highSeqnoSeenAt(Address sender)
|
void |
Digest.setHighSeqnoAt(Address sender,
long high_seqno)
|
void |
Digest.setHighSeqnoSeenAt(Address sender,
long high_seqno_seen)
|
protected boolean |
GMS.wouldBeNewCoordinator(Address potential_new_coord)
Checks whether the potential_new_coord would be the new coordinator (2nd in line) |
abstract void |
GmsImpl.join(Address mbr)
|
abstract void |
GmsImpl.leave(Address mbr)
|
abstract void |
GmsImpl.suspect(Address mbr)
|
abstract void |
GmsImpl.unsuspect(Address mbr)
|
void |
GmsImpl.handleMergeRequest(Address sender,
java.lang.Object merge_id)
|
abstract JoinRsp |
GmsImpl.handleJoin(Address mbr)
|
abstract void |
GmsImpl.handleLeave(Address mbr,
boolean suspected)
|
abstract void |
GmsImpl.handleSuspect(Address mbr)
|
void |
ClientGmsImpl.join(Address mbr)
Joins this process to a group. |
void |
ClientGmsImpl.leave(Address mbr)
|
void |
ClientGmsImpl.suspect(Address mbr)
|
void |
ClientGmsImpl.unsuspect(Address mbr)
|
JoinRsp |
ClientGmsImpl.handleJoin(Address mbr)
|
void |
ClientGmsImpl.handleLeave(Address mbr,
boolean suspected)
Returns false. |
void |
ClientGmsImpl.handleSuspect(Address mbr)
Returns immediately. |
Constructors in org.jgroups.protocols.pbcast with parameters of type Address | |
STATE_TRANSFER.StateHeader(int type,
Address sender,
long id,
Digest digest)
|
|
Gossip(Address obj,
long id)
|
|
Gossip(Address obj,
long id,
Digest d,
java.util.Vector not_seen)
|
|
MergeData(Address sender,
View view,
Digest digest)
|
|
GMS.GmsHeader(int type,
Address mbr)
Used for JOIN_REQ or LEAVE_REQ header |
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.setAruId(Address address)
|
void |
RingToken.addRecoveredMember(Address member)
|
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.service |
Methods in org.jgroups.service that return Address | |
Address |
AbstractService.getAddress()
Get address of this service in service group. |
Methods in org.jgroups.service with parameters of type Address | |
void |
AbstractService.suspect(Address suspectedMember)
This method is called when a member of service group is suspected to be failed. |
Uses of Address in org.jgroups.service.lease |
Methods in org.jgroups.service.lease that return Address | |
Address |
LeaseFactoryClient.getAddress()
Get address of this client in group. |
Methods in org.jgroups.service.lease with parameters of type Address | |
protected void |
LeaseFactoryService.denyLeaseRequest(int denialType,
Address requester,
java.lang.String reason,
java.lang.Object leaseTarget,
java.lang.Object tenant)
Deny lease request. |
protected void |
LeaseFactoryService.processNewLeaseRequest(LeaseRequestHeader header,
java.lang.Object leaseTarget,
Address requester)
Process new lease request. |
protected void |
LeaseFactoryService.processRenewLeaseRequest(LeaseRequestHeader header,
java.lang.Object leaseTarget,
Address requester)
Process request to renew a lease. |
protected void |
LeaseFactoryService.processCancelLeaseRequest(LeaseRequestHeader header,
java.lang.Object leaseTarget,
Address requester)
Process request to cancel lease. |
Uses of Address in org.jgroups.stack |
Classes in org.jgroups.stack that implement Address | |
class |
IpAddress
Network-dependent address (Internet). |
class |
LogicalAddress1_4
Logical address that spans the lifetime of a member. |
Fields in org.jgroups.stack declared as Address | |
Address |
StateTransferInfo.requester
|
Address |
StateTransferInfo.target
|
Methods in org.jgroups.stack that return Address | |
Address |
GossipData.getMbr()
|
Address |
RouterStub.connect()
Establishes a connection to the router. |
Methods in org.jgroups.stack with parameters of type Address | |
void |
AckSenderWindow.retransmit(long first_seqno,
long last_seqno,
Address sender)
|
void |
GossipClient.register(java.lang.String group,
Address mbr)
Adds the member to the given group. |
void |
AckMcastSenderWindow.ack(long seqno,
Address sender)
An ACK has been received from sender . |
void |
AckMcastSenderWindow.remove(Address obj)
Remove obj from all receiver sets and wake up
retransmission thread. |
void |
AckMcastSenderWindow.suspect(Address suspected)
Process with address suspected is suspected: remove it
from all receiver sets. |
void |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest)
Retranmit the given msg |
void |
Retransmitter.RetransmitCommand.retransmit(long first_seqno,
long last_seqno,
Address sender)
Get the missing messages between sequence numbers first_seqno and last_seqno . |
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)
|
java.lang.Object |
RpcProtocol.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout)
|
Constructors in org.jgroups.stack with parameters of type Address | |
StateTransferInfo(Address requester,
int type,
Address target)
|
|
StateTransferInfo(int type,
Address target)
|
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long start_seqno,
TimeScheduler sched)
Creates a new instance with the given retransmit command |
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long start_seqno)
Creates a new instance with the given retransmit command |
|
NakReceiverWindow(Address sender,
long start_seqno)
Creates a new instance without a retransmission thread |
|
GossipData(int type,
java.lang.String group,
Address mbr,
java.util.Vector mbrs)
|
|
Retransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address |
|
Retransmitter(Address sender,
Retransmitter.RetransmitCommand cmd)
Create a new Retransmitter associated with the given sender address |
Uses of Address in org.jgroups.util |
Methods in org.jgroups.util with parameters of type Address | |
static boolean |
Util.sameHost(Address one,
Address two)
Checks whether 2 Addresses are on the same host |
void |
RspList.addRsp(Address sender,
java.lang.Object retval)
|
void |
RspList.addNotReceived(Address sender)
|
void |
RspList.addSuspect(Address sender)
|
boolean |
RspList.isReceived(Address sender)
|
boolean |
RspList.isSuspected(Address sender)
|
java.lang.Object |
RspList.get(Address sender)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |