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