Synnefo » snf-ganeti

    # Cancel here if we were asked to

    if self._op.status == constants.OP_STATUS_CANCELING:

      raise CancelJob()

    self._op.status = constants.OP_STATUS_RUNNING

    self._op.exec_timestamp = TimeStampNow()

            queue.acquire(shared=1)

            try:

              if op.status == constants.OP_STATUS_CANCELED:

                raise CancelJob()

              assert op.status == constants.OP_STATUS_QUEUED

              op.status = constants.OP_STATUS_WAITLOCK

              op.result = None

              op.start_timestamp = TimeStampNow()

            queue.acquire(shared=1)

            try:

              op.status = constants.OP_STATUS_SUCCESS

              op.result = result

              op.end_timestamp = TimeStampNow()

            queue.acquire(shared=1)

            try:

              try:

                op.status = constants.OP_STATUS_ERROR

                if isinstance(err, errors.GenericError):

                  to_encode = err

        names and the second one with the node addresses

    """

    name_list = self._nodes.keys()

    addr_list = [self._nodes[name] for name in name_list]

    return name_list, addr_list