Frames | No Frames |
Constructors with parameter type org.jgroups.Address | |
Creates a new view
| |
Public constructor
| |
Public constructor
| |
Constructs a message. | |
Creates a new view
| |
Creates a ViewID with the coordinator address and a Lamport timestamp of 0. | |
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 | 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 | Retrieve the state of the group. |
boolean | |
boolean | Retrieves the current group state. |
void | removes an member from the membership. |
void | Helper method. |
void | |
void | 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 |
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 | |
void | |
void | |
void | |
Xid | |
Xid | |
Serializable | 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 addr from 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 | 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 |
Classes implementing org.jgroups.Address | |
class |
Fields of type org.jgroups.Address | |
Address |
Methods with parameter type org.jgroups.Address | |
void | |
void | |
void | Called when a member is suspected |
Methods with parameter type org.jgroups.Address | |
void | LeaseFactoryService.denyLeaseRequest(int denialType, Address requester, String reason, Object leaseTarget, Object tenant) Deny lease request. |
void | LeaseFactoryService.processCancelLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process request to cancel lease. |
void | LeaseFactoryService.processNewLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process new lease request. |
void | LeaseFactoryService.processRenewLeaseRequest(LeaseRequestHeader header, Object leaseTarget, Address requester) Process request to renew a lease. |
Methods with return type org.jgroups.Address | |
Address | Get address of this client in group. |
Constructors with parameter type org.jgroups.Address | |
Used for JOIN_REQ or LEAVE_REQ header | |
Fields of type org.jgroups.Address | |
Address |
Methods with parameter type org.jgroups.Address | |
void | |
void | |
void | |
boolean | |
int | |
JoinRsp | |
JoinRsp | Computes the new view (including the newly joined member) and get the digest from PBCAST. |
JoinRsp | |
JoinRsp | |
void | Returns false. |
void | Exclude mbr from the membership. |
void | |
void | |
void | Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender. |
void | |
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 | Similar to add(), but if the sender already exists, its seqnos will be modified (no new entry) as follows:
|
void | Removes obj from not_seen list |
void | Implementation of Retransmitter.RetransmitCommand. |
void | |
void | |
void | |
void | |
void | |
void | |
void | |
void | |
void | |
void | Removes previously suspected member from list of currently suspected members |
boolean | Checks whether the potential_new_coord would be the new coordinator (2nd in line) |
Methods with return type org.jgroups.Address | |
Address | |
Address | |
Address |
Constructors with parameter type org.jgroups.Address | |
TokenLostException.TokenLostException(String message, Throwable cause, Address failedNode, int mode) | |
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 |
Methods with parameter type org.jgroups.Address | |
void | 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. |
Methods with parameter type org.jgroups.Address | |
void | |
void | |
void | |
Object | |
boolean | |
boolean | |
boolean | Checks whether 2 Addresses are on the same host |
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 | |
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 | Returns false. |
void | Exclude mbr from the membership. |
void | |
void | |
void | |
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 | 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
|
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 | |
Creates a new instance without a retransmission thread
| |
NakReceiverWindow.NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno) Creates a new instance with the given retransmit command
| |
NakReceiverWindow.NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, long start_seqno, TimeScheduler sched) Creates a new instance with the given retransmit command
| |
Create a new Retransmitter associated with the given sender address
| |
Retransmitter.Retransmitter(Address sender, Retransmitter.RetransmitCommand cmd, TimeScheduler sched) Create a new Retransmitter associated with the given sender address
| |
Fields of type org.jgroups.Address | |
Address | |
Address |
Methods with parameter type org.jgroups.Address | |
void | 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 | |
Object | |
void | Adds the member to the given group. |
void | Remove obj from all receiver sets and wake up
retransmission thread. |
void | |
void | 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 |
Methods with parameter type org.jgroups.Address | |
void | |
void | |
void | |
void | |
void | |
void | Called when a member is suspected |
void | Called when a member is suspected |
void | |
void | Called when a member is suspected |