Synnefo » snf-ganeti

  def __new__(cls, *args, **kwargs):

    obj = object.__new__(cls, *args, **kwargs)

    # Condition to wait for changes

    obj.change = threading.Condition()

    return obj

            def _Log(*args):

              op.Log(*args)

              job.change.acquire()

              try:

                job.change.notifyAll()

              finally:

                job.change.release()

            result = proc.ExecOpCode(input_opcode, _Log)

    # Notify waiters about potential changes

    job.change.acquire()

    try:

      job.change.notifyAll()

    finally:

      job.change.release()

  @_RequireOpenQueue

  def WaitForJobChanges(self, job_id, fields, previous):

    logging.debug("Waiting for changes in job %s", job_id)

    while True:

      self.acquire()

      try:

        job = self._LoadJobUnlocked(job_id)

        if not job:

          logging.debug("Job %s not found", job_id)

          new_state = None

          break

        new_state = self._GetJobInfoUnlocked(job, fields)

      finally:

        self.release()

      # Serializing and deserializing data can cause type changes (e.g. from

      # tuple to list) or precision loss. We're doing it here so that we get

      # the same modifications as the data received from the client. Without

      # this, the comparison afterwards might fail without the data being

      # significantly different.

      new_state = serializer.LoadJson(serializer.DumpJson(new_state))

      if previous != new_state:

        break

      job.change.acquire()

      try:

        job.change.wait()

      finally:

        job.change.release()

    logging.debug("Job %s changed", job_id)

    return new_state