From 44d614591d74b1dcf402bb74c8954d3ca2b173e5 Mon Sep 17 00:00:00 2001
From: Eddie Hebert <ehebert@quantopian.com>
Date: Mon, 15 Oct 2012 14:16:50 -0400
Subject: [PATCH] Removes non-zipline specific delayed_signals module.

The delayed_signals module isn't actually necessary for the
running of zipline, so removing to reduce the surface area.
---
 tests/test_delayed_signals.py    | 69 --------------------------------
 zipline/utils/delayed_signals.py | 41 -------------------
 2 files changed, 110 deletions(-)
 delete mode 100644 tests/test_delayed_signals.py
 delete mode 100644 zipline/utils/delayed_signals.py

diff --git a/tests/test_delayed_signals.py b/tests/test_delayed_signals.py
deleted file mode 100644
index 24c6f465..00000000
--- a/tests/test_delayed_signals.py
+++ /dev/null
@@ -1,69 +0,0 @@
-#
-# Copyright 2012 Quantopian, Inc.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import os
-from signal import signal, SIGHUP, SIGINT
-import time
-from types import FrameType
-import unittest
-
-from zipline.utils.delayed_signals import delayed_signals
-
-
-class DelayedSignals(unittest.TestCase):
-    def handler(self, signum, frame):
-        print "Got signal " + str(signum)
-        self.got[signum] = time.time()
-        self.assertTrue(isinstance(frame, FrameType))
-
-    def setUp(self):
-        signal(SIGHUP, self.handler)
-        signal(SIGINT, self.handler)
-
-    def reset(self):
-        self.got = {}
-
-    def test_delayed_signals(self):
-        self.reset()
-        with delayed_signals([SIGHUP]):
-            os.kill(os.getpid(), SIGHUP)
-            time.sleep(2)
-        self.assertTrue(self.got[SIGHUP])
-        self.assertTrue(time.time() - self.got[SIGHUP] < 2)
-
-    def test_immediate_signals(self):
-        self.reset()
-        os.kill(os.getpid(), SIGHUP)
-        time.sleep(2)
-        self.assertTrue(self.got[SIGHUP])
-        self.assertTrue(time.time() - self.got[SIGHUP] > 1)
-
-    def test_multiple_signals(self):
-        self.reset()
-        with delayed_signals([SIGHUP, SIGINT]):
-            os.kill(os.getpid(), SIGINT)
-        self.assertFalse(SIGHUP in self.got)
-        self.assertTrue(SIGINT in self.got)
-
-    @delayed_signals([SIGHUP])
-    def kill_and_sleep(self):
-        os.kill(os.getpid(), SIGHUP)
-        time.sleep(2)
-
-    def test_decorator(self):
-        self.reset()
-        self.kill_and_sleep()
-        self.assertTrue(SIGHUP in self.got)
-        self.assertTrue(time.time() - self.got[SIGHUP] < 2)
diff --git a/zipline/utils/delayed_signals.py b/zipline/utils/delayed_signals.py
deleted file mode 100644
index 78ccf453..00000000
--- a/zipline/utils/delayed_signals.py
+++ /dev/null
@@ -1,41 +0,0 @@
-from functools import wraps
-from signal import signal
-
-
-class delayed_signals(object):
-    """
-    Utility to temporary intercept one or more signals while a function or code
-    block is executed, restore their signal handlers at the end of execution,
-    and invoke them if the signals were in fact received during execution.
-
-    Can be used either as a decorator or a context manager.
-
-    Pass in an iterable of signals to intercept.
-    """
-
-    def handler(self, signum, frame=None):
-        self.got.append({'signum': signum, 'frame': frame})
-
-    def __init__(self, signals):
-        self.signals = signals
-        self.handlers = {}
-        self.got = []
-
-    def __enter__(self):
-        for signum in self.signals:
-            # signal() returns the old signal handler
-            self.handlers[signum] = signal(signum, self.handler)
-
-    def __exit__(self, time, value, traceback):
-        for signum, handler in self.handlers.items():
-            signal(signum, handler)
-        for signum, frame in ((i['signum'], i['frame']) for i in self.got):
-            self.handlers[signum](signum, frame)
-
-    def __call__(self, fn):
-        @wraps(fn)
-        def call_fn(*args, **kwargs):
-            with self:
-                outval = fn(*args, **kwargs)
-            return outval
-        return call_fn