epaxos

Documentation

Index

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

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(replica *genericsmr.Replica, id int, peerAddrList []string, thrifty bool, exec bool, lread bool, dreply bool, beacon bool, durable bool, batchWait int, transconf bool, failures int, storageParentDir string, fastLearn bool, emulatedSS bool, emulatedWriteTime time.Duration, cmpCommitExec bool, cmpCommitExecLoc string, sepExecThread bool, deadTime int32, sendToFastQrm bool) *Replica

func (*Replica) BatchingEnabled

func (r *Replica) BatchingEnabled() bool

func (*Replica) BeTheLeader

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

func (*Replica) CloseUp

func (r *Replica) CloseUp()

type SCComponent

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

type ToRecord

type ToRecord struct {
	CommitExecutionComparator.InstanceID
	time.Time
}