mirror of
https://github.com/munki/munki.git
synced 2026-04-29 17:00:13 -05:00
Clean up catalog files that are no longer in use by the client.
git-svn-id: http://munki.googlecode.com/svn/trunk@1091 a4e17f2e-e282-11dd-95e1-755cbddbdd66
This commit is contained in:
@@ -2001,6 +2001,15 @@ def getCatalogs(cataloglist):
|
||||
CATALOG[catalogname] = makeCatalogDB(catalogdata)
|
||||
|
||||
|
||||
def cleanUpCatalogs():
|
||||
"""Removes any catalog files that are no longer in use by this client"""
|
||||
catalog_dir = os.path.join(munkicommon.pref('ManagedInstallDir'),
|
||||
'catalogs')
|
||||
for item in os.listdir(catalog_dir):
|
||||
if item not in CATALOG.keys():
|
||||
os.unlink(os.path.join(catalog_dir, item))
|
||||
|
||||
|
||||
class ManifestException(Exception):
|
||||
"""Lets us raise an exception when we get an invalid
|
||||
manifest."""
|
||||
@@ -2517,7 +2526,7 @@ def getResourceIfChangedAtomically(url, destinationpath,
|
||||
# TODO: in theory NFS, AFP, or SMB could be supported here.
|
||||
else:
|
||||
raise MunkiDownloadError(
|
||||
'Unknown scheme for %s: %s' % (url, url_parse.scheme))
|
||||
'Unsupported scheme for %s: %s' % (url, url_parse.scheme))
|
||||
|
||||
|
||||
def getFileIfChangedAtomically(path, destinationpath):
|
||||
@@ -2873,6 +2882,9 @@ def check(client_id='', localmanifestpath=None):
|
||||
# record the filtered lists
|
||||
munkicommon.report['ItemsToInstall'] = installinfo['managed_installs']
|
||||
munkicommon.report['ItemsToRemove'] = installinfo['removals']
|
||||
|
||||
# clean up catalogs directory
|
||||
cleanUpCatalogs()
|
||||
|
||||
# clean up cache dir
|
||||
# remove any item in the cache that isn't scheduled
|
||||
|
||||
Reference in New Issue
Block a user