X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/c8eded0ba8ca02baeed5497bb590c840d62ac3fb..69b999879d380c6c8ea2e8871085ffe46a13779b:/lib/daemon.py

diff --git a/lib/daemon.py b/lib/daemon.py
index ac250cd..809e538 100644
--- a/lib/daemon.py
+++ b/lib/daemon.py
@@ -24,13 +24,13 @@
 
 import asyncore
 import os
-import select
 import signal
 import errno
 import logging
 import sched
 import time
 import socket
+import sys
 
 from ganeti import utils
 from ganeti import constants
@@ -157,25 +157,22 @@ class AsyncUDPSocket(asyncore.dispatcher):
 class Mainloop(object):
   """Generic mainloop for daemons
 
+  @ivar scheduler: A sched.scheduler object, which can be used to register
+    timed events
+
   """
   def __init__(self):
     """Constructs a new Mainloop instance.
 
-    @ivar scheduler: A L{sched.scheduler} object, which can be used to register
-    timed events
-
     """
     self._signal_wait = []
     self.scheduler = AsyncoreScheduler(time.time)
 
   @utils.SignalHandled([signal.SIGCHLD])
   @utils.SignalHandled([signal.SIGTERM])
-  def Run(self, stop_on_empty=False, signal_handlers=None):
+  def Run(self, signal_handlers=None):
     """Runs the mainloop.
 
-    @type stop_on_empty: bool
-    @param stop_on_empty: Whether to stop mainloop once all I/O waiters
-                          unregistered
     @type signal_handlers: dict
     @param signal_handlers: signal->L{utils.SignalHandler} passed by decorator
 
@@ -186,10 +183,6 @@ class Mainloop(object):
     running = True
     # Start actual main loop
     while running:
-      # Stop if nothing is listening anymore
-      if stop_on_empty and not (self._io_wait):
-        break
-
       if not self.scheduler.empty():
         try:
           self.scheduler.run()
@@ -233,11 +226,9 @@ def GenericMain(daemon_name, optionparser, dirs, check_fn, exec_fn):
 
   @type daemon_name: string
   @param daemon_name: daemon name
-  @type optionparser: L{optparse.OptionParser}
+  @type optionparser: optparse.OptionParser
   @param optionparser: initialized optionparser with daemon-specific options
                        (common -f -d options will be handled by this module)
-  @type options: object @param options: OptionParser result, should contain at
-                 least the fork and the debug options
   @type dirs: list of strings
   @param dirs: list of directories that must exist for this daemon to work
   @type check_fn: function which accepts (options, args)
@@ -310,4 +301,3 @@ def GenericMain(daemon_name, optionparser, dirs, check_fn, exec_fn):
     exec_fn(options, args)
   finally:
     utils.RemovePidFile(daemon_name)
-