[ovs-dev] [PATCH v2 1/2] python/ovs/socket_util: add tcp related helper functions which will be used by tcp
Isaku Yamahata
yamahata at valinux.co.jp
Thu Sep 27 09:28:07 UTC 2012
Signed-off-by: Isaku Yamahata <yamahata at valinux.co.jp>
---
Change v1 -> v2:
- typo
---
python/ovs/socket_util.py | 42 ++++++++++++++++++++++++++++++++++++++++++
1 file changed, 42 insertions(+)
diff --git a/python/ovs/socket_util.py b/python/ovs/socket_util.py
index a978707..845511e 100644
--- a/python/ovs/socket_util.py
+++ b/python/ovs/socket_util.py
@@ -84,6 +84,41 @@ def check_connection_completion(sock):
return errno.EAGAIN
+def inet_parse_active(target, default_port):
+ address = target.split(":")
+ host_name = address[0]
+ if not host_name:
+ raise Exception("%s: bad peer name format" % target)
+ if len(address) >= 2:
+ port = int(address[1])
+ elif default_port:
+ port = default_port
+ else:
+ raise Exception("%s: port number must be specified" % target)
+ return (host_name, port)
+
+
+def inet_open_active(style, target, default_port, dscp):
+ address = inet_parse_active(target, default_port)
+ try:
+ sock = socket.socket(socket.AF_INET, style, 0)
+ except socket.error, e:
+ return get_exception_errno(e), None
+
+ try:
+ set_nonblocking(sock)
+ set_dscp(sock, dscp)
+ try:
+ sock.connect(address)
+ except socket.error, e:
+ if get_exception_errno(e) != errno.EINPROGRESS:
+ raise
+ return 0, sock
+ except socket.error, e:
+ sock.close()
+ return get_exception_errno(e), None
+
+
def get_socket_error(sock):
"""Returns the errno value associated with 'socket' (0 if no error) and
resets the socket's error status."""
@@ -148,3 +183,10 @@ def set_nonblocking(sock):
except socket.error, e:
vlog.err("could not set nonblocking mode on socket: %s"
% os.strerror(get_socket_error(e)))
+
+
+def set_dscp(sock, dscp):
+ if dscp > 63:
+ raise Exception("Invalid dscp %d" % dscp)
+ val = dscp << 2
+ sock.setsockopt(socket.IPPROTO_IP, socket.IP_TOS, val)
--
1.7.10.4
More information about the dev
mailing list