Synnefo » snf-ganeti » ganeti-local

class _JobFileChangesWaiter(object):

    """Initializes this class.

    @type filename: string

    @raises errors.InotifyError: if the notifier cannot be setup

    """

    self._inotify_handler = \

      asyncnotifier.SingleFileEventHandler(self._wm, self._OnInotify, filename)

    self._notifier = \

class _JobChangesWaiter(object):

    """Initializes this class.

    @type filename: string

    """

    self._filewaiter = None

    self._filename = filename

  def Wait(self, timeout):

    """Waits for a job to change.

    # If this point is reached, return immediately and let caller check the job

    # file again in case there were changes since the last check. This avoids a

    # race condition.

    return True

    return result

  def __call__(self, filename, job_load_fn,

    """Waits for changes on a job.

    @type filename: string

    counter = itertools.count()

    try:

      check_fn = _JobChangesChecker(fields, prev_job_info, prev_log_serial)

      try:

        return utils.Retry(compat.partial(self._CheckForChanges,

                                          counter, job_load_fn, check_fn),

                           wait_fn=waiter.Wait)

      finally:

        waiter.Close()

      return None

    except utils.RetryTimeout:

      return constants.JOB_NOTCHANGED