Index: third_party/twisted_8_1/twisted/python/timeoutqueue.py |
diff --git a/third_party/twisted_8_1/twisted/python/timeoutqueue.py b/third_party/twisted_8_1/twisted/python/timeoutqueue.py |
deleted file mode 100644 |
index 9252dc312011f53794b1ce5724250bd3fb01f2b2..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/python/timeoutqueue.py |
+++ /dev/null |
@@ -1,49 +0,0 @@ |
-# -*- test-case-name: twisted.test.test_timeoutqueue -*- |
-# Copyright (c) 2001-2007 Twisted Matrix Laboratories. |
-# See LICENSE for details. |
- |
-""" |
-A Queue subclass that supports timeouts. |
-""" |
- |
-# System Imports |
-import Queue, time, warnings |
- |
- |
-_time = time.time |
-_sleep = time.sleep |
- |
- |
-class TimedOut(Exception): |
- pass |
- |
- |
-class TimeoutQueue(Queue.Queue): |
- """ |
- A thread-safe queue that supports timeouts. |
- """ |
- |
- def __init__(self, max=0): |
- warnings.warn("timeoutqueue is deprecated since Twisted 8.0", |
- category=DeprecationWarning, stacklevel=2) |
- Queue.Queue.__init__(self, max) |
- |
- def wait(self, timeout): |
- """ |
- Wait until the queue isn't empty. Raises TimedOut if still empty. |
- """ |
- endtime = _time() + timeout |
- delay = 0.0005 # 500 us -> initial delay of 1 ms |
- while 1: |
- gotit = not self.empty() |
- if gotit: |
- break |
- remaining = endtime - _time() |
- if remaining <= 0: |
- raise TimedOut, "timed out." |
- delay = min(delay * 2, remaining, .05) |
- _sleep(delay) |
- |
- |
-__all__ = ["TimeoutQueue", "TimedOut"] |
- |