openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/action/OF13SetFieldActionSerializer.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 package org.opendaylight.openflowjava.protocol.impl.serialization.action;
   9
  10 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
  11 import io.netty.buffer.ByteBuf;
  12 import java.util.Objects;
  13 import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderSerializer;
  14 import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;
  15 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
  16 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistryInjector;
  17 import org.opendaylight.openflowjava.protocol.api.keys.MatchEntrySerializerKey;
  18 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  19 import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev150225.experimenter.id.match.entry.ExperimenterIdCase;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetFieldCase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.Action;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.ExperimenterClass;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
  25
  26 /**
  27  * Serializes OF 1.3 SetField actions.
  28  *
  29  * @author michal.polkorab
  30  */
  31 public class OF13SetFieldActionSerializer implements OFSerializer<Action>,
  32         HeaderSerializer<Action>, SerializerRegistryInjector {
  33
  34     private SerializerRegistry registry;
  35
  36     @Override
  37     @SuppressFBWarnings("UWF_FIELD_NOT_INITIALIZED_IN_CONSTRUCTOR") // FB doesn't recognize Objects.requireNonNull
  38     public void serialize(final Action action, final ByteBuf outBuffer) {
  39         Objects.requireNonNull(registry);
  40
  41         final int startIndex = outBuffer.writerIndex();
  42         outBuffer.writeShort(ActionConstants.SET_FIELD_CODE);
  43         final int lengthIndex = outBuffer.writerIndex();
  44         outBuffer.writeShort(EncodeConstants.EMPTY_LENGTH);
  45         MatchEntry entry = ((SetFieldCase) action.getActionChoice()).getSetFieldAction()
  46                 .getMatchEntry().get(0);
  47         MatchEntrySerializerKey<?, ?> key = new MatchEntrySerializerKey<>(
  48                 EncodeConstants.OF_VERSION_1_3, entry.getOxmClass(), entry.getOxmMatchField());
  49         if (entry.getOxmClass().equals(ExperimenterClass.class)) {
  50             ExperimenterIdCase experimenterIdCase = (ExperimenterIdCase) entry.getMatchEntryValue();
  51             key.setExperimenterId(experimenterIdCase.getExperimenter().getExperimenter().getValue());
  52         } else {
  53             key.setExperimenterId(null);
  54         }
  55         OFSerializer<MatchEntry> serializer = registry.getSerializer(key);
  56         serializer.serialize(entry, outBuffer);
  57         int paddingRemainder = (outBuffer.writerIndex() - startIndex) % EncodeConstants.PADDING;
  58         if (paddingRemainder != 0) {
  59             outBuffer.writeZero(EncodeConstants.PADDING - paddingRemainder);
  60         }
  61         outBuffer.setShort(lengthIndex, outBuffer.writerIndex() - startIndex);
  62     }
  63
  64     @Override
  65     public void serializeHeader(final Action input, final ByteBuf outBuffer) {
  66         outBuffer.writeShort(ActionConstants.SET_FIELD_CODE);
  67         outBuffer.writeShort(ActionConstants.ACTION_IDS_LENGTH);
  68     }
  69
  70     @Override
  71     public void injectSerializerRegistry(final SerializerRegistry serializerRegistry) {
  72         registry = serializerRegistry;
  73     }
  74 }