1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
#!/usr/bin/python -S
#
# Copyright 2009 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""Archive Override Check
Given a distribution to run on, report any override inconsistence found.
It basically check if all published source and binaries are coherent.
"""
import _pythonpath
from optparse import OptionParser
import sys
from zope.component import getUtility
# Still needed fake import to stop circular imports.
import canonical.launchpad.interfaces
from canonical.config import config
from canonical.launchpad.scripts import (
execute_zcml_for_scripts, logger, logger_options)
from lp.app.errors import NotFoundError
from canonical.lp import initZopeless
from lp.registry.interfaces.distribution import IDistributionSet
from lp.registry.interfaces.pocket import PackagePublishingPocket
from lp.soyuz.scripts.ftpmaster import PubSourceChecker
from lp.soyuz.enums import PackagePublishingStatus
from contrib.glock import GlobalLock
def main():
# Parse command-line arguments
parser = OptionParser()
logger_options(parser)
parser.add_option("-d", "--distribution", action="store",
dest="distribution", metavar="DISTRO", default="ubuntu",
help="Distribution to consider")
parser.add_option("-s", "--suite", action="store",
dest="suite", metavar="SUITE", default=None,
help=("Suite to consider, if not passed consider the "
"currentseries and the RELEASE pocket"))
(options, args) = parser.parse_args()
log = logger(options, "archive-override-check")
log.debug("Acquiring lock")
lock = GlobalLock('/var/lock/archive-override-check.lock')
lock.acquire(blocking=True)
log.debug("Initializing connection.")
execute_zcml_for_scripts()
ztm = initZopeless(dbuser=config.archivepublisher.dbuser)
try:
try:
distribution = getUtility(IDistributionSet)[options.distribution]
if options.suite is None:
distroseries = distribution.currentseries
pocket = PackagePublishingPocket.RELEASE
else:
distroseries, pocket = distribution.getDistroSeriesAndPocket(
options.suite)
log.debug("Considering: %s/%s/%s/%s."
% (distribution.name, distroseries.name, pocket.name,
distroseries.status.name))
checkOverrides(distroseries, pocket, log)
except NotFoundError, info:
log.error('Not found: %s' % info)
finally:
log.debug("Rolling back any remaining transactions.")
ztm.abort()
log.debug("Releasing lock")
lock.release()
return 0
def checkOverrides(distroseries, pocket, log):
"""Initialize and handle PubSourceChecker.
Iterate over PUBLISHED sources and perform PubSourceChecker.check()
on each published Source/Binaries couple.
"""
spps = distroseries.getSourcePackagePublishing(
status=PackagePublishingStatus.PUBLISHED,
pocket=pocket)
log.debug('%s published sources' % spps.count())
for spp in spps:
spr = spp.sourcepackagerelease
checker = PubSourceChecker(
spr.name, spr.version, spp.component.name, spp.section.name,
spr.urgency.name)
for bpp in spp.getPublishedBinaries():
bpr = bpp.binarypackagerelease
checker.addBinary(
bpr.name, bpr.version, bpp.distroarchseries.architecturetag,
bpp.component.name, bpp.section.name, bpr.priority.name)
checker.check()
report = checker.renderReport()
if report:
print report
if __name__ == '__main__':
sys.exit(main())
|