Noted in passing:

  s/nubmer/number/

Did not review rest


On Aug 22, 2555 BE, at 3:05, Isaku Yamahata <yamah...@valinux.co.jp> wrote:

> Signed-off-by: Isaku Yamahata <yamah...@valinux.co.jp>
> ---
> python/ovs/socket_util.py |   40 ++++++++++++++++++++++++++++++++++++++++
> 1 files changed, 40 insertions(+), 0 deletions(-)
> 
> diff --git a/python/ovs/socket_util.py b/python/ovs/socket_util.py
> index a8e8d92..d05f165 100644
> --- a/python/ovs/socket_util.py
> +++ b/python/ovs/socket_util.py
> @@ -83,6 +83,39 @@ def check_connection_completion(sock):
>         return errno.EAGAIN
> 
> 
> +def inet_parse_active(target, default_port):
> +    address = target.split(":")
> +    host_name = address[0]
> +    if len(address) >= 2:
> +        port = int(address[1])
> +    elif not default_port:
> +        port = default_port
> +    else:
> +        raise Exception('%s: port nubmer 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."""
> @@ -147,3 +180,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.1.1
> 
> _______________________________________________
> dev mailing list
> dev@openvswitch.org
> http://openvswitch.org/mailman/listinfo/dev
_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev

Reply via email to