Package | Description |
---|---|
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.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field | Description |
---|---|---|
protected Address |
Message.dest_addr |
|
protected Address |
Message.src_addr |
Modifier and Type | Field | Description |
---|---|---|
protected java.util.Vector<Address> |
View.members |
A list containing all the members of the view
This list is always ordered, with the coordinator being the first member.
|
Modifier and Type | Method | Description |
---|---|---|
Address |
Membership.elementAt(int index) |
Returns the component at the specified index
|
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() |
Modifier and Type | Method | Description |
---|---|---|
java.util.Vector<Address> |
Membership.getMembers() |
returns a copy (clone) of the members in this membership.
|
java.util.Vector<Address> |
View.getMembers() |
Returns a reference to the List of members (ordered)
Do NOT change this list, hence your will invalidate the view
Make a copy if you have to modify it.
|
Modifier and Type | Method | Description |
---|---|---|
void |
Membership.add(Address new_member) |
Adds a new member to this membership.
|
void |
ChannelListener.channelReconnected(Address addr) |
|
void |
ChannelListenerAdapter.channelReconnected(Address addr) |
|
abstract void |
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
|
void |
JChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout) |
Connects this channel to a group and gets a state from a specified state
provider.
|
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.
|
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,
long timeout) |
Retrieves a full state from the target member.
|
boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout) |
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent) |
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
protected boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout,
java.util.concurrent.Callable<java.lang.Boolean> flushInvoker) |
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
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 |
ExtendedReceiverAdapter.suspect(Address suspected_mbr) |
|
void |
MembershipListener.suspect(Address suspected_mbr) |
Called whenever a member is suspected of having crashed,
but has not yet been excluded.
|
void |
ReceiverAdapter.suspect(Address suspected_mbr) |
Modifier and Type | Method | Description |
---|---|---|
void |
Membership.add(java.util.Collection<Address> v) |
Adds a list of members to this membership
|
void |
Membership.merge(java.util.Collection<Address> new_mems,
java.util.Collection<Address> suspects) |
merges membership with the new members and removes suspects
The Merge method will remove all the suspects and add in the new members.
|
void |
Membership.remove(java.util.Collection<Address> v) |
removes all the members contained in v from this membership
|
void |
Membership.set(java.util.Collection<Address> v) |
Clear the membership and adds all members of v
This method will clear out all the old members of this membership by
invoking the
Clear method. |
abstract boolean |
Channel.startFlush(java.util.List<Address> flushParticipants,
boolean automatic_resume) |
|
boolean |
JChannel.startFlush(java.util.List<Address> flushParticipants,
boolean automatic_resume) |
Performs a partial flush in a cluster for flush participants.
|
abstract void |
Channel.stopFlush(java.util.List<Address> flushParticipants) |
|
void |
JChannel.stopFlush(java.util.List<Address> flushParticipants) |
Constructor | Description |
---|---|
MergeView(Address creator,
long id,
java.util.Vector<Address> members,
java.util.Vector<View> 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<Address> 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.
|
Constructor | Description |
---|---|
Membership(java.util.Collection<Address> initial_members) |
Creates a member ship object with the initial members.
|
MergeView(Address creator,
long id,
java.util.Vector<Address> members,
java.util.Vector<View> subgroups) |
Creates a new view
|
MergeView(ViewId vid,
java.util.Vector<Address> members,
java.util.Vector<View> subgroups) |
Creates a new view
|
View(Address creator,
long id,
java.util.Vector<Address> members) |
Creates a new view
|
View(ViewId vid,
java.util.Vector<Address> members) |
Creates a new view
|
Modifier and Type | Field | Description |
---|---|---|
protected Address |
MessageDispatcher.local_addr |
|
protected Address |
RequestCorrelator.local_addr |
The address of this group member
|
Modifier and Type | Field | Description |
---|---|---|
protected java.util.Stack<Address> |
RequestCorrelator.call_stack |
This field is used only if deadlock detection is enabled.
|
java.util.Stack<Address> |
RequestCorrelator.Header.callStack |
Stack<Address>.
|
java.util.List<Address> |
RequestCorrelator.Header.dest_mbrs |
Contains a list of members who should receive the request (others will drop).
|
Modifier and Type | Method | Description |
---|---|---|
Address |
GroupRequest.getCaller() |
|
Address |
BasicConnectionTable.getLocalAddress() |
|
Address |
DistributedHashtable.getLocalAddress() |
Deprecated.
|
Address |
DistributedQueue.getLocalAddress() |
|
Address |
NotificationBus.getLocalAddress() |
|
Address |
ReplicatedHashMap.getLocalAddress() |
|
Address |
ReplicatedHashtable.getLocalAddress() |
Deprecated.
|
Address |
ReplicatedTree.getLocalAddress() |
|
Address |
RequestCorrelator.getLocalAddress() |
Modifier and Type | Method | Description |
---|---|---|
java.util.Vector<Address> |
GroupRequest.getSuspects() |
Returns the list of suspected members.
|
Modifier and Type | Method | Description |
---|---|---|
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) |
|
java.lang.Object |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout,
boolean oob) |
|
void |
PullPushAdapter.channelReconnected(Address addr) |
Deprecated.
|
void |
RpcDispatcher.channelReconnected(Address new_addr) |
|
void |
BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr) |
|
void |
BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr) |
|
java.io.Serializable |
NotificationBus.getCacheFromMember(Address mbr,
long timeout,
int max_tries) |
Determines the coordinator and asks it for its cache.
|
boolean |
RspFilter.isAcceptable(java.lang.Object response,
Address sender) |
Determines whether a response from a given sender should be added to the response list of the request
|
void |
NotificationBus.Consumer.memberJoined(Address mbr) |
|
void |
NotificationBus.Consumer.memberLeft(Address mbr) |
|
protected void |
PullPushAdapter.notifySuspect(Address suspected_mbr) |
Deprecated.
|
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 |
GroupRequest.receiveResponse(java.lang.Object response_value,
Address sender) |
Callback (called by RequestCorrelator or Transport).
|
void |
RspCollector.receiveResponse(java.lang.Object response_value,
Address sender) |
|
void |
RequestCorrelator.receiveSuspect(Address mbr) |
Event.SUSPECT event received from a layer below.
|
void |
BasicConnectionTable.removeConnection(Address addr) |
Remove
addr from connection table. |
protected void |
ConnectionTableNIO.runRequest(Address addr,
java.nio.ByteBuffer buf) |
|
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) |
Deprecated.
Called when a member 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 |
ReplicatedHashMap.suspect(Address suspected_mbr) |
Called when a member is suspected
|
void |
ReplicatedHashtable.suspect(Address suspected_mbr) |
Deprecated.
Called when a member is suspected
|
void |
ReplicatedTree.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
|
Modifier and Type | Method | Description |
---|---|---|
void |
GroupRequest.reset(java.util.Vector<Address> mbrs) |
This method sets the
membership variable to the value of
members . |
void |
BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs) |
Removes all connections from ConnectionTable which are not in current_mbrs
|
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll) |
|
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll,
boolean use_anycasting) |
Send a request to a group.
|
void |
ReplicatedHashMap.Notification.viewChange(View view,
java.util.Vector<Address> new_mbrs,
java.util.Vector<Address> old_mbrs) |
Constructor | Description |
---|---|
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) |
|
RequestCorrelator(java.lang.String name,
java.lang.Object transport,
RequestHandler handler,
Address local_addr) |
Constructor | Description |
---|---|
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector<Address> members,
int rsp_mode) |
|
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector<Address> members,
int rsp_mode,
long timeout,
int expected_mbrs) |
|
GroupRequest(Message m,
Transport transport,
java.util.Vector<Address> members,
int rsp_mode) |
|
GroupRequest(Message m,
Transport transport,
java.util.Vector<Address> members,
int rsp_mode,
long timeout,
int expected_mbrs) |
Modifier and Type | Method | Description |
---|---|---|
void |
Simulator.addMember(Address addr) |
|
void |
Simulator.addMember(Address addr,
Simulator s) |
|
void |
Simulator.setLocalAddress(Address addr) |
Modifier and Type | Method | Description |
---|---|---|
void |
Draw.channelReconnected(Address addr) |
|
void |
Gossip.channelReconnected(Address new_addr) |
|
void |
NotificationBusDemo.memberJoined(Address mbr) |
|
void |
NotificationBusDemo.memberLeft(Address mbr) |
|
void |
ChatCore.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
|
Modifier and Type | Field | Description |
---|---|---|
Address |
Node.addr |
Modifier and Type | Method | Description |
---|---|---|
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) |
Modifier and Type | Method | Description |
---|---|---|
Address |
JChannel.getLocalAddress() |
|
Address |
JChannelMBean.getLocalAddress() |
Modifier and Type | Method | Description |
---|---|---|
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) |
Modifier and Type | Method | Description |
---|---|---|
Address |
TP.getLocalAddress() |
|
Address |
TPMBean.getLocalAddress() |
Modifier and Type | Method | Description |
---|---|---|
Address |
MuxChannel.getLocalAddress() |
Modifier and Type | Method | Description |
---|---|---|
void |
MuxChannel.connect(java.lang.String cluster_name,
Address target,
java.lang.String state_id,
long timeout) |
|
boolean |
MuxChannel.getState(Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent) |
|
void |
MuxChannel.send(Address dst,
Address src,
java.io.Serializable obj) |
Constructor | Description |
---|---|
ServiceInfo(byte type,
java.lang.String service,
Address host,
byte[] state) |
Modifier and Type | Class | Description |
---|---|---|
static class |
JMS.JMSAddress |
Simple
Address representing the JMS node ID or JMS topic group. |
Modifier and Type | Field | Description |
---|---|---|
Address |
PingRsp.coord_addr |
|
protected Address |
TP.local_addr |
The address (host and port) of this member
|
protected Address |
PARTITION.local_address |
|
Address |
PingRsp.own_addr |
Modifier and Type | Field | Description |
---|---|---|
protected java.util.HashSet<Address> |
TP.members |
The members of this group (updated when a member joins or leaves)
|
Modifier and Type | Method | Description |
---|---|---|
protected Address |
UDP.createLocalAddress() |
|
Address |
PingRsp.getAddress() |
|
Address |
PingRsp.getCoordAddress() |
|
Address |
SEQUENCER.getCoordinator() |
|
protected Address |
ENCRYPT.getKeyServerAddr() |
|
protected Address |
ENCRYPT.getLocal_addr() |
|
Address |
SEQUENCER.getLocalAddress() |
|
Address |
TP.getLocalAddress() |
|
Address |
SEQUENCER.SequencerHeader.getOriginalSender() |
Modifier and Type | Method | Description |
---|---|---|
java.util.List<Address> |
TCPPING.getInitialHosts() |
Returns the list of initial hosts as configured by the user via XML.
|
java.util.List<Address> |
TP.ProtocolAdapter.getMembers() |
Modifier and Type | Method | Description |
---|---|---|
void |
DISCARD.addIgnoreMember(Address sender) |
Messages from this sender will get dropped
|
protected void |
FD.Broadcaster.addSuspectedMember(Address mbr) |
Adds a suspected member.
|
void |
FD.BroadcastTask.addSuspectedMember(Address suspect) |
|
void |
UNICAST.expired(Address key) |
Called by AgeOutCache, to removed expired connections
|
void |
Discovery.localAddressSet(Address addr) |
Called after local_addr was set
|
void |
PING.localAddressSet(Address addr) |
|
void |
TCPPING.localAddressSet(Address addr) |
|
void |
BasicTCP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
LOOPBACK.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
SHARED_LOOPBACK.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
abstract void |
TP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
TUNNEL.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
UDP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
BasicTCP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
LOOPBACK.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
SHARED_LOOPBACK.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
abstract void |
TP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
TUNNEL.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
UDP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
BasicTCP.receive(Address sender,
byte[] data,
int offset,
int length) |
ConnectionTable.Receiver interface
|
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.
|
boolean |
UNICAST.removeConnection(Address mbr) |
Removes and resets from connection table (which is already locked).
|
void |
DISCARD.removeIgnoredMember(Address member) |
|
void |
SMACK.retransmit(long seqno,
Message msg,
Address dest) |
|
abstract void |
BasicTCP.send(Address dest,
byte[] data,
int offset,
int length) |
|
void |
TCP_NIO.send(Address dest,
byte[] data,
int offset,
int length) |
|
void |
TCP.send(Address dest,
byte[] data,
int offset,
int length) |
|
void |
BasicTCP.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
void |
LOOPBACK.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
void |
SHARED_LOOPBACK.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
abstract void |
TP.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
Send to all members in the group.
|
void |
TUNNEL.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
void |
UDP.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
protected void |
ENCRYPT.setKeyServerAddr(Address keyServerAddr) |
|
protected void |
ENCRYPT.setLocal_addr(Address local_addr) |
|
void |
DISCARD.setLocalAddress(Address localAddress) |
Modifier and Type | Method | Description |
---|---|---|
abstract void |
BasicTCP.retainAll(java.util.Collection<Address> members) |
|
void |
TCP_NIO.retainAll(java.util.Collection<Address> members) |
|
void |
TCP.retainAll(java.util.Collection<Address> members) |
Constructor | Description |
---|---|
CoordAnnouncement(Address coord) |
|
FdHeader(byte type,
Address mbr) |
|
FdHeader(byte type,
Address mbr,
IpAddress sock_addr) |
|
FdHeader(byte type,
java.util.Vector<Address> mbrs,
Address from) |
|
Header(byte type,
Address suspect) |
|
HTotalHeader(Address dest,
Address src) |
|
MergefastHeader(Address coord) |
|
PingRsp(Address own_addr,
Address coord_addr,
boolean is_server) |
|
ProtocolAdapter(java.lang.String cluster_name,
java.lang.String transport_name,
Protocol up,
Protocol down,
java.lang.String pattern,
Address addr) |
|
SequencerHeader(byte type,
Address original_sender,
long seqno) |
Constructor | Description |
---|---|
DiscardHeader(java.util.Set<Address> ignoredAddresses) |
|
FdHeader(byte type,
java.util.Map<Address,IpAddress> cachedAddrs) |
|
FdHeader(byte type,
java.util.Set<Address> mbrs) |
|
FdHeader(byte type,
java.util.Vector<Address> mbrs,
Address from) |
Modifier and Type | Method | Description |
---|---|---|
protected Address |
GMS.determineCoordinator() |
|
Address |
GMS.GmsHeader.getMember() |
|
Address |
MergeData.getSender() |
Modifier and Type | Method | Description |
---|---|---|
void |
Gossip.addToSeenList(Address mbr) |
|
double |
NAKACK.getSmoothedAverageRetransmissionTime(Address sender) |
Returns the smoothed average retransmission time for a given sender
|
void |
CoordGmsImpl.handleDigestResponse(Address sender,
Digest digest) |
|
void |
GmsImpl.handleDigestResponse(Address sender,
Digest digest) |
|
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 |
GmsImpl.handleMergeRequest(Address sender,
ViewId merge_id) |
|
void |
ParticipantGmsImpl.handleMergeRequest(Address sender,
ViewId merge_id) |
|
void |
ClientGmsImpl.join(Address address) |
|
void |
CoordGmsImpl.join(Address mbr) |
|
abstract void |
GmsImpl.join(Address mbr) |
|
void |
ParticipantGmsImpl.join(Address mbr) |
|
void |
ClientGmsImpl.joinWithStateTransfer(Address address) |
|
void |
CoordGmsImpl.joinWithStateTransfer(Address mbr) |
|
abstract void |
GmsImpl.joinWithStateTransfer(Address local_addr) |
|
void |
ParticipantGmsImpl.joinWithStateTransfer(Address mbr) |
|
void |
ClientGmsImpl.leave(Address mbr) |
|
void |
CoordGmsImpl.leave(Address mbr) |
The coordinator itself wants to leave the group
|
abstract void |
GmsImpl.leave(Address mbr) |
|
void |
ParticipantGmsImpl.leave(Address mbr) |
Loop: determine coord.
|
void |
NAKACK.messageGapDetected(long from,
long to,
Address src) |
Called when a message gap is detected
|
void |
NAKACK.missingMessageReceived(long seqno,
Address original_sender) |
|
void |
Gossip.removeFromNotSeenList(Address mbr) |
Removes obj from not_seen list
|
void |
NAKACK.retransmit(long first_seqno,
long last_seqno,
Address sender) |
Implementation of Retransmitter.RetransmitCommand.
|
protected void |
NAKACK.retransmit(long first_seqno,
long last_seqno,
Address sender,
boolean multicast_xmit_request) |
|
void |
GMS.sendJoinResponse(JoinRsp rsp,
Address dest) |
|
protected void |
GmsImpl.sendMergeRejectedResponse(Address sender,
ViewId merge_id) |
|
void |
ClientGmsImpl.suspect(Address mbr) |
|
void |
CoordGmsImpl.suspect(Address mbr) |
|
abstract void |
GmsImpl.suspect(Address mbr) |
|
void |
ParticipantGmsImpl.suspect(Address mbr) |
|
void |
ClientGmsImpl.unsuspect(Address mbr) |
|
void |
CoordGmsImpl.unsuspect(Address mbr) |
|
abstract void |
GmsImpl.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)
|
Modifier and Type | Method | Description |
---|---|---|
void |
GMS.castViewChangeWithDest(View new_view,
Digest digest,
JoinRsp jr,
java.util.Collection<Address> newMembers) |
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
|
protected boolean |
GMS.checkSelfInclusion(java.util.Vector<Address> mbrs) |
Returns true if local_addr is member of mbrs, else false
|
View |
GMS.getNextView(java.util.Collection<Address> new_mbrs,
java.util.Collection<Address> old_mbrs,
java.util.Collection<Address> suspected_mbrs) |
Computes the next view.
|
View |
GMS.makeView(java.util.Vector<Address> mbrs) |
|
static View |
GMS.makeView(java.util.Vector<Address> mbrs,
ViewId vid) |
|
void |
CoordGmsImpl.merge(java.util.Vector<Address> other_coords) |
Invoked upon receiving a MERGE event from the MERGE layer.
|
void |
GmsImpl.merge(java.util.Vector<Address> other_coords) |
Constructor | Description |
---|---|
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) |
|
StateHeader(byte type,
Address sender,
long id,
Digest digest) |
|
StateHeader(byte type,
Address sender,
long id,
Digest digest,
java.lang.String state_id) |
|
StateHeader(byte type,
Address sender,
long id,
Digest digest) |
|
StateHeader(byte type,
Address sender,
java.lang.String state_id) |
|
StateHeader(byte type,
Address sender,
IpAddress bind_addr,
Digest digest,
java.lang.String state_id) |
Constructor | Description |
---|---|
FlushHeader(byte type,
long viewID,
java.util.Collection<Address> flushView) |
Modifier and Type | Class | Description |
---|---|---|
class |
IpAddress |
Network-dependent address (Internet).
|
Modifier and Type | Field | Description |
---|---|---|
Address |
StateTransferInfo.target |
Modifier and Type | Method | Description |
---|---|---|
Address |
GossipData.getAddress() |
|
Address |
RouterStub.getLocalAddress() |
Modifier and Type | Method | Description |
---|---|---|
java.util.List<Address> |
GossipClient.getMembers(java.lang.String group) |
Returns all members of a given group
|
Modifier and Type | Method | Description |
---|---|---|
void |
AckMcastSenderWindow.ack(long seqno,
Address sender) |
An ACK has been received from
sender . |
void |
NakReceiverWindow.Listener.messageGapDetected(long from,
long to,
Address src) |
|
void |
NakReceiverWindow.Listener.missingMessageReceived(long seqno,
Address original_sender) |
|
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 |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest) |
Retranmit the given msg
|
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 |
RouterStub.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
|
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) |
Constructor | Description |
---|---|
AckSenderWindow(AckSenderWindow.RetransmitCommand com,
Interval interval,
TimeScheduler sched,
Address sender) |
|
GossipData(byte type,
java.lang.String group,
Address addr,
java.util.List mbrs) |
|
NakReceiverWindow(Address local_addr,
Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
long lowest_seqno,
TimeScheduler sched) |
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno) |
Creates a new instance with the given retransmit command
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
long lowest_seqno,
TimeScheduler sched) |
Creates a new instance with the given retransmit command
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_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,
long timeout) |
|
StateTransferInfo(Address target,
java.io.InputStream is,
java.lang.String state_id) |
|
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) |
Modifier and Type | Field | Description |
---|---|---|
protected java.util.Map<Address,Digest.Entry> |
Digest.senders |
Map<Address, Entry>
|
Modifier and Type | Method | Description |
---|---|---|
Address |
Rsp.getSender() |
|
static Address |
Util.readAddress(java.io.DataInputStream in) |
Modifier and Type | Method | Description |
---|---|---|
static java.util.Vector<Address> |
Util.determineLeftMembers(java.util.Vector<Address> old_mbrs,
java.util.Vector<Address> new_mbrs) |
Returns all members that left between 2 views.
|
java.util.Set<java.util.Map.Entry<Address,Rsp>> |
RspList.entrySet() |
|
java.util.Map<Address,T> |
ResponseCollector.getResults() |
|
java.util.Map<Address,Digest.Entry> |
Digest.getSenders() |
Returns an unmodifiable map, so modifications will result in exceptions
|
java.util.Map<Address,Digest.Entry> |
MutableDigest.getSenders() |
|
java.util.Vector<Address> |
RspList.getSuspectedMembers() |
|
java.util.Set<Address> |
RspList.keySet() |
|
static java.util.Collection<Address> |
Util.readAddresses(java.io.DataInputStream in,
java.lang.Class cl) |
Modifier and Type | Method | Description |
---|---|---|
void |
MutableDigest.add(Address sender,
long low_seqno,
long highest_delivered_seqno) |
|
void |
MutableDigest.add(Address sender,
long low_seqno,
long highest_delivered_seqno,
long highest_received_seqno) |
|
void |
ResponseCollector.add(Address member,
T data) |
|
boolean |
SeqnoTable.add(Address member,
long seqno) |
|
void |
RspList.addNotReceived(Address sender) |
|
void |
RspList.addRsp(Address sender,
java.lang.Object retval) |
|
void |
RspList.addSuspect(Address sender) |
|
boolean |
Digest.contains(Address sender) |
|
static View |
Util.createView(Address coord,
long id,
Address... members) |
|
void |
FIFOMessageQueue.done(Address sender,
K dest) |
|
Digest.Entry |
Digest.get(Address sender) |
Returns the Entry for the given sender.
|
long |
SeqnoTable.getHighestReceived(Address member) |
|
long |
SeqnoTable.getNextToReceive(Address member) |
|
long |
Digest.highestDeliveredSeqnoAt(Address sender) |
|
long |
Digest.highestReceivedSeqnoAt(Address sender) |
|
void |
MutableDigest.incrementHighestDeliveredSeqno(Address sender) |
Increments the sender's high_seqno by 1.
|
boolean |
RspList.isReceived(Address sender) |
|
boolean |
RspList.isSuspected(Address sender) |
|
long |
Digest.lowSeqnoAt(Address sender) |
|
void |
MutableDigest.merge(Address sender,
long low_seqno,
long highest_delivered_seqno,
long highest_received_seqno) |
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.highest_delivered_seqno=max(this.highest_delivered_seqno, highest_delivered_seqno)
this.highest_received_seqno=max(this.highest_received_seqno, highest_received_seqno)
If the sender doesn not exist, a new entry will be added (provided there is enough space)
|
void |
FIFOMessageQueue.put(Address sender,
K dest,
V el) |
|
Rsp |
RspList.put(Address key,
Rsp value) |
|
void |
ResponseCollector.remove(Address member) |
|
void |
SeqnoTable.remove(Address member) |
|
void |
MutableDigest.resetAt(Address sender) |
Resets the seqnos for the sender at 'index' to 0.
|
static boolean |
Util.sameHost(Address one,
Address two) |
Checks whether 2 Addresses are on the same host
|
boolean |
MutableDigest.set(Address sender,
long low_seqno,
long highest_delivered_seqno,
long highest_received_seqno) |
|
void |
MutableDigest.setHighestDeliveredAndSeenSeqnos(Address sender,
long low_seqno,
long highest_delivered_seqno,
long highest_received_seqno) |
|
static int |
Util.size(Address addr) |
|
void |
AckCollector.suspect(Address member) |
|
void |
ResponseCollector.suspect(Address member) |
|
void |
AckCollector.unsuspect(Address member) |
|
static void |
Util.writeAddress(Address addr,
java.io.DataOutputStream out) |
Modifier and Type | Method | Description |
---|---|---|
static java.util.Vector<Address> |
Util.determineLeftMembers(java.util.Vector<Address> old_mbrs,
java.util.Vector<Address> new_mbrs) |
Returns all members that left between 2 views.
|
void |
RspList.putAll(java.util.Map<? extends Address,? extends Rsp> m) |
|
void |
AckCollector.reset(ViewId v,
java.util.List<Address> members) |
|
void |
ResponseCollector.reset(java.util.Collection<Address> members) |
|
boolean |
SeqnoTable.retainAll(java.util.Collection<Address> members) |
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants) |
|
static boolean |
Util.startFlush(Channel c,
java.util.List<Address> flushParticipants,
int numberOfAttempts,
long randomSleepTimeoutFloor,
long randomSleepTimeoutCeiling) |
Constructor | Description |
---|---|
Digest(Address sender,
long low,
long highest_delivered) |
|
Digest(Address sender,
long low,
long highest_delivered,
long highest_received) |
|
Rsp(Address sender) |
|
Rsp(Address sender,
boolean suspected) |
|
Rsp(Address sender,
java.lang.Object retval) |
Constructor | Description |
---|---|
Digest(java.util.Map<Address,Digest.Entry> map) |
Creates a new digest from an existing map by copying the keys and values from map
|
MutableDigest(java.util.Map<Address,Digest.Entry> map) |
|
ResponseCollector(java.util.Collection<Address> members) |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.