diff options
| author | YAMADA Hideki <yamada.hideki@po.ntts.co.jp> | 2014-05-14 19:10:59 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2014-05-16 05:03:10 +0900 |
| commit | 73e16c15ccaf45420da25dfec3b05a8488cb0b46 (patch) | |
| tree | 85774ddf390712c6e340d94156b24e4793830482 | |
| parent | ca1b2717052cc895f5bc7fbce896c077f18d80bf (diff) | |
hub: import semaphore
Signed-off-by: YAMADA Hideki <yamada.hideki@po.ntts.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/lib/hub.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ryu/lib/hub.py b/ryu/lib/hub.py index 95199e75..c68f19be 100644 --- a/ryu/lib/hub.py +++ b/ryu/lib/hub.py @@ -29,6 +29,7 @@ if HUB_TYPE == 'eventlet': import eventlet import eventlet.event import eventlet.queue + import eventlet.semaphore import eventlet.timeout import eventlet.wsgi import greenlet @@ -90,6 +91,8 @@ if HUB_TYPE == 'eventlet': Queue = eventlet.queue.Queue QueueEmpty = eventlet.queue.Empty + Semaphore = eventlet.semaphore.Semaphore + BoundedSemaphore = eventlet.semaphore.BoundedSemaphore class StreamServer(object): def __init__(self, listen_info, handle=None, backlog=None, |