openstack/deb-ryu
Code Issues Proposed changes

hub: Enable StreamServer to listen Unix domain socket

Browse Source 
Signed-off-by: IWASE Yusuke <iwase.yusuke0@gmail.com>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
IWASE Yusuke 2017-02-17 13:05:58 +09:00 committed by FUJITA Tomonori
parent fd3bfb55de
commit 9efde1d2f5
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ryu/lib/hub.py
View File

@ -17,6 +17,8 @@
import logging
import os
import netaddr
# We don't bother to use cfg.py because monkey patch needs to be
# called very early. Instead, we use an environment variable to
@ -110,11 +112,19 @@ if HUB_TYPE == 'eventlet':
assert backlog is None
assert spawn == 'default'
if ':' in listen_info[0]:
if netaddr.valid_ipv4(listen_info[0]):
self.server = eventlet.listen(listen_info)
elif netaddr.valid_ipv6(listen_info[0]):
self.server = eventlet.listen(listen_info,
family=socket.AF_INET6)
elif os.path.isdir(os.path.dirname(listen_info[0])):
# Case for Unix domain socket
self.server = eventlet.listen(listen_info[0],
family=socket.AF_UNIX)
else:
self.server = eventlet.listen(listen_info)
raise ValueError(
'Invalid listen_info: %s' % str(listen_info))
if ssl_args:
def wrap_and_handle(sock, addr):
ssl_args.setdefault('server_side', True)