X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fstream-tcp.c;h=1767fe44e039c47c88d3099562d4ff6ffcf348d6;hb=f40869bdf6feca4d3ff7c59a1fb1f7ac101bc967;hp=97492937bbb163093728255263f09ecdcae54e39;hpb=8706009e555bb9fa04a5679e4be2c7c67506802b;p=sliver-openvswitch.git diff --git a/lib/stream-tcp.c b/lib/stream-tcp.c index 97492937b..1767fe44e 100644 --- a/lib/stream-tcp.c +++ b/lib/stream-tcp.c @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2012 Nicira, Inc. + * Copyright (c) 2008, 2009, 2010, 2012, 2013 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -108,6 +108,7 @@ ptcp_open(const char *name OVS_UNUSED, char *suffix, struct pstream **pstreamp, { struct sockaddr_in sin; char bound_name[128]; + int error; int fd; fd = inet_open_passive(SOCK_STREAM, suffix, -1, &sin, dscp); @@ -116,8 +117,13 @@ ptcp_open(const char *name OVS_UNUSED, char *suffix, struct pstream **pstreamp, } sprintf(bound_name, "ptcp:%"PRIu16":"IP_FMT, - ntohs(sin.sin_port), IP_ARGS(&sin.sin_addr.s_addr)); - return new_fd_pstream(bound_name, fd, ptcp_accept, NULL, pstreamp); + ntohs(sin.sin_port), IP_ARGS(sin.sin_addr.s_addr)); + error = new_fd_pstream(bound_name, fd, ptcp_accept, set_dscp, NULL, + pstreamp); + if (!error) { + pstream_set_bound_port(*pstreamp, sin.sin_port); + } + return error; } static int @@ -128,7 +134,7 @@ ptcp_accept(int fd, const struct sockaddr *sa, size_t sa_len, char name[128]; if (sa_len == sizeof(struct sockaddr_in) && sin->sin_family == AF_INET) { - sprintf(name, "tcp:"IP_FMT, IP_ARGS(&sin->sin_addr)); + sprintf(name, "tcp:"IP_FMT, IP_ARGS(sin->sin_addr.s_addr)); sprintf(strchr(name, '\0'), ":%"PRIu16, ntohs(sin->sin_port)); } else { strcpy(name, "tcp"); @@ -142,6 +148,7 @@ const struct pstream_class ptcp_pstream_class = { ptcp_open, NULL, NULL, - NULL + NULL, + NULL, };