Module Name: src
Committed By: christos
Date: Mon Jul 6 18:45:26 UTC 2020
Modified Files:
src/tests/net/net: Makefile
Added Files:
src/tests/net/net: t_mapped.c
Log Message:
add a test for v4 mapped addresses
To generate a diff of this commit:
cvs rdiff -u -r1.23 -r1.24 src/tests/net/net/Makefile
cvs rdiff -u -r0 -r1.1 src/tests/net/net/t_mapped.c
Please note that diffs are not public domain; they are subject to the
copyright notices on the relevant files.
Modified files:
Index: src/tests/net/net/Makefile
diff -u src/tests/net/net/Makefile:1.23 src/tests/net/net/Makefile:1.24
--- src/tests/net/net/Makefile:1.23 Sun Mar 1 13:08:16 2020
+++ src/tests/net/net/Makefile Mon Jul 6 14:45:25 2020
@@ -1,4 +1,4 @@
-# $NetBSD: Makefile,v 1.23 2020/03/01 18:08:16 christos Exp $
+# $NetBSD: Makefile,v 1.24 2020/07/06 18:45:25 christos Exp $
#
.include <bsd.own.mk>
@@ -6,6 +6,7 @@
TESTSDIR= ${TESTSBASE}/net/net
TESTS_C= t_unix
+TESTS_C+= t_mapped
TESTS_C+= t_tcp
TESTS_C+= t_udp
TESTS_C+= t_pktinfo
@@ -26,4 +27,6 @@ LDADD.t_pktinfo_send+= ${LIBRUMPBASE}
LDADD.t_raw+= -lrumpnet_local -lrumpnet_netinet -lrumpnet_net
LDADD.t_raw+= -lrumpnet ${LIBRUMPBASE}
+LDADD.t_mapped+= -lutil
+
.include <bsd.test.mk>
Added files:
Index: src/tests/net/net/t_mapped.c
diff -u /dev/null src/tests/net/net/t_mapped.c:1.1
--- /dev/null Mon Jul 6 14:45:26 2020
+++ src/tests/net/net/t_mapped.c Mon Jul 6 14:45:25 2020
@@ -0,0 +1,320 @@
+/* $NetBSD: t_mapped.c,v 1.1 2020/07/06 18:45:25 christos Exp $ */
+
+/*-
+ * Copyright (c) 2020 The NetBSD Foundation, Inc.
+ * All rights reserved.
+ *
+ * This code is derived from software contributed to The NetBSD Foundation
+ * by Christos Zoulas.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
+ * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
+ * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
+ * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#define _GNU_SOURCE
+
+#include <sys/cdefs.h>
+#ifdef __RCSID
+__RCSID("$Id: t_mapped.c,v 1.1 2020/07/06 18:45:25 christos Exp $");
+#endif
+
+#include <sys/param.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/wait.h>
+#include <netinet/in.h>
+#include <stdio.h>
+#include <string.h>
+#include <sched.h>
+#include <stdbool.h>
+#include <unistd.h>
+#include <time.h>
+#include <fcntl.h>
+#include <errno.h>
+#include <err.h>
+#include <stdlib.h>
+#include <signal.h>
+#include "util.h"
+
+#include "test.h"
+
+static char mymsg[] = "hi mom!";
+
+static void
+print(const char *msg, const struct sockaddr *addr)
+{
+ char buf[1024];
+
+ sockaddr_snprintf(buf, sizeof(buf), "%a:%p", addr);
+ printf("%s: %s\n", msg, buf);
+}
+
+static int
+mksocket(int sfam)
+{
+ int fd = socket(sfam, SOCK_STREAM, 0);
+ if (fd == -1)
+ FAIL("socket");
+ if (sfam != AF_INET6)
+ return fd;
+ int f = 0;
+#if 0
+ /* crashes the kernel, should not be allowed kernel only? */
+ if (setsockopt(fd, IPPROTO_IPV6, 24 /* IPV6_2292RTHDR */,
+ &f, sizeof(f)) == -1)
+ FAIL("setsockopt");
+#endif
+ if (setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &f, sizeof(f)) == -1)
+ FAIL("setsockopt");
+ return fd;
+fail:
+ return -1;
+}
+
+static socklen_t
+mkserver(int sfam, struct sockaddr_storage *ss)
+{
+ struct sockaddr_in *sin;
+ struct sockaddr_in6 *sin6;
+
+ memset(ss, 0, sizeof(*ss));
+ ss->ss_family = sfam;
+ switch (sfam) {
+ case AF_INET:
+ sin = (struct sockaddr_in *)ss;
+ sin->sin_port = htons(12345);
+#ifdef BSD4_4
+ sin->sin_len = sizeof(*sin);
+#endif
+ return sizeof(*sin);
+ case AF_INET6:
+ sin6 = (struct sockaddr_in6 *)ss;
+ sin6->sin6_port = htons(12345);
+#ifdef BSD4_4
+ sin6->sin6_len = sizeof(*sin6);
+#endif
+ return sizeof(*sin6);
+ default:
+ FAIL("bad family");
+ }
+fail:
+ return -1;
+}
+
+#if 0
+static const struct in6_addr in6addr_loopback = IN6ADDR_LOOPBACK_INIT;
+#endif
+static socklen_t
+mkclient(int sfam, struct sockaddr_storage *ss)
+{
+ struct sockaddr_in *sin;
+ struct sockaddr_in6 *sin6;
+
+ memset(ss, 0, sizeof(*ss));
+ ss->ss_family = sfam;
+ switch (sfam) {
+ case AF_INET:
+ sin = (struct sockaddr_in *)ss;
+ sin->sin_port = htons(12345);
+#ifdef BSD4_4
+ sin->sin_len = sizeof(*sin);
+#endif
+ sin->sin_addr.s_addr = htonl(INADDR_LOOPBACK);
+ return sizeof(*sin);
+ case AF_INET6:
+ sin6 = (struct sockaddr_in6 *)ss;
+ sin6->sin6_port = htons(12345);
+#ifdef BSD4_4
+ sin6->sin6_len = sizeof(*sin6);
+#endif
+#if 1
+ sin6->sin6_addr = in6addr_loopback;
+#else
+ struct in6_addr *a = &sin6->sin6_addr;
+ a->__u6_addr.__u6_addr32[0] == 0;
+ a->__u6_addr.__u6_addr32[1] == 0;
+ a->__u6_addr.__u6_addr32[2] == ntohl(0x0000ffff);
+ a->__u6_addr.__u6_addr32[3] == ntohl(INADDR_LOOPBACK);
+#endif
+ return sizeof(*sin6);
+ default:
+ FAIL("bad family");
+ }
+fail:
+ return -1;
+}
+
+static int
+test(int forkit, int sfam, int cfam)
+{
+ int sfd = -1, cfd = -1, afd = -1;
+ pid_t sfdpid, cfdpid;
+ struct sockaddr_storage saddr, caddr, paddr;
+ socklen_t slen, clen, plen;
+
+ sfdpid = cfdpid = getpid();
+
+ sfd = mksocket(sfam);
+ slen = mkserver(sfam, &saddr);
+
+ if (bind(sfd, (struct sockaddr *)&saddr, slen) == -1) {
+ FAIL("bind");
+ }
+
+ if (listen(sfd, SOMAXCONN) == -1)
+ FAIL("listen");
+
+ if (forkit) {
+ switch (cfdpid = fork()) {
+ case 0: /* child */
+ sfdpid = getppid();
+ cfdpid = getpid();
+ break;
+ case -1:
+ FAIL("fork");
+ default:
+ break;
+ }
+ }
+
+ if (cfdpid == getpid()) {
+ cfd = mksocket(cfam);
+ clen = mkclient(cfam, &caddr);
+
+ if (connect(cfd, (const struct sockaddr *)&caddr, clen) == -1)
+ FAIL("connect");
+ }
+
+ if (sfdpid == getpid()) {
+ plen = sizeof(paddr);
+ afd = accept(sfd, (struct sockaddr *)&paddr, &plen);
+ if (afd == -1)
+ FAIL("accept");
+
+ print("peer", (const struct sockaddr *)&paddr);
+ }
+
+ if (cfdpid == getpid()) {
+ if (write(cfd, mymsg, sizeof(mymsg)) != sizeof(mymsg))
+ FAIL("write");
+ (void)close(cfd);
+ }
+
+ if (sfdpid == getpid()) {
+ char buf[1024];
+ if (read(afd, buf, sizeof(mymsg)) != sizeof(mymsg))
+ FAIL("write");
+
+ if (strcmp(buf, mymsg) != 0)
+ FAIL("compare");
+
+ (void)close(afd);
+ (void)close(sfd);
+ if (forkit && waitpid(cfdpid, NULL, 0) == -1)
+ FAIL("waitpid");
+ }
+ (void)close(cfd);
+
+ return 0;
+fail:
+ if (sfdpid == getpid()) {
+ (void)close(afd);
+ (void)close(sfd);
+ }
+ if (cfdpid == getpid()) {
+ (void)close(cfd);
+ }
+ return -1;
+}
+
+#ifndef TEST
+
+ATF_TC(mapped_4_4);
+ATF_TC_HEAD(mapped_4_4, tc)
+{
+
+ atf_tc_set_md_var(tc, "descr", "Check AF_INET <- AF_INET connections");
+}
+
+ATF_TC_BODY(mapped_4_4, tc)
+{
+ test(0, AF_INET, AF_INET);
+}
+
+ATF_TC(mapped_6_4);
+ATF_TC_HEAD(mapped_6_4, tc)
+{
+
+ atf_tc_set_md_var(tc, "descr", "Check AF_INET6 <- AF_INET connections");
+}
+
+ATF_TC_BODY(mapped_6_4, tc)
+{
+ test(0, AF_INET6, AF_INET);
+}
+
+#if 0
+ATF_TC(mapped_4_6);
+ATF_TC_HEAD(mapped_4_6, tc)
+{
+
+ atf_tc_set_md_var(tc, "descr", "Check AF_INET <- AF_INET6 connections");
+}
+
+ATF_TC_BODY(mapped_4_6, tc)
+{
+ test(0, AF_INET, AF_INET6);
+}
+#endif
+
+ATF_TC(mapped_6_6);
+ATF_TC_HEAD(mapped_6_6, tc)
+{
+
+ atf_tc_set_md_var(tc, "descr", "Check AF_INET6 <- AF_INET6 connections");
+}
+
+ATF_TC_BODY(mapped_6_6, tc)
+{
+ test(0, AF_INET6, AF_INET6);
+}
+
+ATF_TP_ADD_TCS(tp)
+{
+
+ ATF_TP_ADD_TC(tp, mapped_4_4);
+#if 0
+ ATF_TP_ADD_TC(tp, mapped_4_6);
+#endif
+ ATF_TP_ADD_TC(tp, mapped_6_4);
+ ATF_TP_ADD_TC(tp, mapped_6_6);
+ return atf_no_error();
+}
+#else
+int
+main(int argc, char *argv[])
+{
+ test(0, AF_INET, AF_INET);
+// test(0, AF_INET, AF_INET6);
+ test(0, AF_INET6, AF_INET);
+ test(0, AF_INET6, AF_INET6);
+}
+#endif
