latentcopilot

Documentation

Index

• Constants
• type BatchExecLatency
• type ExecStats
• type Instance
• type LeaderBookkeeping
• type RecoveryInstance
• type Replica
  • func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, ...) *Replica
• type Result
• type Stats
• type ViewChangeState
• type ViewManagerBookkeeping

Constants

const ADAPTIVE_TIMEOUT_ENABLED = false

variable controlling toggle mode

const ADAPT_TIME_SEC = 10

const BATCH_INTERVAL = 100 * time.Microsecond

const BEACON_FAILURE_THRESHOLD = 1

Detect failure if miss >= BEACON_FAILURE_THRESHOLD beacons in a row

const BEACON_MISS_INTERVAL = 1000 * 1e6 // 110 ms

Miss a beacon if time since last beacon received >= BEACON_MISS_INTERVAL

const BEACON_SENDING_INTERVAL = 100 * 1e6 // 100 ms

Heartbeat/Beacon

const BF_K = 4

const BF_M_N = 32.0

const CHECKPOINT_PERIOD = 10000

const COMMIT_GRACE_PERIOD = 10 * time.Millisecond // 10 ms

const DO_CHECKPOINTING = false

const DS = 1

const FALSE = uint8(0)

const FAST_PATH_TIMEOUT = 5 * 1e6 // 5ms

const HIGH_PRIORITY_LEADER = 0

const HT_INIT_SIZE = 200000

const INJECT_SLOWDOWN = false

injecting slowdown

const LATENCY_THRESHOLD = 180 * time.Second

const LATENT_PIILOT_DELAY = 10 * time.Millisecond

delay for latent copilot

const MAX_BATCH = 5000

const MAX_CLIENTS = 100 // increase this if experimenting with >100 clients

const MIN_NEW_COMMITS_TO_BECOME_LATENT = 50

const MIN_NEW_PROPOSALS_TO_BECOME_ACTIVE = 50

const NUM_LEADERS = 2

const PINGPONG = false

Enable/Disable Pingpong optimization 1

const PINGPONG_TIMEOUT = 1000 * time.Microsecond

const PINGPONG_TIMEOUT_ENABLED = true

const PRINT_STATS = false

printing stats

const RECORD_EXEC_STATS = false

record execution stats

const REPLICA_ID_BITMASK = int32(1<<REPLICA_ID_NBITS - 1)

const REPLICA_ID_NBITS = 4

Ballot number is comprised of 3 parts: - subballot: 24 bits - replicaId of original proposer: 4 bits - replicaId of current owner: 4 bits total nbits should be 32 (we use int32 for ballot)

const SWITCHING_MODE_WINDOW = 100 * time.Millisecond

const TRUE = uint8(1)

Types

type BatchExecLatency

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

type ExecStats

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

Execution stats

type Instance

type Instance struct {
	Cmds []state.Command

	Status int8
	Deps   []int32

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

type LeaderBookkeeping

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

type RecoveryInstance

type RecoveryInstance 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)

	IsLeader1 bool // does this replica think it is the leader 1
	IsLeader2 bool // does this replica think it is the leader 2

	IsActive bool // active or latent pilot
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(id int, peerAddrList []string, thrifty bool, exec bool, dreply bool, beacon bool, durable bool, rreply bool) *Replica

type Result

type Result struct {
	//Cache   state.Value
	Replied bool
}

Helper map to check duplicating execution

var execMap map[state.OperationId]bool

type Stats

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

type ViewChangeState

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

type ViewManagerBookkeeping

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