From dd36b243507feb8a76c8b7dc99779594a2848d23 Mon Sep 17 00:00:00 2001
From: Narayan Desai <desai@mcs.anl.gov>
Date: Tue, 9 Sep 2008 04:20:38 +0000
Subject: Make file monitor selectable Handle child processes more aggressively

git-svn-id: https://svn.mcs.anl.gov/repos/bcfg/trunk/bcfg2@4908 ce84e21b-d406-0410-9b95-82705330c041
---
 src/lib/Component.py          | 4 +++-
 src/lib/Options.py            | 3 ++-
 src/lib/Server/Core.py        | 8 +++++---
 src/lib/Server/FileMonitor.py | 2 +-
 4 files changed, 11 insertions(+), 6 deletions(-)

(limited to 'src/lib')

diff --git a/src/lib/Component.py b/src/lib/Component.py
index 7ee2df515..aca74f7d1 100644
--- a/src/lib/Component.py
+++ b/src/lib/Component.py
@@ -212,6 +212,7 @@ class Component(TLSServer,
             # need to add waitpid code here to enforce maxchild
             if method in self.fork_funcs:
                 self.clean_up_children()
+                self.check_for_free_slot()
                 pid = os.fork()
                 if pid:
                     self.children.append(pid)
@@ -252,11 +253,12 @@ class Component(TLSServer,
                     break
             except OSError:
                 break
+
+    def check_for_free_slot(self):
         if len(self.children) >= self.child_limit:
             self.logger.info("Reached child_limit; waiting for child exit")
             pid = os.waitpid(0, 0)[0]
             self.children.remove(pid)
-            self.logger.debug("process %d exited" % pid)
 
     def _authenticate_connection(self, method, user, password, address):
         '''Authenticate new connection'''
diff --git a/src/lib/Options.py b/src/lib/Options.py
index 21cb31fdf..a158ab37d 100644
--- a/src/lib/Options.py
+++ b/src/lib/Options.py
@@ -186,7 +186,8 @@ SERVER_GENERATORS = Option('Server generator list', cf=('server', 'generators'),
                            cook=list_split)
 SERVER_STRUCTURES = Option('Server structure list', cf=('server', 'structures'),
                            default=['Bundler', 'Base'], cook=list_split)
-
+SERVER_FILEMONITOR = Option('Server file monitor', cf=('server', 'filemonitor'),
+                            default='default')
 SERVER_LOCATION = Option('Server Location', cf=('components', 'bcfg2'),
                          default='https://localhost:6789', cmd='-S',
                          odesc='https://server:port')
diff --git a/src/lib/Server/Core.py b/src/lib/Server/Core.py
index 5687cba9d..b29c9bf05 100644
--- a/src/lib/Server/Core.py
+++ b/src/lib/Server/Core.py
@@ -24,13 +24,15 @@ class CoreInitError(Exception):
 class Core(object):
     '''The Core object is the container for all Bcfg2 Server logic, and modules'''
 
-    def __init__(self, repo, plugins, structures, generators, password, svn, encoding):
+    def __init__(self, repo, plugins, structures, generators, password, svn,
+                 encoding, filemonitor='default'):
         object.__init__(self)
         self.datastore = repo
         try:
-            self.fam = Bcfg2.Server.FileMonitor.default()
+            self.fam = Bcfg2.Server.FileMonitor.available[filemonitor]()
         except IOError:
-            raise CoreInitError, "failed to connect to fam"
+            raise CoreInitError, "failed to instantiate fam driver (used %s)" % \
+                  filemonitor
         self.pubspace = {}
         self.generators = []
         self.structures = []
diff --git a/src/lib/Server/FileMonitor.py b/src/lib/Server/FileMonitor.py
index bb0441c65..bea210150 100644
--- a/src/lib/Server/FileMonitor.py
+++ b/src/lib/Server/FileMonitor.py
@@ -231,5 +231,5 @@ available['pseudo'] = PseudoFam
 
 for fdrv in ['gamin', 'fam', 'pseudo']:
     if fdrv in available:
-        default = available[fdrv]
+        available['default'] = available[fdrv]
         break
-- 
cgit v1.2.3-1-g7c22