andy/glusterfs
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

snapshot/scheduler: Reload /etc/cron.d/glusterfs_snap_cron_tasks when shared storage is available

Browse Source 
If shared storage is not accessible, create a flag in /var/run/gluster/
So that when /etc/cron.d/glusterfs_snap_cron_tasks is
available again, the flag will tell us, to reload
/etc/cron.d/glusterfs_snap_cron_tasks

Change-Id: I41b19f57ff0b8f7e0b820eaf592b0fdedb0a5d86
BUG: 1218573
Signed-off-by: Avra Sengupta <asengupt@redhat.com>
Reviewed-on: http://review.gluster.org/11139
Tested-by: NetBSD Build System <jenkins@build.gluster.org>
Reviewed-by: Rajesh Joseph <rjoseph@redhat.com>
Reviewed-by: Krishnan Parthasarathi <kparthas@redhat.com>
This commit is contained in:
Avra Sengupta 2015-06-09 18:00:57 +05:30 committed by Krishnan Parthasarathi
parent fefc8730e2
commit 71f27128cb
1 changed files with 33 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
extras/snap_scheduler/gcron.py
View File

@ -21,6 +21,7 @@ import fcntl
GCRON_TASKS = "/var/run/gluster/shared_storage/snaps/glusterfs_snap_cron_tasks"
GCRON_CROND_TASK = "/etc/cron.d/glusterfs_snap_cron_tasks"
GCRON_RELOAD_FLAG = "/var/run/gluster/crond_task_reload_flag"
LOCK_FILE_DIR = "/var/run/gluster/shared_storage/snaps/lock_files/"
log = logging.getLogger("gcron-logger")
start_time = 0.0
@ -121,9 +122,41 @@ def main():
global start_time
if sys.argv[1] == "--update":
if not os.path.exists(GCRON_TASKS):
# Create a flag in /var/run/gluster which indicates that this nodes
# doesn't have access to GCRON_TASKS right now, so that
# when the mount is available and GCRON_TASKS is available
# the flag will tell this routine to reload GCRON_CROND_TASK
try:
f = os.open(GCRON_RELOAD_FLAG, os.O_CREAT | os.O_NONBLOCK, 0644)
os.close(f)
except OSError as (errno, strerror):
if errno != EEXIST:
log.error("Failed to create %s : %s",
GCRON_RELOAD_FLAG, strerror)
output("Failed to create %s. Error: %s"
% (GCRON_RELOAD_FLAG, strerror))
return
if not os.path.exists(GCRON_CROND_TASK):
return
# As GCRON_TASKS exists now, we should check if GCRON_RELOAD_FLAG
# also exists. If so we should touch GCRON_CROND_TASK and remove
# the GCRON_RELOAD_FLAG
if os.path.exists(GCRON_RELOAD_FLAG):
try:
os.remove(GCRON_RELOAD_FLAG);
process = subprocess.Popen(["touch", "-h", GCRON_CROND_TASK],
stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
out, err = process.communicate()
if process.returncode != 0:
log.error("Failed to touch %s. Error: %s.",
GCRON_CROND_TASK, err)
except (IOError, OSError) as (errno, strerror):
log.error("Failed to touch %s. Error: %s.",
GCRON_CROND_TASK, strerror)
return
if os.lstat(GCRON_TASKS).st_mtime > \
os.lstat(GCRON_CROND_TASK).st_mtime:
try: