Author: tuexen
Date: Mon Jul 30 21:27:26 2018
New Revision: 336940
URL: https://svnweb.freebsd.org/changeset/base/336940

Log:
  Allow implicit TCP connection setup for TCP/IPv6.
  
  TCP/IPv4 allows an implicit connection setup using sendto(), which
  is used for TTCP and TCP fast open. This patch adds support for
  TCP/IPv6.
  While there, improve some tests for detecting multicast addresses,
  which are mapped.
  
  Reviewed by:          bz@, kbowling@, rrs@
  Sponsored by:         Netflix, Inc.
  Differential Revision:        https://reviews.freebsd.org/D16458

Modified:
  head/sys/netinet/tcp_usrreq.c
  head/sys/netinet6/in6_proto.c

Modified: head/sys/netinet/tcp_usrreq.c
==============================================================================
--- head/sys/netinet/tcp_usrreq.c       Mon Jul 30 21:25:45 2018        
(r336939)
+++ head/sys/netinet/tcp_usrreq.c       Mon Jul 30 21:27:26 2018        
(r336940)
@@ -378,6 +378,11 @@ tcp6_usr_bind(struct socket *so, struct sockaddr *nam,
                        struct sockaddr_in sin;
 
                        in6_sin6_2_sin(&sin, sin6p);
+                       if (IN_MULTICAST(ntohl(sin.sin_addr.s_addr))) {
+                               error = EAFNOSUPPORT;
+                               INP_HASH_WUNLOCK(&V_tcbinfo);
+                               goto out;
+                       }
                        inp->inp_vflag |= INP_IPV4;
                        inp->inp_vflag &= ~INP_IPV6;
                        error = in_pcbbind(inp, (struct sockaddr *)&sin,
@@ -607,6 +612,10 @@ tcp6_usr_connect(struct socket *so, struct sockaddr *n
                }
 
                in6_sin6_2_sin(&sin, sin6p);
+               if (IN_MULTICAST(ntohl(sin.sin_addr.s_addr))) {
+                       error = EAFNOSUPPORT;
+                       goto out;
+               }
                inp->inp_vflag |= INP_IPV4;
                inp->inp_vflag &= ~INP_IPV6;
                if ((error = prison_remote_ip4(td->td_ucred,
@@ -892,6 +901,9 @@ tcp_usr_send(struct socket *so, int flags, struct mbuf
        struct inpcb *inp;
        struct tcpcb *tp = NULL;
        struct epoch_tracker net_et;
+#ifdef INET
+       struct sockaddr_in sin, *sinp;
+#endif
 #ifdef INET6
        int isipv6;
 #endif
@@ -918,11 +930,124 @@ tcp_usr_send(struct socket *so, int flags, struct mbuf
                error = ECONNRESET;
                goto out;
        }
-#ifdef INET6
-       isipv6 = nam && nam->sa_family == AF_INET6;
-#endif /* INET6 */
        tp = intotcpcb(inp);
        TCPDEBUG1();
+       if (nam != NULL && tp->t_state < TCPS_SYN_SENT) {
+               switch (nam->sa_family) {
+#ifdef INET
+               case AF_INET:
+                       sinp = (struct sockaddr_in *)nam;
+                       if (sinp->sin_len != sizeof(struct sockaddr_in)) {
+                               if (m)
+                                       m_freem(m);
+                               error = EINVAL;
+                               goto out;
+                       }
+                       if ((inp->inp_vflag & INP_IPV6) != 0) {
+                               if (m)
+                                       m_freem(m);
+                               error = EAFNOSUPPORT;
+                               goto out;
+                       }
+                       if (IN_MULTICAST(ntohl(sinp->sin_addr.s_addr))) {
+                               if (m)
+                                       m_freem(m);
+                               error = EAFNOSUPPORT;
+                               goto out;
+                       }
+                       if ((error = prison_remote_ip4(td->td_ucred,
+                           &sinp->sin_addr))) {
+                               if (m)
+                                       m_freem(m);
+                               goto out;
+                       }
+#ifdef INET6
+                       isipv6 = 0;
+#endif
+                       break;
+#endif /* INET */
+#ifdef INET6
+               case AF_INET6:
+               {
+                       struct sockaddr_in6 *sin6p;
+
+                       sin6p = (struct sockaddr_in6 *)nam;
+                       if (sin6p->sin6_len != sizeof(struct sockaddr_in6)) {
+                               if (m)
+                                       m_freem(m);
+                               error = EINVAL;
+                               goto out;
+                       }
+                       if (IN6_IS_ADDR_MULTICAST(&sin6p->sin6_addr)) {
+                               if (m)
+                                       m_freem(m);
+                               error = EAFNOSUPPORT;
+                               goto out;
+                       }
+                       if (IN6_IS_ADDR_V4MAPPED(&sin6p->sin6_addr)) {
+#ifdef INET
+                               if ((inp->inp_flags & IN6P_IPV6_V6ONLY) != 0) {
+                                       error = EINVAL;
+                                       if (m)
+                                               m_freem(m);
+                                       goto out;
+                               }
+                               if ((inp->inp_vflag & INP_IPV4) == 0) {
+                                       error = EAFNOSUPPORT;
+                                       if (m)
+                                               m_freem(m);
+                                       goto out;
+                               }
+                               inp->inp_vflag &= ~INP_IPV6;
+                               sinp = &sin;
+                               in6_sin6_2_sin(sinp, sin6p);
+                               if (IN_MULTICAST(
+                                   ntohl(sinp->sin_addr.s_addr))) {
+                                       error = EAFNOSUPPORT;
+                                       if (m)
+                                               m_freem(m);
+                                       goto out;
+                               }
+                               if ((error = prison_remote_ip4(td->td_ucred,
+                                   &sinp->sin_addr))) {
+                                       if (m)
+                                               m_freem(m);
+                                       goto out;
+                               }
+                               isipv6 = 0;
+#else /* !INET */
+                               error = EAFNOSUPPORT;
+                               if (m)
+                                       m_freem(m);
+                               goto out;
+#endif /* INET */
+                       } else {
+                               if ((inp->inp_vflag & INP_IPV6) == 0) {
+                                       if (m)
+                                               m_freem(m);
+                                       error = EAFNOSUPPORT;
+                                       goto out;
+                               }
+                               inp->inp_vflag &= ~INP_IPV4;
+                               inp->inp_inc.inc_flags |= INC_ISIPV6;
+                               if ((error = prison_remote_ip6(td->td_ucred,
+                                   &sin6p->sin6_addr))) {
+                                       if (m)
+                                               m_freem(m);
+                                       goto out;
+                               }
+                               isipv6 = 1;
+                       }
+                       break;
+               }
+#endif /* INET6 */
+               default:
+                       if (m)
+                               m_freem(m);
+                       error = EAFNOSUPPORT;
+                       goto out;
+               }
+       }
        if (control) {
                /* TCP doesn't do control messages (rights, creds, etc) */
                if (control->m_len) {
@@ -950,7 +1075,8 @@ tcp_usr_send(struct socket *so, int flags, struct mbuf
                        else
 #endif
 #ifdef INET
-                               error = tcp_connect(tp, nam, td);
+                               error = tcp_connect(tp,
+                                   (struct sockaddr *)sinp, td);
 #endif
                        if (error)
                                goto out;
@@ -1019,7 +1145,8 @@ tcp_usr_send(struct socket *so, int flags, struct mbuf
                        else
 #endif
 #ifdef INET
-                               error = tcp_connect(tp, nam, td);
+                               error = tcp_connect(tp,
+                                   (struct sockaddr *)sinp, td);
 #endif
                        if (error)
                                goto out;

Modified: head/sys/netinet6/in6_proto.c
==============================================================================
--- head/sys/netinet6/in6_proto.c       Mon Jul 30 21:25:45 2018        
(r336939)
+++ head/sys/netinet6/in6_proto.c       Mon Jul 30 21:27:26 2018        
(r336940)
@@ -171,7 +171,7 @@ struct protosw inet6sw[] = {
        .pr_type =              SOCK_STREAM,
        .pr_domain =            &inet6domain,
        .pr_protocol =          IPPROTO_TCP,
-       .pr_flags =             PR_CONNREQUIRED|PR_WANTRCVD|PR_LISTEN,
+       .pr_flags =             
PR_CONNREQUIRED|PR_IMPLOPCL|PR_WANTRCVD|PR_LISTEN,
        .pr_input =             tcp6_input,
        .pr_ctlinput =          tcp6_ctlinput,
        .pr_ctloutput =         tcp_ctloutput,
_______________________________________________
svn-src-head@freebsd.org mailing list
https://lists.freebsd.org/mailman/listinfo/svn-src-head
To unsubscribe, send any mail to "svn-src-head-unsubscr...@freebsd.org"

Reply via email to