Revision 0cb94105

b/lib/constants.py
253 253
JOB_QUEUE_LOCK_FILE = QUEUE_DIR + "/lock"
254 254
JOB_QUEUE_VERSION_FILE = QUEUE_DIR + "/version"
255 255
JOB_QUEUE_SERIAL_FILE = QUEUE_DIR + "/serial"
256
JOB_QUEUE_ARCHIVE_DIR = QUEUE_DIR + "/archive"
256 257

  
257 258
JOB_ID_TEMPLATE = r"\d+"
258 259

  
b/lib/jqueue.py
303 303
    self._memcache = {}
304 304
    self._my_hostname = utils.HostInfo().name
305 305

  
306
    # Make sure our directory exists
307
    try:
308
      os.mkdir(constants.QUEUE_DIR, 0700)
309
    except OSError, err:
310
      if err.errno not in (errno.EEXIST, ):
311
        raise
306
    # Make sure our directories exists
307
    for path in (constants.QUEUE_DIR, constants.JOB_QUEUE_ARCHIVE_DIR):
308
      try:
309
        os.mkdir(path, 0700)
310
      except OSError, err:
311
        if err.errno not in (errno.EEXIST, ):
312
          raise
312 313

  
313 314
    # Get queue lock
314 315
    self.lock_fd = open(constants.JOB_QUEUE_LOCK_FILE, "w")
......
419 420
  def _GetJobPath(self, job_id):
420 421
    return os.path.join(constants.QUEUE_DIR, "job-%s" % job_id)
421 422

  
423
  def _GetArchivedJobPath(self, job_id):
424
    return os.path.join(constants.JOB_QUEUE_ARCHIVE_DIR, "job-%s" % job_id)
425

  
422 426
  def _GetJobIDsUnlocked(self, archived=False):
423 427
    """Return all known job IDs.
424 428

  

Also available in: Unified diff