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

           ops = [opcodes.OpCode.LoadOpCode(state) for state in args]
           return queue.SubmitJob(ops)
         if method == luxi.REQ_SUBMIT_MANY_JOBS:
           logging.info("Received multiple jobs")
           jobs = []
           for ops in args:
             jobs.append([opcodes.OpCode.LoadOpCode(state) for state in ops])
           return queue.SubmitManyJobs(jobs)
         elif method == luxi.REQ_CANCEL_JOB:
           job_id = args
           logging.info("Received job cancel request for %s", job_id)

           utils.RemoveFile(constants.JOB_QUEUE_DRAIN_FILE)
         return True
       @utils.LockedMethod
       @_RequireOpenQueue
       def SubmitJob(self, ops):
       def _SubmitJobUnlocked(self, ops):
         """Create and store a new job.
         This enters the job into our job queue and also puts it on the new
-...
         """
         if self._IsQueueMarkedDrain():
           raise errors.JobQueueDrainError()
           raise errors.JobQueueDrainError("Job queue is drained, refusing job")
         # Check job queue size
         size = len(self._ListJobFiles())
-...
         return job.id
       @utils.LockedMethod
       @_RequireOpenQueue
       def SubmitJob(self, ops):
         """Create and store a new job.
         @see: L{_SubmitJobUnlocked}
         """
         return self._SubmitJobUnlocked(ops)
       @utils.LockedMethod
       @_RequireOpenQueue
       def SubmitManyJobs(self, jobs):
         """Create and store multiple jobs.
         @see: L{_SubmitJobUnlocked}
         """
         results = []
         for ops in jobs:
           try:
             data = self._SubmitJobUnlocked(ops)
             status = True
           except errors.GenericError, err:
             data = str(err)
             status = False
           results.append((status, data))
         return results
       @_RequireOpenQueue
       def UpdateJobUnlocked(self, job):
         """Update a job's on disk storage.

     KEY_RESULT = "result"
     REQ_SUBMIT_JOB = "SubmitJob"
     REQ_SUBMIT_MANY_JOBS = "SubmitManyJobs"
     REQ_WAIT_FOR_JOB_CHANGE = "WaitForJobChange"
     REQ_CANCEL_JOB = "CancelJob"
     REQ_ARCHIVE_JOB = "ArchiveJob"
-...
         ops_state = map(lambda op: op.__getstate__(), ops)
         return self.CallMethod(REQ_SUBMIT_JOB, ops_state)
       def SubmitManyJobs(self, jobs):
         jobs_state = []
         for ops in jobs:
           jobs_state.append([op.__getstate__() for op in ops])
         return self.CallMethod(REQ_SUBMIT_MANY_JOBS, jobs_state)
       def CancelJob(self, job_id):
         return self.CallMethod(REQ_CANCEL_JOB, job_id)

Synnefo » snf-ganeti » ganeti-local