summaryrefslogtreecommitdiffstats
path: root/src/lib/Bcfg2/Client/Tools/POSIX/Directory.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib/Bcfg2/Client/Tools/POSIX/Directory.py')
-rw-r--r--src/lib/Bcfg2/Client/Tools/POSIX/Directory.py22
1 files changed, 20 insertions, 2 deletions
diff --git a/src/lib/Bcfg2/Client/Tools/POSIX/Directory.py b/src/lib/Bcfg2/Client/Tools/POSIX/Directory.py
index 675a4461a..24667d162 100644
--- a/src/lib/Bcfg2/Client/Tools/POSIX/Directory.py
+++ b/src/lib/Bcfg2/Client/Tools/POSIX/Directory.py
@@ -11,6 +11,10 @@ class POSIXDirectory(POSIXTool):
""" Handle <Path type='directory' ...> entries """
__req__ = ['name', 'mode', 'owner', 'group']
+ def __init__(self, logger, setup, config):
+ super(POSIXDirectory, self).__init__(logger, setup, config)
+ self.prunes = dict()
+
def verify(self, entry, modlist):
ondisk = self._exists(entry)
if not ondisk:
@@ -25,10 +29,18 @@ class POSIXDirectory(POSIXTool):
if entry.get('prune', 'false').lower() == 'true':
# check for any extra entries when prune='true' attribute is set
try:
+ prune_list = list()
+ if entry.get('name') in self.prunes:
+ prune_list = self.prunes[entry.get('name')]
+ else:
+ self.prunes[entry.get('name')] = list()
+
extras = [os.path.join(entry.get('name'), ent)
for ent in os.listdir(entry.get('name'))
- if os.path.join(entry.get('name'),
- ent) not in modlist]
+ if (os.path.join(entry.get('name'),
+ ent) not in modlist and
+ os.path.join(entry.get('name'),
+ ent) not in prune_list)]
if extras:
prune = False
msg = "Directory %s contains extra entries: %s" % \
@@ -37,6 +49,10 @@ class POSIXDirectory(POSIXTool):
entry.set('qtext', entry.get('qtext', '') + '\n' + msg)
for extra in extras:
Bcfg2.Client.XML.SubElement(entry, 'Prune', name=extra)
+ self.prunes[entry.get('name')] += extras
+ elif entry.get('name') in self.prunes and \
+ len(self.prunes[entry.get('name')]) > 0:
+ prune = False
except OSError:
prune = True
@@ -71,6 +87,8 @@ class POSIXDirectory(POSIXTool):
try:
self.logger.debug("POSIX: Removing %s" % pname)
self._remove(pent)
+ if entry.get('name') in self.prunes:
+ self.prunes[entry.get('name')].remove(pname)
except OSError:
err = sys.exc_info()[1]
self.logger.error("POSIX: Failed to unlink %s: %s" %