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 and Description |
---|---|
protected Address |
Message.dest_addr |
protected Address |
Message.src_addr |
Modifier and Type | Field and 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 and 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() |
Address |
JChannel.getLocalAddress()
returns the local address of the channel
returns null if the channel is closed
|
abstract Address |
Channel.getLocalAddress()
Returns the channel's own address.
|
Address |
Message.getSrc() |
Modifier and Type | Method and Description |
---|---|
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.
|
java.util.Vector<Address> |
Membership.getMembers()
returns a copy (clone) of the members in this membership.
|
Modifier and Type | Method and Description |
---|---|
void |
Membership.add(Address new_member)
Adds a new member to this membership.
|
void |
ChannelListenerAdapter.channelReconnected(Address addr) |
void |
ChannelListener.channelReconnected(Address addr) |
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.
|
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
|
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
|
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves a full state from the target member.
|
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group.
|
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.
|
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,
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.
|
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
|
abstract void |
Channel.send(Address dst,
Address src,
java.io.Serializable obj)
Helper method.
|
void |
Message.setDest(Address new_dest) |
void |
Message.setSrc(Address new_src) |
void |
ReceiverAdapter.suspect(Address suspected_mbr) |
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.
|
Modifier and Type | Method and 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.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. |
boolean |
JChannel.startFlush(java.util.List<Address> flushParticipants,
boolean automatic_resume)
Performs a partial flush in a cluster for flush participants.
|
abstract boolean |
Channel.startFlush(java.util.List<Address> flushParticipants,
boolean automatic_resume) |
void |
JChannel.stopFlush(java.util.List<Address> flushParticipants) |
abstract void |
Channel.stopFlush(java.util.List<Address> flushParticipants) |
Constructor and 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 and 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 and Description |
---|---|
protected Address |
RequestCorrelator.local_addr
The address of this group member
|
protected Address |
MessageDispatcher.local_addr |
Modifier and Type | Field and 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 and Description |
---|---|
Address |
GroupRequest.getCaller() |
Address |
RequestCorrelator.getLocalAddress() |
Address |
ReplicatedTree.getLocalAddress() |
Address |
ReplicatedHashMap.getLocalAddress() |
Address |
NotificationBus.getLocalAddress() |
Address |
BasicConnectionTable.getLocalAddress() |
Address |
DistributedHashtable.getLocalAddress()
Deprecated.
|
Address |
ReplicatedHashtable.getLocalAddress()
Deprecated.
|
Address |
DistributedQueue.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
java.util.Vector<Address> |
GroupRequest.getSuspects()
Returns the list of suspected members.
|
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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 |
RspCollector.receiveResponse(java.lang.Object response_value,
Address sender) |
void |
GroupRequest.receiveResponse(java.lang.Object response_value,
Address sender)
Callback (called by RequestCorrelator or Transport).
|
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 |
DistributedLockManager.suspect(Address suspected_mbr) |
void |
ReplicatedTree.suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
VotingAdapter.suspect(Address suspected)
Callback for notification that one node is suspected
|
void |
MembershipListenerAdapter.suspect(Address suspected_mbr)
Notify membership listener that some node was suspected.
|
void |
RspCollector.suspect(Address mbr) |
void |
GroupRequest.suspect(Address suspected_member)
Callback (called by RequestCorrelator or Transport).
|
void |
ReplicatedHashMap.suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
NotificationBus.suspect(Address suspected_mbr) |
void |
DistributedHashtable.suspect(Address suspected_mbr)
Deprecated.
Called when a member is suspected
|
void |
ReplicatedHashtable.suspect(Address suspected_mbr)
Deprecated.
Called when a member is suspected
|
void |
DistributedQueue.suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
DistributedTree.suspect(Address suspected_mbr)
Called when a member is suspected
|
Modifier and Type | Method and 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) |
void |
ReplicatedHashMap.Notification.viewChange(View view,
java.util.Vector<Address> new_mbrs,
java.util.Vector<Address> old_mbrs) |
Constructor and Description |
---|
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) |
Constructor and 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 and Description |
---|---|
void |
Simulator.addMember(Address addr) |
void |
Simulator.addMember(Address addr,
Simulator s) |
void |
Simulator.setLocalAddress(Address addr) |
Modifier and Type | Method and Description |
---|---|
void |
Gossip.channelReconnected(Address new_addr) |
void |
Draw.channelReconnected(Address addr) |
void |
NotificationBusDemo.memberJoined(Address mbr) |
void |
NotificationBusDemo.memberLeft(Address mbr) |
void |
Topology.suspect(Address suspected_mbr) |
void |
ChatCore.suspect(Address suspected_mbr) |
void |
QuoteClient.suspect(Address suspected_mbr) |
void |
ViewDemo.suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
QuoteServer.suspect(Address suspected_mbr) |
Modifier and Type | Field and Description |
---|---|
Address |
Node.addr |
Modifier and Type | Method and 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 and Description |
---|---|
Address |
JChannelMBean.getLocalAddress() |
Address |
JChannel.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
boolean |
JChannelMBean.getState(Address target,
long timeout) |
boolean |
JChannel.getState(Address target,
long timeout) |
void |
JChannelMBean.send(Address dst,
Address src,
java.io.Serializable obj) |
void |
JChannel.send(Address dst,
Address src,
java.io.Serializable obj) |
Modifier and Type | Method and Description |
---|---|
Address |
TPMBean.getLocalAddress() |
Address |
TP.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
Address |
MuxChannel.getLocalAddress() |
Modifier and Type | Method and 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 and Description |
---|
ServiceInfo(byte type,
java.lang.String service,
Address host,
byte[] state) |
Modifier and Type | Class and Description |
---|---|
static class |
JMS.JMSAddress
Simple
Address representing the JMS node ID or JMS topic group. |
Modifier and Type | Field and 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 and Description |
---|---|
protected java.util.HashSet<Address> |
TP.members
The members of this group (updated when a member joins or leaves)
|
Modifier and Type | Method and Description |
---|---|
protected Address |
UDP.createLocalAddress() |
Address |
PingRsp.getAddress() |
Address |
PingRsp.getCoordAddress() |
Address |
SEQUENCER.getCoordinator() |
protected Address |
ENCRYPT.getKeyServerAddr() |
protected Address |
ENCRYPT.getLocal_addr() |
Address |
TP.getLocalAddress() |
Address |
SEQUENCER.getLocalAddress() |
Address |
SEQUENCER.SequencerHeader.getOriginalSender() |
Modifier and Type | Method and 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 and 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 |
TCPPING.localAddressSet(Address addr) |
void |
Discovery.localAddressSet(Address addr)
Called after local_addr was set
|
void |
PING.localAddressSet(Address addr) |
void |
UDP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
void |
TUNNEL.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 |
BasicTCP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
void |
LOOPBACK.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
void |
UDP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
void |
TUNNEL.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 |
BasicTCP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
void |
LOOPBACK.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
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.
|
void |
BasicTCP.receive(Address sender,
byte[] data,
int offset,
int length)
ConnectionTable.Receiver interface
|
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) |
void |
TCP.send(Address dest,
byte[] data,
int offset,
int length) |
void |
TCP_NIO.send(Address dest,
byte[] data,
int offset,
int length) |
abstract void |
BasicTCP.send(Address dest,
byte[] data,
int offset,
int length) |
void |
UDP.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
void |
TUNNEL.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 |
BasicTCP.sendToSingleMember(Address dest,
byte[] data,
int offset,
int length) |
void |
LOOPBACK.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 and Description |
---|---|
void |
TCP.retainAll(java.util.Collection<Address> members) |
void |
TCP_NIO.retainAll(java.util.Collection<Address> members) |
abstract void |
BasicTCP.retainAll(java.util.Collection<Address> members) |
Constructor and Description |
---|
FD_ALL.Header(byte type,
Address suspect) |
FD_SOCK.FdHeader(byte type,
Address mbr) |
FD_SOCK.FdHeader(byte type,
Address mbr,
IpAddress sock_addr) |
FD.FdHeader(byte type,
java.util.Vector<Address> mbrs,
Address from) |
HTOTAL.HTotalHeader(Address dest,
Address src) |
MERGE3.CoordAnnouncement(Address coord) |
MERGEFAST.MergefastHeader(Address coord) |
PingRsp(Address own_addr,
Address coord_addr,
boolean is_server) |
SEQUENCER.SequencerHeader(byte type,
Address original_sender,
long seqno) |
TP.ProtocolAdapter(java.lang.String cluster_name,
java.lang.String transport_name,
Protocol up,
Protocol down,
java.lang.String pattern,
Address addr) |
Constructor and Description |
---|
DISCARD.DiscardHeader(java.util.Set<Address> ignoredAddresses) |
FD_SOCK.FdHeader(byte type,
java.util.Map<Address,IpAddress> cachedAddrs) |
FD_SOCK.FdHeader(byte type,
java.util.Set<Address> mbrs) |
FD.FdHeader(byte type,
java.util.Vector<Address> mbrs,
Address from) |
Modifier and Type | Method and Description |
---|---|
protected Address |
GMS.determineCoordinator() |
Address |
GMS.GmsHeader.getMember() |
Address |
MergeData.getSender() |
Modifier and Type | Method and Description |
---|---|
void |
Gossip.addToSeenList(Address mbr) |
double |
NAKACK.getSmoothedAverageRetransmissionTime(Address sender)
Returns the smoothed average retransmission time for a given sender
|
void |
GmsImpl.handleDigestResponse(Address sender,
Digest digest) |
void |
CoordGmsImpl.handleDigestResponse(Address sender,
Digest digest) |
void |
GmsImpl.handleMergeRequest(Address sender,
ViewId merge_id) |
void |
ParticipantGmsImpl.handleMergeRequest(Address sender,
ViewId merge_id) |
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.
|
abstract void |
GmsImpl.join(Address mbr) |
void |
ParticipantGmsImpl.join(Address mbr) |
void |
CoordGmsImpl.join(Address mbr) |
void |
ClientGmsImpl.join(Address address) |
abstract void |
GmsImpl.joinWithStateTransfer(Address local_addr) |
void |
ParticipantGmsImpl.joinWithStateTransfer(Address mbr) |
void |
CoordGmsImpl.joinWithStateTransfer(Address mbr) |
void |
ClientGmsImpl.joinWithStateTransfer(Address address) |
abstract void |
GmsImpl.leave(Address mbr) |
void |
ParticipantGmsImpl.leave(Address mbr)
Loop: determine coord.
|
void |
CoordGmsImpl.leave(Address mbr)
The coordinator itself wants to leave the group
|
void |
ClientGmsImpl.leave(Address mbr) |
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) |
abstract void |
GmsImpl.suspect(Address mbr) |
void |
ParticipantGmsImpl.suspect(Address mbr) |
void |
CoordGmsImpl.suspect(Address mbr) |
void |
ClientGmsImpl.suspect(Address mbr) |
abstract void |
GmsImpl.unsuspect(Address mbr) |
void |
ParticipantGmsImpl.unsuspect(Address mbr)
Removes previously suspected member from list of currently suspected members
|
void |
CoordGmsImpl.unsuspect(Address mbr) |
void |
ClientGmsImpl.unsuspect(Address mbr) |
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 and 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.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.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 |
GmsImpl.merge(java.util.Vector<Address> other_coords) |
void |
CoordGmsImpl.merge(java.util.Vector<Address> other_coords)
Invoked upon receiving a MERGE event from the MERGE layer.
|
Constructor and Description |
---|
GMS.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) |
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest) |
STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest,
java.lang.String state_id) |
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
IpAddress bind_addr,
Digest digest,
java.lang.String state_id) |
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
long id,
Digest digest) |
STREAMING_STATE_TRANSFER.StateHeader(byte type,
Address sender,
java.lang.String state_id) |
Constructor and Description |
---|
FLUSH.FlushHeader(byte type,
long viewID,
java.util.Collection<Address> flushView) |
Modifier and Type | Class and Description |
---|---|
class |
IpAddress
Network-dependent address (Internet).
|
Modifier and Type | Field and Description |
---|---|
Address |
StateTransferInfo.target |
Modifier and Type | Method and Description |
---|---|
Address |
GossipData.getAddress() |
Address |
RouterStub.getLocalAddress() |
Modifier and Type | Method and Description |
---|---|
java.util.List<Address> |
GossipClient.getMembers(java.lang.String group)
Returns all members of a given group
|
Modifier and Type | Method and 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 |
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 |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest)
Retranmit the given msg
|
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 and 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,
java.io.InputStream is,
java.lang.String state_id) |
StateTransferInfo(Address target,
long timeout) |
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 and Description |
---|---|
protected java.util.Map<Address,Digest.Entry> |
Digest.senders
Map<Address, Entry>
|
Modifier and Type | Method and Description |
---|---|
Address |
Rsp.getSender() |
static Address |
Util.readAddress(java.io.DataInputStream in) |
Modifier and Type | Method and 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 and Description |
---|---|
boolean |
SeqnoTable.add(Address member,
long seqno) |
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) |
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) |
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 |
SeqnoTable.remove(Address member) |
void |
ResponseCollector.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 |
ResponseCollector.suspect(Address member) |
void |
AckCollector.suspect(Address member) |
void |
AckCollector.unsuspect(Address member) |
static void |
Util.writeAddress(Address addr,
java.io.DataOutputStream out) |
Modifier and Type | Method and 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.
|
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 |
ResponseCollector.reset(java.util.Collection<Address> members) |
void |
AckCollector.reset(ViewId v,
java.util.List<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 and 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 and 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.