/* * Copyright (c) 2008, 2009, 2010, 2012, 2013, 2014 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include #include "stream.h" #include #include #include #include #include #include #include #include #include #include #include "dynamic-string.h" #include "packets.h" #include "socket-util.h" #include "util.h" #include "stream-provider.h" #include "stream-fd.h" #include "vlog.h" VLOG_DEFINE_THIS_MODULE(stream_tcp); /* Active TCP. */ static int new_tcp_stream(const char *name, int fd, int connect_status, struct stream **streamp) { struct sockaddr_storage local; socklen_t local_len = sizeof local; int on = 1; int retval; /* Get the local IP and port information */ retval = getsockname(fd, (struct sockaddr *) &local, &local_len); if (retval) { memset(&local, 0, sizeof local); } retval = setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &on, sizeof on); if (retval) { int error = sock_errno(); VLOG_ERR("%s: setsockopt(TCP_NODELAY): %s", name, sock_strerror(error)); closesocket(fd); return error; } return new_fd_stream(name, fd, connect_status, streamp); } static int tcp_open(const char *name, char *suffix, struct stream **streamp, uint8_t dscp) { int fd, error; error = inet_open_active(SOCK_STREAM, suffix, 0, NULL, &fd, dscp); if (fd >= 0) { return new_tcp_stream(name, fd, error, streamp); } else { VLOG_ERR("%s: connect: %s", name, ovs_strerror(error)); return error; } } const struct stream_class tcp_stream_class = { "tcp", /* name */ true, /* needs_probes */ tcp_open, /* open */ NULL, /* close */ NULL, /* connect */ NULL, /* recv */ NULL, /* send */ NULL, /* run */ NULL, /* run_wait */ NULL, /* wait */ }; /* Passive TCP. */ static int ptcp_accept(int fd, const struct sockaddr_storage *, size_t, struct stream **streamp); static int ptcp_open(const char *name OVS_UNUSED, char *suffix, struct pstream **pstreamp, uint8_t dscp) { char bound_name[SS_NTOP_BUFSIZE + 16]; char addrbuf[SS_NTOP_BUFSIZE]; struct sockaddr_storage ss; uint16_t port; int error; int fd; fd = inet_open_passive(SOCK_STREAM, suffix, -1, &ss, dscp); if (fd < 0) { return -fd; } port = ss_get_port(&ss); snprintf(bound_name, sizeof bound_name, "ptcp:%"PRIu16":%s", port, ss_format_address(&ss, addrbuf, sizeof addrbuf)); error = new_fd_pstream(bound_name, fd, ptcp_accept, set_dscp, NULL, pstreamp); if (!error) { pstream_set_bound_port(*pstreamp, htons(port)); } return error; } static int ptcp_accept(int fd, const struct sockaddr_storage *ss, size_t ss_len OVS_UNUSED, struct stream **streamp) { char name[SS_NTOP_BUFSIZE + 16]; char addrbuf[SS_NTOP_BUFSIZE]; snprintf(name, sizeof name, "tcp:%s:%"PRIu16, ss_format_address(ss, addrbuf, sizeof addrbuf), ss_get_port(ss)); return new_tcp_stream(name, fd, 0, streamp); } const struct pstream_class ptcp_pstream_class = { "ptcp", true, ptcp_open, NULL, NULL, NULL, NULL, };