类 com.fr.third.jgroups.annotations.GuardedBy
的使用

使用GuardedBy的程序包

程序包	说明
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
com.fr.third.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
com.fr.third.jgroups.stack	Support for managing protocol stacks.
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.third.jgroups.blocks中GuardedBy的使用

注释类型为GuardedBy的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
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)

com.fr.third.jgroups.protocols中GuardedBy的使用

注释类型为GuardedBy的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
protected java.util.concurrent.Future<?>	FD.Broadcaster.bcast_future
protected long	RATE_LIMITER.end_of_current_period
protected java.util.concurrent.Future<?>	MERGE2.FindSubgroupsTask.future
protected java.util.concurrent.Future<?>	FD_ALL2.heartbeat_sender_future
protected java.util.concurrent.Future<?>	FD_ALL.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_ALL2.timeout_checker_future
protected java.util.concurrent.Future<?>	FD_ALL.timeout_checker_future

注释类型为GuardedBy的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
protected void	TP.BaseBundler.addMessage(Message msg, long size)
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)

com.fr.third.jgroups.protocols.pbcast中GuardedBy的使用

注释类型为GuardedBy的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
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).

注释类型为GuardedBy的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
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.

com.fr.third.jgroups.stack中GuardedBy的使用

注释类型为GuardedBy的com.fr.third.jgroups.stack中的方法

限定符和类型	方法和说明
protected void	RouterStub._doConnect()

com.fr.third.jgroups.util中GuardedBy的使用

注释类型为GuardedBy的com.fr.third.jgroups.util中的字段

限定符和类型	字段和说明
protected java.util.Map<Address,java.lang.Long>	CreditMap.credits
protected boolean	Responses.done

注释类型为GuardedBy的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
protected void	Table._compact() Moves the contents of matrix down by the number of purged rows and resizes the matrix accordingly.
protected Responses	Responses._done()
protected void	Responses.add(PingData data)
protected boolean	RingBuffer.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 .. to] (including from and to), and calls Table.Visitor.visit(long, Object, int, int).
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)