openstack/os-ken
Code Issues Proposed changes

hub: import semaphore

Browse Source 
Signed-off-by: YAMADA Hideki <yamada.hideki@po.ntts.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
YAMADA Hideki 2014-05-14 19:10:59 +09:00 committed by FUJITA Tomonori
parent ca1b271705
commit 73e16c15cc
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ryu/lib/hub.py
View File

@ -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,