2 * Copyright (c) 2014 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.linkstate.nlri;
10 import com.google.common.primitives.UnsignedInteger;
11 import io.netty.buffer.ByteBuf;
12 import io.netty.buffer.ByteBufUtil;
13 import io.netty.buffer.Unpooled;
14 import org.opendaylight.protocol.bgp.linkstate.TlvUtil;
15 import org.opendaylight.protocol.bgp.parser.BGPParsingException;
16 import org.opendaylight.protocol.util.ByteArray;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.AreaIdentifier;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.DomainIdentifier;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.NodeIdentifier;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.OspfInterfaceIdentifier;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.isis.lan.identifier.IsIsRouterIdentifier;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.isis.lan.identifier.IsIsRouterIdentifierBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.linkstate.destination.c.linkstate.destination.LocalNodeDescriptorsBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.linkstate.destination.c.linkstate.destination.RemoteNodeDescriptorsBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.CRouterIdentifier;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.IsisNodeCase;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.IsisNodeCaseBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.IsisPseudonodeCase;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.IsisPseudonodeCaseBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.OspfNodeCase;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.OspfNodeCaseBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.OspfPseudonodeCase;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.OspfPseudonodeCaseBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.isis.node._case.IsisNode;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.isis.node._case.IsisNodeBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.isis.pseudonode._case.IsisPseudonode;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.isis.pseudonode._case.IsisPseudonodeBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.ospf.node._case.OspfNodeBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.ospf.pseudonode._case.OspfPseudonode;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.node.identifier.c.router.identifier.ospf.pseudonode._case.OspfPseudonodeBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.IsoSystemIdentifier;
43 import org.slf4j.Logger;
44 import org.slf4j.LoggerFactory;
45 final class NodeNlriParser {
47 private static final Logger LOG = LoggerFactory.getLogger(NodeNlriParser.class);
49 private static final int OSPF_PSEUDONODE_ROUTER_ID_LENGTH = 8;
50 private static final int OSPF_ROUTER_ID_LENGTH = 4;
51 private static final int ISO_SYSTEM_ID_LENGTH = 6;
52 private static final int PSN_LENGTH = 1;
54 /* Node Descriptor TLVs */
55 private static final int AS_NUMBER = 512;
56 private static final int BGP_LS_ID = 513;
57 private static final int AREA_ID = 514;
58 private static final int IGP_ROUTER_ID = 515;
60 static NodeIdentifier parseNodeDescriptors(final ByteBuf buffer, final boolean local) throws BGPParsingException {
61 AsNumber asnumber = null;
62 DomainIdentifier bgpId = null;
63 AreaIdentifier ai = null;
64 CRouterIdentifier routerId = null;
65 while (buffer.isReadable()) {
66 final int type = buffer.readUnsignedShort();
67 final int length = buffer.readUnsignedShort();
68 final ByteBuf value = buffer.slice(buffer.readerIndex(), length);
69 if (LOG.isTraceEnabled()) {
70 LOG.trace("Parsing Node Descriptor: {}", ByteBufUtil.hexDump(value));
74 asnumber = new AsNumber(value.readUnsignedInt());
75 LOG.debug("Parsed {}", asnumber);
78 bgpId = new DomainIdentifier(value.readUnsignedInt());
79 LOG.debug("Parsed {}", bgpId);
82 ai = new AreaIdentifier(value.readUnsignedInt());
83 LOG.debug("Parsed area identifier {}", ai);
86 routerId = parseRouterId(value);
87 LOG.debug("Parsed Router Identifier {}", routerId);
90 throw new BGPParsingException("Node Descriptor not recognized, type: " + type);
92 buffer.skipBytes(length);
94 LOG.trace("Finished parsing Node descriptors.");
95 return (local) ? new LocalNodeDescriptorsBuilder().setAsNumber(asnumber).setDomainId(bgpId).setAreaId(ai).setCRouterIdentifier(
97 : new RemoteNodeDescriptorsBuilder().setAsNumber(asnumber).setDomainId(bgpId).setAreaId(ai).setCRouterIdentifier(routerId).build();
100 private static CRouterIdentifier parseRouterId(final ByteBuf value) throws BGPParsingException {
101 if (value.readableBytes() == ISO_SYSTEM_ID_LENGTH || (value.readableBytes() == ISO_SYSTEM_ID_LENGTH + PSN_LENGTH && value.getByte(ISO_SYSTEM_ID_LENGTH) == 0)) {
102 return new IsisNodeCaseBuilder().setIsisNode(
103 new IsisNodeBuilder().setIsoSystemId(new IsoSystemIdentifier(ByteArray.readBytes(value, ISO_SYSTEM_ID_LENGTH))).build()).build();
105 if (value.readableBytes() == ISO_SYSTEM_ID_LENGTH + PSN_LENGTH) {
106 final IsIsRouterIdentifier iri = new IsIsRouterIdentifierBuilder().setIsoSystemId(
107 new IsoSystemIdentifier(ByteArray.readBytes(value, ISO_SYSTEM_ID_LENGTH))).build();
108 return new IsisPseudonodeCaseBuilder().setIsisPseudonode(new IsisPseudonodeBuilder().setIsIsRouterIdentifier(iri).setPsn((short) value.readByte()).build()).build();
110 if (value.readableBytes() == OSPF_ROUTER_ID_LENGTH) {
111 return new OspfNodeCaseBuilder().setOspfNode(
112 new OspfNodeBuilder().setOspfRouterId(value.readUnsignedInt()).build()).build();
114 if (value.readableBytes() == OSPF_PSEUDONODE_ROUTER_ID_LENGTH) {
115 return new OspfPseudonodeCaseBuilder().setOspfPseudonode(
116 new OspfPseudonodeBuilder().setOspfRouterId(value.readUnsignedInt()).setLanInterface(new OspfInterfaceIdentifier(value.readUnsignedInt())).build()).build();
118 throw new BGPParsingException("Router Id of invalid length " + value.readableBytes());
121 static void serializeNodeDescriptors(final NodeIdentifier descriptors, final ByteBuf buffer) {
122 if (descriptors.getAsNumber() != null) {
123 TlvUtil.writeTLV(AS_NUMBER, Unpooled.copyInt(UnsignedInteger.valueOf(descriptors.getAsNumber().getValue()).intValue()), buffer);
125 if (descriptors.getDomainId() != null) {
126 TlvUtil.writeTLV(BGP_LS_ID, Unpooled.copyInt(UnsignedInteger.valueOf(descriptors.getDomainId().getValue()).intValue()), buffer);
128 if (descriptors.getAreaId() != null) {
129 TlvUtil.writeTLV(AREA_ID, Unpooled.copyInt(UnsignedInteger.valueOf(descriptors.getAreaId().getValue()).intValue()), buffer);
131 if (descriptors.getCRouterIdentifier() != null) {
132 final ByteBuf routerIdBuf = Unpooled.buffer();
133 serializeRouterId(descriptors.getCRouterIdentifier(), routerIdBuf);
134 TlvUtil.writeTLV(IGP_ROUTER_ID, routerIdBuf, buffer);
138 private static void serializeRouterId(final CRouterIdentifier routerId, final ByteBuf buffer) {
139 if (routerId instanceof IsisNodeCase) {
140 final IsisNode isis = ((IsisNodeCase) routerId).getIsisNode();
141 buffer.writeBytes(isis.getIsoSystemId().getValue());
142 } else if (routerId instanceof IsisPseudonodeCase) {
143 final IsisPseudonode isis = ((IsisPseudonodeCase) routerId).getIsisPseudonode();
144 buffer.writeBytes(isis.getIsIsRouterIdentifier().getIsoSystemId().getValue());
145 buffer.writeByte(((isis.getPsn() != null) ? isis.getPsn() : 0));
146 } else if (routerId instanceof OspfNodeCase) {
147 buffer.writeInt(UnsignedInteger.valueOf(((OspfNodeCase) routerId).getOspfNode().getOspfRouterId()).intValue());
148 } else if (routerId instanceof OspfPseudonodeCase) {
149 final OspfPseudonode node = ((OspfPseudonodeCase) routerId).getOspfPseudonode();
150 buffer.writeInt(UnsignedInteger.valueOf(node.getOspfRouterId()).intValue());
151 buffer.writeInt(UnsignedInteger.valueOf(node.getLanInterface().getValue()).intValue());