Synnefo » snf-ganeti

    Processor.ExecOpCode) set to OP_STATUS_WAITLOCK.

    """

    try:

      assert self._op.status in (constants.OP_STATUS_WAITLOCK,

                                 constants.OP_STATUS_CANCELING)

    finally:

      self._queue.release()

  def _AppendFeedback(self, timestamp, log_type, log_msg):

    """Internal feedback append function, with locks

            logging.info("Op %s/%s: Starting opcode %s", idx + 1, count,

                         op_summary)

            try:

              if op.status == constants.OP_STATUS_CANCELED:

                raise CancelJob()

            result = proc.ExecOpCode(input_opcode,

                                     _OpExecCallbacks(queue, job, op))

            try:

              op.status = constants.OP_STATUS_SUCCESS

              op.result = result

            # Will be handled further up

            raise

          except Exception, err:

            try:

              try:

                op.status = constants.OP_STATUS_ERROR

            raise

      except CancelJob:

        try:

          job.MarkUnfinishedOps(constants.OP_STATUS_CANCELED,

                                "Job canceled by request")

      except:

        logging.exception("Unhandled exception")

    finally:

      try:

        try:

          job.lock_status = None