Uses of Class
org.jgroups.raft.util.CommitTable.Entry
Packages that use CommitTable.Entry
-
Uses of CommitTable.Entry in org.jgroups.protocols.raft
Methods in org.jgroups.protocols.raft with parameters of type CommitTable.EntryModifier and TypeMethodDescriptionprotected voidRAFT.sendAppendEntriesMessage(org.jgroups.Address member, CommitTable.Entry e) Runs (on the leader) as part of the queue handling loop: checks if all members (except the leader) in the commit table have received all messages and resends AppendEntries messages to members who haven't.
For each member, a next-index and match-index is maintained: next-index is the index of the next message to send to that member (initialized to last-applied) and match-index is the index of the highest message known to have been received by the member.
Messages are resent to a given member as long as that member's match-index is smaller than its next-index. -
Uses of CommitTable.Entry in org.jgroups.raft.util
Fields in org.jgroups.raft.util with type parameters of type CommitTable.EntryModifier and TypeFieldDescriptionprotected final ConcurrentMap<org.jgroups.Address, CommitTable.Entry> CommitTable.mapMethods in org.jgroups.raft.util that return CommitTable.EntryModifier and TypeMethodDescriptionCommitTable.Entry.commitIndex(long idx) CommitTable.get(org.jgroups.Address a) CommitTable.Entry.matchIndex(long idx) CommitTable.Entry.nextIndex(long idx) CommitTable.Entry.sendSingleMessage(boolean flag) Method parameters in org.jgroups.raft.util with type arguments of type CommitTable.EntryModifier and TypeMethodDescriptionvoidCommitTable.forEach(BiConsumer<org.jgroups.Address, CommitTable.Entry> function) Applies a function to all elements of the commit table