Uses of Annotation Interface
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
org.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 final RspList<T>	GroupRequest.rsps	Correlates requests and responses

Methods 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
protected void	NioConnection.addBuffer(ByteBuffer buf)
protected void	NioConnection.addBuffers(ByteBuffer[] bufs)
protected void	TcpConnection.doSend(byte[] data, int offset, int length, boolean flush)
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 long	BaseBundler.count
protected long	RATE_LIMITER.current_period_start
protected Future<?>	FailureDetection.heartbeat_sender
protected long	RATE_LIMITER.num_bytes_sent_in_period	Keeps track of the number of bytes sent in the current time period
protected Thread	FD_SOCK.pinger_thread
protected Future<?>	COUNTER.reconciliation_task_future
protected Future<?>	FailureDetection.timeout_checker

Methods in org.jgroups.protocols with annotations of type GuardedBy

Modifier and Type	Method	Description
protected void	BaseBundler.addMessage(Message msg, int size)
protected void	BaseBundler.sendBundledMessages()	Sends all messages in the map.
protected void	FD_SOCK2.BroadcastTask.startTask()
protected void	FD_SOCK2.BroadcastTask.stopTask()
protected void	VERIFY_SUSPECT2.stopThreadPool()
protected void	VERIFY_SUSPECT.stopTimer()

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 final List<Address>	StreamingStateTransfer.members
protected long	STABLE.num_bytes_received	The total number of bytes received from unicast and multicast messages
protected final AtomicBoolean	ViewHandler.processing
protected 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-null
protected Collection<R>	ViewHandler.remove(Collection<R> requests)	Removes requests as long as they match - breaks at the first non-matching request or when requests is empty This method must catch all exceptions; or else process() might return without setting processing to true again!
protected void	STABLE.resetDigest()
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 final Map<Address,Long>	CreditMap.credits
protected boolean	Responses.done

Methods in org.jgroups.util with annotations of type GuardedBy

Modifier and Type	Method	Description
protected void	DynamicBuffer._compact()	Moves the contents of matrix down by the number of purged rows and resizes the matrix accordingly.
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	FixedBuffer.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	DynamicBuffer.computeIndex(long seqno)	Computes and returns the index within a row for seqno
protected int	Table.computeIndex(long seqno)	Computes and returns the index within a row for seqno
protected long	AckTable.computeMin()
protected int	DynamicBuffer.computeRow(long seqno)	Computes and returns the row index for seqno.
protected int	Table.computeRow(long seqno)	Computes and returns the row index for seqno.
int	Buffer.computeSize()	Iterates from hd to high and adds up non-null values.
int	Table.computeSize()	Iterate from low to hr and add up non-null values.
protected void	FixedBuffer.decreaseCapacity(int new_cap)
protected boolean	Credit.decrement(long credits)
protected int	Responses.find(PingData data)
void	DynamicBuffer.forEach(long from, long to, Buffer.Visitor<T> visitor, boolean nullify)	Iterates over the matrix with range [from ..
void	Table.forEach(long from, long to, Table.Visitor<T> visitor)	Iterates over the matrix with range [from ..
protected T[]	DynamicBuffer.getRow(int index)	Returns a row.
protected T[]	Table.getRow(int index)	Returns a row.
protected void	FixedBuffer.increaseCapacity(int new_cap)
protected void	DynamicBuffer.move(int num_rows)	Moves contents of matrix num_rows down.
protected void	Table.move(int num_rows)	Moves contents of matrix num_rows down.
protected int	BlockingInputStream.remaining()
protected void	DynamicBuffer.resize(long seqno)	Moves rows down the matrix, by removing purged rows.
protected void	Table.resize(long seqno)	Moves rows down the matrix, by removing purged rows.
protected int	BlockingInputStream.size()
protected List<PingData>	Responses.toList()
boolean	Buffer.Remover.visit(long seqno, T element)
boolean	Table.Remover.visit(long seqno, T element, int row, int column)