mappingservice/implementation/src/main/java/org/opendaylight/lispflowmapping/implementation/serializer/address/LispTrafficEngineeringLCAFAddressSerializer.java

   1 /*
   2  * Copyright (c) 2014 Contextream, 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.lispflowmapping.implementation.serializer.address;
   9
  10 import java.nio.ByteBuffer;
  11 import java.util.ArrayList;
  12 import java.util.List;
  13
  14 import org.apache.commons.lang3.BooleanUtils;
  15 import org.opendaylight.lispflowmapping.implementation.util.ByteUtil;
  16 import org.opendaylight.lispflowmapping.implementation.util.LispAFIConvertor;
  17 import org.opendaylight.lispflowmapping.type.AddressFamilyNumberEnum;
  18 import org.opendaylight.lispflowmapping.type.LispCanonicalAddressFormatEnum;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.LcafTrafficEngineeringAddress;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.LispAFIAddress;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lcaftrafficengineeringaddress.Hops;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lcaftrafficengineeringaddress.HopsBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispaddress.lispaddresscontainer.address.lcaftrafficengineering.LcafTrafficEngineeringAddrBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispsimpleaddress.PrimitiveAddress;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.reencaphop.HopBuilder;
  26
  27 public class LispTrafficEngineeringLCAFAddressSerializer extends LispLCAFAddressSerializer {
  28
  29     private static final LispTrafficEngineeringLCAFAddressSerializer INSTANCE = new LispTrafficEngineeringLCAFAddressSerializer();
  30
  31     // Private constructor prevents instantiation from other classes
  32     private LispTrafficEngineeringLCAFAddressSerializer() {
  33     }
  34
  35     public static LispTrafficEngineeringLCAFAddressSerializer getInstance() {
  36         return INSTANCE;
  37     }
  38
  39     @Override
  40     protected short getLcafLength(LispAFIAddress lispAddress) {
  41         short totalSize = 0;
  42         if (((LcafTrafficEngineeringAddress) lispAddress).getHops() != null) {
  43             for (Hops hop : ((LcafTrafficEngineeringAddress) lispAddress).getHops()) {
  44                 totalSize += LispAddressSerializer.getInstance().getAddressSize(LispAFIConvertor.toAFIfromPrimitive(hop.getHop().getPrimitiveAddress())) + 2;
  45             }
  46         }
  47         return totalSize;
  48     }
  49
  50     @Override
  51     protected void serializeData(ByteBuffer buffer, LispAFIAddress lispAddress) {
  52         if (((LcafTrafficEngineeringAddress) lispAddress).getHops() != null) {
  53             for (Hops hop : ((LcafTrafficEngineeringAddress) lispAddress).getHops()) {
  54                 buffer.put((byte) 0);
  55                 buffer.put((byte) (ByteUtil.boolToBit(BooleanUtils.isTrue(hop.isLookup()), Flags.LOOKUP) | //
  56                         ByteUtil.boolToBit(BooleanUtils.isTrue(hop.isRLOCProbe()), Flags.RLOC_PROBE) | //
  57                 ByteUtil.boolToBit(BooleanUtils.isTrue(hop.isStrict()), Flags.STRICT)));
  58                 LispAddressSerializer.getInstance().serialize(buffer, LispAFIConvertor.toAFIfromPrimitive(hop.getHop().getPrimitiveAddress()));
  59             }
  60         }
  61     }
  62
  63     @Override
  64     protected LcafTrafficEngineeringAddress deserializeData(ByteBuffer buffer, byte res2, short length) {
  65         List<Hops> hops = new ArrayList<Hops>();
  66         while (length > 0) {
  67             byte flags = (byte) buffer.getShort();
  68             boolean lookup = ByteUtil.extractBit(flags, Flags.LOOKUP);
  69             boolean RLOCProbe = ByteUtil.extractBit(flags, Flags.RLOC_PROBE);
  70             boolean strict = ByteUtil.extractBit(flags, Flags.STRICT);
  71             PrimitiveAddress address = LispAFIConvertor.toPrimitive(LispAddressSerializer.getInstance().deserialize(buffer));
  72             HopsBuilder builder = new HopsBuilder();
  73             builder.setLookup(lookup);
  74             builder.setRLOCProbe(RLOCProbe);
  75             builder.setStrict(strict);
  76             builder.setHop(new HopBuilder().setPrimitiveAddress(address).build());
  77             builder.setName("Hop " + (hops.size()+1));
  78             length -= LispAddressSerializer.getInstance().getAddressSize(LispAFIConvertor.toAFIfromPrimitive(address)) + 2;
  79             hops.add(builder.build());
  80         }
  81         return new LcafTrafficEngineeringAddrBuilder().setAfi(AddressFamilyNumberEnum.LCAF.getIanaCode())
  82                 .setLcafType((short) LispCanonicalAddressFormatEnum.TRAFFIC_ENGINEERING.getLispCode()).setHops(hops).build();
  83     }
  84
  85     private interface Flags {
  86         int LOOKUP = 0x04;
  87         int RLOC_PROBE = 0x02;
  88         int STRICT = 0x01;
  89     }
  90
  91 }