Module org.jgroups.raft

Package org.jgroups.raft.util

Class CommitTable

java.lang.Object

org.jgroups.raft.util.CommitTable

public class CommitTable
extends Object

Keeps track of next_index and match_index for each cluster member (excluding this leader).

Used to (1) compute the commit_index and (2) to resend log entries to members which haven't yet seen them. Only created on the leader.

Since:

0.1

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CommitTable.Entry

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<org.jgroups.Address,CommitTable.Entry>	map

Constructor Summary

Constructors

Constructor	Description
CommitTable(List<org.jgroups.Address> members, long next_index)

Method Summary

Modifier and Type	Method	Description
void	adjust(List<org.jgroups.Address> members, long next_index)
void	forEach(BiConsumer<org.jgroups.Address,CommitTable.Entry> function)	Applies a function to all elements of the commit table
CommitTable.Entry	get(org.jgroups.Address a)
Set<org.jgroups.Address>	keys()
String	toString()
CommitTable	update(org.jgroups.Address member, long match_index, long next_index, long commit_index, boolean single_resend)
CommitTable	update(org.jgroups.Address member, long match_index, long next_index, long commit_index, boolean single_resend, boolean overwrite)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

map

protected final ConcurrentMap<org.jgroups.Address,CommitTable.Entry> map

Constructor Details

CommitTable

public CommitTable(List<org.jgroups.Address> members,
 long next_index)

Method Details

keys

public Set<org.jgroups.Address> keys()

get

public CommitTable.Entry get(org.jgroups.Address a)

adjust

public void adjust(List<org.jgroups.Address> members,
 long next_index)

update

public CommitTable update(org.jgroups.Address member,
 long match_index,
 long next_index,
 long commit_index,
 boolean single_resend)

update

public CommitTable update(org.jgroups.Address member,
 long match_index,
 long next_index,
 long commit_index,
 boolean single_resend,
 boolean overwrite)

forEach

public void forEach(BiConsumer<org.jgroups.Address,CommitTable.Entry> function)

Applies a function to all elements of the commit table

toString

public String toString()

Overrides:

toString in class Object