Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep
Overview  Package  Class  Use  Deprecated   Index 
Home >> All >> org >> jgroups >> protocols >> [ pbcast overview ]  PREV  NEXT
A B C D E F G H I J L M N O P Q R S T U V W X

A

ack_collector - Variable in class org.jgroups.protocols.pbcast.GMS
To collect VIEW_ACKs from all members
add(Address, long, long) - Method in class org.jgroups.protocols.pbcast.Digest
 
add(Address, long, long, long) - Method in class org.jgroups.protocols.pbcast.Digest
 
add(Address, Digest.Entry) - Method in class org.jgroups.protocols.pbcast.Digest
 
add(Digest) - Method in class org.jgroups.protocols.pbcast.Digest
 
add(GMS.Request) - Method in class org.jgroups.protocols.pbcast.GMS.ViewHandler
 
addToSeenList(Address) - Method in class org.jgroups.protocols.pbcast.Gossip
 
adjustReceivers() - Method in class org.jgroups.protocols.pbcast.NAKACK
Remove old members from NakReceiverWindows and add new members (starting seqno=0).
adjustSenders(Digest, Vector) - Method in class org.jgroups.protocols.pbcast.STABLE
Digest and members are guaranteed to be non-null
avg_state_size - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 

B

becomeClient() - Method in class org.jgroups.protocols.pbcast.GMS
 
becomeCoordinator() - Method in class org.jgroups.protocols.pbcast.GMS
 
becomeParticipant() - Method in class org.jgroups.protocols.pbcast.GMS
 
becomeSingletonMember(Address) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 

C

CANCEL_MERGE - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
CLIENT - Static variable in class org.jgroups.protocols.pbcast.GMS
 
COORD - Static variable in class org.jgroups.protocols.pbcast.GMS
 
ClientGmsImpl - class org.jgroups.protocols.pbcast.ClientGmsImpl.
Client part of GMS.
ClientGmsImpl(GMS) - Constructor for class org.jgroups.protocols.pbcast.ClientGmsImpl
 
CoordGmsImpl - class org.jgroups.protocols.pbcast.CoordGmsImpl.
Coordinator role of the Group MemberShip (GMS) protocol.
CoordGmsImpl(GMS) - Constructor for class org.jgroups.protocols.pbcast.CoordGmsImpl
 
CoordGmsImpl.MergeCanceller - class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller.
 
CoordGmsImpl.MergeCanceller(Object, long) - Constructor for class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 
CoordGmsImpl.MergeTask - class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeTask.
Starts the merge protocol (only run by the merge leader).
CoordGmsImpl.MergeTask() - Constructor for class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeTask
 
cancel() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 
cancelMerge() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
cancelled - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 
cancelled() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 
cancelled() - Method in class org.jgroups.protocols.pbcast.STABLE.ResumeTask
 
cancelled() - Method in class org.jgroups.protocols.pbcast.STABLE.StabilitySendTask
 
cancelled() - Method in class org.jgroups.protocols.pbcast.STABLE.StableTask
 
castViewChange(Vector, Vector, Vector) - Method in class org.jgroups.protocols.pbcast.GMS
Compute a new view, given the current view, the new members and the suspected/left members.
castViewChange(View, Digest) - Method in class org.jgroups.protocols.pbcast.GMS
 
checkSelfInclusion(Vector) - Method in class org.jgroups.protocols.pbcast.GMS
Returns true if local_addr is member of mbrs, else false
checker - Variable in class org.jgroups.protocols.pbcast.FD
 
checker_lock - Variable in class org.jgroups.protocols.pbcast.FD
 
clear() - Method in class org.jgroups.protocols.pbcast.Digest
 
clear() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
clearDigest() - Method in class org.jgroups.protocols.pbcast.STABLE
 
computeGossipInterval(int, double) - Method in class org.jgroups.protocols.pbcast.PBCAST
Computes the gossip_interval.
computeSleepTime() - Method in class org.jgroups.protocols.pbcast.STABLE.StableTask
 
consolidateDigests(Vector, int) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Merge all digests into one.
consolidateMergeData(Vector) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Merge all MergeData.
contains(Address) - Method in class org.jgroups.protocols.pbcast.Digest
 
coordinators - Variable in class org.jgroups.protocols.pbcast.GMS.Request
 
coords - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeTask
 
copy() - Method in class org.jgroups.protocols.pbcast.Digest
 
copy() - Method in class org.jgroups.protocols.pbcast.Gossip
 
copy() - Method in class org.jgroups.protocols.pbcast.NakAckHeader
 
createNakReceiverWindow(Address, long) - Method in class org.jgroups.protocols.pbcast.NAKACK
 
createSenders(int) - Method in class org.jgroups.protocols.pbcast.Digest
 

D

Digest - class org.jgroups.protocols.pbcast.Digest.
A message digest, which is used by the PBCAST layer for gossiping (also used by NAKACK for keeping track of current seqnos for all members).
Digest() - Constructor for class org.jgroups.protocols.pbcast.Digest
 
Digest(int) - Constructor for class org.jgroups.protocols.pbcast.Digest
 
Digest.Entry - class org.jgroups.protocols.pbcast.Digest.Entry.
Class keeping track of the lowest and highest sequence numbers delivered, and the highest sequence numbers received, per member
Digest.Entry(long, long, long) - Constructor for class org.jgroups.protocols.pbcast.Digest.Entry
 
Digest.Entry(long, long) - Constructor for class org.jgroups.protocols.pbcast.Digest.Entry
 
Digest.Entry(Digest.Entry) - Constructor for class org.jgroups.protocols.pbcast.Digest.Entry
 
d - Variable in class org.jgroups.protocols.pbcast.STABLE.StabilitySendTask
 
data - Variable in class org.jgroups.protocols.pbcast.PBCAST.GossipEntry
 
delay - Variable in class org.jgroups.protocols.pbcast.STABLE.StabilitySendTask
 
desired_avg_gossip - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
desired_avg_gossip - Variable in class org.jgroups.protocols.pbcast.STABLE
Sends a STABLE gossip every 20 seconds on average.
determineCoord(Vector) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
The coordinator is determined by a majority vote.
determineCoordinator() - Method in class org.jgroups.protocols.pbcast.GMS
 
determineCoordinator() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
Return the first element of members which is not me.
digest - Variable in class org.jgroups.protocols.pbcast.Gossip
 
digest - Variable in class org.jgroups.protocols.pbcast.JoinRsp
 
digest - Variable in class org.jgroups.protocols.pbcast.MergeData
 
digest - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
digest - Variable in class org.jgroups.protocols.pbcast.STABLE
 
digest - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
digest_mutex - Variable in class org.jgroups.protocols.pbcast.GMS
 
digest_promise - Variable in class org.jgroups.protocols.pbcast.GMS
 
digest_timeout - Variable in class org.jgroups.protocols.pbcast.GMS
 
disable_initial_coord - Variable in class org.jgroups.protocols.pbcast.GMS
 
discard_delivered_msgs - Variable in class org.jgroups.protocols.pbcast.NAKACK
Messages that have been received in order are sent up the stack (= delivered to the application).
down(Event) - Method in class org.jgroups.protocols.pbcast.FD
 
down(Event) - Method in class org.jgroups.protocols.pbcast.GMS
 
down(Event) - Method in class org.jgroups.protocols.pbcast.NAKACK
Callback.
down(Event) - Method in class org.jgroups.protocols.pbcast.PBCAST
 
down(Event) - Method in class org.jgroups.protocols.pbcast.STABLE
 
down(Event) - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
dumpStats() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
dynamic - Variable in class org.jgroups.protocols.pbcast.PBCAST
 

E

equals(Object) - Method in class org.jgroups.protocols.pbcast.Digest.Entry
 
equals(Object) - Method in class org.jgroups.protocols.pbcast.Digest
 
equals(Object) - Method in class org.jgroups.protocols.pbcast.Gossip
 
equals(Object) - Method in class org.jgroups.protocols.pbcast.MergeData
 
equals(Object) - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 

F

FD - class org.jgroups.protocols.pbcast.FD.
Passive failure detection protocol.
FD() - Constructor for class org.jgroups.protocols.pbcast.FD
 
FD.Entry - class org.jgroups.protocols.pbcast.FD.Entry.
 
FD.Entry(long) - Constructor for class org.jgroups.protocols.pbcast.FD.Entry
 
findInitialMembers() - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Pings initial members.

G

GMS - class org.jgroups.protocols.pbcast.GMS.
Group membership protocol.
GMS() - Constructor for class org.jgroups.protocols.pbcast.GMS
 
GMS.GmsHeader - class org.jgroups.protocols.pbcast.GMS.GmsHeader.
 
GMS.GmsHeader() - Constructor for class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
GMS.GmsHeader(byte) - Constructor for class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
GMS.GmsHeader(byte, View) - Constructor for class org.jgroups.protocols.pbcast.GMS.GmsHeader
Used for VIEW header
GMS.GmsHeader(byte, Address) - Constructor for class org.jgroups.protocols.pbcast.GMS.GmsHeader
Used for JOIN_REQ or LEAVE_REQ header
GMS.GmsHeader(byte, JoinRsp) - Constructor for class org.jgroups.protocols.pbcast.GMS.GmsHeader
Used for JOIN_RSP header
GMS.Request - class org.jgroups.protocols.pbcast.GMS.Request.
 
GMS.Request(int, Address, boolean, Vector) - Constructor for class org.jgroups.protocols.pbcast.GMS.Request
 
GMS.ViewHandler - class org.jgroups.protocols.pbcast.GMS.ViewHandler.
Class which processes JOIN, LEAVE and MERGE requests.
GMS.ViewHandler() - Constructor for class org.jgroups.protocols.pbcast.GMS.ViewHandler
 
GOSSIP - Static variable in class org.jgroups.protocols.pbcast.PbcastHeader
 
GmsImpl - class org.jgroups.protocols.pbcast.GmsImpl.
 
GmsImpl() - Constructor for class org.jgroups.protocols.pbcast.GmsImpl
 
GmsImpl(GMS) - Constructor for class org.jgroups.protocols.pbcast.GmsImpl
 
Gossip - class org.jgroups.protocols.pbcast.Gossip.
 
Gossip(Address, long) - Constructor for class org.jgroups.protocols.pbcast.Gossip
 
Gossip(Address, long, Digest, Vector) - Constructor for class org.jgroups.protocols.pbcast.Gossip
 
garbageCollect(Digest) - Method in class org.jgroups.protocols.pbcast.PBCAST
 
gc_lag - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
gc_lag - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
generateMergeId() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Generates a unique merge id by taking the local address and the current time
get(Address) - Method in class org.jgroups.protocols.pbcast.Digest
 
getAverageStateSize() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
getDesiredAverageGossip() - Method in class org.jgroups.protocols.pbcast.STABLE
 
getDigest() - Method in class org.jgroups.protocols.pbcast.GMS
Sends down a GET_DIGEST event and waits for the GET_DIGEST_OK response, or timeout, whichever occurs first
getDigest() - Method in class org.jgroups.protocols.pbcast.JoinRsp
 
getDigest() - Method in class org.jgroups.protocols.pbcast.MergeData
 
getDigest() - Method in class org.jgroups.protocols.pbcast.NAKACK
Returns a message digest: for each member P the highest seqno received from P is added to the digest.
getDigest() - Method in class org.jgroups.protocols.pbcast.PBCAST
Returns for each sender the 'highest seen' seqno from the digest.
getDigest() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 
getDigestHighestDeliveredMsgs() - Method in class org.jgroups.protocols.pbcast.NAKACK
Returns a message digest: for each member P the highest seqno received from P without a gap is added to the digest.
getGcLag() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getHighSeqnoSeen(Address) - Method in class org.jgroups.protocols.pbcast.NAKACK
Returns the highest seqno seen from sender.
getImpl() - Method in class org.jgroups.protocols.pbcast.GMS
 
getJoinRetryTimeout() - Method in class org.jgroups.protocols.pbcast.GMS
 
getJoinTimeout() - Method in class org.jgroups.protocols.pbcast.GMS
 
getLocalAddress() - Method in class org.jgroups.protocols.pbcast.GMS
 
getLog() - Method in class org.jgroups.protocols.pbcast.GMS
 
getLowestAndHighestSeqno(Address, boolean) - Method in class org.jgroups.protocols.pbcast.NAKACK
Returns the lowest seqno still in cache (so it can be retransmitted) and the highest seqno received so far.
getMaxBytes() - Method in class org.jgroups.protocols.pbcast.STABLE
 
getMaxXmitBufSize() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getMaxXmitSize() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getMembers() - Method in class org.jgroups.protocols.pbcast.GMS
 
getMemeber() - Method in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
getMergeDataFromSubgroupCoordinators(Vector, long) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Sends a MERGE_REQ to all coords and populates a list of MergeData (in merge_rsps).
getMergeResponse(Address, ViewId) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
getMissingMessagesReceived() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getName() - Method in class org.jgroups.protocols.pbcast.FD
 
getName() - Method in class org.jgroups.protocols.pbcast.GMS
 
getName() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getName() - Method in class org.jgroups.protocols.pbcast.PBCAST
 
getName() - Method in class org.jgroups.protocols.pbcast.STABLE
 
getName() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
All protocol names have to be unique !
getNextSeqno() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getNextView(Vector, Vector, Vector) - Method in class org.jgroups.protocols.pbcast.GMS
Computes the next view.
getNotSeenList() - Method in class org.jgroups.protocols.pbcast.Gossip
 
getNumMembers() - Method in class org.jgroups.protocols.pbcast.GMS
 
getNumberOfGossipMessages() - Method in class org.jgroups.protocols.pbcast.STABLE
 
getNumberOfStateBytesSent() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
getNumberOfStateRequests() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
getNumberOfViews() - Method in class org.jgroups.protocols.pbcast.GMS
 
getPendingRetransmissionRequests() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getRandom(long) - Method in class org.jgroups.protocols.pbcast.PBCAST
 
getRandom(long) - Method in class org.jgroups.protocols.pbcast.STABLE.StableTask
 
getReceivedTableSize() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getSeenList() - Method in class org.jgroups.protocols.pbcast.Gossip
 
getSender() - Method in class org.jgroups.protocols.pbcast.MergeData
 
getSentTableSize() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getSeqno() - Method in class org.jgroups.protocols.pbcast.PbcastHeader
 
getType() - Method in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
getType() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 
getView() - Method in class org.jgroups.protocols.pbcast.GMS
 
getView() - Method in class org.jgroups.protocols.pbcast.JoinRsp
 
getView() - Method in class org.jgroups.protocols.pbcast.MergeData
 
getXmitRequestsReceived() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getXmitRequestsSent() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getXmitResponsesReceived() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
getXmitResponsesSent() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
gms - Variable in class org.jgroups.protocols.pbcast.GmsImpl
 
gossip - Variable in class org.jgroups.protocols.pbcast.PbcastHeader
 
gossip_handler - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
gossip_interval - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
gossip_list - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
gossip_queue - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
gossip_round - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
gossip_thread - Variable in class org.jgroups.protocols.pbcast.PBCAST
 

H

handleConfigEvent(HashMap) - Method in class org.jgroups.protocols.pbcast.NAKACK
 
handleDownEvent(Event) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleExit() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleExit() - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleGossip(Gossip) - Method in class org.jgroups.protocols.pbcast.PBCAST
MOST IMPORTANT METHOD IN THIS CLASS !! This guy really decides how a gossip reaches all members, or whether it will flood the network !
handleJoin(Address) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
handleJoin(Address) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Computes the new view (including the newly joined member) and get the digest from PBCAST.
handleJoin(Address) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleJoin(Address) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
handleJoinResponse(JoinRsp) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
handleJoinResponse(JoinRsp) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleJoinResponse(JoinRsp) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleJoinResponse(JoinRsp) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
handleLeave(Address, boolean) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Returns false.
handleLeave(Address, boolean) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Exclude mbr from the membership.
handleLeave(Address, boolean) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleLeave(Address, boolean) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
handleLeaveResponse() - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
handleLeaveResponse() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleLeaveResponse() - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleLeaveResponse() - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
handleMergeCancelled(ViewId) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleMergeCancelled(ViewId) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleMergeRequest(Address, ViewId) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Get the view and digest and send back both (MergeData) in the form of a MERGE_RSP to the sender.
handleMergeRequest(Vector) - Method in class org.jgroups.protocols.pbcast.GMS.ViewHandler
 
handleMergeRequest(Address, ViewId) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleMergeResponse(MergeData, ViewId) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleMergeResponse(MergeData, ViewId) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleMergeView(MergeData, ViewId) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
If merge_id is not equal to this.merge_id then discard.
handleMergeView(MergeData, ViewId) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleMessage(Message, NakAckHeader) - Method in class org.jgroups.protocols.pbcast.NAKACK
Finds the corresponding NakReceiverWindow and adds the message to it (according to seqno).
handleStabilityMessage(Digest, Address) - Method in class org.jgroups.protocols.pbcast.STABLE
 
handleStableMessage(Address, Digest) - Method in class org.jgroups.protocols.pbcast.STABLE
Digest d contains (a) the highest seqnos deliverable for each sender and (b) the highest seqnos seen for each member.
handleStateReq(Object) - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
If a state transfer is in progress, we don't need to send a GET_APPLSTATE event to the application, but instead we just add the sender to the requester list so it will receive the same state when done.
handleStateRsp(Object, Digest, byte[]) - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
Set the digest and the send the state up to the application
handleSuspect(Address) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Returns immediately.
handleSuspect(Address) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
handleSuspect(Address) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleSuspect(Address) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
handleUpEvent(Event) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
handleUpEvent(Event) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleUpMessage(Message, PbcastHeader) - Method in class org.jgroups.protocols.pbcast.PBCAST
Ensures that FIFO is observed for all messages for a certain member.
handleViewChange(View, Digest) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Does nothing.
handleViewChange(View, Digest) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Called by the GMS when a VIEW is received.
handleViewChange(View, Digest) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
handleViewChange(View, Digest) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
If we are leaving, we have to wait for the view change (last msg in the current view) that excludes us before we can leave.
handleViewChange(View) - Method in class org.jgroups.protocols.pbcast.STABLE
 
handleViewChange(View) - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
handleXmitReq(Address, long, long, Address) - Method in class org.jgroups.protocols.pbcast.NAKACK
Retransmit from sent-table, called when XMIT_REQ is received.
handleXmitRequest(Address, Hashtable) - Method in class org.jgroups.protocols.pbcast.PBCAST
Find the messages indicated in xmit_reqs and re-send them to requester
handleXmitRsp(Message) - Method in class org.jgroups.protocols.pbcast.NAKACK
 
handleXmitRsp(List) - Method in class org.jgroups.protocols.pbcast.PBCAST
 
handle_concurrent_startup - Variable in class org.jgroups.protocols.pbcast.GMS
Setting this to false disables concurrent startups.
hashCode() - Method in class org.jgroups.protocols.pbcast.Gossip
 
hashCode() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 
haveCoordinatorRole() - Method in class org.jgroups.protocols.pbcast.GMS
 
hdr - Variable in class org.jgroups.protocols.pbcast.PBCAST.GossipEntry
 
heard_from - Variable in class org.jgroups.protocols.pbcast.STABLE
 
highSeqnoAt(Address) - Method in class org.jgroups.protocols.pbcast.Digest
 
highSeqnoSeenAt(Address) - Method in class org.jgroups.protocols.pbcast.Digest
 
high_seqno - Variable in class org.jgroups.protocols.pbcast.Digest.Entry
 
high_seqno_seen - Variable in class org.jgroups.protocols.pbcast.Digest.Entry
 

I

INSTALL_MERGE_VIEW - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
INTERVAL - Static variable in class org.jgroups.protocols.pbcast.GMS.ViewHandler
 
iWouldBeCoordinator(Vector) - Method in class org.jgroups.protocols.pbcast.GmsImpl
Returns potential coordinator based on lexicographic ordering of member addresses.
id - Variable in class org.jgroups.protocols.pbcast.Gossip
 
id - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 
impl - Variable in class org.jgroups.protocols.pbcast.GMS
 
impl_mutex - Variable in class org.jgroups.protocols.pbcast.GMS
 
impls - Variable in class org.jgroups.protocols.pbcast.GMS
 
incrementHighSeqno(Address) - Method in class org.jgroups.protocols.pbcast.Digest
Increments the sender's high_seqno by 1.
init() - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
init() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
init() - Method in class org.jgroups.protocols.pbcast.GMS
 
init() - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
init() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
init() - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
init() - Method in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
initState() - Method in class org.jgroups.protocols.pbcast.GMS
 
initial_mbrs - Variable in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
initial_mbrs_received - Variable in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
initialized - Variable in class org.jgroups.protocols.pbcast.STABLE
 
installView(View) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Called by join().
installView(View, Digest) - Method in class org.jgroups.protocols.pbcast.GMS
Sets the new view and sends a VIEW_CHANGE event up and down the stack.
installView(View) - Method in class org.jgroups.protocols.pbcast.GMS
Sets the new view and sends a VIEW_CHANGE event up and down the stack.
invalid_gossipers - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
isCoordinator() - Method in class org.jgroups.protocols.pbcast.GMS
 
isDiscardDeliveredMsgs() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
isRunning() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeTask
 
isShun() - Method in class org.jgroups.protocols.pbcast.GMS
 
isUseMcastXmit() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
isXmitFromRandomMember() - Method in class org.jgroups.protocols.pbcast.NAKACK
 
is_server - Variable in class org.jgroups.protocols.pbcast.NAKACK
 

J

JOIN - Static variable in class org.jgroups.protocols.pbcast.GMS.Request
 
JOIN_REQ - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
JOIN_RSP - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
JoinRsp - class org.jgroups.protocols.pbcast.JoinRsp.
 
JoinRsp() - Constructor for class org.jgroups.protocols.pbcast.JoinRsp
 
JoinRsp(View, Digest) - Constructor for class org.jgroups.protocols.pbcast.JoinRsp
 
join(Address) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
Joins this process to a group.
join(Address) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
join(Address) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
join(Address) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
join_promise - Variable in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
join_retry_timeout - Variable in class org.jgroups.protocols.pbcast.GMS
 
join_rsp - Variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
join_timeout - Variable in class org.jgroups.protocols.pbcast.GMS
 
joining - Variable in class org.jgroups.protocols.pbcast.GMS
Members joined but for which no view has been received yet

L

LEAVE - Static variable in class org.jgroups.protocols.pbcast.GMS.Request
 
LEAVE_REQ - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
LEAVE_RSP - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
latest_local_digest - Variable in class org.jgroups.protocols.pbcast.STABLE
 
leave(Address) - Method in class org.jgroups.protocols.pbcast.ClientGmsImpl
 
leave(Address) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
The coordinator itself wants to leave the group
leave(Address) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
leave(Address) - Method in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
Loop: determine coord.
leave_promise - Variable in class org.jgroups.protocols.pbcast.ParticipantGmsImpl
 
leave_timeout - Variable in class org.jgroups.protocols.pbcast.GMS
 
leaving - Variable in class org.jgroups.protocols.pbcast.GMS
Members excluded from group, but for which no view has been received yet
leaving - Variable in class org.jgroups.protocols.pbcast.GmsImpl
 
leaving - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
local_addr - Variable in class org.jgroups.protocols.pbcast.FD
 
local_addr - Variable in class org.jgroups.protocols.pbcast.GMS
 
local_addr - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
local_addr - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
local_addr - Variable in class org.jgroups.protocols.pbcast.STABLE
 
local_addr - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
log - Static variable in class org.jgroups.protocols.pbcast.Digest
 
log - Variable in class org.jgroups.protocols.pbcast.GmsImpl
 
lowSeqnoAt(Address) - Method in class org.jgroups.protocols.pbcast.Digest
 
low_seqno - Variable in class org.jgroups.protocols.pbcast.Digest.Entry
 
ltime - Variable in class org.jgroups.protocols.pbcast.GMS
 

M

MCAST_MSG - Static variable in class org.jgroups.protocols.pbcast.PbcastHeader
 
MERGE - Static variable in class org.jgroups.protocols.pbcast.GMS.Request
 
MERGE_REQ - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
MERGE_RSP - Static variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
MSG - Static variable in class org.jgroups.protocols.pbcast.NakAckHeader
 
MergeData - class org.jgroups.protocols.pbcast.MergeData.
Encapsulates data sent with a MERGE_RSP (handleMergeResponse()) and INSTALL_MERGE_VIEW (handleMergeView()).
MergeData() - Constructor for class org.jgroups.protocols.pbcast.MergeData
Empty constructor needed for externalization
MergeData(Address, View, Digest) - Constructor for class org.jgroups.protocols.pbcast.MergeData
 
main(String[]) - Static method in class org.jgroups.protocols.pbcast.Gossip
 
makeView(Vector) - Method in class org.jgroups.protocols.pbcast.GMS
 
makeView(Vector, ViewId) - Method in class org.jgroups.protocols.pbcast.GMS
 
map - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
max_bytes - Variable in class org.jgroups.protocols.pbcast.STABLE
Total amount of bytes from incoming messages (default = 0 = disabled).
max_gossip_cache - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
max_invalid_gossips - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
max_queue - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
max_suspend_time - Variable in class org.jgroups.protocols.pbcast.STABLE.ResumeTask
 
max_xmit_buf_size - Variable in class org.jgroups.protocols.pbcast.NAKACK
If value is > 0, the retransmit buffer is bounded: only the max_xmit_buf_size latest messages are kept, older ones are discarded when the buffer size is exceeded.
max_xmit_size - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
mbr - Variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
mbr - Variable in class org.jgroups.protocols.pbcast.GMS.Request
 
mbrs - Variable in class org.jgroups.protocols.pbcast.STABLE
 
mcast_gossip - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
members - Variable in class org.jgroups.protocols.pbcast.FD
 
members - Variable in class org.jgroups.protocols.pbcast.GMS
 
members - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
members - Variable in class org.jgroups.protocols.pbcast.PBCAST
 
members - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
merge(Vector) - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl
Invoked upon receiving a MERGE event from the MERGE layer.
merge(Digest) - Method in class org.jgroups.protocols.pbcast.Digest
Adds a digest to this digest.
merge(Address, long, long, long) - Method in class org.jgroups.protocols.pbcast.Digest
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)
merge(Vector) - Method in class org.jgroups.protocols.pbcast.GmsImpl
 
mergeDigest(Digest) - Method in class org.jgroups.protocols.pbcast.GMS
Send down a MERGE_DIGEST event
mergeDigest(Digest) - Method in class org.jgroups.protocols.pbcast.NAKACK
For all members of the digest, adjust the NakReceiverWindows in the received_msgs hashtable.
merge_canceller - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_canceller_mutex - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_id - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_id - Variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
merge_leader - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_leader - Variable in class org.jgroups.protocols.pbcast.GMS
 
merge_rejected - Variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
merge_rejected - Variable in class org.jgroups.protocols.pbcast.MergeData
 
merge_rsps - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_task - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
merge_timeout - Variable in class org.jgroups.protocols.pbcast.GMS
 
merging - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl
 
missingMessageReceived(long, Message) - Method in class org.jgroups.protocols.pbcast.NAKACK
 
missing_msgs_rcvd - Variable in class org.jgroups.protocols.pbcast.NAKACK.Entry
 
missing_msgs_received - Variable in class org.jgroups.protocols.pbcast.NAKACK
 
my_digest - Variable in class org.jgroups.protocols.pbcast.GMS.GmsHeader
 
my_digest - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER.StateHeader
 
my_merge_id - Variable in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 

N

NAKACK - class org.jgroups.protocols.pbcast.NAKACK.
Negative AcKnowledgement layer (NAKs).
NAKACK() - Constructor for class org.jgroups.protocols.pbcast.NAKACK
 
NAKACK.Entry - class org.jgroups.protocols.pbcast.NAKACK.Entry.
 
NAKACK.Entry() - Constructor for class org.jgroups.protocols.pbcast.NAKACK.Entry
 
NAKACK.MissingMessage - class org.jgroups.protocols.pbcast.NAKACK.MissingMessage.
 
NAKACK.MissingMessage(Address, long) - Constructor for class org.jgroups.protocols.pbcast.NAKACK.MissingMessage
 
NAKACK.XmitRequest - class org.jgroups.protocols.pbcast.NAKACK.XmitRequest.
 
NAKACK.XmitRequest(Address, long, Address) - Constructor for class org.jgroups.protocols.pbcast.NAKACK.XmitRequest
 
NOT_MEMBER - Static variable in class org.jgroups.protocols.pbcast.PbcastHeader
 
NakAckHeader - class org.jgroups.protocols.pbcast.NakAckHeader.
 
NakAckHeader() - Constructor for class org.jgroups.protocols.pbcast.NakAckHeader
 
NakAckHeader(byte, long) - Constructor for class org.jgroups.protocols.pbcast.NakAckHeader
Constructor for regular messages
NakAckHeader(byte, long, long) - Constructor for class org.jgroups.protocols.pbcast.NakAckHeader
Constructor for retransmit requests/responses (low and high define the range of msgs)
NakAckHeader(byte, long, long, Address) - Constructor for class org.jgroups.protocols.pbcast.NakAckHeader
 
name - Static variable in class org.jgroups.protocols.pbcast.GMS
 
name - Static variable in class org.jgroups.protocols.pbcast.NAKACK
 
name - Static variable in class org.jgroups.protocols.pbcast.STABLE
 
name - Static variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
nextInterval() - Method in class org.jgroups.protocols.pbcast.CoordGmsImpl.MergeCanceller
 
nextInterval() - Method in class org.jgroups.protocols.pbcast.STABLE.ResumeTask
 
nextInterval() - Method in class org.jgroups.protocols.pbcast.STABLE.StabilitySendTask
wait a random number of msecs (to give other a chance to send the STABILITY msg first)
nextInterval() - Method in class org.jgroups.protocols.pbcast.STABLE.StableTask
 
not_seen - Variable in class org.jgroups.protocols.pbcast.Gossip
 
num_bytes_received - Variable in class org.jgroups.protocols.pbcast.STABLE
The total number of bytes received from unicast and multicast messages
num_bytes_sent - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
num_gossips - Variable in class org.jgroups.protocols.pbcast.STABLE
Number of gossip messages
num_prev_mbrs - Variable in class org.jgroups.protocols.pbcast.GMS
Max number of old members to keep in history
num_state_reqs - Variable in class org.jgroups.protocols.pbcast.STATE_TRANSFER
 
num_views - Variable in class org.jgroups.protocols.pbcast.GMS
 

O

operational - Variable in class org.jgroups.protocols.pbcast.PBCAST</