Synnefo » snf-ganeti

from ganeti import ht

from ganeti import query

from ganeti import qlang

JOBQUEUE_THREADS = 25

    files = [self._GetJobPath(job_id) for job_id in self._GetJobIDsUnlocked()]

    # Upload current serial file

    # Static address list

    addrs = [node.primary_ip]

    serial = self._last_serial + count

    # Write to file

                             "%s\n" % serial, True)

    result = [jstore.FormatJobID(v)

    @return: the path to the job file

    """

  @staticmethod

  def _GetArchivedJobPath(job_id):

    @return: the path to the archived job file

    """

                          jstore.GetArchiveDirectory(job_id),

                          "job-%s" % job_id)

    """

    jlist = []

      m = constants.JOB_FILE_RE.match(filename)

      if m:

        jlist.append(int(m.group(1)))

from ganeti import errors

from ganeti import runtime

from ganeti import utils

JOBS_PER_ARCHIVE_DIRECTORY = 10000

  The queue should be locked while this function is called.

  """

def ReadVersion():

  The queue should be locked while this function is called.

  """

def InitAndVerifyQueue(must_lock):

  getents = runtime.GetEnts()

  # Lock queue

  try:

    # The queue needs to be locked in exclusive mode to write to the serial and

    # version files.

      version = ReadVersion()

      if version is None:

        # Write new version file

                        uid=getents.masterd_uid, gid=getents.masterd_gid,

                        data="%s\n" % constants.JOB_QUEUE_VERSION)

      serial = ReadSerial()

      if serial is None:

        # Write new serial file

                        uid=getents.masterd_uid, gid=getents.masterd_gid,

                        data="%s\n" % 0)

  @return: True if the job queue is marked drained

  """

def SetDrainFlag(drain_flag):

  getents = runtime.GetEnts()

  if drain_flag:

                    uid=getents.masterd_uid, gid=getents.masterd_gid)

  else:

  assert (not drain_flag) ^ CheckDrainFlag()