1 files changed, 0 insertions, 67 deletions
diff --git a/rpki/async.py b/rpki/async.py
index 5b3d35b1..74143bd1 100644
--- a/rpki/async.py
+++ b/rpki/async.py
@@ -336,73 +336,6 @@ def event_loop(catch_signals = (signal.SIGINT, signal.SIGTERM)):
       for sig in old_signal_handlers:
         signal.signal(sig, old_signal_handlers[sig])
 
-class sync_wrapper(object):
-  """
-  Synchronous wrapper around asynchronous functions.  Running in
-  asynchronous mode at all times makes sense for event-driven daemons,
-  but is kind of tedious for simple scripts, hence this wrapper.
-
-  The wrapped function should take at least two arguments: a callback
-  function and an errback function.  If any arguments are passed to
-  the wrapper, they will be passed as additional arguments to the
-  wrapped function.
-  """
-
-  res = None
-  err = None
-  fin = False
-
-  def __init__(self, func, disable_signal_handlers = False):
-    self.func = func
-    self.disable_signal_handlers = disable_signal_handlers
-
-  def cb(self, res = None):
-    """
-    Wrapped code has requested normal termination.  Store result, and
-    exit the event loop.
-    """
-
-    self.res = res
-    self.fin = True
-    logger.debug("%r callback with result %r", self, self.res)
-    raise ExitNow
-
-  def eb(self, err):
-    """
-    Wrapped code raised an exception.  Store exception data, then exit
-    the event loop.
-    """
-
-    exc_info = sys.exc_info()
-    self.err = exc_info if exc_info[1] is err else err
-    self.fin = True
-    logger.debug("%r errback with exception %r", self, self.err)
-    raise ExitNow
-
-  def __call__(self, *args, **kwargs):
-
-    def thunk():
-      try:
-        self.func(self.cb, self.eb, *args, **kwargs)
-      except ExitNow:
-        raise
-      except Exception, e:
-        self.eb(e)
-
-    event_defer(thunk)
-    if self.disable_signal_handlers:
-      event_loop(catch_signals = ())
-    else:
-      event_loop()
-    if not self.fin:
-      logger.warning("%r event_loop terminated without callback or errback", self)
-    if self.err is None:
-      return self.res
-    elif isinstance(self.err, tuple):
-      raise self.err[0], self.err[1], self.err[2]
-    else:
-      raise self.err
-
 class gc_summary(object):
   """
   Periodic summary of GC state, for tracking down memory bloat.