Uses of Class
org.jgroups.annotations.GuardedBy
-
Packages that use GuardedBy Package Description org.jgroups.blocks Provides building blocks that are layered on top of channels.org.jgroups.blocks.cs This package contains all client-server related interfaces and classesorg.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.protocols.pbcast org.jgroups.stack Support for managing protocol stacks.org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of GuardedBy in org.jgroups.blocks
Fields in org.jgroups.blocks with annotations of type GuardedBy Modifier and Type Field Description protected int
GroupRequest. num_received
protected int
GroupRequest. num_valid
protected RspList<T>
GroupRequest. rsps
Correlates requests and responsesMethods in org.jgroups.blocks with annotations of type GuardedBy Modifier and Type Method Description protected boolean
GroupRequest. responsesComplete()
boolean
UnicastRequest. responsesComplete()
-
Uses of GuardedBy in org.jgroups.blocks.cs
Methods in org.jgroups.blocks.cs with annotations of type GuardedBy Modifier and Type Method Description void
BaseServer. replaceConnection(Address address, Connection conn)
-
Uses of GuardedBy in org.jgroups.protocols
Fields in org.jgroups.protocols with annotations of type GuardedBy Modifier and Type Field Description protected java.util.concurrent.Future<?>
FD.Broadcaster. bcast_future
protected long
BaseBundler. count
protected long
RATE_LIMITER. current_period_start
protected java.util.concurrent.Future<?>
FailureDetection. heartbeat_sender
protected java.util.concurrent.Future<?>
FD. heartbeat_sender_future
protected java.util.List<Address>
FD. members
protected long
RATE_LIMITER. num_bytes_sent_in_period
Keeps track of the number of bytes sent in the current time periodprotected Address
FD. ping_dest
protected java.util.List<Address>
FD. pingable_mbrs
Members from which we select ping_dest.protected java.lang.Thread
FD_SOCK. pinger_thread
protected FD.BroadcastTask
FD.Broadcaster. task
protected java.util.concurrent.Future<?>
FailureDetection. timeout_checker
protected java.util.concurrent.Future<?>
FD. timeout_checker_future
Methods in org.jgroups.protocols with annotations of type GuardedBy Modifier and Type Method Description protected void
BaseBundler. addMessage(Message msg, long size)
protected void
BaseBundler. clearMessages()
protected void
FD. computePingDest(Address remove)
Computes pingable_mbrs (based on the current membership and the suspected members) and ping_destprotected void
BaseBundler. sendBundledMessages()
Sends all messages in the map.protected void
FD. startMonitor()
Requires lock to held by callerprotected void
FD. stopMonitor()
Requires lock to be held by callerprotected void
VERIFY_SUSPECT. stopTimer()
protected void
FD. unsuspect(Address mbr)
-
Uses of GuardedBy in org.jgroups.protocols.pbcast
Fields in org.jgroups.protocols.pbcast with annotations of type GuardedBy Modifier and Type Field Description protected MutableDigest
STABLE. digest
protected java.util.List<Address>
StreamingStateTransfer. members
protected long
STABLE. num_bytes_received
The total number of bytes received from unicast and multicast messagesprotected boolean
ViewHandler. processing
protected Digest
NAKACK2. rebroadcast_digest
protected java.util.concurrent.Future<?>
STABLE. stable_task_future
protected FixedSizeBitSet
STABLE. votes
Keeps track of who we already heard from (STABLE_GOSSIP msgs).Methods in org.jgroups.protocols.pbcast with annotations of type GuardedBy Modifier and Type Method Description protected boolean
STABLE. addVote(int rank)
Adds mbr to votes and returns true if we have all the votes, otherwise false.protected static boolean
STABLE. allVotesReceived(FixedSizeBitSet votes)
Votes is already locked and guaranteed to be non-nullprotected void
STABLE. resetDigest()
protected boolean
ViewHandler. setProcessing(boolean flag)
protected void
STABLE. updateLocalDigest(Digest d, Address sender)
Update my own digest from a digest received by somebody else. -
Uses of GuardedBy in org.jgroups.stack
Methods in org.jgroups.stack with annotations of type GuardedBy Modifier and Type Method Description protected void
RouterStub. _doConnect()
-
Uses of GuardedBy in org.jgroups.util
Fields in org.jgroups.util with annotations of type GuardedBy Modifier and Type Field Description protected java.util.Map<Address,java.lang.Long>
CreditMap. credits
protected boolean
Responses. done
Methods in org.jgroups.util with annotations of type GuardedBy Modifier and Type Method Description protected boolean
RequestTable. _compact()
Shrinks the array to half of its current size if the current number of elements fit into half of the capacity.protected void
Table. _compact()
Moves the contents of matrix down by the number of purged rows and resizes the matrix accordingly.protected boolean
RequestTable. _contiguousSpaceAvailable(int space_needed)
Check if we have at least space_needed contiguous free slots available in range [low+1 ..protected Responses
Responses. _done()
protected void
RequestTable. _grow(long new_capacity)
protected void
Responses. add(PingData data)
protected void
RequestTable. advanceLow()
protected boolean
RingBufferSeqno. block(long seqno)
protected void
BlockingInputStream. compact()
Moves the bytes between [read_pos and write_pos] read_pos bytes to the left, such that the new read_pos is 0 and the write_pos is write_pos - read_pos.protected int
Table. computeIndex(long seqno)
Computes and returns the index within a row for seqnoprotected int
Table. computeRow(long seqno)
Computes and returns the row index for seqno.int
Table. computeSize()
Iterate from low to hr and add up non-null values.protected boolean
Credit. decrement(long credits)
protected int
Responses. find(PingData data)
void
Table. forEach(long from, long to, Table.Visitor<T> visitor)
Iterates over the matrix with range [from ..protected T[]
Table. getRow(int index)
Returns a row.protected void
Table. move(int num_rows)
Moves contents of matrix num_rows down.protected int
BlockingInputStream. remaining()
protected void
Table. resize(long seqno)
Moves rows down the matrix, by removing purged rows.protected int
BlockingInputStream. size()
protected java.util.List<PingData>
Responses. toList()
boolean
Table.Remover. visit(long seqno, T element, int row, int column)
-