extension/openflowplugin-extension-onf/src/main/java/org/opendaylight/openflowplugin/extension/onf/serializer/BundleAddMessageFactory.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. 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
   9 package org.opendaylight.openflowplugin.extension.onf.serializer;
  10
  11 import io.netty.buffer.ByteBuf;
  12 import java.util.List;
  13 import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;
  14 import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey;
  15 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowMod;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInput;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GroupMod;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GroupModInput;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortMod;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInput;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.BundleInnerMessage;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundleFlowModCase;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundleGroupModCase;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundlePortModCase;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.common.grouping.BundleProperty;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.experimenter.input.experimenter.data.of.choice.BundleAddMessage;
  28
  29 /**
  30  * Translates BundleAddMessage messages (OpenFlow v1.3 extension #230).
  31  */
  32 public class BundleAddMessageFactory extends AbstractBundleMessageFactory<BundleAddMessage> {
  33
  34     @Override
  35     public void serialize(BundleAddMessage input, ByteBuf outBuffer) {
  36         outBuffer.writeInt(input.getBundleId().getValue().intValue());
  37         outBuffer.writeZero(2);
  38         writeBundleFlags(input.getFlags(), outBuffer);
  39
  40         int msgStart = outBuffer.writerIndex();
  41         final BundleInnerMessage message = input.getBundleInnerMessage();
  42         serializeInnerMessage(message, outBuffer);
  43         int msgLength = outBuffer.writerIndex() - msgStart;
  44
  45         List<BundleProperty> bundleProperties = input.getBundleProperty();
  46         if (bundleProperties != null && !bundleProperties.isEmpty()) {
  47             outBuffer.writeZero(paddingNeeded(msgLength));
  48             writeBundleProperties(input.getBundleProperty(), outBuffer);
  49         }
  50     }
  51
  52     private void serializeInnerMessage(final BundleInnerMessage message, final ByteBuf outBuffer) {
  53         final Class clazz = message.getImplementedInterface();
  54         if (clazz.equals(BundleFlowModCase.class)) {
  55             OFSerializer<FlowMod> serializer = serializerRegistry.getSerializer(
  56                     new MessageTypeKey<>(EncodeConstants.OF13_VERSION_ID, FlowModInput.class));
  57             serializer.serialize((FlowMod)message, outBuffer);
  58         } else if (clazz.equals(BundleGroupModCase.class)) {
  59             OFSerializer<GroupMod> serializer = serializerRegistry.getSerializer(
  60                     new MessageTypeKey<>(EncodeConstants.OF13_VERSION_ID, GroupModInput.class));
  61             serializer.serialize((GroupMod)message, outBuffer);
  62         } else if (clazz.equals(BundlePortModCase.class)) {
  63             OFSerializer<PortMod> serializer = serializerRegistry.getSerializer(
  64                     new MessageTypeKey<>(EncodeConstants.OF13_VERSION_ID, PortModInput.class));
  65             serializer.serialize((PortMod)message, outBuffer);
  66         }
  67     }
  68
  69     private static int paddingNeeded(final int length) {
  70         int paddingRemainder = length % EncodeConstants.PADDING;
  71         return (paddingRemainder != 0) ? (EncodeConstants.PADDING - paddingRemainder) : 0;
  72     }
  73
  74 }