Home | History | Annotate | Line # | Download | only in netmpls
mpls_proto.c revision 1.24
      1 /*	$NetBSD: mpls_proto.c,v 1.24 2014/08/09 05:33:01 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.24 2014/08/09 05:33:01 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_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