Synnefo » snf-ganeti

    @param job: the job to be processed

    """

    proc = mcpu.Processor(self.pool.queue.context, job.id)

    queue = job.queue

    try:

      finally:

        queue.release()

class _JobQueueWorkerPool(workerpool.WorkerPool):

    """

    super(BaseWorker, self).__init__(name=worker_id)

    self.pool = pool

    self._current_task = None

  def ShouldTerminate(self):

          # We only wait if there's no task for us.

          if not pool._tasks:

            # wait() releases the lock and sleeps until notified

            pool._pool_to_worker.wait()

            # Were we woken up in order to terminate?

            if pool._ShouldWorkerTerminateUnlocked(self):

        # Run the actual task

        try:

          self.RunTask(*self._current_task)

        except: # pylint: disable-msg=W0702

      finally:

        # Notify pool

        pool._lock.acquire()

        finally:

          pool._lock.release()

  def RunTask(self, *args):

    """Function called to start a task.