From 78dfedb4b450005246508cea08874637fcc86885 Mon Sep 17 00:00:00 2001
From: "Chris St. Pierre" <chris.a.st.pierre@gmail.com>
Date: Tue, 30 Oct 2012 09:24:10 -0400
Subject: removed deprecated FAM filemonitor

---
 src/lib/Bcfg2/Server/FileMonitor/Fam.py      | 105 ---------------------------
 src/lib/Bcfg2/Server/FileMonitor/__init__.py |   6 --
 2 files changed, 111 deletions(-)
 delete mode 100644 src/lib/Bcfg2/Server/FileMonitor/Fam.py

(limited to 'src')

diff --git a/src/lib/Bcfg2/Server/FileMonitor/Fam.py b/src/lib/Bcfg2/Server/FileMonitor/Fam.py
deleted file mode 100644
index 253bb2801..000000000
--- a/src/lib/Bcfg2/Server/FileMonitor/Fam.py
+++ /dev/null
@@ -1,105 +0,0 @@
-""" File monitor backend with support for the `File Alteration Monitor
-<http://oss.sgi.com/projects/fam/>`_.  The FAM backend is deprecated. """
-
-import os
-import _fam
-import stat
-import logging
-from time import time
-from Bcfg2.Server.FileMonitor import FileMonitor
-
-LOGGER = logging.getLogger(__name__)
-
-
-class Fam(FileMonitor):
-    """ **Deprecated** file monitor backend with support for the `File
-    Alteration Monitor <http://oss.sgi.com/projects/fam/>`_ (also
-    abbreviated "FAM")."""
-
-    #: FAM is the worst actual monitor backend, so give it a low
-    #: priority.
-    __priority__ = 10
-
-    def __init__(self, ignore=None, debug=False):
-        FileMonitor.__init__(self, ignore=ignore, debug=debug)
-        self.filemonitor = _fam.open()
-        self.users = {}
-        LOGGER.warning("The Fam file monitor backend is deprecated. Please "
-                       "switch to a supported file monitor.")
-    __init__.__doc__ = FileMonitor.__init__.__doc__
-
-    def fileno(self):
-        return self.filemonitor.fileno()
-    fileno.__doc__ = FileMonitor.fileno.__doc__
-
-    def handle_event_set(self, _=None):
-        self.Service()
-    handle_event_set.__doc__ = FileMonitor.handle_event_set.__doc__
-
-    def handle_events_in_interval(self, interval):
-        now = time()
-        while (time() - now) < interval:
-            if self.Service():
-                now = time()
-    handle_events_in_interval.__doc__ = \
-        FileMonitor.handle_events_in_interval.__doc__
-
-    def AddMonitor(self, path, obj, _=None):
-        mode = os.stat(path)[stat.ST_MODE]
-        if stat.S_ISDIR(mode):
-            handle = self.filemonitor.monitorDirectory(path, None)
-        else:
-            handle = self.filemonitor.monitorFile(path, None)
-        self.handles[handle.requestID()] = handle
-        if obj != None:
-            self.users[handle.requestID()] = obj
-        return handle.requestID()
-    AddMonitor.__doc__ = FileMonitor.AddMonitor.__doc__
-
-    def Service(self, interval=0.50):
-        """ Handle events for the specified period of time (in
-        seconds).  This call will block for ``interval`` seconds.
-
-        :param interval: The interval, in seconds, during which events
-                         should be handled.  Any events that are
-                         already pending when :func:`Service` is
-                         called will also be handled.
-        :type interval: int
-        :returns: None
-        """
-        count = 0
-        collapsed = 0
-        rawevents = []
-        start = time()
-        now = time()
-        while (time() - now) < interval:
-            if self.filemonitor.pending():
-                while self.filemonitor.pending():
-                    count += 1
-                    rawevents.append(self.filemonitor.nextEvent())
-                now = time()
-        unique = []
-        bookkeeping = []
-        for event in rawevents:
-            if self.should_ignore(event):
-                continue
-            if event.code2str() != 'changed':
-                # process all non-change events
-                unique.append(event)
-            else:
-                if (event.filename, event.requestID) not in bookkeeping:
-                    bookkeeping.append((event.filename, event.requestID))
-                    unique.append(event)
-                else:
-                    collapsed += 1
-        for event in unique:
-            if event.requestID in self.users:
-                try:
-                    self.users[event.requestID].HandleEvent(event)
-                except:  # pylint: disable=W0702
-                    LOGGER.error("Handling event for file %s" % event.filename,
-                                 exc_info=1)
-        end = time()
-        LOGGER.info("Processed %s fam events in %03.03f seconds. "
-                    "%s coalesced" % (count, (end - start), collapsed))
-        return count
diff --git a/src/lib/Bcfg2/Server/FileMonitor/__init__.py b/src/lib/Bcfg2/Server/FileMonitor/__init__.py
index 42ad4c041..a1ff655d0 100644
--- a/src/lib/Bcfg2/Server/FileMonitor/__init__.py
+++ b/src/lib/Bcfg2/Server/FileMonitor/__init__.py
@@ -322,12 +322,6 @@ available = dict()  # pylint: disable=C0103
 from Bcfg2.Server.FileMonitor.Pseudo import Pseudo
 available['pseudo'] = Pseudo
 
-try:
-    from Bcfg2.Server.FileMonitor.Fam import Fam
-    available['fam'] = Fam
-except ImportError:
-    pass
-
 try:
     from Bcfg2.Server.FileMonitor.Gamin import Gamin
     available['gamin'] = Gamin
-- 
cgit v1.2.3-1-g7c22