Revision fe05a931 lib/jstore.py
| b/lib/jstore.py | ||
|---|---|---|
| 111 | 111 |
if version is None: |
| 112 | 112 |
# Write new version file |
| 113 | 113 |
utils.WriteFile(pathutils.JOB_QUEUE_VERSION_FILE, |
| 114 |
uid=getents.masterd_uid, gid=getents.masterd_gid, |
|
| 114 |
uid=getents.masterd_uid, gid=getents.daemons_gid, |
|
| 115 |
mode=constants.JOB_QUEUE_FILES_PERMS, |
|
| 115 | 116 |
data="%s\n" % constants.JOB_QUEUE_VERSION) |
| 116 | 117 |
|
| 117 | 118 |
# Read again |
| ... | ... | |
| 125 | 126 |
if serial is None: |
| 126 | 127 |
# Write new serial file |
| 127 | 128 |
utils.WriteFile(pathutils.JOB_QUEUE_SERIAL_FILE, |
| 128 |
uid=getents.masterd_uid, gid=getents.masterd_gid, |
|
| 129 |
uid=getents.masterd_uid, gid=getents.daemons_gid, |
|
| 130 |
mode=constants.JOB_QUEUE_FILES_PERMS, |
|
| 129 | 131 |
data="%s\n" % 0) |
| 130 | 132 |
|
| 131 | 133 |
# Read again |
| ... | ... | |
| 174 | 176 |
|
| 175 | 177 |
if drain_flag: |
| 176 | 178 |
utils.WriteFile(pathutils.JOB_QUEUE_DRAIN_FILE, data="", |
| 177 |
uid=getents.masterd_uid, gid=getents.masterd_gid) |
|
| 179 |
uid=getents.masterd_uid, gid=getents.daemons_gid, |
|
| 180 |
mode=constants.JOB_QUEUE_FILES_PERMS) |
|
| 178 | 181 |
else: |
| 179 | 182 |
utils.RemoveFile(pathutils.JOB_QUEUE_DRAIN_FILE) |
| 180 | 183 |
|
Also available in: Unified diff