X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fbinary.py;h=c6ee96f86d5f1eed8b210720697e1620e2448ead;hb=0b301ec56f3b690a1e11a4a8b6b2d9ce391de29b;hp=92727951cb63a5f93b84af238ee740635a769304;hpb=ba5e6fded9973ad7d6275133947b73cbce867f9a;p=dak.git diff --git a/daklib/binary.py b/daklib/binary.py old mode 100755 new mode 100644 index 92727951..c6ee96f8 --- a/daklib/binary.py +++ b/daklib/binary.py @@ -248,12 +248,16 @@ class Binary(object): except: print >> sys.stderr, "E: %s has non-unicode filename: %s" % (package,tarinfo.name) + result = True + except: traceback.print_exc() result = False os.chdir(cwd) + return result + __all__.append('Binary') def copy_temporary_contents(package, version, archname, deb, reject, session=None): @@ -264,14 +268,16 @@ def copy_temporary_contents(package, version, archname, deb, reject, session=Non contents stored in pending_content_associations """ - # first see if contents exist: cnf = Config() + privatetrans = False if session is None: session = DBConn().session() + privatetrans = True arch = get_architecture(archname, session=session) + # first see if contents exist: in_pcaq = """SELECT 1 FROM pending_content_associations WHERE package=:package AND version=:version @@ -281,7 +287,7 @@ def copy_temporary_contents(package, version, archname, deb, reject, session=Non 'version': version, 'archid': arch.arch_id} - exists = True + exists = None check = session.execute(in_pcaq, vals) if check.rowcount > 0: @@ -298,7 +304,8 @@ def copy_temporary_contents(package, version, archname, deb, reject, session=Non message = utils.TemplateSubst(subst, cnf["Dir::Templates"]+"/missing-contents") utils.send_mail(message) - exists = Binary(deb, reject).scan_package() + # Temporarily disable contents storage until we re-do the table layout + #exists = Binary(deb, reject).scan_package() if exists: sql = """INSERT INTO content_associations(binary_pkg,filepath,filename) @@ -311,6 +318,9 @@ def copy_temporary_contents(package, version, archname, deb, reject, session=Non session.execute(sql, vals) session.commit() + if privatetrans: + session.close() + return exists __all__.append('copy_temporary_contents')