openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/MultipartRequestInputFactory.java

   1 /*
   2  * Copyright (c) 2013 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.openflowjava.protocol.impl.serialization.factories;
  10
  11 import io.netty.buffer.ByteBuf;
  12
  13 import java.util.HashMap;
  14 import java.util.List;
  15 import java.util.Map;
  16
  17 import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;
  18 import org.opendaylight.openflowjava.protocol.impl.util.ActionsSerializer;
  19 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;
  20 import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;
  21 import org.opendaylight.openflowjava.protocol.impl.util.InstructionsSerializer;
  22 import org.opendaylight.openflowjava.protocol.impl.util.MatchSerializer;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ActionRelatedTableFeatureProperty;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterRelatedTableFeatureProperty;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.InstructionRelatedTableFeatureProperty;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.NextTableRelatedTableFeatureProperty;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.OxmRelatedTableFeatureProperty;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.table.features.properties.container.table.feature.properties.NextTableIds;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.ActionsList;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.Instructions;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableConfig;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableFeaturesPropType;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.oxm.fields.MatchEntries;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCase;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDescCase;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterCase;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlowCase;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupCase;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupDescCase;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupFeaturesCase;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterCase;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterConfigCase;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterFeaturesCase;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortDescCase;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCase;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCase;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableCase;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableFeaturesCase;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.aggregate._case.MultipartRequestAggregate;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.experimenter._case.MultipartRequestExperimenter;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.flow._case.MultipartRequestFlow;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.group._case.MultipartRequestGroup;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter._case.MultipartRequestMeter;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter.config._case.MultipartRequestMeterConfig;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStats;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueue;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table.features._case.MultipartRequestTableFeatures;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table.features._case.multipart.request.table.features.TableFeatures;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.TableFeatureProperties;
  64
  65 /**
  66  * Translates MultipartRequest messages
  67  * @author timotej.kubas
  68  * @author michal.polkorab
  69  */
  70 public class MultipartRequestInputFactory implements OFSerializer<MultipartRequestInput> {
  71     private static final byte MESSAGE_TYPE = 18;
  72     private static final int MESSAGE_LENGTH = 16;
  73     private static final byte PADDING_IN_MULTIPART_REQUEST_MESSAGE = 4;
  74     private static final byte TABLE_FEAT_HEADER_LENGTH = 4;
  75     private static MultipartRequestInputFactory instance;
  76     private static final byte INSTRUCTIONS_CODE = 0;
  77     private static final byte INSTRUCTIONS_MISS_CODE = 1;
  78     private static final byte NEXT_TABLE_CODE = 2;
  79     private static final byte NEXT_TABLE_MISS_CODE = 3;
  80     private static final byte WRITE_ACTIONS_CODE = 4;
  81     private static final byte WRITE_ACTIONS_MISS_CODE = 5;
  82     private static final byte APPLY_ACTIONS_CODE = 6;
  83     private static final byte APPLY_ACTIONS_MISS_CODE = 7;
  84     private static final byte MATCH_CODE = 8;
  85     private static final byte WILDCARDS_CODE = 10;
  86     private static final byte WRITE_SETFIELD_CODE = 12;
  87     private static final byte WRITE_SETFIELD_MISS_CODE = 13;
  88     private static final byte APPLY_SETFIELD_CODE = 14;
  89     private static final byte APPLY_SETFIELD_MISS_CODE = 15;
  90     private static final int EXPERIMENTER_CODE = 65534; // 0xFFFE
  91     private static final int EXPERIMENTER_MISS_CODE = 65535; // 0xFFFF
  92     private static final byte FLOW_BODY_LENGTH = 32;
  93     private static final byte AGGREGATE_BODY_LENGTH = 32;
  94     private static final byte PORT_STATS_BODY_LENGTH = 8;
  95     private static final byte QUEUE_BODY_LENGTH = 8;
  96     private static final byte GROUP_BODY_LENGTH = 8;
  97     private static final byte METER_BODY_LENGTH = 8;
  98     private static final byte METER_CONFIG_BODY_LENGTH = 8;
  99     private static final byte EXPERIMENTER_BODY_LENGTH = 8;
 100     private static final byte TABLE_FEATURES_LENGTH = 64;
 101     private static final byte STRUCTURE_HEADER_LENGTH = 4;
 102     private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_01 = 3;
 103     private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_02 = 4;
 104     private static final byte PADDING_IN_MULTIPART_REQUEST_AGREGGATE_BODY_01 = 3;
 105     private static final byte PADDING_IN_MULTIPART_REQUEST_AGREGGATE_BODY_02 = 4;
 106     private static final byte PADDING_IN_MULTIPART_REQUEST_PORTSTATS_BODY = 4;
 107     private static final byte PADDING_IN_MULTIPART_REQUEST_GROUP_BODY = 4;
 108     private static final byte PADDING_IN_MULTIPART_REQUEST_METER_BODY = 4;
 109     private static final byte PADDING_IN_MULTIPART_REQUEST_METER_CONFIG_BODY = 4;
 110     private static final byte PADDING_IN_MULTIPART_REQUEST_TABLE_FEATURES_BODY = 5;
 111
 112
 113
 114     private MultipartRequestInputFactory() {
 115         // singleton
 116     }
 117
 118     /**
 119      * @return singleton factory
 120      */
 121     public static synchronized MultipartRequestInputFactory getInstance() {
 122         if (instance == null) {
 123             instance = new MultipartRequestInputFactory();
 124         }
 125         return instance;
 126     }
 127
 128     @Override
 129     public void messageToBuffer(short version, ByteBuf out,
 130             MultipartRequestInput message) {
 131         ByteBufUtils.writeOFHeader(instance, message, out);
 132         out.writeShort(message.getType().getIntValue());
 133         out.writeShort(createMultipartRequestFlagsBitmask(message.getFlags()));
 134         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_MESSAGE, out);
 135
 136         if (message.getMultipartRequestBody() instanceof MultipartRequestDescCase){
 137             encodeDescBody(message.getMultipartRequestBody(), out);
 138         } else if (message.getMultipartRequestBody() instanceof MultipartRequestFlowCase) {
 139             encodeFlowBody(message.getMultipartRequestBody(), out);
 140         } else if (message.getMultipartRequestBody() instanceof MultipartRequestAggregateCase) {
 141             encodeAggregateBody(message.getMultipartRequestBody(), out);
 142         } else if (message.getMultipartRequestBody() instanceof MultipartRequestTableCase) {
 143             encodeTableBody(message.getMultipartRequestBody(), out);
 144         } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortStatsCase) {
 145             encodePortStatsBody(message.getMultipartRequestBody(), out);
 146         } else if (message.getMultipartRequestBody() instanceof MultipartRequestQueueCase) {
 147             encodeQueueBody(message.getMultipartRequestBody(), out);
 148         } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroupCase) {
 149             encodeGroupStatsBody(message.getMultipartRequestBody(), out);
 150         } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroupDescCase) {
 151             encodeGroupDescBody(message.getMultipartRequestBody(), out);
 152         } else if (message.getMultipartRequestBody() instanceof MultipartRequestGroupFeaturesCase) {
 153             encodeGroupFeaturesBody(message.getMultipartRequestBody(), out);
 154         } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeterCase) {
 155             encodeMeterBody(message.getMultipartRequestBody(), out);
 156         } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeterConfigCase) {
 157             encodeMeterConfigBody(message.getMultipartRequestBody(), out);
 158         } else if (message.getMultipartRequestBody() instanceof MultipartRequestMeterFeaturesCase) {
 159             encodeMeterFeaturesBody(message.getMultipartRequestBody(), out);
 160         } else if (message.getMultipartRequestBody() instanceof MultipartRequestTableFeaturesCase) {
 161             encodeTableFeaturesBody(message.getMultipartRequestBody(), out);
 162         } else if (message.getMultipartRequestBody() instanceof MultipartRequestPortDescCase) {
 163             encodePortDescBody(message.getMultipartRequestBody(), out);
 164         } else if (message.getMultipartRequestBody() instanceof MultipartRequestExperimenterCase) {
 165             encodeExperimenterBody(message.getMultipartRequestBody(), out);
 166         }
 167     }
 168
 169     @Override
 170     public int computeLength(MultipartRequestInput message) {
 171         return MESSAGE_LENGTH + computeBodyLength(message);
 172     }
 173     @Override
 174     public byte getMessageType() {
 175         return MESSAGE_TYPE;
 176     }
 177
 178     /**
 179      *
 180      * @param message
 181      * @return length of MultipartRequestMessage
 182      */
 183     public int computeBodyLength(MultipartRequestInput message) {
 184         int length = 0;
 185         MultipartType type = message.getType();
 186         if (type.equals(MultipartType.OFPMPFLOW)) {
 187             MultipartRequestFlowCase bodyCase = (MultipartRequestFlowCase) message.getMultipartRequestBody();
 188             MultipartRequestFlow body = bodyCase.getMultipartRequestFlow();
 189             length += FLOW_BODY_LENGTH + MatchSerializer.computeMatchLength(body.getMatch());
 190         } else if (type.equals(MultipartType.OFPMPAGGREGATE)) {
 191             MultipartRequestAggregateCase bodyCase = (MultipartRequestAggregateCase) message.getMultipartRequestBody();
 192             MultipartRequestAggregate body = bodyCase.getMultipartRequestAggregate();
 193             length += AGGREGATE_BODY_LENGTH + MatchSerializer.computeMatchLength(body.getMatch());
 194         } else if (type.equals(MultipartType.OFPMPPORTSTATS)) {
 195             length += PORT_STATS_BODY_LENGTH;
 196         } else if (type.equals(MultipartType.OFPMPQUEUE)) {
 197             length += QUEUE_BODY_LENGTH;
 198         } else if (type.equals(MultipartType.OFPMPGROUP)) {
 199             length += GROUP_BODY_LENGTH;
 200         } else if (type.equals(MultipartType.OFPMPMETER)) {
 201             length += METER_BODY_LENGTH;
 202         } else if (type.equals(MultipartType.OFPMPMETERCONFIG)) {
 203             length += METER_CONFIG_BODY_LENGTH;
 204         } else if (type.equals(MultipartType.OFPMPTABLEFEATURES)) {
 205             MultipartRequestTableFeaturesCase bodyCase = (MultipartRequestTableFeaturesCase) message.getMultipartRequestBody();
 206             MultipartRequestTableFeatures body = bodyCase.getMultipartRequestTableFeatures();
 207             length += computeTableFeaturesLength(body);
 208         } else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {
 209             MultipartRequestExperimenterCase bodyCase = (MultipartRequestExperimenterCase) message.getMultipartRequestBody();
 210             MultipartRequestExperimenter body = bodyCase.getMultipartRequestExperimenter();
 211             length += EXPERIMENTER_BODY_LENGTH;
 212             if (body.getData() != null) {
 213                 length += body.getData().length;
 214             }
 215         }
 216         return length;
 217     }
 218
 219     private static int computeTableFeaturesLength(MultipartRequestTableFeatures body) {
 220         int length = 0;
 221         if (body != null && body.getTableFeatures() != null) {
 222             List<TableFeatures> tableFeatures = body.getTableFeatures();
 223             for (TableFeatures feature : tableFeatures) {
 224                 length += TABLE_FEATURES_LENGTH;
 225                 List<TableFeatureProperties> featureProperties = feature.getTableFeatureProperties();
 226                 if (featureProperties != null) {
 227                     for (TableFeatureProperties featProp : featureProperties) {
 228                         length += TABLE_FEAT_HEADER_LENGTH;
 229                         if (featProp.getAugmentation(InstructionRelatedTableFeatureProperty.class) != null) {
 230                             InstructionRelatedTableFeatureProperty property =
 231                                     featProp.getAugmentation(InstructionRelatedTableFeatureProperty.class);
 232                             length += property.getInstructions().size() * STRUCTURE_HEADER_LENGTH;
 233                         } else if (featProp.getAugmentation(NextTableRelatedTableFeatureProperty.class) != null) {
 234                             NextTableRelatedTableFeatureProperty property =
 235                                     featProp.getAugmentation(NextTableRelatedTableFeatureProperty.class);
 236                             length += property.getNextTableIds().size();
 237                         } else if (featProp.getAugmentation(ActionRelatedTableFeatureProperty.class) != null) {
 238                             ActionRelatedTableFeatureProperty property =
 239                                     featProp.getAugmentation(ActionRelatedTableFeatureProperty.class);
 240                             length += property.getActionsList().size() * STRUCTURE_HEADER_LENGTH;
 241                         } else if (featProp.getAugmentation(OxmRelatedTableFeatureProperty.class) != null) {
 242                             OxmRelatedTableFeatureProperty property =
 243                                     featProp.getAugmentation(OxmRelatedTableFeatureProperty.class);
 244                             length += property.getMatchEntries().size() * STRUCTURE_HEADER_LENGTH;
 245                         } else if (featProp.getAugmentation(ExperimenterRelatedTableFeatureProperty.class) != null) {
 246                             ExperimenterRelatedTableFeatureProperty property =
 247                                     featProp.getAugmentation(ExperimenterRelatedTableFeatureProperty.class);
 248                             length += 2 * (EncodeConstants.SIZE_OF_INT_IN_BYTES);
 249                             if (property.getData() != null) {
 250                                 length += property.getData().length;
 251                             }
 252                         }
 253                     }
 254                 }
 255             }
 256         }
 257         return length;
 258     }
 259
 260     private static int createMultipartRequestFlagsBitmask(MultipartRequestFlags flags) {
 261         int multipartRequestFlagsBitmask = 0;
 262         Map<Integer, Boolean> multipartRequestFlagsMap = new HashMap<>();
 263         multipartRequestFlagsMap.put(0, flags.isOFPMPFREQMORE());
 264
 265         multipartRequestFlagsBitmask = ByteBufUtils.fillBitMaskFromMap(multipartRequestFlagsMap);
 266         return multipartRequestFlagsBitmask;
 267     }
 268
 269     /**
 270      * @param multipartRequestBody
 271      * @param output
 272      */
 273     private void encodeDescBody(MultipartRequestBody multipartRequestBody,
 274             ByteBuf output) {
 275         // The body of MultiPartRequestDesc is empty
 276     }
 277
 278     /**
 279      * @param multipartRequestBody
 280      * @param out
 281      */
 282     private void encodeTableBody(MultipartRequestBody multipartRequestBody,
 283             ByteBuf out) {
 284      // The body of MultiPartTable is empty
 285     }
 286
 287     /**
 288      * @param multipartRequestBody
 289      * @param out
 290      */
 291     private void encodeGroupDescBody(MultipartRequestBody multipartRequestBody,
 292             ByteBuf out) {
 293      // The body of MultiPartRequestGroupDesc is empty
 294     }
 295
 296     /**
 297      * @param multipartRequestBody
 298      * @param out
 299      */
 300     private void encodeGroupFeaturesBody(
 301             MultipartRequestBody multipartRequestBody, ByteBuf out) {
 302      // The body of MultiPartRequestGroupFeatures is empty
 303     }
 304
 305     /**
 306      * @param multipartRequestBody
 307      * @param out
 308      */
 309     private void encodeMeterFeaturesBody(
 310             MultipartRequestBody multipartRequestBody, ByteBuf out) {
 311      // The body of MultiPartMeterFeatures is empty
 312     }
 313
 314     /**
 315      * @param multipartRequestBody
 316      * @param out
 317      */
 318     private void encodePortDescBody(MultipartRequestBody multipartRequestBody,
 319             ByteBuf out) {
 320      // The body of MultiPartPortDesc is empty
 321     }
 322
 323     private static void encodeFlowBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 324         MultipartRequestFlowCase flowCase = (MultipartRequestFlowCase) multipartRequestBody;
 325         MultipartRequestFlow flow = flowCase.getMultipartRequestFlow();
 326         output.writeByte(flow.getTableId().byteValue());
 327         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_01, output);
 328         output.writeInt(flow.getOutPort().intValue());
 329         output.writeInt(flow.getOutGroup().intValue());
 330         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_02, output);
 331         output.writeLong(flow.getCookie().longValue());
 332         output.writeLong(flow.getCookieMask().longValue());
 333         MatchSerializer.encodeMatch(flow.getMatch(), output);
 334     }
 335
 336     private static void encodeAggregateBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 337         MultipartRequestAggregateCase aggregateCase = (MultipartRequestAggregateCase) multipartRequestBody;
 338         MultipartRequestAggregate aggregate = aggregateCase.getMultipartRequestAggregate();
 339         output.writeByte(aggregate.getTableId().byteValue());
 340         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_AGREGGATE_BODY_01, output);
 341         output.writeInt(aggregate.getOutPort().intValue());
 342         output.writeInt(aggregate.getOutGroup().intValue());
 343         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_AGREGGATE_BODY_02, output);
 344         output.writeLong(aggregate.getCookie().longValue());
 345         output.writeLong(aggregate.getCookieMask().longValue());
 346         MatchSerializer.encodeMatch(aggregate.getMatch(), output);
 347     }
 348
 349     private static void encodePortStatsBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 350         MultipartRequestPortStatsCase portstatsCase = (MultipartRequestPortStatsCase) multipartRequestBody;
 351         MultipartRequestPortStats portstats = portstatsCase.getMultipartRequestPortStats();
 352         output.writeInt(portstats.getPortNo().intValue());
 353         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_PORTSTATS_BODY, output);
 354     }
 355
 356     private static void encodeQueueBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 357         MultipartRequestQueueCase queueCase = (MultipartRequestQueueCase) multipartRequestBody;
 358         MultipartRequestQueue queue = queueCase.getMultipartRequestQueue();
 359         output.writeInt(queue.getPortNo().intValue());
 360         output.writeInt(queue.getQueueId().intValue());
 361     }
 362
 363     private static void encodeGroupStatsBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 364         MultipartRequestGroupCase groupStatsCase = (MultipartRequestGroupCase) multipartRequestBody;
 365         MultipartRequestGroup groupStats = groupStatsCase.getMultipartRequestGroup();
 366         output.writeInt(groupStats.getGroupId().getValue().intValue());
 367         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_GROUP_BODY, output);
 368     }
 369
 370     private static void encodeMeterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 371         MultipartRequestMeterCase meterCase = (MultipartRequestMeterCase) multipartRequestBody;
 372         MultipartRequestMeter meter = meterCase.getMultipartRequestMeter();
 373         output.writeInt(meter.getMeterId().getValue().intValue());
 374         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_METER_BODY, output);
 375     }
 376
 377     private static void encodeMeterConfigBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 378         MultipartRequestMeterConfigCase meterConfigCase = (MultipartRequestMeterConfigCase) multipartRequestBody;
 379         MultipartRequestMeterConfig meterConfig = meterConfigCase.getMultipartRequestMeterConfig();
 380         output.writeInt(meterConfig.getMeterId().getValue().intValue());
 381         ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_METER_CONFIG_BODY, output);
 382     }
 383
 384     private static void encodeExperimenterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 385         MultipartRequestExperimenterCase experimenterCase = (MultipartRequestExperimenterCase) multipartRequestBody;
 386         MultipartRequestExperimenter experimenter = experimenterCase.getMultipartRequestExperimenter();
 387         output.writeInt(experimenter.getExperimenter().intValue());
 388         output.writeInt(experimenter.getExpType().intValue());
 389         byte[] data = experimenter.getData();
 390         if (data != null) {
 391             output.writeBytes(data);
 392         }
 393     }
 394
 395     private static void encodeTableFeaturesBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {
 396         if (multipartRequestBody != null) {
 397             MultipartRequestTableFeaturesCase tableFeaturesCase = (MultipartRequestTableFeaturesCase) multipartRequestBody;
 398             MultipartRequestTableFeatures tableFeatures = tableFeaturesCase.getMultipartRequestTableFeatures();
 399             if(tableFeatures.getTableFeatures() != null) {
 400                 for (TableFeatures currTableFeature : tableFeatures.getTableFeatures()) {
 401                     output.writeByte(currTableFeature.getTableId());
 402                     ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_TABLE_FEATURES_BODY, output);
 403                     output.writeBytes(currTableFeature.getName().getBytes());
 404                     ByteBufUtils.padBuffer((32 - currTableFeature.getName().getBytes().length), output);
 405                     output.writeLong(currTableFeature.getMetadataMatch().longValue());
 406                     output.writeLong(currTableFeature.getMetadataWrite().longValue());
 407                     output.writeInt(createTableConfigBitmask(currTableFeature.getConfig()));
 408                     output.writeInt(currTableFeature.getMaxEntries().intValue());
 409                     writeTableFeatureProperties(output, currTableFeature.getTableFeatureProperties());
 410                 }
 411             }
 412         }
 413     }
 414
 415     private static void writeTableFeatureProperties(ByteBuf output, List<TableFeatureProperties> props) {
 416         if (props != null) {
 417             for (TableFeatureProperties property : props) {
 418                 TableFeaturesPropType type = property.getType();
 419                 if (type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONS)) {
 420                     writeInstructionRelatedTableProperty(output, property, INSTRUCTIONS_CODE);
 421                 } else if (type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONSMISS)) {
 422                     writeInstructionRelatedTableProperty(output, property, INSTRUCTIONS_MISS_CODE);
 423                 } else if (type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLES)) {
 424                     writeNextTableRelatedTableProperty(output, property, NEXT_TABLE_CODE);
 425                 } else if (type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLESMISS)) {
 426                     writeNextTableRelatedTableProperty(output, property, NEXT_TABLE_MISS_CODE);
 427                 } else if (type.equals(TableFeaturesPropType.OFPTFPTWRITEACTIONS)) {
 428                     writeActionsRelatedTableProperty(output, property, WRITE_ACTIONS_CODE);
 429                 } else if (type.equals(TableFeaturesPropType.OFPTFPTWRITEACTIONSMISS)) {
 430                     writeActionsRelatedTableProperty(output, property, WRITE_ACTIONS_MISS_CODE);
 431                 } else if (type.equals(TableFeaturesPropType.OFPTFPTAPPLYACTIONS)) {
 432                     writeActionsRelatedTableProperty(output, property, APPLY_ACTIONS_CODE);
 433                 } else if (type.equals(TableFeaturesPropType.OFPTFPTAPPLYACTIONSMISS)) {
 434                     writeActionsRelatedTableProperty(output, property, APPLY_ACTIONS_MISS_CODE);
 435                 } else if (type.equals(TableFeaturesPropType.OFPTFPTMATCH)) {
 436                     writeOxmRelatedTableProperty(output, property, MATCH_CODE);
 437                 } else if (type.equals(TableFeaturesPropType.OFPTFPTWILDCARDS)) {
 438                     writeOxmRelatedTableProperty(output, property, WILDCARDS_CODE);
 439                 } else if (type.equals(TableFeaturesPropType.OFPTFPTWRITESETFIELD)) {
 440                     writeOxmRelatedTableProperty(output, property, WRITE_SETFIELD_CODE);
 441                 } else if (type.equals(TableFeaturesPropType.OFPTFPTWRITESETFIELDMISS)) {
 442                     writeOxmRelatedTableProperty(output, property, WRITE_SETFIELD_MISS_CODE);
 443                 } else if (type.equals(TableFeaturesPropType.OFPTFPTAPPLYSETFIELD)) {
 444                     writeOxmRelatedTableProperty(output, property, APPLY_SETFIELD_CODE);
 445                 } else if (type.equals(TableFeaturesPropType.OFPTFPTAPPLYSETFIELDMISS)) {
 446                     writeOxmRelatedTableProperty(output, property, APPLY_SETFIELD_MISS_CODE);
 447                 } else if (type.equals(TableFeaturesPropType.OFPTFPTEXPERIMENTER)) {
 448                     writeExperimenterRelatedTableProperty(output, property, EXPERIMENTER_CODE);
 449                 } else if (type.equals(TableFeaturesPropType.OFPTFPTEXPERIMENTERMISS)) {
 450                     writeExperimenterRelatedTableProperty(output, property, EXPERIMENTER_MISS_CODE);
 451                 }
 452             }
 453         }
 454     }
 455
 456     private static void writeInstructionRelatedTableProperty(ByteBuf output,
 457             TableFeatureProperties property, byte code) {
 458         output.writeShort(code);
 459         List<Instructions> instructions = property.
 460                 getAugmentation(InstructionRelatedTableFeatureProperty.class).getInstructions();
 461         int length = TABLE_FEAT_HEADER_LENGTH;
 462         if (instructions != null) {
 463         output.writeShort(InstructionsSerializer.computeInstructionsLength(instructions)
 464                 + TABLE_FEAT_HEADER_LENGTH);
 465         InstructionsSerializer.encodeInstructions(instructions, output);
 466         } else {
 467             output.writeShort(length);
 468         }
 469     }
 470
 471     private static void writeNextTableRelatedTableProperty(ByteBuf output,
 472             TableFeatureProperties property, byte code) {
 473         output.writeShort(code);
 474         List<NextTableIds> nextTableIds = property.
 475                 getAugmentation(NextTableRelatedTableFeatureProperty.class).getNextTableIds();
 476         int length = TABLE_FEAT_HEADER_LENGTH;
 477         if (nextTableIds != null) {
 478             output.writeShort(length + nextTableIds.size());
 479             for (NextTableIds next : nextTableIds) {
 480                 output.writeByte(next.getTableId());
 481             }
 482         } else {
 483             output.writeShort(length);
 484         }
 485     }
 486
 487     private static void writeActionsRelatedTableProperty(ByteBuf output,
 488             TableFeatureProperties property, byte code) {
 489         output.writeShort(code);
 490         List<ActionsList> actions = property.
 491                 getAugmentation(ActionRelatedTableFeatureProperty.class).getActionsList();
 492         int length = TABLE_FEAT_HEADER_LENGTH;
 493         if (actions != null) {
 494         output.writeShort(ActionsSerializer.computeLengthOfActions(actions)
 495                 + TABLE_FEAT_HEADER_LENGTH);
 496         ActionsSerializer.encodeActions(actions, output);
 497         } else {
 498             output.writeShort(length);
 499         }
 500     }
 501
 502     private static void writeOxmRelatedTableProperty(ByteBuf output,
 503             TableFeatureProperties property, byte code) {
 504         output.writeShort(code);
 505         List<MatchEntries> entries = property.
 506                 getAugmentation(OxmRelatedTableFeatureProperty.class).getMatchEntries();
 507         int length = TABLE_FEAT_HEADER_LENGTH;
 508         if (entries != null) {
 509         output.writeShort(MatchSerializer.computeMatchEntriesLength(entries)
 510                 + TABLE_FEAT_HEADER_LENGTH);
 511         MatchSerializer.encodeMatchEntries(entries, output);
 512         } else {
 513             output.writeShort(length);
 514         }
 515     }
 516
 517     private static void writeExperimenterRelatedTableProperty(ByteBuf output,
 518             TableFeatureProperties property, int code) {
 519         output.writeShort(code);
 520         ExperimenterRelatedTableFeatureProperty exp = property.
 521                 getAugmentation(ExperimenterRelatedTableFeatureProperty.class);
 522         byte[] data = exp.getData();
 523         int length = TABLE_FEAT_HEADER_LENGTH + 2 * (EncodeConstants.SIZE_OF_INT_IN_BYTES);
 524         if (data != null) {
 525             output.writeShort(length + data.length);
 526             output.writeInt(exp.getExperimenter().intValue());
 527             output.writeInt(exp.getExpType().intValue());
 528             output.writeBytes(data);
 529         } else {
 530             output.writeShort(length);
 531             output.writeInt(exp.getExperimenter().intValue());
 532             output.writeInt(exp.getExpType().intValue());
 533         }
 534     }
 535
 536     private static int createTableConfigBitmask(TableConfig tableConfig) {
 537         int tableConfigBitmask = 0;
 538         Map<Integer, Boolean> tableConfigMap = new HashMap<>();
 539         tableConfigMap.put(3, tableConfig.isOFPTCDEPRECATEDMASK());
 540
 541         tableConfigBitmask = ByteBufUtils.fillBitMaskFromMap(tableConfigMap);
 542         return tableConfigBitmask;
 543     }
 544 }