mappingservice/lisp-proto/src/main/java/org/opendaylight/lispflowmapping/lisp/serializer/address/LispSourceDestLCAFAddressSerializer.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.lisp.serializer.address;
   9
  10 import java.nio.ByteBuffer;
  11
  12 import org.opendaylight.lispflowmapping.lisp.type.AddressFamilyNumberEnum;
  13 import org.opendaylight.lispflowmapping.lisp.type.LispCanonicalAddressFormatEnum;
  14 import org.opendaylight.lispflowmapping.lisp.util.ByteUtil;
  15 import org.opendaylight.lispflowmapping.lisp.util.LispAFIConvertor;
  16 import org.opendaylight.lispflowmapping.lisp.util.MaskUtil;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.LcafSourceDestAddress;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.LispAFIAddress;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.lcafsourcedestaddress.DstAddressBuilder;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.lcafsourcedestaddress.SrcAddressBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.lispaddress.lispaddresscontainer.address.lcafsourcedest.LcafSourceDestAddrBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.lispsimpleaddress.PrimitiveAddress;
  23
  24 public class LispSourceDestLCAFAddressSerializer extends LispLCAFAddressSerializer {
  25
  26     private static final LispSourceDestLCAFAddressSerializer INSTANCE = new LispSourceDestLCAFAddressSerializer();
  27
  28     // Private constructor prevents instantiation from other classes
  29     private LispSourceDestLCAFAddressSerializer() {
  30     }
  31
  32     public static LispSourceDestLCAFAddressSerializer getInstance() {
  33         return INSTANCE;
  34     }
  35
  36     @Override
  37     protected short getLcafLength(LispAFIAddress lispAddress) {
  38         return (short) (Length.ALL_FIELDS
  39                 + LispAddressSerializer.getInstance().getAddressSize(
  40                         LispAFIConvertor.toAFIfromPrimitive(((LcafSourceDestAddress) lispAddress).getSrcAddress().getPrimitiveAddress())) + LispAddressSerializer
  41                 .getInstance().getAddressSize(LispAFIConvertor.toAFIfromPrimitive(((LcafSourceDestAddress) lispAddress).getDstAddress().getPrimitiveAddress())));
  42     }
  43
  44     @Override
  45     protected void serializeData(ByteBuffer buffer, LispAFIAddress lispAddress) {
  46         LcafSourceDestAddress lispSourceDestLCAFAddress = ((LcafSourceDestAddress) lispAddress);
  47         buffer.putShort((short) 0);
  48         buffer.put(lispSourceDestLCAFAddress.getSrcMaskLength().byteValue());
  49         buffer.put(lispSourceDestLCAFAddress.getDstMaskLength().byteValue());
  50         LispAddressSerializer.getInstance().serialize(buffer, LispAFIConvertor.toAFIfromPrimitive(lispSourceDestLCAFAddress.getSrcAddress().getPrimitiveAddress()));
  51         LispAddressSerializer.getInstance().serialize(buffer, LispAFIConvertor.toAFIfromPrimitive(lispSourceDestLCAFAddress.getDstAddress().getPrimitiveAddress()));
  52     }
  53
  54     @Override
  55     protected LcafSourceDestAddress deserializeData(ByteBuffer buffer, byte res2, short length) {
  56         short res = buffer.getShort();
  57         short srcMaskLength = (short) ByteUtil.getUnsignedByte(buffer);
  58         short dstMaskLength = (short) ByteUtil.getUnsignedByte(buffer);
  59         LispAFIAddress srcAddress = LispAddressSerializer.getInstance().deserialize(buffer);
  60         srcAddress = MaskUtil.fixMask(srcAddress, srcMaskLength);
  61         LispAFIAddress dstAddress = LispAddressSerializer.getInstance().deserialize(buffer);
  62         dstAddress = MaskUtil.fixMask(dstAddress, dstMaskLength);
  63         LcafSourceDestAddrBuilder builder = new LcafSourceDestAddrBuilder();
  64         builder.setDstMaskLength((short) dstMaskLength).setSrcMaskLength((short) srcMaskLength);
  65         builder.setSrcAddress(new SrcAddressBuilder().setPrimitiveAddress((PrimitiveAddress) LispAFIConvertor.toPrimitive(srcAddress)).build());
  66         builder.setDstAddress(new DstAddressBuilder().setPrimitiveAddress((PrimitiveAddress) LispAFIConvertor.toPrimitive(dstAddress)).build());
  67         builder.setAfi(AddressFamilyNumberEnum.LCAF.getIanaCode());
  68         builder.setLcafType((short) LispCanonicalAddressFormatEnum.SOURCE_DEST.getLispCode());
  69
  70         return builder.build();
  71     }
  72
  73     private interface Length {
  74         int SOURCE_MASK_LENGTH = 1;
  75         int DEST_MASK_LENGTH = 1;
  76         int RESERVED = 2;
  77         int ALL_FIELDS = SOURCE_MASK_LENGTH + DEST_MASK_LENGTH + RESERVED;
  78     }
  79 }