summaryrefslogtreecommitdiffstats
path: root/src/lib/Bcfg2/Server/FileMonitor/Pseudo.py
diff options
context:
space:
mode:
authorChris St. Pierre <chris.a.st.pierre@gmail.com>2012-05-21 09:02:30 -0400
committerChris St. Pierre <chris.a.st.pierre@gmail.com>2012-05-21 09:02:37 -0400
commitd78e0cc91947a06ae7687cb54f805787fb00d28f (patch)
tree2555001e52cada4f0dd3bb68163b178874eacddd /src/lib/Bcfg2/Server/FileMonitor/Pseudo.py
parent661c5db322987b14178568325c71957451a3306e (diff)
downloadbcfg2-d78e0cc91947a06ae7687cb54f805787fb00d28f.tar.gz
bcfg2-d78e0cc91947a06ae7687cb54f805787fb00d28f.tar.bz2
bcfg2-d78e0cc91947a06ae7687cb54f805787fb00d28f.zip
fixed bug in pseudo fm, deduplicated code
Diffstat (limited to 'src/lib/Bcfg2/Server/FileMonitor/Pseudo.py')
-rw-r--r--src/lib/Bcfg2/Server/FileMonitor/Pseudo.py17
1 files changed, 7 insertions, 10 deletions
diff --git a/src/lib/Bcfg2/Server/FileMonitor/Pseudo.py b/src/lib/Bcfg2/Server/FileMonitor/Pseudo.py
index 4c2d90250..baff871d0 100644
--- a/src/lib/Bcfg2/Server/FileMonitor/Pseudo.py
+++ b/src/lib/Bcfg2/Server/FileMonitor/Pseudo.py
@@ -10,21 +10,18 @@ logger = logging.getLogger(__name__)
class Pseudo(FileMonitor):
__priority__ = 99
- def AddMonitor(self, path, obj):
+ def AddMonitor(self, path, obj, handleID=None):
"""add a monitor to path, installing a callback to obj.HandleEvent"""
- handleID = len(list(self.handles.keys()))
+ if handleID is None:
+ handleID = len(list(self.handles.keys()))
mode = os.stat(path)[stat.ST_MODE]
- handle = Event(handleID, path, 'exists')
+ self.events.append(Event(handleID, path, 'exists'))
if stat.S_ISDIR(mode):
dirList = os.listdir(path)
- self.pending_events.append(handle)
for includedFile in dirList:
- self.pending_events.append(Event(handleID,
- includedFile,
- 'exists'))
- self.pending_events.append(Event(handleID, path, 'endExist'))
- else:
- self.pending_events.append(Event(handleID, path, 'exists'))
+ self.events.append(Event(handleID, includedFile, 'exists'))
+ self.events.append(Event(handleID, path, 'endExist'))
+
if obj != None:
self.handles[handleID] = obj
return handleID