2 * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.protocol.bgp.rib.impl;
10 import java.util.ArrayList;
11 import java.util.List;
13 import java.util.stream.Collectors;
14 import org.opendaylight.protocol.bgp.parser.spi.PathIdUtil;
15 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Prefix;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.ipv4.prefixes.DestinationIpv4Builder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.ipv4.prefixes.destination.ipv4.Ipv4PrefixesBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.ipv6.prefixes.DestinationIpv6Builder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.ipv6.prefixes.destination.ipv6.Ipv6PrefixesBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationIpv4CaseBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.inet.rev180329.update.attributes.mp.reach.nlri.advertized.routes.destination.type.DestinationIpv6CaseBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.Update;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.UpdateBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.BgpParameters;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.BgpParametersBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.OptionalCapabilities;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.OptionalCapabilitiesBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.open.message.bgp.parameters.optional.capabilities.CParametersBuilder;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.AttributesBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.AsPath;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.AsPathBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.LocalPref;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.LocalPrefBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.Origin;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.OriginBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.as.path.Segments;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes1Builder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.Attributes2Builder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.CParameters1Builder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.SendReceive;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.destination.DestinationType;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.AddPathCapabilityBuilder;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapability;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.GracefulRestartCapabilityBuilder;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapabilityBuilder;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamiliesBuilder;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.graceful.restart.capability.Tables;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.graceful.restart.capability.TablesBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpReachNlri;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpReachNlriBuilder;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.MpUnreachNlri;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.update.attributes.mp.reach.nlri.AdvertizedRoutesBuilder;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.rib.TablesKey;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.AddressFamily;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.BgpOrigin;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.Ipv4AddressFamily;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.Ipv6AddressFamily;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.UnicastSubsequentAddressFamily;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.CNextHop;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.Ipv4NextHopCaseBuilder;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.Ipv6NextHopCaseBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.ipv4.next.hop._case.Ipv4NextHopBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.ipv6.next.hop._case.Ipv6NextHopBuilder;
70 import org.opendaylight.yangtools.yang.common.Uint32;
72 final class PeerUtil {
77 static MpReachNlri createMpReachNlri(final IpAddress nextHop, final List<IpPrefix> prefixes) {
78 final Class<? extends AddressFamily> afi;
79 final CNextHop cNextHop;
80 final DestinationType destinationType;
81 if (nextHop.getIpv4Address() != null) {
82 afi = Ipv4AddressFamily.class;
83 cNextHop = new Ipv4NextHopCaseBuilder().setIpv4NextHop(new Ipv4NextHopBuilder()
84 .setGlobal(nextHop.getIpv4Address())
86 destinationType = new DestinationIpv4CaseBuilder().setDestinationIpv4(
87 new DestinationIpv4Builder().setIpv4Prefixes(prefixes.stream()
88 .map(prefix -> new Ipv4PrefixesBuilder()
89 .setPathId(PathIdUtil.NON_PATH_ID)
90 .setPrefix(new Ipv4Prefix(prefix.getIpv4Prefix())).build())
91 .collect(Collectors.toList()))
94 afi = Ipv6AddressFamily.class;
95 cNextHop = new Ipv6NextHopCaseBuilder().setIpv6NextHop(new Ipv6NextHopBuilder()
96 .setGlobal(nextHop.getIpv6Address())
98 destinationType = new DestinationIpv6CaseBuilder().setDestinationIpv6(
99 new DestinationIpv6Builder().setIpv6Prefixes(prefixes.stream()
100 .map(prefix -> new Ipv6PrefixesBuilder()
101 .setPathId(PathIdUtil.NON_PATH_ID)
102 .setPrefix(new Ipv6Prefix(prefix.getIpv6Prefix())).build())
103 .collect(Collectors.toList()))
107 return new MpReachNlriBuilder()
108 .setCNextHop(cNextHop)
110 .setSafi(UnicastSubsequentAddressFamily.class)
111 .setAdvertizedRoutes(new AdvertizedRoutesBuilder().setDestinationType(destinationType).build())
115 static Update createUpdate(final BgpOrigin bgpOrigin,
116 final List<Segments> pathSegments,
117 // FIXME: consider using Uint32
118 final long preference,
119 final MpReachNlri mpReach,
120 final MpUnreachNlri mpUnreach) {
121 final Origin origin = new OriginBuilder().setValue(bgpOrigin).build();
122 final AsPath asPath = new AsPathBuilder().setSegments(pathSegments).build();
123 final LocalPref localPref = new LocalPrefBuilder().setPref(Uint32.valueOf(preference)).build();
124 final AttributesBuilder attributeBuilder = new AttributesBuilder()
125 .setOrigin(origin).setAsPath(asPath).setLocalPref(localPref);
127 if (mpReach != null) {
128 attributeBuilder.addAugmentation(Attributes1.class, new Attributes1Builder()
129 .setMpReachNlri(mpReach)
133 if (mpUnreach != null) {
134 attributeBuilder.addAugmentation(Attributes2.class, new Attributes2Builder()
135 .setMpUnreachNlri(mpUnreach)
139 return new UpdateBuilder()
140 .setAttributes(new AttributesBuilder()
143 .setLocalPref(localPref)
144 .addAugmentation(Attributes1.class, new Attributes1Builder()
145 .setMpReachNlri(mpReach)
150 static BgpParameters createBgpParameters(final List<TablesKey> advertisedTables,
151 final List<TablesKey> addPathTables,
152 final Map<TablesKey, Boolean> gracefulTabes,
153 final int gracefulTimer) {
154 final List<OptionalCapabilities> capabilities = new ArrayList<>();
155 advertisedTables.forEach(key -> capabilities.add(createMultiprotocolCapability(key)));
156 if (addPathTables != null && !addPathTables.isEmpty()) {
157 capabilities.add(createAddPathCapability(addPathTables));
159 if (gracefulTabes != null && !gracefulTabes.isEmpty()) {
160 capabilities.add(createGracefulRestartCapability(gracefulTabes, gracefulTimer));
162 return new BgpParametersBuilder().setOptionalCapabilities(capabilities).build();
165 private static OptionalCapabilities createMultiprotocolCapability(final TablesKey key) {
166 return new OptionalCapabilitiesBuilder().setCParameters(
167 new CParametersBuilder().addAugmentation(
168 CParameters1.class, new CParameters1Builder().setMultiprotocolCapability(
169 new MultiprotocolCapabilityBuilder()
170 .setAfi(key.getAfi())
171 .setSafi(key.getSafi())
172 .build()).build()).build()).build();
175 private static OptionalCapabilities createGracefulRestartCapability(final Map<TablesKey, Boolean> gracefulTables,
176 final int restartTime) {
177 return new OptionalCapabilitiesBuilder().setCParameters(
178 new CParametersBuilder().addAugmentation(
179 CParameters1.class, new CParameters1Builder()
180 .setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
181 .setRestartFlags(new GracefulRestartCapability.RestartFlags(false))
182 .setRestartTime(restartTime)
183 .setTables(gracefulTables.keySet().stream()
184 .map(key -> new TablesBuilder()
185 .setAfi(key.getAfi())
186 .setSafi(key.getSafi())
187 .setAfiFlags(new Tables.AfiFlags(gracefulTables.get(key)))
189 .collect(Collectors.toList()))
190 .build()).build()).build()).build();
193 private static OptionalCapabilities createAddPathCapability(final List<TablesKey> keys) {
194 return new OptionalCapabilitiesBuilder().setCParameters(
195 new CParametersBuilder().addAugmentation(CParameters1.class,
196 new CParameters1Builder().setAddPathCapability(
197 new AddPathCapabilityBuilder().setAddressFamilies(keys.stream()
198 .map(key -> new AddressFamiliesBuilder()
199 .setAfi(key.getAfi())
200 .setSafi(key.getSafi())
201 .setSendReceive(SendReceive.Both)
203 .collect(Collectors.toList()))
204 .build()).build()).build()).build();