1*2a2cde5cSkefren /* $NetBSD: mpls_interface.c,v 1.13 2013/08/02 07:29:56 kefren Exp $ */
2e7341adaSkefren
3e7341adaSkefren /*-
4e7341adaSkefren * Copyright (c) 2010 The NetBSD Foundation, Inc.
5e7341adaSkefren * All rights reserved.
6e7341adaSkefren *
7e7341adaSkefren * This code is derived from software contributed to The NetBSD Foundation
8e7341adaSkefren * by Mihai Chelaru <kefren@NetBSD.org>
9e7341adaSkefren *
10e7341adaSkefren * Redistribution and use in source and binary forms, with or without
11e7341adaSkefren * modification, are permitted provided that the following conditions
12e7341adaSkefren * are met:
13e7341adaSkefren * 1. Redistributions of source code must retain the above copyright
14e7341adaSkefren * notice, this list of conditions and the following disclaimer.
15e7341adaSkefren * 2. Redistributions in binary form must reproduce the above copyright
16e7341adaSkefren * notice, this list of conditions and the following disclaimer in the
17e7341adaSkefren * documentation and/or other materials provided with the distribution.
18e7341adaSkefren *
19e7341adaSkefren * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20e7341adaSkefren * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21e7341adaSkefren * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22e7341adaSkefren * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23e7341adaSkefren * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24e7341adaSkefren * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25e7341adaSkefren * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26e7341adaSkefren * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27e7341adaSkefren * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28e7341adaSkefren * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29e7341adaSkefren * POSSIBILITY OF SUCH DAMAGE.
30e7341adaSkefren */
31e7341adaSkefren
32e7341adaSkefren #include <arpa/inet.h>
33e7341adaSkefren #include <netinet/in.h>
34e7341adaSkefren #include <netmpls/mpls.h>
3534493327Skefren #include <net/route.h>
36e7341adaSkefren
37e7341adaSkefren #include <sys/param.h>
38e7341adaSkefren
39e7341adaSkefren #include <assert.h>
40e7341adaSkefren #include <stdio.h>
41e7341adaSkefren #include <string.h>
42e7341adaSkefren #include <stdlib.h>
43e7341adaSkefren #include <unistd.h>
44e7341adaSkefren
45e7341adaSkefren #include "ldp.h"
46e7341adaSkefren #include "ldp_peer.h"
47e7341adaSkefren #include "ldp_errors.h"
48e7341adaSkefren #include "tlv_stack.h"
49e7341adaSkefren #include "label.h"
50e7341adaSkefren #include "mpls_interface.h"
51e7341adaSkefren #include "mpls_routes.h"
52e7341adaSkefren
539b733c1cSkefren extern int no_default_route;
549b733c1cSkefren
55e7341adaSkefren int
mpls_add_label(struct label * lab)569b2110ebSkefren mpls_add_label(struct label *lab)
57e7341adaSkefren {
589b2110ebSkefren char p_str[20];
599b2110ebSkefren union sockunion *so_dest, *so_nexthop, *so_tag, so_ifa;
609b2110ebSkefren uint8_t prefixlen;
619b2110ebSkefren uint32_t oldbinding;
62*2a2cde5cSkefren struct peer_map *pm;
63e7341adaSkefren
649b2110ebSkefren assert(lab != NULL);
659b2110ebSkefren
669b2110ebSkefren oldbinding = lab->binding;
679b2110ebSkefren prefixlen = from_union_to_cidr(&lab->so_pref);
689b2110ebSkefren
699b2110ebSkefren strlcpy(p_str, satos(lab->p->address), sizeof(p_str));
709b2110ebSkefren warnp("Trying to add %s/%d as label %d (oldlocal %d) to peer %s\n",
719b2110ebSkefren satos(&lab->so_dest.sa), prefixlen, lab->label, lab->binding,p_str);
72e7341adaSkefren
739b733c1cSkefren /* Check if we should accept default route */
749b2110ebSkefren if (prefixlen == 0 && no_default_route != 0)
75e7341adaSkefren return LDP_E_BAD_AF;
76e7341adaSkefren
779b2110ebSkefren /* double check if there is a label mapping for this */
78*2a2cde5cSkefren if ((pm = ldp_test_mapping(&lab->so_dest.sa, prefixlen,
79*2a2cde5cSkefren &lab->so_gate.sa)) == NULL || pm->peer != lab->p) {
80*2a2cde5cSkefren if (pm != NULL)
81*2a2cde5cSkefren free(pm);
82e7341adaSkefren return LDP_E_NOENT;
83*2a2cde5cSkefren }
84*2a2cde5cSkefren free(pm);
85e7341adaSkefren
869b2110ebSkefren if (lab->so_gate.sa.sa_family != AF_INET &&
879b2110ebSkefren lab->so_gate.sa.sa_family != AF_INET6) {
889b2110ebSkefren warnp("mpls_add_label: so_gate is not IP or IPv6\n");
89e7341adaSkefren return LDP_E_BAD_AF;
90e7341adaSkefren }
91e7341adaSkefren
92e7341adaSkefren /* Check if the address is bounded to the peer */
939b2110ebSkefren if (check_ifaddr(lab->p, &lab->so_gate.sa) == NULL) {
949b2110ebSkefren warnp("Failed at next-hop check\n");
95e7341adaSkefren return LDP_E_ROUTE_ERROR;
96e7341adaSkefren }
97e7341adaSkefren
989b2110ebSkefren /* if binding is implicit null we need to generate a new one */
99e7341adaSkefren if (lab->binding == MPLS_LABEL_IMPLNULL) {
100e8941bb5Skefren lab->binding = get_free_local_label();
101e7341adaSkefren if (!lab->binding) {
10242c11e10Skefren fatalp("Label pool depleted\n");
103e7341adaSkefren return LDP_E_TOO_MANY_LABELS;
104e7341adaSkefren }
105e8941bb5Skefren announce_label_change(lab);
106e7341adaSkefren }
107e7341adaSkefren
1089b2110ebSkefren warnp("[mpls_add_label] Adding %s/%d as local binding %d (%d), label %d"
1099b2110ebSkefren " to peer %s\n", satos(&lab->so_dest.sa), prefixlen, lab->binding,
1109b2110ebSkefren oldbinding, lab->label, p_str);
111e7341adaSkefren
112e7341adaSkefren /* Add switching route */
1139b2110ebSkefren if ((so_dest = make_mpls_union(lab->binding)) == NULL)
1149b2110ebSkefren return LDP_E_MEMORY;
1159b2110ebSkefren if ((so_tag = make_mpls_union(lab->label)) == NULL) {
11653e5c5d4Skefren free(so_dest);
11714db3bb9Schristos fatalp("Out of memory\n");
11814db3bb9Schristos return LDP_E_MEMORY;
11914db3bb9Schristos }
1209b2110ebSkefren if ((so_nexthop = malloc(lab->so_gate.sa.sa_len)) == NULL) {
12153e5c5d4Skefren free(so_dest);
1229b2110ebSkefren free(so_tag);
12353e5c5d4Skefren fatalp("Out of memory\n");
12453e5c5d4Skefren return LDP_E_MEMORY;
12553e5c5d4Skefren }
1269b2110ebSkefren memcpy(so_nexthop, &lab->so_gate, lab->so_gate.sa.sa_len);
1279b2110ebSkefren
1289b2110ebSkefren if (add_route(so_dest, NULL, so_nexthop, NULL, so_tag, FREESO,
1299b2110ebSkefren oldbinding == MPLS_LABEL_IMPLNULL ? RTM_ADD : RTM_CHANGE)
1309b2110ebSkefren != LDP_E_OK) {
1319b2110ebSkefren fatalp("[mpls_add_label] MPLS route error\n");
132e7341adaSkefren return LDP_E_ROUTE_ERROR;
1339b2110ebSkefren }
134e7341adaSkefren
13542c11e10Skefren /* Now, let's add tag to IP route and point it to mpls interface */
1369b2110ebSkefren
1379b2110ebSkefren if (getsockname(lab->p->socket, &so_ifa.sa,
1389b2110ebSkefren & (socklen_t) { sizeof(union sockunion) } )) {
1399b2110ebSkefren fatalp("[mpls_add_label]: getsockname\n");
1409b2110ebSkefren return LDP_E_ROUTE_ERROR;
1419b2110ebSkefren }
1429b2110ebSkefren
1439b2110ebSkefren if ((so_tag = make_mpls_union(lab->label)) == NULL) {
14453e5c5d4Skefren fatalp("Out of memory\n");
14553e5c5d4Skefren return LDP_E_MEMORY;
14653e5c5d4Skefren }
1470c8e14c9Skefren
1480c8e14c9Skefren if (add_route(&lab->so_dest, lab->host ? NULL : &lab->so_pref,
1490c8e14c9Skefren &lab->so_gate, &so_ifa, so_tag, NO_FREESO, RTM_CHANGE) != LDP_E_OK){
1509b2110ebSkefren free(so_tag);
1519b2110ebSkefren fatalp("[mpls_add_label]: INET route failure\n");
152e7341adaSkefren return LDP_E_ROUTE_ERROR;
1539b2110ebSkefren }
1549b2110ebSkefren free(so_tag);
155e7341adaSkefren
1569b2110ebSkefren warnp("[mpls_add_label]: SUCCESS\n");
157e7341adaSkefren
158e7341adaSkefren return LDP_E_OK;
159e7341adaSkefren }
160e7341adaSkefren
161e7341adaSkefren int
mpls_add_ldp_peer(const struct ldp_peer * p)1622cc7bf11Skefren mpls_add_ldp_peer(const struct ldp_peer * p)
163e7341adaSkefren {
164e7341adaSkefren return LDP_E_OK;
165e7341adaSkefren }
166e7341adaSkefren
167e7341adaSkefren int
mpls_delete_ldp_peer(const struct ldp_peer * p)1682cc7bf11Skefren mpls_delete_ldp_peer(const struct ldp_peer * p)
169e7341adaSkefren {
170e7341adaSkefren
171e7341adaSkefren /* Reput all the routes also to IPv4 */
172e8941bb5Skefren label_reattach_all_peer_labels(p, REATT_INET_CHANGE);
173e7341adaSkefren
174e7341adaSkefren return LDP_E_OK;
175e7341adaSkefren }
176e7341adaSkefren
177e7341adaSkefren int
mpls_start_ldp()178e7341adaSkefren mpls_start_ldp()
179e7341adaSkefren {
180e7341adaSkefren ldp_peer_init();
181e7341adaSkefren label_init();
182e7341adaSkefren
183e7341adaSkefren return LDP_E_OK;
184e7341adaSkefren }
185