dvar.py

class Variable:
    def __init__(self, nodes, q, node_id):
        self.proposer = Proposer(nodes, q, node_id)
    @endpoint
    def write(self, ver, value, due):
        def change(previous):
            if previous == None or previous.ver==ver:
                return Val(ver = ver+1, value = value)
            return previous
        def query(current):
            if current.ver == ver+1 and current.value==value:
                return current
            raise Conflict(current)
        return self.proposer.change_query(change, query, due)
    @endpoint
    def read(self, due):
        def change(previous):
            return previous
        def query(current):
            return current
        return self.proposer.change_query(change, query, due)