paxos

Documentation

Index

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

Constants

const CHAN_BUFFER_SIZE = 200000

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

const FALSE = uint8(0)

const SLEEP_TIME_NS = 1e6

const TRUE = uint8(1)

Types

type Instance

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

type InstanceStatus

type InstanceStatus int

const (
	NOT_STARTED InstanceStatus = iota
	PREPARING
	PREPARED
	ACCEPTED
	COMMITTED
	IGNORING
)

type LeaderBookkeeping

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

type Replica

type Replica struct {
	learner.Learner
	proposalmanager.AcceptorQrmInfo

	*genericsmr.Replica // extends a generic Paxos replica

	IsLeader bool // does this replica think it is the leader

	Shutdown bool
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(replica *genericsmr.Replica, id int, peerAddrList []string, Isleader bool, thrifty bool, exec bool, lread bool,
	dreply bool, durable bool, batchWait int, f int, storageLoc string, emulatedSS bool, emulatedWriteTime time.Duration,
	deadTime int32, sendToFastestQrm bool, minimalAcceptors bool, mappedProposers bool, mappedPropsPerInst int32, pam bool, pamloc string) *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()

func (*Replica) GetEmptyInstance

func (r *Replica) GetEmptyInstance() *Instance