From ced839899ff9a114da58750c268048ea759268fc Mon Sep 17 00:00:00 2001 From: Mark Hymers Date: Fri, 1 Apr 2011 16:03:11 +0000 Subject: [PATCH] Short circuit already processed packages much more quickly Signed-off-by: Mark Hymers --- dak/show_new.py | 32 ++++++++++++++++++++++++-------- 1 file changed, 24 insertions(+), 8 deletions(-) diff --git a/dak/show_new.py b/dak/show_new.py index 694fddc4..4d7e75b7 100755 --- a/dak/show_new.py +++ b/dak/show_new.py @@ -154,22 +154,38 @@ def do_pkg(changes_file): session = DBConn().session() u = Upload() u.pkg.changes_file = changes_file - (u.pkg.changes["fingerprint"], rejects) = utils.check_signature(changes_file, session=session) + # We can afoord not to check the signature before loading the changes file + # as we've validated it already (otherwise it couldn't be in new) + # and we can more quickly skip over already processed files this way u.load_changes(changes_file) + + origchanges = os.path.abspath(u.pkg.changes_file) + + # Still be cautious in case paring the changes file went badly + if u.pkg.changes.has_key('source') and u.pkg.changes.has_key('version'): + htmlname = u.pkg.changes["source"] + "_" + u.pkg.changes["version"] + ".html" + htmlfile = os.path.join(cnf["Show-New::HTMLPath"], htmlname) + else: + # Changes file was bad + print "Changes file %s missing source or version field" % changes_file + session.close() + return + + # Have we already processed this? + if os.path.exists(htmlfile) and \ + os.stat(htmlfile).st_mtime > os.stat(origchanges).st_mtime: + session.close() + return + + # Now we'll load the fingerprint + (u.pkg.changes["fingerprint"], rejects) = utils.check_signature(changes_file, session=session) new_queue = get_policy_queue('new', session ); u.pkg.directory = new_queue.path u.update_subst() - origchanges = os.path.abspath(u.pkg.changes_file) files = u.pkg.files changes = u.pkg.changes - htmlname = changes["source"] + "_" + changes["version"] + ".html" sources.add(htmlname) - htmlfile = os.path.join(cnf["Show-New::HTMLPath"], htmlname) - if os.path.exists(htmlfile) and \ - os.stat(htmlfile).st_mtime > os.stat(origchanges).st_mtime: - session.close() - return for deb_filename, f in files.items(): if deb_filename.endswith(".udeb") or deb_filename.endswith(".deb"): -- 2.39.2