2 * Copyright (c) 2016 Cisco Systems, Inc. and others. 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.evpn.impl.nlri;
10 import static org.opendaylight.protocol.bgp.evpn.impl.nlri.NlriModelUtil.MPLS_NID;
11 import static org.opendaylight.protocol.bgp.evpn.impl.nlri.NlriModelUtil.extractETI;
12 import static org.opendaylight.protocol.bgp.evpn.impl.nlri.NlriModelUtil.extractMplsLabel;
13 import static org.opendaylight.protocol.util.MplsLabelUtil.byteBufForMplsLabel;
14 import static org.opendaylight.protocol.util.MplsLabelUtil.mplsLabelForByteBuf;
16 import com.google.common.base.Preconditions;
17 import io.netty.buffer.ByteBuf;
18 import io.netty.buffer.Unpooled;
19 import org.opendaylight.protocol.bgp.evpn.spi.pojo.SimpleEsiTypeRegistry;
20 import org.opendaylight.protocol.util.ByteBufWriteUtil;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.NlriType;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.esi.Esi;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.ethernet.a.d.route.EthernetADRoute;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.ethernet.a.d.route.EthernetADRouteBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.ethernet.tag.id.EthernetTagId;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.ethernet.tag.id.EthernetTagIdBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.evpn.EvpnChoice;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.evpn.evpn.choice.EthernetADRouteCase;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.evpn.rev160321.evpn.evpn.choice.EthernetADRouteCaseBuilder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.MplsLabel;
31 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
32 import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
34 final class EthADRParser extends AbstractEvpnNlri {
35 protected static final NodeIdentifier ETH_AD_ROUTE_NID = new NodeIdentifier(EthernetADRoute.QNAME);
36 private static final int CONTENT_LENGTH = 17;
39 public EvpnChoice parseEvpn(final ByteBuf buffer) {
40 Preconditions.checkArgument(buffer.readableBytes() == CONTENT_LENGTH, "Wrong length of array of bytes. Passed: %s ;", buffer);
41 final Esi esi = SimpleEsiTypeRegistry.getInstance().parseEsi(buffer.readSlice(ESI_SIZE));
42 final EthernetTagId eti = new EthernetTagIdBuilder().setVlanId(buffer.readUnsignedInt()).build();
43 final MplsLabel label = mplsLabelForByteBuf(buffer);
44 final EthernetADRouteBuilder builder = new EthernetADRouteBuilder().setEsi(esi).setEthernetTagId(eti).setMplsLabel(label);
45 return new EthernetADRouteCaseBuilder().setEthernetADRoute(builder.build()).build();
49 protected NlriType getType() {
50 return NlriType.EthADDisc;
54 public ByteBuf serializeBody(final EvpnChoice evpn) {
55 Preconditions.checkArgument(evpn instanceof EthernetADRouteCase, "Unknown evpn instance. Passed %s. Needed EthernetADRouteCase.", evpn.getClass());
56 return serializeBody(((EthernetADRouteCase) evpn).getEthernetADRoute());
60 public EvpnChoice serializeEvpnModel(final ContainerNode evpn) {
61 final EthernetADRouteBuilder builder = serializeKeyModel(evpn);
62 builder.setMplsLabel(extractMplsLabel(evpn, MPLS_NID));
63 return new EthernetADRouteCaseBuilder().setEthernetADRoute(builder.build()).build();
67 public EvpnChoice createRouteKey(final ContainerNode evpn) {
68 return new EthernetADRouteCaseBuilder().setEthernetADRoute(serializeKeyModel(evpn).build()).build();
71 private static EthernetADRouteBuilder serializeKeyModel(final ContainerNode evpn) {
72 final EthernetADRouteBuilder builder = new EthernetADRouteBuilder();
73 builder.setEsi(serializeEsi(evpn));
74 builder.setEthernetTagId(extractETI(evpn));
78 private static ByteBuf serializeBody(final EthernetADRoute evpn) {
79 final ByteBuf body = Unpooled.buffer(CONTENT_LENGTH);
80 SimpleEsiTypeRegistry.getInstance().serializeEsi(evpn.getEsi(), body);
81 ByteBufWriteUtil.writeUnsignedInt(evpn.getEthernetTagId().getVlanId(), body);
83 final MplsLabel mpls = evpn.getMplsLabel();
85 body.writeBytes(byteBufForMplsLabel(evpn.getMplsLabel()));