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