Revision 82b22e19 lib/jstore.py
| b/lib/jstore.py | ||
|---|---|---|
| 25 | 25 |
|
| 26 | 26 |
from ganeti import constants |
| 27 | 27 |
from ganeti import errors |
| 28 |
from ganeti import runtime |
|
| 28 | 29 |
from ganeti import utils |
| 29 | 30 |
|
| 30 | 31 |
|
| ... | ... | |
| 73 | 74 |
locking mode. |
| 74 | 75 |
|
| 75 | 76 |
""" |
| 76 |
dirs = [(d, constants.JOB_QUEUE_DIRS_MODE) for d in constants.JOB_QUEUE_DIRS] |
|
| 77 |
utils.EnsureDirs(dirs) |
|
| 77 |
getents = runtime.GetEnts() |
|
| 78 | 78 |
|
| 79 | 79 |
# Lock queue |
| 80 | 80 |
queue_lock = utils.FileLock.Open(constants.JOB_QUEUE_LOCK_FILE) |
| ... | ... | |
| 99 | 99 |
if version is None: |
| 100 | 100 |
# Write new version file |
| 101 | 101 |
utils.WriteFile(constants.JOB_QUEUE_VERSION_FILE, |
| 102 |
uid=getents.masterd_uid, gid=getents.masterd_gid, |
|
| 102 | 103 |
data="%s\n" % constants.JOB_QUEUE_VERSION) |
| 103 | 104 |
|
| 104 | 105 |
# Read again |
| ... | ... | |
| 112 | 113 |
if serial is None: |
| 113 | 114 |
# Write new serial file |
| 114 | 115 |
utils.WriteFile(constants.JOB_QUEUE_SERIAL_FILE, |
| 116 |
uid=getents.masterd_uid, gid=getents.masterd_gid, |
|
| 115 | 117 |
data="%s\n" % 0) |
| 116 | 118 |
|
| 117 | 119 |
# Read again |
Also available in: Unified diff