2 * Copyright (c) 2014 Contextream, 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.lispflowmapping.implementation.serializer;
10 import java.nio.ByteBuffer;
12 import org.apache.commons.lang3.BooleanUtils;
13 import org.opendaylight.lispflowmapping.implementation.serializer.address.LispAddressSerializer;
14 import org.opendaylight.lispflowmapping.implementation.util.ByteUtil;
15 import org.opendaylight.lispflowmapping.implementation.util.LispAFIConvertor;
16 import org.opendaylight.lispflowmapping.implementation.util.NumberUtil;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.LispAFIAddress;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.locatorrecords.LocatorRecord;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.locatorrecords.LocatorRecordBuilder;
21 public class LocatorRecordSerializer {
23 private static final LocatorRecordSerializer INSTANCE = new LocatorRecordSerializer();
25 // Private constructor prevents instantiation from other classes
26 private LocatorRecordSerializer() {
29 public static LocatorRecordSerializer getInstance() {
33 protected LocatorRecord deserialize(ByteBuffer buffer) {
34 LocatorRecordBuilder builder = new LocatorRecordBuilder();
35 builder.setPriority((short) ByteUtil.getUnsignedByte(buffer));
36 builder.setWeight((short) ByteUtil.getUnsignedByte(buffer));
37 builder.setMulticastPriority((short) ByteUtil.getUnsignedByte(buffer));
38 builder.setMulticastWeight((short) ByteUtil.getUnsignedByte(buffer));
39 byte flags = (byte) buffer.getShort();
40 builder.setLocalLocator(ByteUtil.extractBit(flags, Flags.LOCAL_LOCATOR));
41 builder.setRlocProbed(ByteUtil.extractBit(flags, Flags.RLOC_PROBED));
42 builder.setRouted(ByteUtil.extractBit(flags, Flags.ROUTED));
43 LispAFIAddress afiAddress = LispAddressSerializer.getInstance().deserialize(buffer);
44 builder.setLispAddressContainer(LispAFIConvertor.toContainer(afiAddress));
45 return builder.build();
48 public void serialize(ByteBuffer replyBuffer, LocatorRecord record) {
49 replyBuffer.put((byte) NumberUtil.asShort(record.getPriority()));
50 replyBuffer.put((byte) NumberUtil.asShort(record.getWeight()));
51 replyBuffer.put((byte) NumberUtil.asShort(record.getMulticastPriority()));
52 replyBuffer.put((byte) NumberUtil.asShort(record.getMulticastWeight()));
53 replyBuffer.position(replyBuffer.position() + Length.UNUSED_FLAGS);
54 replyBuffer.put((byte) (ByteUtil.boolToBit(BooleanUtils.isTrue(record.isLocalLocator()), Flags.LOCAL_LOCATOR) | //
55 ByteUtil.boolToBit(BooleanUtils.isTrue(record.isRlocProbed()), Flags.RLOC_PROBED) | //
56 ByteUtil.boolToBit(BooleanUtils.isTrue(record.isRouted()), Flags.ROUTED)));
57 LispAddressSerializer.getInstance().serialize(replyBuffer, LispAFIConvertor.toAFI(record.getLispAddressContainer()));
60 public int getSerializationSize(LocatorRecord record) {
61 return Length.HEADER_SIZE
62 + LispAddressSerializer.getInstance().getAddressSize(LispAFIConvertor.toAFI(record.getLispAddressContainer()));
65 private interface Flags {
66 int LOCAL_LOCATOR = 0x04;
67 int RLOC_PROBED = 0x02;
71 private interface Length {