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