X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fstream-tcp.c;h=c7a2ee2e8dcf6dc2fbacdc694a7515da55a60814;hb=6e492d81450217a5c90cbb4ad31d81b1e611989b;hp=052ad8cb54c6a8a7bd4d2f77352c22152379d135;hpb=7921b912de1e347f418a116f6d83f802dee655e2;p=openvswitch diff --git a/lib/stream-tcp.c b/lib/stream-tcp.c index 052ad8cb..c7a2ee2e 100644 --- a/lib/stream-tcp.c +++ b/lib/stream-tcp.c @@ -38,7 +38,7 @@ VLOG_DEFINE_THIS_MODULE(stream_tcp); static int new_tcp_stream(const char *name, int fd, int connect_status, - const struct sockaddr_in *remote, struct stream **streamp) + const struct sockaddr_in *remote, struct stream **streamp) { struct sockaddr_in local; socklen_t local_len = sizeof local; @@ -70,12 +70,12 @@ new_tcp_stream(const char *name, int fd, int connect_status, } static int -tcp_open(const char *name, char *suffix, struct stream **streamp) +tcp_open(const char *name, char *suffix, struct stream **streamp, uint8_t dscp) { struct sockaddr_in sin; int fd, error; - error = inet_open_active(SOCK_STREAM, suffix, 0, &sin, &fd); + error = inet_open_active(SOCK_STREAM, suffix, 0, &sin, &fd, dscp); if (fd >= 0) { return new_tcp_stream(name, fd, error, &sin, streamp); } else { @@ -102,13 +102,14 @@ static int ptcp_accept(int fd, const struct sockaddr *sa, size_t sa_len, struct stream **streamp); static int -ptcp_open(const char *name OVS_UNUSED, char *suffix, struct pstream **pstreamp) +ptcp_open(const char *name OVS_UNUSED, char *suffix, struct pstream **pstreamp, + uint8_t dscp) { struct sockaddr_in sin; char bound_name[128]; int fd; - fd = inet_open_passive(SOCK_STREAM, suffix, -1, &sin); + fd = inet_open_passive(SOCK_STREAM, suffix, -1, &sin, dscp); if (fd < 0) { return -fd; }