CASPaxos 在Acceptor里缺少一个vballot

drmingdrmer commented 2 years ago

这篇文章里: https://vizee.org/2019/12/11/caspaxos-implement/

Acceptor 需要存储2个ballot: 除了下面这个见到的最大ballot, 还有一个最后接受一个value时的ballot:

type Acceptor struct {
    mu        sync.Mutex
    ballotNum int
        // vballot int
    value     *ValueType
}

onAccept时, 需要更新vballot:

func onAccept(args *Propose) *Accept {
    acceptor := &self.acceptor
    acceptor.mu.Lock()
    defer acceptor.mu.Unlock()
    if acceptor.ballotNum > args.BallotNum {
        return &Accept{
            OK: false,
        }
    }
    acceptor.ballotNum = args.BallotNum
        // Add the following line:
        // acceptor.vbalot = args.BallotNum
    acceptor.value = args.Value
    return &Accept{
        OK: true,
    }
}

CASPaxos paper里写的不清楚,完全没提vballot, 它的TLA里有提到: https://gist.github.com/grogers0/c7e87f9dfe58c6070b19db9d3c073b72#file-gryadkacasregister-tla-L50

ballot跟vballot跟classic paxos中的行为是一样的. 这里有一个classic paxos中实现accept的例子: https://github.com/openacid/paxoskv/blob/93cbcd20b37d5588880130d263a8dcfdec5d4544/paxoskv/impl.go#L258-L281

vizee commented 2 years ago

@drmingdrmer 抱歉，我今天才看到 issue，这个 vballot 的设计我需要再理解一下，非常感谢大佬指正！

vizee commented 2 years ago

已经修复问题代码，再次感谢 xp 大佬回复❤️

vizee / vizee.github.io

CASPaxos 在Acceptor里缺少一个vballot #2