/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

Revision 942817f2

     from ganeti import vcluster
     JOBQUEUE_THREADS = 25
     JOBQUEUE_THREADS = 1
     # member lock names to be passed to @ssynchronized decorator
     _LOCK = "_lock"
-...
           self._enqueue_fn(jobs)
     def _RequireOpenQueue(fn):
       """Decorator for "public" functions.
       This function should be used for all 'public' functions. That is,
       functions usually called from other classes. Note that this should
       be applied only to methods (not plain functions), since it expects
       that the decorated function is called with a first argument that has
       a '_queue_filelock' argument.
       @warning: Use this decorator only after locking.ssynchronized
       Example::
         @locking.ssynchronized(_LOCK)
         @_RequireOpenQueue
         def Example(self):
           pass
       """
       def wrapper(self, *args, **kwargs):
         # pylint: disable=W0212
         assert self._queue_filelock is not None, "Queue should be open"
         return fn(self, *args, **kwargs)
       return wrapper
     def _RequireNonDrainedQueue(fn):
       """Decorator checking for a non-drained queue.
-...
         # Accept jobs by default
         self._accepting_jobs = True
         # Initialize the queue, and acquire the filelock.
         # This ensures no other process is working on the job queue.
         self._queue_filelock = jstore.InitAndVerifyQueue(must_lock=True)
         # Read serial file
         self._last_serial = jstore.ReadSerial()
         assert self._last_serial is not None, ("Serial file was modified between"
-...
         return rpc.JobQueueRunner(self.context, address_list)
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def AddNode(self, node):
         """Register a new node with the queue.
-...
         self._nodes[node_name] = node.primary_ip
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def RemoveNode(self, node_name):
         """Callback called when removing nodes from the cluster.
-...
         self._queue_size = len(self._GetJobIDsUnlocked(sort=False))
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def SetDrainFlag(self, drain_flag):
         """Sets the drain flag for the queue.
-...
         raise errors.JobLost("Job %s not found" % job_id)
       @_RequireOpenQueue
       def UpdateJobUnlocked(self, job, replicate=True):
         """Update a job's on disk storage.
-...
           return None
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def CancelJob(self, job_id):
         """Cancels a job.
-...
         return self._ModifyJobUnlocked(job_id, lambda job: job.Cancel())
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def ChangeJobPriority(self, job_id, priority):
         """Changes a job's priority.
-...
         return (success, msg)
       @_RequireOpenQueue
       def _ArchiveJobsUnlocked(self, jobs):
         """Archives jobs.
-...
         return len(archive_jobs)
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def ArchiveJob(self, job_id):
         """Archives a job.
-...
         return self._ArchiveJobsUnlocked([job]) == 1
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def AutoArchiveJobs(self, age, timeout):
         """Archives all jobs based on age.
-...
         return self._accepting_jobs
       @locking.ssynchronized(_LOCK)
       @_RequireOpenQueue
       def Shutdown(self):
         """Stops the job queue.
-...
         """
         self._wpool.TerminateWorkers()
         self._queue_filelock.Close()
         self._queue_filelock = None

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 942817f2