From bc52f6ac0c56c9551b58fb5110259d87b3a97056 Mon Sep 17 00:00:00 2001
From: "Chris St. Pierre" <chris.a.st.pierre@gmail.com>
Date: Fri, 18 May 2012 10:53:35 -0400
Subject: Added inotify filemonitor driver Moved list of files to ignore into
 config

---
 src/lib/Bcfg2/Server/FileMonitor/Gamin.py | 64 +++++++++++++++++++++++++++++++
 1 file changed, 64 insertions(+)
 create mode 100644 src/lib/Bcfg2/Server/FileMonitor/Gamin.py

(limited to 'src/lib/Bcfg2/Server/FileMonitor/Gamin.py')

diff --git a/src/lib/Bcfg2/Server/FileMonitor/Gamin.py b/src/lib/Bcfg2/Server/FileMonitor/Gamin.py
new file mode 100644
index 000000000..60f80c9c3
--- /dev/null
+++ b/src/lib/Bcfg2/Server/FileMonitor/Gamin.py
@@ -0,0 +1,64 @@
+""" Gamin driver for file alteration events """
+
+import os
+import stat
+import logging
+from gamin import WatchMonitor, GAMCreated, GAMExists, GAMEndExist, \
+    GAMChanged, GAMDeleted
+from Bcfg2.Server.FileMonitor import Event, FileMonitor
+
+logger = logging.getLogger(__name__)
+
+class GaminEvent(Event):
+    """
+    This class provides an event analogous to
+    python-fam events based on gamin sources.
+    """
+    action_map = {GAMCreated: 'created', GAMExists: 'exists',
+                  GAMChanged: 'changed', GAMDeleted: 'deleted',
+                  GAMEndExist: 'endExist'}
+
+    def __init__(self, request_id, filename, code):
+        Event.__init__(self, request_id, filename, code)
+        if code in self.action_map:
+            self.action = self.action_map[code]
+
+class Gamin(FileMonitor):
+    __priority__ = 10
+
+    def __init__(self, ignore=None, debug=False):
+        FileMonitor.__init__(self, ignore=ignore, debug=debug)
+        self.mon = WatchMonitor()
+        self.counter = 0
+
+    def fileno(self):
+        return self.mon.get_fd()
+
+    def queue(self, path, action, request_id):
+        """queue up the event for later handling"""
+        self.events.append(GaminEvent(request_id, path, action))
+
+    def AddMonitor(self, path, obj):
+        """Add a monitor to path, installing a callback to obj."""
+        handle = self.counter
+        self.counter += 1
+        mode = os.stat(path)[stat.ST_MODE]
+
+        # Flush queued gamin events
+        while self.mon.event_pending():
+            self.mon.handle_one_event()
+
+        if stat.S_ISDIR(mode):
+            self.mon.watch_directory(path, self.queue, handle)
+        else:
+            self.mon.watch_file(path, self.queue, handle)
+        self.handles[handle] = obj
+        return handle
+
+    def pending(self):
+        return FileMonitor.pending(self) or self.mon.event_pending()
+
+    def get_event(self):
+        if self.mon.event_pending():
+            self.mon.handle_one_event()
+        return FileMonitor.get_event(self)
-- 
cgit v1.2.3-1-g7c22