Home | History | Annotate | Line # | Download | only in netmpls
mpls_proto.c revision 1.23
      1 /*	$NetBSD: mpls_proto.c,v 1.23 2014/08/08 03:05:45 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 (at) 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.23 2014/08/08 03:05:45 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 mbuf *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_disconnect(struct socket *so)
    131 {
    132 	KASSERT(solocked(so));
    133 
    134 	return EOPNOTSUPP;
    135 }
    136 
    137 static int
    138 mpls_shutdown(struct socket *so)
    139 {
    140 	KASSERT(solocked(so));
    141 
    142 	return EOPNOTSUPP;
    143 }
    144 
    145 static int
    146 mpls_abort(struct socket *so)
    147 {
    148 	KASSERT(solocked(so));
    149 
    150 	return EOPNOTSUPP;
    151 }
    152 
    153 static int
    154 mpls_ioctl(struct socket *so, u_long cmd, void *nam, struct ifnet *ifp)
    155 {
    156 	return EOPNOTSUPP;
    157 }
    158 
    159 static int
    160 mpls_stat(struct socket *so, struct stat *ub)
    161 {
    162 	KASSERT(solocked(so));
    163 
    164 	return EOPNOTSUPP;
    165 }
    166 
    167 static int
    168 mpls_peeraddr(struct socket *so, struct mbuf *nam)
    169 {
    170 	KASSERT(solocked(so));
    171 
    172 	return EOPNOTSUPP;
    173 }
    174 
    175 static int
    176 mpls_sockaddr(struct socket *so, struct mbuf *nam)
    177 {
    178 	KASSERT(solocked(so));
    179 
    180 	return EOPNOTSUPP;
    181 }
    182 
    183 static int
    184 mpls_rcvd(struct socket *so, int flags, struct lwp *l)
    185 {
    186 	KASSERT(solocked(so));
    187 
    188 	return EOPNOTSUPP;
    189 }
    190 
    191 static int
    192 mpls_recvoob(struct socket *so, struct mbuf *m, int flags)
    193 {
    194 	KASSERT(solocked(so));
    195 
    196 	return EOPNOTSUPP;
    197 }
    198 
    199 static int
    200 mpls_send(struct socket *so, struct mbuf *m, struct mbuf *nam,
    201     struct mbuf *control, struct lwp *l)
    202 {
    203 	KASSERT(solocked(so));
    204 
    205 	return EOPNOTSUPP;
    206 }
    207 
    208 static int
    209 mpls_sendoob(struct socket *so, struct mbuf *m, struct mbuf *control)
    210 {
    211 	KASSERT(solocked(so));
    212 
    213 	return EOPNOTSUPP;
    214 }
    215 
    216 static int
    217 mpls_usrreq(struct socket *so, int req, struct mbuf *m,
    218     struct mbuf *nam, struct mbuf *control, struct lwp *l)
    219 {
    220 
    221 	KASSERT(req != PRU_ATTACH);
    222 	KASSERT(req != PRU_DETACH);
    223 	KASSERT(req != PRU_ACCEPT);
    224 	KASSERT(req != PRU_BIND);
    225 	KASSERT(req != PRU_LISTEN);
    226 	KASSERT(req != PRU_CONNECT);
    227 	KASSERT(req != PRU_DISCONNECT);
    228 	KASSERT(req != PRU_SHUTDOWN);
    229 	KASSERT(req != PRU_ABORT);
    230 	KASSERT(req != PRU_CONTROL);
    231 	KASSERT(req != PRU_SENSE);
    232 	KASSERT(req != PRU_PEERADDR);
    233 	KASSERT(req != PRU_SOCKADDR);
    234 	KASSERT(req != PRU_RCVD);
    235 	KASSERT(req != PRU_RCVOOB);
    236 	KASSERT(req != PRU_SEND);
    237 	KASSERT(req != PRU_SENDOOB);
    238 
    239 	return EOPNOTSUPP;
    240 }
    241 
    242 /*
    243  * Sysctl for MPLS variables.
    244  */
    245 static void
    246 sysctl_net_mpls_setup(struct sysctllog **clog)
    247 {
    248 
    249         sysctl_createv(clog, 0, NULL, NULL,
    250                        CTLFLAG_PERMANENT,
    251                        CTLTYPE_NODE, "mpls", NULL,
    252                        NULL, 0, NULL, 0,
    253                        CTL_NET, PF_MPLS, CTL_EOL);
    254 
    255         sysctl_createv(clog, 0, NULL, NULL,
    256                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    257                        CTLTYPE_INT, "ttl",
    258                        SYSCTL_DESCR("Default TTL"),
    259                        NULL, 0, &mpls_defttl, 0,
    260                        CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    261 	sysctl_createv(clog, 0, NULL, NULL,
    262 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    263 		       CTLTYPE_INT, "forwarding",
    264 		       SYSCTL_DESCR("MPLS forwarding"),
    265 		       NULL, 0, &mpls_forwarding, 0,
    266 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    267 	sysctl_createv(clog, 0, NULL, NULL,
    268 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    269 		       CTLTYPE_INT, "accept",
    270 		       SYSCTL_DESCR("Accept MPLS Frames"),
    271 		       NULL, 0, &mpls_frame_accept, 0,
    272 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    273 	sysctl_createv(clog, 0, NULL, NULL,
    274 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    275 		       CTLTYPE_INT, "ifq_len",
    276 		       SYSCTL_DESCR("MPLS queue length"),
    277 		       NULL, 0, &mplsintrq.ifq_maxlen, 0,
    278 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    279 	sysctl_createv(clog, 0, NULL, NULL,
    280 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    281 		       CTLTYPE_INT, "rfc4182",
    282 		       SYSCTL_DESCR("RFC 4182 conformance"),
    283 		       NULL, 0, &mpls_rfc4182, 0,
    284 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    285 #ifdef INET
    286 	sysctl_createv(clog, 0, NULL, NULL,
    287 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    288 		       CTLTYPE_INT, "inet_mapttl",
    289 		       SYSCTL_DESCR("Map IP TTL"),
    290 		       NULL, 0, &mpls_mapttl_inet, 0,
    291 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    292 	sysctl_createv(clog, 0, NULL, NULL,
    293 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    294 		       CTLTYPE_INT, "inet_map_prec",
    295 		       SYSCTL_DESCR("Map IP Prec"),
    296 		       NULL, 0, &mpls_mapprec_inet, 0,
    297 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    298 	sysctl_createv(clog, 0, NULL, NULL,
    299 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    300 		       CTLTYPE_INT, "icmp_respond",
    301 		       SYSCTL_DESCR("Emit ICMP packets on errors"),
    302 		       NULL, 0, &mpls_icmp_respond, 0,
    303 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    304 #endif
    305 #ifdef INET6
    306 	sysctl_createv(clog, 0, NULL, NULL,
    307 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    308 		       CTLTYPE_INT, "inet6_mapttl",
    309 		       SYSCTL_DESCR("Map IP6 TTL"),
    310 		       NULL, 0, &mpls_mapttl_inet6, 0,
    311 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    312 	sysctl_createv(clog, 0, NULL, NULL,
    313 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    314 		       CTLTYPE_INT, "inet6_map_prec",
    315 		       SYSCTL_DESCR("Map IP6 class"),
    316 		       NULL, 0, &mpls_mapclass_inet6, 0,
    317 		       CTL_NET, PF_MPLS, CTL_CREATE, CTL_EOL);
    318 #endif
    319 }
    320 
    321 DOMAIN_DEFINE(mplsdomain);
    322 
    323 PR_WRAP_USRREQS(mpls)
    324 #define	mpls_attach	mpls_attach_wrapper
    325 #define	mpls_detach	mpls_detach_wrapper
    326 #define	mpls_accept	mpls_accept_wrapper
    327 #define	mpls_bind	mpls_bind_wrapper
    328 #define	mpls_listen	mpls_listen_wrapper
    329 #define	mpls_connect	mpls_connect_wrapper
    330 #define	mpls_disconnect	mpls_disconnect_wrapper
    331 #define	mpls_shutdown	mpls_shutdown_wrapper
    332 #define	mpls_abort	mpls_abort_wrapper
    333 #define	mpls_ioctl	mpls_ioctl_wrapper
    334 #define	mpls_stat	mpls_stat_wrapper
    335 #define	mpls_peeraddr	mpls_peeraddr_wrapper
    336 #define	mpls_sockaddr	mpls_sockaddr_wrapper
    337 #define	mpls_rcvd	mpls_rcvd_wrapper
    338 #define	mpls_recvoob	mpls_recvoob_wrapper
    339 #define	mpls_send	mpls_send_wrapper
    340 #define	mpls_sendoob	mpls_sendoob_wrapper
    341 #define	mpls_usrreq	mpls_usrreq_wrapper
    342 
    343 static const struct pr_usrreqs mpls_usrreqs = {
    344 	.pr_attach	= mpls_attach,
    345 	.pr_detach	= mpls_detach,
    346 	.pr_accept	= mpls_accept,
    347 	.pr_bind	= mpls_bind,
    348 	.pr_listen	= mpls_listen,
    349 	.pr_connect	= mpls_connect,
    350 	.pr_disconnect	= mpls_disconnect,
    351 	.pr_shutdown	= mpls_shutdown,
    352 	.pr_abort	= mpls_abort,
    353 	.pr_ioctl	= mpls_ioctl,
    354 	.pr_stat	= mpls_stat,
    355 	.pr_peeraddr	= mpls_peeraddr,
    356 	.pr_sockaddr	= mpls_sockaddr,
    357 	.pr_rcvd	= mpls_rcvd,
    358 	.pr_recvoob	= mpls_recvoob,
    359 	.pr_send	= mpls_send,
    360 	.pr_sendoob	= mpls_sendoob,
    361 	.pr_generic	= mpls_usrreq,
    362 };
    363 
    364 const struct protosw mplssw[] = {
    365 	{	.pr_domain = &mplsdomain,
    366 		.pr_init = mpls_init,
    367 	},
    368 	{
    369 		.pr_type = SOCK_DGRAM,
    370 		.pr_domain = &mplsdomain,
    371 		.pr_flags = PR_ATOMIC | PR_ADDR,
    372 		.pr_usrreqs = &mpls_usrreqs,
    373 	},
    374 	{
    375 		.pr_type = SOCK_RAW,
    376 		.pr_domain = &mplsdomain,
    377 		.pr_flags = PR_ATOMIC | PR_ADDR,
    378 		.pr_usrreqs = &mpls_usrreqs,
    379 	},
    380 };
    381 
    382 struct domain mplsdomain = {
    383 	.dom_family = PF_MPLS,
    384 	.dom_name = "MPLS",
    385 	.dom_init = NULL,
    386 	.dom_externalize = NULL,
    387 	.dom_dispose = NULL,
    388 	.dom_protosw = mplssw,
    389 	.dom_protoswNPROTOSW = &mplssw[__arraycount(mplssw)],
    390 	.dom_rtattach = rt_inithead,
    391 	.dom_rtoffset = offsetof(struct sockaddr_mpls, smpls_addr) << 3,
    392 	.dom_maxrtkey = sizeof(union mpls_shim),
    393 	.dom_ifattach = NULL,
    394 	.dom_ifdetach = NULL,
    395 	.dom_ifqueues = { &mplsintrq, NULL },
    396 	.dom_link = { NULL },
    397 	.dom_mowner = MOWNER_INIT("MPLS", ""),
    398 	.dom_sa_cmpofs = offsetof(struct sockaddr_mpls, smpls_addr),
    399 	.dom_sa_cmplen = sizeof(union mpls_shim),
    400 	.dom_rtcache = LIST_HEAD_INITIALIZER(mplsdomain.dom_rtcache)
    401 };
    402