1 /* $NetBSD: t_mapped.c,v 1.1 2020/07/06 18:45:25 christos Exp $ */
2
3 /*-
4 * Copyright (c) 2020 The NetBSD Foundation, Inc.
5 * All rights reserved.
6 *
7 * This code is derived from software contributed to The NetBSD Foundation
8 * by Christos Zoulas.
9 *
10 * Redistribution and use in source and binary forms, with or without
11 * modification, are permitted provided that the following conditions
12 * are met:
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
18 *
19 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 * POSSIBILITY OF SUCH DAMAGE.
30 */
31
32 #define _GNU_SOURCE
33
34 #include <sys/cdefs.h>
35 #ifdef __RCSID
36 __RCSID("$Id: t_mapped.c,v 1.1 2020/07/06 18:45:25 christos Exp $");
37 #endif
38
39 #include <sys/param.h>
40 #include <sys/types.h>
41 #include <sys/socket.h>
42 #include <sys/wait.h>
43 #include <netinet/in.h>
44 #include <stdio.h>
45 #include <string.h>
46 #include <sched.h>
47 #include <stdbool.h>
48 #include <unistd.h>
49 #include <time.h>
50 #include <fcntl.h>
51 #include <errno.h>
52 #include <err.h>
53 #include <stdlib.h>
54 #include <signal.h>
55 #include "util.h"
56
57 #include "test.h"
58
59 static char mymsg[] = "hi mom!";
60
61 static void
print(const char * msg,const struct sockaddr * addr)62 print(const char *msg, const struct sockaddr *addr)
63 {
64 char buf[1024];
65
66 sockaddr_snprintf(buf, sizeof(buf), "%a:%p", addr);
67 printf("%s: %s\n", msg, buf);
68 }
69
70 static int
mksocket(int sfam)71 mksocket(int sfam)
72 {
73 int fd = socket(sfam, SOCK_STREAM, 0);
74 if (fd == -1)
75 FAIL("socket");
76 if (sfam != AF_INET6)
77 return fd;
78 int f = 0;
79 #if 0
80 /* crashes the kernel, should not be allowed kernel only? */
81 if (setsockopt(fd, IPPROTO_IPV6, 24 /* IPV6_2292RTHDR */,
82 &f, sizeof(f)) == -1)
83 FAIL("setsockopt");
84 #endif
85 if (setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &f, sizeof(f)) == -1)
86 FAIL("setsockopt");
87 return fd;
88 fail:
89 return -1;
90 }
91
92 static socklen_t
mkserver(int sfam,struct sockaddr_storage * ss)93 mkserver(int sfam, struct sockaddr_storage *ss)
94 {
95 struct sockaddr_in *sin;
96 struct sockaddr_in6 *sin6;
97
98 memset(ss, 0, sizeof(*ss));
99 ss->ss_family = sfam;
100 switch (sfam) {
101 case AF_INET:
102 sin = (struct sockaddr_in *)ss;
103 sin->sin_port = htons(12345);
104 #ifdef BSD4_4
105 sin->sin_len = sizeof(*sin);
106 #endif
107 return sizeof(*sin);
108 case AF_INET6:
109 sin6 = (struct sockaddr_in6 *)ss;
110 sin6->sin6_port = htons(12345);
111 #ifdef BSD4_4
112 sin6->sin6_len = sizeof(*sin6);
113 #endif
114 return sizeof(*sin6);
115 default:
116 FAIL("bad family");
117 }
118 fail:
119 return -1;
120 }
121
122 #if 0
123 static const struct in6_addr in6addr_loopback = IN6ADDR_LOOPBACK_INIT;
124 #endif
125 static socklen_t
mkclient(int sfam,struct sockaddr_storage * ss)126 mkclient(int sfam, struct sockaddr_storage *ss)
127 {
128 struct sockaddr_in *sin;
129 struct sockaddr_in6 *sin6;
130
131 memset(ss, 0, sizeof(*ss));
132 ss->ss_family = sfam;
133 switch (sfam) {
134 case AF_INET:
135 sin = (struct sockaddr_in *)ss;
136 sin->sin_port = htons(12345);
137 #ifdef BSD4_4
138 sin->sin_len = sizeof(*sin);
139 #endif
140 sin->sin_addr.s_addr = htonl(INADDR_LOOPBACK);
141 return sizeof(*sin);
142 case AF_INET6:
143 sin6 = (struct sockaddr_in6 *)ss;
144 sin6->sin6_port = htons(12345);
145 #ifdef BSD4_4
146 sin6->sin6_len = sizeof(*sin6);
147 #endif
148 #if 1
149 sin6->sin6_addr = in6addr_loopback;
150 #else
151 struct in6_addr *a = &sin6->sin6_addr;
152 a->__u6_addr.__u6_addr32[0] == 0;
153 a->__u6_addr.__u6_addr32[1] == 0;
154 a->__u6_addr.__u6_addr32[2] == ntohl(0x0000ffff);
155 a->__u6_addr.__u6_addr32[3] == ntohl(INADDR_LOOPBACK);
156 #endif
157 return sizeof(*sin6);
158 default:
159 FAIL("bad family");
160 }
161 fail:
162 return -1;
163 }
164
165 static int
test(int forkit,int sfam,int cfam)166 test(int forkit, int sfam, int cfam)
167 {
168 int sfd = -1, cfd = -1, afd = -1;
169 pid_t sfdpid, cfdpid;
170 struct sockaddr_storage saddr, caddr, paddr;
171 socklen_t slen, clen, plen;
172
173 sfdpid = cfdpid = getpid();
174
175 sfd = mksocket(sfam);
176 slen = mkserver(sfam, &saddr);
177
178 if (bind(sfd, (struct sockaddr *)&saddr, slen) == -1) {
179 FAIL("bind");
180 }
181
182 if (listen(sfd, SOMAXCONN) == -1)
183 FAIL("listen");
184
185 if (forkit) {
186 switch (cfdpid = fork()) {
187 case 0: /* child */
188 sfdpid = getppid();
189 cfdpid = getpid();
190 break;
191 case -1:
192 FAIL("fork");
193 default:
194 break;
195 }
196 }
197
198 if (cfdpid == getpid()) {
199 cfd = mksocket(cfam);
200 clen = mkclient(cfam, &caddr);
201
202 if (connect(cfd, (const struct sockaddr *)&caddr, clen) == -1)
203 FAIL("connect");
204 }
205
206 if (sfdpid == getpid()) {
207 plen = sizeof(paddr);
208 afd = accept(sfd, (struct sockaddr *)&paddr, &plen);
209 if (afd == -1)
210 FAIL("accept");
211
212 print("peer", (const struct sockaddr *)&paddr);
213 }
214
215 if (cfdpid == getpid()) {
216 if (write(cfd, mymsg, sizeof(mymsg)) != sizeof(mymsg))
217 FAIL("write");
218 (void)close(cfd);
219 }
220
221 if (sfdpid == getpid()) {
222 char buf[1024];
223 if (read(afd, buf, sizeof(mymsg)) != sizeof(mymsg))
224 FAIL("write");
225
226 if (strcmp(buf, mymsg) != 0)
227 FAIL("compare");
228
229 (void)close(afd);
230 (void)close(sfd);
231 if (forkit && waitpid(cfdpid, NULL, 0) == -1)
232 FAIL("waitpid");
233 }
234 (void)close(cfd);
235
236 return 0;
237 fail:
238 if (sfdpid == getpid()) {
239 (void)close(afd);
240 (void)close(sfd);
241 }
242 if (cfdpid == getpid()) {
243 (void)close(cfd);
244 }
245 return -1;
246 }
247
248 #ifndef TEST
249
250 ATF_TC(mapped_4_4);
ATF_TC_HEAD(mapped_4_4,tc)251 ATF_TC_HEAD(mapped_4_4, tc)
252 {
253
254 atf_tc_set_md_var(tc, "descr", "Check AF_INET <- AF_INET connections");
255 }
256
ATF_TC_BODY(mapped_4_4,tc)257 ATF_TC_BODY(mapped_4_4, tc)
258 {
259 test(0, AF_INET, AF_INET);
260 }
261
262 ATF_TC(mapped_6_4);
ATF_TC_HEAD(mapped_6_4,tc)263 ATF_TC_HEAD(mapped_6_4, tc)
264 {
265
266 atf_tc_set_md_var(tc, "descr", "Check AF_INET6 <- AF_INET connections");
267 }
268
ATF_TC_BODY(mapped_6_4,tc)269 ATF_TC_BODY(mapped_6_4, tc)
270 {
271 test(0, AF_INET6, AF_INET);
272 }
273
274 #if 0
275 ATF_TC(mapped_4_6);
276 ATF_TC_HEAD(mapped_4_6, tc)
277 {
278
279 atf_tc_set_md_var(tc, "descr", "Check AF_INET <- AF_INET6 connections");
280 }
281
282 ATF_TC_BODY(mapped_4_6, tc)
283 {
284 test(0, AF_INET, AF_INET6);
285 }
286 #endif
287
288 ATF_TC(mapped_6_6);
ATF_TC_HEAD(mapped_6_6,tc)289 ATF_TC_HEAD(mapped_6_6, tc)
290 {
291
292 atf_tc_set_md_var(tc, "descr", "Check AF_INET6 <- AF_INET6 connections");
293 }
294
ATF_TC_BODY(mapped_6_6,tc)295 ATF_TC_BODY(mapped_6_6, tc)
296 {
297 test(0, AF_INET6, AF_INET6);
298 }
299
ATF_TP_ADD_TCS(tp)300 ATF_TP_ADD_TCS(tp)
301 {
302
303 ATF_TP_ADD_TC(tp, mapped_4_4);
304 #if 0
305 ATF_TP_ADD_TC(tp, mapped_4_6);
306 #endif
307 ATF_TP_ADD_TC(tp, mapped_6_4);
308 ATF_TP_ADD_TC(tp, mapped_6_6);
309 return atf_no_error();
310 }
311 #else
312 int
main(int argc,char * argv[])313 main(int argc, char *argv[])
314 {
315 test(0, AF_INET, AF_INET);
316 // test(0, AF_INET, AF_INET6);
317 test(0, AF_INET6, AF_INET);
318 test(0, AF_INET6, AF_INET6);
319 }
320 #endif
321