paxos-variable-api.py

    def put(self, test, val, timeout):
        due = now() + timeout
        while due > now():
            result = self._read_write_read(test, val, due)
            if isinstance(result, NetworkError): continue
            return result # OK or Conflict
        return NetworkError()
    def get(self, timeout):
        return self.put(None, None, timeout)