xref: /netbsd-src/sys/netmpls/mpls_proto.c (revision f89f6560d453f5e37386cc7938c072d2f528b9fa)
1 /*	$NetBSD: mpls_proto.c,v 1.25 2015/04/03 20:01:07 rtr Exp $ */
2 
3 /*
4  * Copyright (c) 2010 The NetBSD Foundation, Inc.
5  * All rights reserved.
6  *
7  * This code is derived from software contributed to The NetBSD Foundation
8  * by Mihai Chelaru <kefren@NetBSD.org>
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 #include <sys/cdefs.h>
33 __KERNEL_RCSID(0, "$NetBSD: mpls_proto.c,v 1.25 2015/04/03 20:01:07 rtr Exp $");
34 
35 #include "opt_inet.h"
36 #include "opt_mbuftrace.h"
37 
38 #include <sys/param.h>
39 #include <sys/socket.h>
40 #include <sys/protosw.h>
41 #include <sys/domain.h>
42 #include <sys/socketvar.h>
43 #include <sys/sysctl.h>
44 
45 #include <net/route.h>
46 
47 #include <netmpls/mpls.h>
48 #include <netmpls/mpls_var.h>
49 
50 struct ifqueue mplsintrq;
51 
52 static int mpls_attach(struct socket *, int);
53 static void sysctl_net_mpls_setup(struct sysctllog **);
54 
55 #ifdef MBUFTRACE
56 struct mowner mpls_owner = MOWNER_INIT("MPLS", "");
57 #endif
58 
59 int mpls_defttl = 255;
60 int mpls_mapttl_inet = 1;
61 int mpls_mapttl_inet6 = 1;
62 int mpls_icmp_respond = 0;
63 int mpls_forwarding = 0;
64 int mpls_frame_accept = 0;
65 int mpls_mapprec_inet = 1;
66 int mpls_mapclass_inet6 = 1;
67 int mpls_rfc4182 = 1;
68 
69 void mpls_init(void)
70 {
71 #ifdef MBUFTRACE
72 	MOWNER_ATTACH(&mpls_owner);
73 #endif
74 	memset(&mplsintrq, 0, sizeof(mplsintrq));
75 	mplsintrq.ifq_maxlen = 256;
76 
77 	sysctl_net_mpls_setup(NULL);
78 }
79 
80 static int
81 mpls_attach(struct socket *so, int proto)
82 {
83 	int error = EOPNOTSUPP;
84 
85 	sosetlock(so);
86 	if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
87 		error = soreserve(so, 8192, 8192);
88 	}
89 	return error;
90 }
91 
92 static void
93 mpls_detach(struct socket *so)
94 {
95 }
96 
97 static int
98 mpls_accept(struct socket *so, struct mbuf *nam)
99 {
100 	KASSERT(solocked(so));
101 
102 	return EOPNOTSUPP;
103 }
104 
105 static int
106 mpls_bind(struct socket *so, struct sockaddr *nam, struct lwp *l)
107 {
108 	KASSERT(solocked(so));
109 
110 	return EOPNOTSUPP;
111 }
112 
113 static int
114 mpls_listen(struct socket *so, struct lwp *l)
115 {
116 	KASSERT(solocked(so));
117 
118 	return EOPNOTSUPP;
119 }
120 
121 static int
122 mpls_connect(struct socket *so, struct mbuf *nam, struct lwp *l)
123 {
124 	KASSERT(solocked(so));
125 
126 	return EOPNOTSUPP;
127 }
128 
129 static int
130 mpls_connect2(struct socket *so, struct socket *so2)
131 {
132 	KASSERT(solocked(so));
133 
134 	return EOPNOTSUPP;
135 }
136 
137 static int
138 mpls_disconnect(struct socket *so)
139 {
140 	KASSERT(solocked(so));
141 
142 	return EOPNOTSUPP;
143 }
144 
145 static int
146 mpls_shutdown(struct socket *so)
147 {
148 	KASSERT(solocked(so));
149 
150 	return EOPNOTSUPP;
151 }
152 
153 static int
154 mpls_abort(struct socket *so)
155 {
156 	KASSERT(solocked(so));
157 
158 	return EOPNOTSUPP;
159 }
160 
161 static int
162 mpls_ioctl(struct socket *so, u_long cmd, void *nam, struct ifnet *ifp)
163 {
164 	return EOPNOTSUPP;
165 }
166 
167 static int
168 mpls_stat(struct socket *so, struct stat *ub)
169 {
170 	KASSERT(solocked(so));
171 
172 	return EOPNOTSUPP;
173 }
174 
175 static int
176 mpls_peeraddr(struct socket *so, struct mbuf *nam)
177 {
178 	KASSERT(solocked(so));
179 
180 	return EOPNOTSUPP;
181 }
182 
183 static int
184 mpls_sockaddr(struct socket *so, struct mbuf *nam)
185 {
186 	KASSERT(solocked(so));
187 
188 	return EOPNOTSUPP;
189 }
190 
191 static int
192 mpls_rcvd(struct socket *so, int flags, struct lwp *l)
193 {
194 	KASSERT(solocked(so));
195 
196 	return EOPNOTSUPP;
197 }
198 
199 static int
200 mpls_recvoob(struct socket *so, struct mbuf *m, int flags)
201 {
202 	KASSERT(solocked(so));
203 
204 	return EOPNOTSUPP;
205 }
206 
207 static int
208 mpls_send(struct socket *so, struct mbuf *m, struct mbuf *nam,
209     struct mbuf *control, struct lwp *l)
210 {
211 	KASSERT(solocked(so));
212 
213 	return EOPNOTSUPP;
214 }
215 
216 static int
217 mpls_sendoob(struct socket *so, struct mbuf *m, struct mbuf *control)
218 {
219 	KASSERT(solocked(so));
220 
221 	return EOPNOTSUPP;
222 }
223 
224 static int
225 mpls_purgeif(struct socket *so, struct ifnet *ifp)
226 {
227 
228 	return EOPNOTSUPP;
229 }
230 
231 static int
232 mpls_usrreq(struct socket *so, int req, struct mbuf *m,
233     struct mbuf *nam, struct mbuf *control, struct lwp *l)
234 {
235 	KASSERT(req != PRU_ATTACH);
236 	KASSERT(req != PRU_DETACH);
237 	KASSERT(req != PRU_ACCEPT);
238 	KASSERT(req != PRU_BIND);
239 	KASSERT(req != PRU_LISTEN);
240 	KASSERT(req != PRU_CONNECT);
241 	KASSERT(req != PRU_CONNECT2);
242 	KASSERT(req != PRU_DISCONNECT);
243 	KASSERT(req != PRU_SHUTDOWN);
244 	KASSERT(req != PRU_ABORT);
245 	KASSERT(req != PRU_CONTROL);
246 	KASSERT(req != PRU_SENSE);
247 	KASSERT(req != PRU_PEERADDR);
248 	KASSERT(req != PRU_SOCKADDR);
249 	KASSERT(req != PRU_RCVD);
250 	KASSERT(req != PRU_RCVOOB);
251 	KASSERT(req != PRU_SEND);
252 	KASSERT(req != PRU_SENDOOB);
253 	KASSERT(req != PRU_PURGEIF);
254 
255 	return EOPNOTSUPP;
256 }
257 
258 /*
259  * Sysctl for MPLS variables.
260  */
261 static void
262 sysctl_net_mpls_setup(struct sysctllog **clog)
263 {
264 
265         sysctl_createv(clog, 0, NULL, NULL,
266                        CTLFLAG_PERMANENT,
267                        CTLTYPE_NODE, "mpls", NULL,
268                        NULL, 0, NULL, 0,
269                        CTL_NET, PF_MPLS, CTL_EOL);
270 
271         sysctl_createv(clog, 0, NULL, NULL,
272                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
273                        CTLTYPE_INT, "ttl",
274                        SYSCTL_DESCR("Default TTL"),
275                        NULL, 0, &mpls_defttl, 0,
276                        CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
277 	sysctl_createv(clog, 0, NULL, NULL,
278 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
279 		       CTLTYPE_INT, "forwarding",
280 		       SYSCTL_DESCR("MPLS forwarding"),
281 		       NULL, 0, &mpls_forwarding, 0,
282 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
283 	sysctl_createv(clog, 0, NULL, NULL,
284 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
285 		       CTLTYPE_INT, "accept",
286 		       SYSCTL_DESCR("Accept MPLS Frames"),
287 		       NULL, 0, &mpls_frame_accept, 0,
288 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
289 	sysctl_createv(clog, 0, NULL, NULL,
290 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
291 		       CTLTYPE_INT, "ifq_len",
292 		       SYSCTL_DESCR("MPLS queue length"),
293 		       NULL, 0, &mplsintrq.ifq_maxlen, 0,
294 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
295 	sysctl_createv(clog, 0, NULL, NULL,
296 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
297 		       CTLTYPE_INT, "rfc4182",
298 		       SYSCTL_DESCR("RFC 4182 conformance"),
299 		       NULL, 0, &mpls_rfc4182, 0,
300 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
301 #ifdef INET
302 	sysctl_createv(clog, 0, NULL, NULL,
303 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
304 		       CTLTYPE_INT, "inet_mapttl",
305 		       SYSCTL_DESCR("Map IP TTL"),
306 		       NULL, 0, &mpls_mapttl_inet, 0,
307 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
308 	sysctl_createv(clog, 0, NULL, NULL,
309 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
310 		       CTLTYPE_INT, "inet_map_prec",
311 		       SYSCTL_DESCR("Map IP Prec"),
312 		       NULL, 0, &mpls_mapprec_inet, 0,
313 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
314 	sysctl_createv(clog, 0, NULL, NULL,
315 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
316 		       CTLTYPE_INT, "icmp_respond",
317 		       SYSCTL_DESCR("Emit ICMP packets on errors"),
318 		       NULL, 0, &mpls_icmp_respond, 0,
319 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
320 #endif
321 #ifdef INET6
322 	sysctl_createv(clog, 0, NULL, NULL,
323 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
324 		       CTLTYPE_INT, "inet6_mapttl",
325 		       SYSCTL_DESCR("Map IP6 TTL"),
326 		       NULL, 0, &mpls_mapttl_inet6, 0,
327 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
328 	sysctl_createv(clog, 0, NULL, NULL,
329 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
330 		       CTLTYPE_INT, "inet6_map_prec",
331 		       SYSCTL_DESCR("Map IP6 class"),
332 		       NULL, 0, &mpls_mapclass_inet6, 0,
333 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
334 #endif
335 }
336 
337 DOMAIN_DEFINE(mplsdomain);
338 
339 PR_WRAP_USRREQS(mpls)
340 #define	mpls_attach	mpls_attach_wrapper
341 #define	mpls_detach	mpls_detach_wrapper
342 #define	mpls_accept	mpls_accept_wrapper
343 #define	mpls_bind	mpls_bind_wrapper
344 #define	mpls_listen	mpls_listen_wrapper
345 #define	mpls_connect	mpls_connect_wrapper
346 #define	mpls_connect2	mpls_connect2_wrapper
347 #define	mpls_disconnect	mpls_disconnect_wrapper
348 #define	mpls_shutdown	mpls_shutdown_wrapper
349 #define	mpls_abort	mpls_abort_wrapper
350 #define	mpls_ioctl	mpls_ioctl_wrapper
351 #define	mpls_stat	mpls_stat_wrapper
352 #define	mpls_peeraddr	mpls_peeraddr_wrapper
353 #define	mpls_sockaddr	mpls_sockaddr_wrapper
354 #define	mpls_rcvd	mpls_rcvd_wrapper
355 #define	mpls_recvoob	mpls_recvoob_wrapper
356 #define	mpls_send	mpls_send_wrapper
357 #define	mpls_sendoob	mpls_sendoob_wrapper
358 #define	mpls_purgeif	mpls_purgeif_wrapper
359 #define	mpls_usrreq	mpls_usrreq_wrapper
360 
361 static const struct pr_usrreqs mpls_usrreqs = {
362 	.pr_attach	= mpls_attach,
363 	.pr_detach	= mpls_detach,
364 	.pr_accept	= mpls_accept,
365 	.pr_bind	= mpls_bind,
366 	.pr_listen	= mpls_listen,
367 	.pr_connect	= mpls_connect,
368 	.pr_connect2	= mpls_connect2,
369 	.pr_disconnect	= mpls_disconnect,
370 	.pr_shutdown	= mpls_shutdown,
371 	.pr_abort	= mpls_abort,
372 	.pr_ioctl	= mpls_ioctl,
373 	.pr_stat	= mpls_stat,
374 	.pr_peeraddr	= mpls_peeraddr,
375 	.pr_sockaddr	= mpls_sockaddr,
376 	.pr_rcvd	= mpls_rcvd,
377 	.pr_recvoob	= mpls_recvoob,
378 	.pr_send	= mpls_send,
379 	.pr_sendoob	= mpls_sendoob,
380 	.pr_purgeif	= mpls_purgeif,
381 	.pr_generic	= mpls_usrreq,
382 };
383 
384 const struct protosw mplssw[] = {
385 	{	.pr_domain = &mplsdomain,
386 		.pr_init = mpls_init,
387 	},
388 	{
389 		.pr_type = SOCK_DGRAM,
390 		.pr_domain = &mplsdomain,
391 		.pr_flags = PR_ATOMIC | PR_ADDR,
392 		.pr_usrreqs = &mpls_usrreqs,
393 	},
394 	{
395 		.pr_type = SOCK_RAW,
396 		.pr_domain = &mplsdomain,
397 		.pr_flags = PR_ATOMIC | PR_ADDR,
398 		.pr_usrreqs = &mpls_usrreqs,
399 	},
400 };
401 
402 struct domain mplsdomain = {
403 	.dom_family = PF_MPLS,
404 	.dom_name = "MPLS",
405 	.dom_init = NULL,
406 	.dom_externalize = NULL,
407 	.dom_dispose = NULL,
408 	.dom_protosw = mplssw,
409 	.dom_protoswNPROTOSW = &mplssw[__arraycount(mplssw)],
410 	.dom_rtattach = rt_inithead,
411 	.dom_rtoffset = offsetof(struct sockaddr_mpls, smpls_addr) << 3,
412 	.dom_maxrtkey = sizeof(union mpls_shim),
413 	.dom_ifattach = NULL,
414 	.dom_ifdetach = NULL,
415 	.dom_ifqueues = { &mplsintrq, NULL },
416 	.dom_link = { NULL },
417 	.dom_mowner = MOWNER_INIT("MPLS", ""),
418 	.dom_sa_cmpofs = offsetof(struct sockaddr_mpls, smpls_addr),
419 	.dom_sa_cmplen = sizeof(union mpls_shim),
420 	.dom_rtcache = LIST_HEAD_INITIALIZER(mplsdomain.dom_rtcache)
421 };
422