Revision dc31eae3 lib/backend.py
b/lib/backend.py | ||
---|---|---|
1655 | 1655 |
return result |
1656 | 1656 |
|
1657 | 1657 |
|
1658 |
def JobQueueUpdate(file_name, content):
|
|
1659 |
"""Updates a file in the queue directory.
|
|
1658 |
def _IsJobQueueFile(file_name):
|
|
1659 |
"""Checks whether the given filename is in the queue directory.
|
|
1660 | 1660 |
|
1661 | 1661 |
""" |
1662 | 1662 |
queue_dir = os.path.normpath(constants.QUEUE_DIR) |
1663 |
if os.path.commonprefix([queue_dir, file_name]) != queue_dir: |
|
1663 |
result = (os.path.commonprefix([queue_dir, file_name]) == queue_dir) |
|
1664 |
|
|
1665 |
if not result: |
|
1664 | 1666 |
logging.error("'%s' is not a file in the queue directory", |
1665 | 1667 |
file_name) |
1668 |
|
|
1669 |
return result |
|
1670 |
|
|
1671 |
|
|
1672 |
def JobQueueUpdate(file_name, content): |
|
1673 |
"""Updates a file in the queue directory. |
|
1674 |
|
|
1675 |
""" |
|
1676 |
if not _IsJobQueueFile(file_name): |
|
1666 | 1677 |
return False |
1667 | 1678 |
|
1668 | 1679 |
# Write and replace the file atomically |
Also available in: Unified diff