epaxos

Documentation

Index

• Constants
• type Exec
• type Instance
• type LeaderBookkeeping
• type Replica
  • func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, lread bool, ...) *Replica
  • func (r *Replica) BatchingEnabled() bool
  • func (r *Replica) BeTheLeader(args *genericsmrproto.BeTheLeaderArgs, reply *genericsmrproto.BeTheLeaderReply) error
• type SCComponent

Constants

const (
	WHITE int8 = iota
	GRAY
	BLACK
)

const ADAPT_TIME_SEC = 10

const BF_K = 4

const BF_M_N = 32.0

const COMMIT_GRACE_PERIOD = 10 * 1e9 // 10 second(s)

const FALSE = uint8(0)

const HT_INIT_SIZE = 200000

const MAX_DEPTH_DEP = 10

const MAX_INSTANCE = 10 * 1024 * 1024

const TRUE = uint8(1)

Types

type Exec

type Exec struct {
	// contains filtered or unexported fields
}

type Instance

type Instance struct {
	Cmds []state.Command

	Status int8
	Seq    int32
	Deps   []int32

	Index, Lowlink int
	// contains filtered or unexported fields
}

type LeaderBookkeeping

type LeaderBookkeeping struct {
	// contains filtered or unexported fields
}

type Replica

type Replica struct {
	*genericsmr.Replica

	InstanceSpace [][]*Instance // the space of all instances (used and not yet used)

	CommittedUpTo []int32 // highest committed instance per replica that this replica knows about
	ExecedUpTo    []int32 // instance up to which all commands have been executed (including iteslf)

	IsLeader bool // does this replica think it is the leader
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, lread bool, dreply bool, beacon bool, durable bool, batchWait int, transconf bool, failures int) *Replica

func (*Replica) BatchingEnabled

func (r *Replica) BatchingEnabled() bool

func (*Replica) BeTheLeader

func (r *Replica) BeTheLeader(args *genericsmrproto.BeTheLeaderArgs, reply *genericsmrproto.BeTheLeaderReply) error

type SCComponent

type SCComponent struct {
	// contains filtered or unexported fields
}