dpp-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)
    def set_q(self, q):
        return self._epic_change(
            lambda state: state.q==q,
            lambda state: state.q=q
        )
    def add_node(self, node):
        return self._epic_change(
            lambda state: node in state.nodes,
            lambda state: state.nodes.append(node)
        )
    def rm_node(self, node):
        return self._epic_change(
            lambda state: node not in state.nodes,
            lambda state: state.nodes.rm(node)
        )