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 classes
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.

Uses of GuardedBy in org.jgroups.blocks

Fields in org.jgroups.blocks with annotations of type GuardedBy

Modifier and Type	Field and Description
protected java.util.Map<Address,Rsp<T>>	GroupRequest.requests Correlates requests and responses

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

Modifier and Type	Method and Description
protected boolean	UnicastRequest.responsesComplete()
protected boolean	GroupRequest.responsesComplete()
protected boolean	Request.responsesComplete(long timeout) This method runs with lock locked (called by execute()).
protected boolean	Request.waitForResults(long timeout)

Uses of GuardedBy in org.jgroups.blocks.cs

Methods in org.jgroups.blocks.cs with annotations of type GuardedBy

Modifier and Type	Method and 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 and 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<?>	MERGE2.FindSubgroupsTask.future
protected java.util.concurrent.Future<?>	FD_ALL.heartbeat_sender_future
protected java.util.concurrent.Future<?>	FD_ALL2.heartbeat_sender_future
protected java.util.List<Address>	FD.members
protected java.util.concurrent.Future<?>	FD.monitor_future
protected long	RATE_LIMITER.num_bytes_sent_in_period Keeps track of the number of bytes sent in the current time period
protected 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<?>	FD_ALL.timeout_checker_future
protected java.util.concurrent.Future<?>	FD_ALL2.timeout_checker_future

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

Modifier and Type	Method and 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_dest
protected void	FD.startMonitor() Requires lock to held by caller
protected void	FD.stopMonitor() Requires lock to be held by caller
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 and 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 messages
protected Digest	NAKACK2.rebroadcast_digest
protected java.util.concurrent.Future<?>	STABLE.stability_task_future
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 and 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 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

Fields in org.jgroups.stack with annotations of type GuardedBy

Modifier and Type	Field and Description
protected java.util.concurrent.ConcurrentMap<RouterStub,java.util.concurrent.Future<?>>	RouterStubManager.futures

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

Modifier and Type	Method and 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 and 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 and 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 seqno
protected 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 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)
boolean	Table.RemoverOnAdd.visit(long seqno, T element, int row, int column)
boolean	Table.Dump.visit(long seqno, T element, int row, int column)