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