Michael Foord | 65b69a1 | 2010-03-27 13:25:41 +0000 | [diff] [blame] | 1 | import signal |
| 2 | import weakref |
| 3 | |
| 4 | __unittest = True |
| 5 | |
| 6 | |
| 7 | class _InterruptHandler(object): |
| 8 | def __init__(self, default_handler): |
| 9 | self.called = False |
| 10 | self.default_handler = default_handler |
| 11 | |
| 12 | def __call__(self, signum, frame): |
| 13 | installed_handler = signal.getsignal(signal.SIGINT) |
| 14 | if installed_handler is not self: |
| 15 | # if we aren't the installed handler, then delegate immediately |
| 16 | # to the default handler |
| 17 | self.default_handler(signum, frame) |
| 18 | |
| 19 | if self.called: |
| 20 | self.default_handler(signum, frame) |
| 21 | self.called = True |
| 22 | for result in _results.keys(): |
| 23 | result.stop() |
| 24 | |
| 25 | _results = weakref.WeakKeyDictionary() |
| 26 | def registerResult(result): |
| 27 | _results[result] = 1 |
| 28 | |
| 29 | def removeResult(result): |
| 30 | return bool(_results.pop(result, None)) |
| 31 | |
| 32 | _interrupt_handler = None |
| 33 | def installHandler(): |
| 34 | global _interrupt_handler |
| 35 | if _interrupt_handler is None: |
| 36 | default_handler = signal.getsignal(signal.SIGINT) |
| 37 | _interrupt_handler = _InterruptHandler(default_handler) |
| 38 | signal.signal(signal.SIGINT, _interrupt_handler) |