bgp/linkstate/src/main/java/org/opendaylight/protocol/bgp/linkstate/attribute/sr/RangeTlvParser.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.protocol.bgp.linkstate.attribute.sr;
   9
  10 import io.netty.buffer.ByteBuf;
  11 import io.netty.buffer.Unpooled;
  12 import java.util.ArrayList;
  13 import java.util.List;
  14 import org.opendaylight.protocol.bgp.linkstate.attribute.PrefixAttributesParser;
  15 import org.opendaylight.protocol.bgp.linkstate.attribute.sr.SidLabelIndexParser.Size;
  16 import org.opendaylight.protocol.bgp.linkstate.spi.TlvUtil;
  17 import org.opendaylight.protocol.util.BitArray;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.prefix.state.SrRange;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev150210.prefix.state.SrRangeBuilder;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.RangeSubTlv;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.BindingSidTlvCase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.BindingSidTlvCaseBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.PrefixSidTlvCase;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.PrefixSidTlvCaseBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.SidLabelTlvCase;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.sub.tlvs.range.sub.tlv.SidLabelTlvCaseBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.tlv.SubTlvs;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev151014.range.tlv.SubTlvsBuilder;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 public final class RangeTlvParser {
  33
  34     private static final Logger LOG = LoggerFactory.getLogger(RangeTlvParser.class);
  35
  36     private RangeTlvParser() {
  37         throw new UnsupportedOperationException();
  38     }
  39
  40     /* Flags */
  41     private static final int FLAGS_SIZE = 8;
  42     private static final int INNER_AREA = 0;
  43
  44     private static final int RESERVED = 1;
  45
  46     public static SrRange parseSrRange(final ByteBuf buffer) {
  47         final BitArray flags = BitArray.valueOf(buffer, FLAGS_SIZE);
  48         final SrRangeBuilder range = new SrRangeBuilder();
  49         range.setInterArea(flags.get(INNER_AREA));
  50         buffer.skipBytes(RESERVED);
  51         range.setRangeSize(buffer.readUnsignedShort());
  52         range.setSubTlvs(parseRangeSubTlvs(buffer));
  53         return range.build();
  54     }
  55
  56     private static List<SubTlvs> parseRangeSubTlvs(final ByteBuf buffer) {
  57         final List<SubTlvs> subTlvs = new ArrayList<>();
  58         while (buffer.isReadable()) {
  59             final SubTlvsBuilder subTlv = new SubTlvsBuilder();
  60             RangeSubTlv subTlvCase = null;
  61             final int type = buffer.readUnsignedShort();
  62             final int length = buffer.readUnsignedShort();
  63             switch (type) {
  64             case PrefixAttributesParser.PREFIX_SID:
  65                 subTlvCase = new PrefixSidTlvCaseBuilder(SrPrefixAttributesParser.parseSrPrefix(buffer.readSlice(length))).build();
  66                 break;
  67             case PrefixAttributesParser.BINDING_SID:
  68                 subTlvCase = new BindingSidTlvCaseBuilder(BindingSidLabelParser.parseBindingSidLabel(buffer.readSlice(length))).build();
  69                 break;
  70             case SidLabelIndexParser.SID_TYPE:
  71                 subTlvCase = new SidLabelTlvCaseBuilder().setSidLabelIndex(SidLabelIndexParser.parseSidLabelIndex(Size.forValue(length), buffer.readSlice(length))).build();
  72                 break;
  73             default:
  74                 LOG.info("Unknown type of range sub-tlv: {}", type);
  75                 buffer.skipBytes(length);
  76                 continue;
  77             }
  78             subTlvs.add(subTlv.setRangeSubTlv(subTlvCase).build());
  79         }
  80         return subTlvs;
  81     }
  82
  83     public static void serializeSrRange(final SrRange srRange, final ByteBuf aggregator) {
  84         final BitArray flags = new BitArray(FLAGS_SIZE);
  85         flags.set(INNER_AREA, srRange.isInterArea());
  86         flags.toByteBuf(aggregator);
  87         aggregator.writeZero(RESERVED);
  88         aggregator.writeShort(srRange.getRangeSize());
  89         serializeSubTlvs(aggregator, srRange.getSubTlvs());
  90     }
  91
  92     private static void serializeSubTlvs(final ByteBuf aggregator, final List<SubTlvs> subTlvs) {
  93         for (final SubTlvs subTlv : subTlvs) {
  94             ByteBuf buffer = Unpooled.buffer();
  95             final RangeSubTlv rangeSubTlv = subTlv.getRangeSubTlv();
  96             if (rangeSubTlv instanceof PrefixSidTlvCase) {
  97                 final PrefixSidTlvCase prefixSidTlv = (PrefixSidTlvCase) rangeSubTlv;
  98                 SrPrefixAttributesParser.serializePrefixAttributes(
  99                     prefixSidTlv.getFlags(),
 100                     prefixSidTlv.getAlgorithm(),
 101                     prefixSidTlv.getSidLabelIndex(),
 102                     buffer);
 103                 TlvUtil.writeTLV(PrefixAttributesParser.PREFIX_SID, buffer, aggregator);
 104             } else if (rangeSubTlv instanceof BindingSidTlvCase) {
 105                 final BindingSidTlvCase rangeTlv = (BindingSidTlvCase) rangeSubTlv;
 106                 BindingSidLabelParser.serializeBindingSidAttributes(
 107                     rangeTlv.getWeight(),
 108                     rangeTlv.getFlags(),
 109                     rangeTlv.getBindingSubTlvs(),
 110                     buffer);
 111                 TlvUtil.writeTLV(PrefixAttributesParser.BINDING_SID, buffer, aggregator);
 112             } else if (rangeSubTlv instanceof SidLabelTlvCase) {
 113                 buffer = SidLabelIndexParser.serializeSidValue(((SidLabelTlvCase) rangeSubTlv).getSidLabelIndex());
 114                 TlvUtil.writeTLV(SidLabelIndexParser.SID_TYPE, buffer, aggregator);
 115             }
 116         }
 117     }
 118
 119 }