openflow-extension-nicira/src/main/java/org/opendaylight/openflowjava/nx/codec/action/ActionDeserializer.java

   1 package org.opendaylight.openflowjava.nx.codec.action;
   2
   3 import io.netty.buffer.ByteBuf;
   4
   5 import org.opendaylight.openflowjava.nx.NiciraConstants;
   6 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
   7 import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterActionDeserializerKey;
   8 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterIdAction;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev131002.ExperimenterIdActionBuilder;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.Experimenter;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.Action;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.actions.grouping.ActionBuilder;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ExperimenterId;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.extension.nicira.action.rev140421.NxmNxRegLoad;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.extension.nicira.action.rev140421.NxmNxRegMove;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.extension.nicira.action.rev140421.OfjAugNxAction;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.extension.nicira.action.rev140421.OfjAugNxActionBuilder;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 public class ActionDeserializer implements OFDeserializer<Action> {
  23
  24     private static final Logger LOG = LoggerFactory.getLogger(ActionDeserializer.class);
  25
  26     public static final ExperimenterActionDeserializerKey DESERIALIZER_KEY = new ExperimenterActionDeserializerKey(
  27             EncodeConstants.OF13_VERSION_ID, NiciraConstants.NX_VENDOR_ID);
  28
  29     @Override
  30     public Action deserialize(ByteBuf message) {
  31         // size of experimenter type
  32         message.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
  33         // size of length
  34         message.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
  35         ExperimenterIdActionBuilder expIdBuilder = new ExperimenterIdActionBuilder();
  36         expIdBuilder.setExperimenter(new ExperimenterId(message.readUnsignedInt()));
  37         int subtype = message.readUnsignedShort();
  38         OfjAugNxActionBuilder augNxActionBuilder = new OfjAugNxActionBuilder();
  39         switch (subtype) {
  40         case RegMoveCodec.SUBTYPE:
  41             augNxActionBuilder.setActionRegMove(NiciraActionCodecs.REG_MOVE_CODEC.deserialize(message));
  42             expIdBuilder.setSubType(NxmNxRegMove.class);
  43             break;
  44         case RegLoadCodec.SUBTYPE:
  45             augNxActionBuilder.setActionRegLoad(NiciraActionCodecs.REG_LOAD_CODEC.deserialize(message));
  46             expIdBuilder.setSubType(NxmNxRegLoad.class);
  47             break;
  48         default:
  49             LOG.info("Action {} does not have any deserializer.", subtype);
  50             return null;
  51         }
  52         ActionBuilder actionBuilder = new ActionBuilder();
  53         actionBuilder.setType(Experimenter.class);
  54         actionBuilder.addAugmentation(ExperimenterIdAction.class, expIdBuilder.build());
  55         actionBuilder.addAugmentation(OfjAugNxAction.class, augNxActionBuilder.build());
  56         return actionBuilder.build();
  57     }
  58
  59 }