[projects/pld-ftp-admin.git] / bin / pfa-from-incoming

#!/usr/bin/env python
# vi: encoding=utf-8 ts=8 sts=4 sw=4 et

import sys, os, stat, time, re
sys.path.insert(0, os.environ['HOME']+'/pld-ftp-admin/modules')
from config import incoming_dir, default_to, ftp_archs
from config import value as cval
import config
from common import noarchcachedir, tmpdir, fileexists
from baseftptree import BaseFtpTree, BasePkg
from ftptree import FtpTree, Pkg
import ftpio

os.umask(022)

def rm(file):
    os.remove(file)

def mv(src, dst):
    os.rename(src, dst + '/' + src.split('/')[-1])

# duplicate code in ftptree.py
def is_debuginfo(nvr):
    """
    returns true if NVR is debuginfo package and separate debuginfo is enabled
    """
    if not config.separate_debuginfo:
        return False
    pkg = nvr.split('-')[:-2]
    return pkg[-1] == 'debuginfo'

def findfiles(dir):
    def filterinfos(x):
        if x[-11:] == '.uploadinfo':
            return True
        else:
            return False
    return filter(filterinfos, os.listdir(dir))

def getcontent(file):
    f = open(file, 'r')
    content = f.read()
    f.close()
    if not content[-5:] == '\nEND\n':
        return None
    else:
        return content[:-4]

def send_noarch_msg(files_differ, reqs_differ, pkg, rpmfile, arch):
    req_email=pkg.build[pkg.lastbid].requester_email
    req_bid=pkg.lastbid
    cc_list=[]
    if 'logs_list' in cval:
        cc_list.append(cval['logs_list'])
    m_subject="Noarch error: %s files differ among builders" % rpmfile
    bids=pkg.build.keys()
    if len(bids)>1:
        for bid in bids:
            newcc=pkg.build[bid].requester_email
            if req_email!=newcc and newcc not in cc_list:
                cc_list.append(newcc)

    msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
    if cc_list:
        msg=msg+"Cc: %s\n" % ", ".join(cc_list)
    msg=msg+"""X-PLD-Builder: %s
References: <%s@pld.src.builder>
In-Reply-To: <%s@pld.src.builder>
Subject: %s

""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)

    sm = os.popen("/usr/sbin/sendmail -t", "w")

    sm.write(msg)

    if files_differ:
        f=open("%s/files.diff" % tmpdir, 'r')
        sm.write("Difference between %s (currently in %s) and %s FILES\n" %
              (pkg.noarch_arch[rpmfile], `ftptree`, arch)),
        for line in f.readlines(True)[2:]:
            sm.write(line)
        f.close()

    sm.write('\n')

    if reqs_differ:
        f=open("%s/reqs.diff" % tmpdir, 'r')
        sm.write("Difference between %s (currently in %s) and %s REQS\n" %
              (pkg.noarch_arch[rpmfile], `ftptree`, arch)),
        for line in f.readlines(True)[2:]:
            sm.write(line)
        f.close()

    sm.close()

def move_noarch(f, arch, rpmfile, dstpkg):
    if dstpkg.noarch_arch.has_key(rpmfile):
        os.system("LC_ALL=C rpm -qlp %s | LC_ALL=C sort > %s/files.new" %
                  (incoming_dir + arch + '/' + rpmfile, tmpdir))
        os.system("rpm -qRp %s | LC_ALL=C sort | LC_ALL=C uniq > %s/reqs.new" %
                  (incoming_dir + arch + '/' + rpmfile, tmpdir))

        files_differ = False
        reqs_differ = False

        if os.system("diff -u %s/%s.filelist %s/files.new > %s/files.diff" %
                     (noarchcachedir, rpmfile, tmpdir, tmpdir)):
            files_differ = True
        if os.system("diff -u %s/%s.reqlist %s/reqs.new > %s/reqs.diff" %
                     (noarchcachedir, rpmfile, tmpdir, tmpdir)):
            reqs_differ = True

        if files_differ or reqs_differ:
            send_noarch_msg(files_differ, reqs_differ, dstpkg, rpmfile, arch)

        rm(incoming_dir + arch + '/' + rpmfile)
    else:
        os.system("LC_ALL=C rpm -qlp %s | LC_ALL=C sort > %s/%s.filelist" %
                  (incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
        os.system("rpm -qRp %s | LC_ALL=C sort | LC_ALL=C uniq > %s/%s.reqlist" %
                  (incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
        f.write("file:noarch:%s\ninfo:noarch_arch:%s:%s\n" % (rpmfile, rpmfile, arch))
        mv(incoming_dir + arch + '/' + rpmfile, default_to + 'noarch/RPMS')

def send_vr_msg(snvr, anvr, pkg, arch):
    req_email=pkg.build[pkg.lastbid].requester_email
    req_bid=pkg.lastbid
    cc_list=[]
    if 'logs_list' in cval:
        cc_list.append(cval['logs_list'])
    m_subject="NVR error: %s version or relese differ among subpackages" % snvr[0]
    bids=pkg.build.keys()
    if len(bids)>1:
        for bid in bids:
            newcc=pkg.build[bid].requester_email
            if req_email!=newcc and newcc not in cc_list:
                cc_list.append(newcc)

    msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
    if cc_list:
        msg=msg+"Cc: %s\n" % ", ".join(cc_list)
    msg=msg+"""X-PLD-Builder: %s
References: <%s@pld.src.builder>
In-Reply-To: <%s@pld.src.builder>
Subject: %s

""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)

    sm = os.popen("/usr/sbin/sendmail -t", "w")

    sm.write(msg)

    sm.write("Difference between %s SRPM (currently in %s) and %s RPM NVR:\n\n" %
          (snvr[0], `ftptree`, arch)),
    sm.write("Expected (%s):\nV: %s\nR: %s\n\n" % snvr)
    sm.write("RPM:\nN: %s\nV: %s\nR: %s\n" % anvr)
    sm.write('\n')

    sm.close()

# main()
try:
    ftpio.connect('from-incoming-pid-%s' % os.getpid())
except:
    print "Can't get ftpiod connection"
    sys.exit(1)

ftptree = BaseFtpTree(cval['default_to'])

if not ftpio.lock(cval['default_to']):
    print "Can't get lock: %s" % cval['default_to']
    sys.exit(1)

moved_anything = False

for uploadinfo in findfiles(incoming_dir + 'SRPMS'):
    content = getcontent(incoming_dir + 'SRPMS/' + uploadinfo)
    if not content:
        continue # Uploading not finished

    pkg = BasePkg(uploadinfo[:-19], content = content)
    srpm = pkg.files['SRPMS'][0]

    if not os.path.exists(incoming_dir + 'SRPMS/' + srpm):
        ftpio.log("%s file missing; skipping move until next round" % (srpm))
        continue

    if ftptree.has_key(`pkg`):
        ftpio.log("%s already present in %s; removing newer files" % (srpm, ftptree))
        rm(incoming_dir + 'SRPMS/' + srpm)
        f = open(default_to + 'SRPMS/.metadata/' + srpm+'.info', 'a')
        bid = pkg.build.keys()[0]
        build = pkg.build[bid]
        f.write("info:build:%s:requester:%s\ninfo:build:%s:requester_email:%s\n"
                 % (bid, build.requester, bid, build.requester_email))
        f.close()
    else:
        mv(incoming_dir + 'SRPMS/' + srpm, default_to + 'SRPMS/RPMS')

        f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'w')
        f.write(content)
        f.close()

    rm(incoming_dir + 'SRPMS/' + uploadinfo)

for arch in ftp_archs:
    for uploadinfo in findfiles(incoming_dir + arch):
        content = getcontent(incoming_dir + arch + '/' + uploadinfo)
        if not content:
            ftpio.log("%s not finished uploading" % uploadinfo)
            continue # Uploading not finished

        srcpkg = BasePkg(uploadinfo[:-19], content = content)
        srpm = srcpkg.files['SRPMS'][0]

        if not ftptree.has_key(`srcpkg`):
            continue # We require the src.rpm to be present

        renvr = re.compile(r'(.*)-(.*)-(.*)\.[^.]*\.rpm')
        srcnvr = renvr.match(srpm).groups()

        rpmfile_missing = [f for f in srcpkg.files['ARCH'] if not os.path.exists(incoming_dir + arch + '/'+f)]
        if len(rpmfile_missing):
            for filem in rpmfile_missing:
                ftpio.log("%s file missing; skipping move until next round" % (filem))
            continue

        dstpkg = BasePkg(`srcpkg`, ftptree)

        if dstpkg.files.has_key(arch):
            ftpio.log("files from %s for arch %s already present in %s; removing newer files" % (`srcpkg`, arch, ftptree))
            for rpmfile in srcpkg.files['ARCH']:
                try:
                    rm(incoming_dir + arch + '/'+rpmfile)
                except OSError, e:
                    l = "Removing %s problem: %s" % (incoming_dir + arch + '/' + rpmfile, e)
                    ftpio.log(l)
                    print l
            rm(incoming_dir + arch + '/' + uploadinfo)
            continue

        f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'a')
        for rpmfile in srcpkg.files['ARCH']:
            moved_anything = True

# Too much noise, too little use
#            archnvr = renvr.match(rpmfile).groups()
#            if srcnvr[1] != archnvr[1] or srcnvr[2] != archnvr[2]:
#                send_vr_msg(srcnvr, archnvr, dstpkg, arch)

            if rpmfile[-11:] == '.noarch.rpm' and config.separate_noarch:
                move_noarch(f, arch, rpmfile, dstpkg)
            else:
                f.write("file:%s:%s\n" % (arch, rpmfile))
                srcfile = incoming_dir + arch + '/' + rpmfile

                if is_debuginfo(rpmfile):
                    dstfile = default_to + arch + '/debuginfo'
                else:
                    dstfile = default_to + arch + '/RPMS'

                try:
                    mv(srcfile, dstfile)
                except OSError, e:
                    l = "Moving %s to %s problem: %s" % (srcfile, dstfile, e)
                    ftpio.log(l)
                    print l
        f.close()

        rm(incoming_dir + arch + '/' + uploadinfo)

ftpio.unlock(cval['default_to'])

if moved_anything:
    os.system("%s/pld-ftp-admin/bin/pfa-genindex --quiet test > /dev/null" % (os.getenv("HOME")))
Commit	Line	Data
38b2b764 MM	1	#!/usr/bin/env python
	2	# vi: encoding=utf-8 ts=8 sts=4 sw=4 et
	3
c77db9e7	4	import sys, os, stat, time, re
38b2b764 MM	5	sys.path.insert(0, os.environ['HOME']+'/pld-ftp-admin/modules')
38b2b764 MM	6	from config import incoming_dir, default_to, ftp_archs
8e089d4f	7	from config import value as cval
38b2b764	8	import config
acd976ec	9	from common import noarchcachedir, tmpdir, fileexists
bb2cb325	10	from baseftptree import BaseFtpTree, BasePkg
8e089d4f	11	from ftptree import FtpTree, Pkg
0a108b7f	12	import ftpio
38b2b764	13
fc574b00 AM	14	os.umask(022)
fc574b00 AM	15
38b2b764	16	def rm(file):
18c8e935	17	os.remove(file)
38b2b764 MM	18
38b2b764 MM	19	def mv(src, dst):
8911f226	20	os.rename(src, dst + '/' + src.split('/')[-1])
38b2b764	21
54ff0049 ER	22	# duplicate code in ftptree.py
	23	def is_debuginfo(nvr):
	24	"""
	25	returns true if NVR is debuginfo package and separate debuginfo is enabled
	26	"""
	27	if not config.separate_debuginfo:
	28	return False
	29	pkg = nvr.split('-')[:-2]
	30	return pkg[-1] == 'debuginfo'
	31
38b2b764 MM	32	def findfiles(dir):
38b2b764 MM	33	def filterinfos(x):
8911f226	34	if x[-11:] == '.uploadinfo':
76dc40c3	35	return True
38b2b764 MM	36	else:
	37	return False
	38	return filter(filterinfos, os.listdir(dir))
	39
38b2b764	40	def getcontent(file):
8911f226 ER	41	f = open(file, 'r')
8911f226 ER	42	content = f.read()
38b2b764	43	f.close()
8911f226	44	if not content[-5:] == '\nEND\n':
38b2b764 MM	45	return None
	46	else:
	47	return content[:-4]
	48
8e089d4f	49	def send_noarch_msg(files_differ, reqs_differ, pkg, rpmfile, arch):
200470c5 MM	50	req_email=pkg.build[pkg.lastbid].requester_email
	51	req_bid=pkg.lastbid
	52	cc_list=[]
0fa16f20 MM	53	if 'logs_list' in cval:
0fa16f20 MM	54	cc_list.append(cval['logs_list'])
8e089d4f	55	m_subject="Noarch error: %s files differ among builders" % rpmfile
200470c5 MM	56	bids=pkg.build.keys()
	57	if len(bids)>1:
	58	for bid in bids:
	59	newcc=pkg.build[bid].requester_email
	60	if req_email!=newcc and newcc not in cc_list:
	61	cc_list.append(newcc)
	62
	63	msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
	64	if cc_list:
	65	msg=msg+"Cc: %s\n" % ", ".join(cc_list)
	66	msg=msg+"""X-PLD-Builder: %s
	67	References: <%s@pld.src.builder>
	68	In-Reply-To: <%s@pld.src.builder>
	69	Subject: %s
	70
	71	""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)
	72
	73	sm = os.popen("/usr/sbin/sendmail -t", "w")
8e089d4f	74
200470c5 MM	75	sm.write(msg)
	76
	77	if files_differ:
	78	f=open("%s/files.diff" % tmpdir, 'r')
	79	sm.write("Difference between %s (currently in %s) and %s FILES\n" %
8e089d4f	80	(pkg.noarch_arch[rpmfile], `ftptree`, arch)),
200470c5 MM	81	for line in f.readlines(True)[2:]:
	82	sm.write(line)
	83	f.close()
	84
	85	sm.write('\n')
	86
	87	if reqs_differ:
	88	f=open("%s/reqs.diff" % tmpdir, 'r')
	89	sm.write("Difference between %s (currently in %s) and %s REQS\n" %
8e089d4f	90	(pkg.noarch_arch[rpmfile], `ftptree`, arch)),
200470c5 MM	91	for line in f.readlines(True)[2:]:
	92	sm.write(line)
	93	f.close()
	94
	95	sm.close()
	96
8e089d4f ER	97	def move_noarch(f, arch, rpmfile, dstpkg):
8e089d4f ER	98	if dstpkg.noarch_arch.has_key(rpmfile):
a999d554	99	os.system("LC_ALL=C rpm -qlp %s \| LC_ALL=C sort > %s/files.new" %
8e089d4f	100	(incoming_dir + arch + '/' + rpmfile, tmpdir))
ca2e224a	101	os.system("rpm -qRp %s \| LC_ALL=C sort \| LC_ALL=C uniq > %s/reqs.new" %
8e089d4f	102	(incoming_dir + arch + '/' + rpmfile, tmpdir))
bb2cb325	103
8911f226 ER	104	files_differ = False
8911f226 ER	105	reqs_differ = False
bb2cb325 MM	106
bb2cb325 MM	107	if os.system("diff -u %s/%s.filelist %s/files.new > %s/files.diff" %
8e089d4f	108	(noarchcachedir, rpmfile, tmpdir, tmpdir)):
8911f226	109	files_differ = True
bb2cb325	110	if os.system("diff -u %s/%s.reqlist %s/reqs.new > %s/reqs.diff" %
8e089d4f	111	(noarchcachedir, rpmfile, tmpdir, tmpdir)):
8911f226	112	reqs_differ = True
bb2cb325 MM	113
bb2cb325 MM	114	if files_differ or reqs_differ:
8e089d4f	115	send_noarch_msg(files_differ, reqs_differ, dstpkg, rpmfile, arch)
bb2cb325	116
8e089d4f	117	rm(incoming_dir + arch + '/' + rpmfile)
bb2cb325	118	else:
ca2e224a	119	os.system("LC_ALL=C rpm -qlp %s \| LC_ALL=C sort > %s/%s.filelist" %
8e089d4f	120	(incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
ca2e224a	121	os.system("rpm -qRp %s \| LC_ALL=C sort \| LC_ALL=C uniq > %s/%s.reqlist" %
8e089d4f ER	122	(incoming_dir + arch + '/' + rpmfile, noarchcachedir, rpmfile))
	123	f.write("file:noarch:%s\ninfo:noarch_arch:%s:%s\n" % (rpmfile, rpmfile, arch))
	124	mv(incoming_dir + arch + '/' + rpmfile, default_to + 'noarch/RPMS')
38b2b764	125
c77db9e7 JR	126	def send_vr_msg(snvr, anvr, pkg, arch):
	127	req_email=pkg.build[pkg.lastbid].requester_email
	128	req_bid=pkg.lastbid
	129	cc_list=[]
	130	if 'logs_list' in cval:
	131	cc_list.append(cval['logs_list'])
	132	m_subject="NVR error: %s version or relese differ among subpackages" % snvr[0]
	133	bids=pkg.build.keys()
	134	if len(bids)>1:
	135	for bid in bids:
	136	newcc=pkg.build[bid].requester_email
	137	if req_email!=newcc and newcc not in cc_list:
	138	cc_list.append(newcc)
	139
	140	msg="From: %s\nTo: %s\n" % (cval['from_field'], req_email)
	141	if cc_list:
	142	msg=msg+"Cc: %s\n" % ", ".join(cc_list)
	143	msg=msg+"""X-PLD-Builder: %s
	144	References: <%s@pld.src.builder>
	145	In-Reply-To: <%s@pld.src.builder>
	146	Subject: %s
	147
	148	""" % (cval['xpldbuilder'], req_bid, req_bid, m_subject)
	149
	150	sm = os.popen("/usr/sbin/sendmail -t", "w")
	151
	152	sm.write(msg)
	153
	154	sm.write("Difference between %s SRPM (currently in %s) and %s RPM NVR:\n\n" %
	155	(snvr[0], `ftptree`, arch)),
c82d0ed4 JR	156	sm.write("Expected (%s):\nV: %s\nR: %s\n\n" % snvr)
c82d0ed4 JR	157	sm.write("RPM:\nN: %s\nV: %s\nR: %s\n" % anvr)
c77db9e7 JR	158	sm.write('\n')
	159
	160	sm.close()
	161
e4b21e2b ER	162	# main()
	163	try:
	164	ftpio.connect('from-incoming-pid-%s' % os.getpid())
	165	except:
65017da5 ER	166	print "Can't get ftpiod connection"
65017da5 ER	167	sys.exit(1)
e4b21e2b ER	168
	169	ftptree = BaseFtpTree(cval['default_to'])
	170
	171	if not ftpio.lock(cval['default_to']):
65017da5 ER	172	print "Can't get lock: %s" % cval['default_to']
65017da5 ER	173	sys.exit(1)
e4b21e2b	174
7c2f5e4c AM	175	moved_anything = False
7c2f5e4c AM	176
e4b21e2b ER	177	for uploadinfo in findfiles(incoming_dir + 'SRPMS'):
	178	content = getcontent(incoming_dir + 'SRPMS/' + uploadinfo)
	179	if not content:
	180	continue # Uploading not finished
	181
	182	pkg = BasePkg(uploadinfo[:-19], content = content)
	183	srpm = pkg.files['SRPMS'][0]
	184
46d96a92 AM	185	if not os.path.exists(incoming_dir + 'SRPMS/' + srpm):
	186	ftpio.log("%s file missing; skipping move until next round" % (srpm))
	187	continue
	188
e4b21e2b ER	189	if ftptree.has_key(`pkg`):
	190	ftpio.log("%s already present in %s; removing newer files" % (srpm, ftptree))
	191	rm(incoming_dir + 'SRPMS/' + srpm)
	192	f = open(default_to + 'SRPMS/.metadata/' + srpm+'.info', 'a')
	193	bid = pkg.build.keys()[0]
	194	build = pkg.build[bid]
	195	f.write("info:build:%s:requester:%s\ninfo:build:%s:requester_email:%s\n"
	196	% (bid, build.requester, bid, build.requester_email))
	197	f.close()
	198	else:
	199	mv(incoming_dir + 'SRPMS/' + srpm, default_to + 'SRPMS/RPMS')
8e089d4f	200
e4b21e2b ER	201	f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'w')
	202	f.write(content)
	203	f.close()
	204
	205	rm(incoming_dir + 'SRPMS/' + uploadinfo)
	206
38b2b764	207	for arch in ftp_archs:
8e089d4f	208	for uploadinfo in findfiles(incoming_dir + arch):
8911f226	209	content = getcontent(incoming_dir + arch + '/' + uploadinfo)
38b2b764	210	if not content:
2abd3b77	211	ftpio.log("%s not finished uploading" % uploadinfo)
38b2b764 MM	212	continue # Uploading not finished
38b2b764 MM	213
8911f226 ER	214	srcpkg = BasePkg(uploadinfo[:-19], content = content)
8911f226 ER	215	srpm = srcpkg.files['SRPMS'][0]
38b2b764	216
bb2cb325	217	if not ftptree.has_key(`srcpkg`):
38b2b764 MM	218	continue # We require the src.rpm to be present
38b2b764 MM	219
c77db9e7 JR	220	renvr = re.compile(r'(.)-(.)-(.)\.[^.]\.rpm')
	221	srcnvr = renvr.match(srpm).groups()
	222
46d96a92 AM	223	rpmfile_missing = [f for f in srcpkg.files['ARCH'] if not os.path.exists(incoming_dir + arch + '/'+f)]
	224	if len(rpmfile_missing):
	225	for filem in rpmfile_missing:
	226	ftpio.log("%s file missing; skipping move until next round" % (filem))
	227	continue
	228
8911f226	229	dstpkg = BasePkg(`srcpkg`, ftptree)
38b2b764	230
bb2cb325	231	if dstpkg.files.has_key(arch):
0a108b7f	232	ftpio.log("files from %s for arch %s already present in %s; removing newer files" % (`srcpkg`, arch, ftptree))
8e089d4f	233	for rpmfile in srcpkg.files['ARCH']:
2eb653d6	234	try:
8e089d4f	235	rm(incoming_dir + arch + '/'+rpmfile)
2eb653d6	236	except OSError, e:
8e089d4f	237	l = "Removing %s problem: %s" % (incoming_dir + arch + '/' + rpmfile, e)
2eb653d6 AM	238	ftpio.log(l)
2eb653d6 AM	239	print l
8911f226	240	rm(incoming_dir + arch + '/' + uploadinfo)
38b2b764 MM	241	continue
38b2b764 MM	242
8911f226	243	f = open(default_to + 'SRPMS/.metadata/' + srpm + '.info', 'a')
8e089d4f	244	for rpmfile in srcpkg.files['ARCH']:
7c2f5e4c	245	moved_anything = True
c77db9e7	246
164d8d15 JR	247	# Too much noise, too little use
	248	# archnvr = renvr.match(rpmfile).groups()
	249	# if srcnvr[1] != archnvr[1] or srcnvr[2] != archnvr[2]:
	250	# send_vr_msg(srcnvr, archnvr, dstpkg, arch)
c77db9e7	251
8e089d4f ER	252	if rpmfile[-11:] == '.noarch.rpm' and config.separate_noarch:
8e089d4f ER	253	move_noarch(f, arch, rpmfile, dstpkg)
bb2cb325	254	else:
8e089d4f ER	255	f.write("file:%s:%s\n" % (arch, rpmfile))
8e089d4f ER	256	srcfile = incoming_dir + arch + '/' + rpmfile
8911f226	257
8e089d4f	258	if is_debuginfo(rpmfile):
54ff0049 ER	259	dstfile = default_to + arch + '/debuginfo'
	260	else:
	261	dstfile = default_to + arch + '/RPMS'
8911f226	262
631d11b9	263	try:
8911f226	264	mv(srcfile, dstfile)
631d11b9	265	except OSError, e:
8911f226	266	l = "Moving %s to %s problem: %s" % (srcfile, dstfile, e)
631d11b9 AM	267	ftpio.log(l)
631d11b9 AM	268	print l
38b2b764 MM	269	f.close()
38b2b764 MM	270
8911f226	271	rm(incoming_dir + arch + '/' + uploadinfo)
38b2b764	272
0a108b7f	273	ftpio.unlock(cval['default_to'])
7c2f5e4c AM	274
7c2f5e4c AM	275	if moved_anything:
a34f0e55	276	os.system("%s/pld-ftp-admin/bin/pfa-genindex --quiet test > /dev/null" % (os.getenv("HOME")))