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

glusterfind: add logs to identify parsing phases

Browse Source 
Add logs to idenitfy start and finish of changelog parsing phases.

Change-Id: Id250231f2af7829f887401d30ac98875ae1ae793
fixes: bz#1632236
Signed-off-by: Milind Changire <mchangir@redhat.com>
This commit is contained in:
Milind Changire 2018-09-24 17:53:35 +05:30 committed by Amar Tumballi
parent 81ea27c82c
commit 48a06e0eaf
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tools/glusterfind/src/changelog.py
View File

@ -276,6 +276,7 @@ def get_changes(brick, hash_dir, log_file, start, end, args):
fail("%s: %s Historical Changelogs not available: %s" % fail("%s: %s Historical Changelogs not available: %s" %
(args.node, brick, e), logger=logger) (args.node, brick, e), logger=logger)
logger.info("[1/4] Starting changelog parsing ...")
try: try:
# scan followed by getchanges till scan returns zero. # scan followed by getchanges till scan returns zero.
# history_scan() is blocking call, till it gets the number # history_scan() is blocking call, till it gets the number
@ -304,18 +305,27 @@ def get_changes(brick, hash_dir, log_file, start, end, args):
fail("%s Error during Changelog Crawl: %s" % (brick, e), fail("%s Error during Changelog Crawl: %s" % (brick, e),
logger=logger) logger=logger)
logger.info("[1/4] Finished changelog parsing.")
# Convert all pgfid available from Changelogs # Convert all pgfid available from Changelogs
logger.info("[2/4] Starting 'pgfid to path' conversions ...")
pgfid_to_path(brick, changelog_data) pgfid_to_path(brick, changelog_data)
changelog_data.commit() changelog_data.commit()
logger.info("[2/4] Finished 'pgfid to path' conversions.")
# Convert all GFIDs for which no other additional details available # Convert all GFIDs for which no other additional details available
logger.info("[3/4] Starting 'gfid to path using pgfid' conversions ...")
gfid_to_path_using_pgfid(brick, changelog_data, args) gfid_to_path_using_pgfid(brick, changelog_data, args)
changelog_data.commit() changelog_data.commit()
logger.info("[3/4] Finished 'gfid to path using pgfid' conversions.")
# If some GFIDs fail to get converted from previous step, # If some GFIDs fail to get converted from previous step,
# convert using find # convert using find
logger.info("[4/4] Starting 'gfid to path using batchfind' "
"conversions ...")
gfid_to_path_using_batchfind(brick, changelog_data) gfid_to_path_using_batchfind(brick, changelog_data)
changelog_data.commit() changelog_data.commit()
logger.info("[4/4] Finished 'gfid to path using batchfind' conversions.")
return actual_end return actual_end