Synnefo » snf-ganeti

import itertools

try:

  from pyinotify import pyinotify

except ImportError:

  import pyinotify

  @ivar writable: Whether the job is allowed to be modified

  """

  __slots__ = ["queue", "id", "ops", "log_serial", "ops_iter", "cur_opctx",

               "received_timestamp", "start_timestamp", "end_timestamp",

               "__weakref__", "processor_lock", "writable"]

      logging.exception("%s: Canceling job", opctx.log_prefix)

      assert op.status == constants.OP_STATUS_CANCELING

      return (constants.OP_STATUS_CANCELING, None)

      logging.exception("%s: Caught exception in %s",

                        opctx.log_prefix, opctx.summary)

      return (constants.OP_STATUS_ERROR, _EncodeOpError(err))

  """The actual job workers.

  """

    """Job executor.

    @type job: L{_QueuedJob}

    self._lock = locking.SharedLock("JobDepMgr")

  @locking.ssynchronized(_LOCK, shared=1)

    """Retrieves information about waiting jobs.

    @type requested: set

  """

  def wrapper(self, *args, **kwargs):

    assert self._queue_filelock is not None, "Queue should be open"

    return fn(self, *args, **kwargs)

  return wrapper

    try:

      data = serializer.LoadJson(raw_data)

      job = _QueuedJob.Restore(self, data, writable)

      raise errors.JobFileCorrupted(err)

    return job