package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * Base class for action deserializers.
*
+ * @author michal.polkorab
*/
public abstract class AbstractActionDeserializer implements OFDeserializer<Action>,
HeaderDeserializer<Action> {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueId;
/**
- * @author michal.polkorab
+ * OF10EnqueueActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10EnqueueActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
- EnqueueCaseBuilder caseBuilder = new EnqueueCaseBuilder();
+ final EnqueueCaseBuilder caseBuilder = new EnqueueCaseBuilder();
EnqueueActionBuilder actionBuilder = new EnqueueActionBuilder();
actionBuilder.setPort(new PortNumber((long) input.readUnsignedShort()));
input.skipBytes(ActionConstants.PADDING_IN_ENQUEUE_ACTION);
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.OutputActionCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
/**
- * @author michal.polkorab
+ * OF10OutputActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10OutputActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
OutputActionCaseBuilder caseBuilder = new OutputActionCaseBuilder();
OutputActionBuilder actionBuilder = new OutputActionBuilder();
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetDlDstActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetDlDstActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(final ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetDlDstCaseBuilder caseBuilder = new SetDlDstCaseBuilder();
SetDlDstActionBuilder actionBuilder = new SetDlDstActionBuilder();
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetDlSrcActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetDlSrcActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(final ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetDlSrcCaseBuilder caseBuilder = new SetDlSrcCaseBuilder();
SetDlSrcActionBuilder actionBuilder = new SetDlSrcActionBuilder();
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetNwDstActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetNwDstActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(final ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetNwDstCaseBuilder caseBuilder = new SetNwDstCaseBuilder();
SetNwDstActionBuilder actionBuilder = new SetNwDstActionBuilder();
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetNwSrcActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetNwSrcActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(final ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetNwSrcCaseBuilder caseBuilder = new SetNwSrcCaseBuilder();
SetNwSrcActionBuilder actionBuilder = new SetNwSrcActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetNwTosActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetNwTosActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetNwTosCaseBuilder caseBuilder = new SetNwTosCaseBuilder();
SetNwTosActionBuilder tosBuilder = new SetNwTosActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
/**
- * @author michal.polkorab
+ * OF10SetTpDstActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetTpDstActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetTpDstCaseBuilder caseBuilder = new SetTpDstCaseBuilder();
SetTpDstActionBuilder actionBuilder = new SetTpDstActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
/**
- * @author michal.polkorab
+ * OF10SetTpSrcActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetTpSrcActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetTpSrcCaseBuilder caseBuilder = new SetTpSrcCaseBuilder();
SetTpSrcActionBuilder actionBuilder = new SetTpSrcActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetVlanPcpActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetVlanPcpActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping
+ .ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetVlanPcpCaseBuilder caseBuilder = new SetVlanPcpCaseBuilder();
SetVlanPcpActionBuilder actionBuilder = new SetVlanPcpActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10SetVlanVidActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10SetVlanVidActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping
+ .ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetVlanVidCaseBuilder caseBuilder = new SetVlanVidCaseBuilder();
SetVlanVidActionBuilder actionBuilder = new SetVlanVidActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF10StripVlanActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF10StripVlanActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
builder.setActionChoice(getType());
input.skipBytes(ActionConstants.PADDING_IN_ACTION_HEADER);
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13CopyTtlInActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13CopyTtlInActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13CopyTtlOutActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13CopyTtlOutActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13DecMplsTtlActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13DecMplsTtlActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13DecNwTtlActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13DecNwTtlActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.GroupCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13GroupActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13GroupActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping
+ .ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
GroupCaseBuilder caseBuilder = new GroupCaseBuilder();
GroupActionBuilder actionBuilder = new GroupActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;
/**
- * @author michal.polkorab
+ * OF13OutputActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13OutputActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping
+ .ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
OutputActionCaseBuilder caseBuilder = new OutputActionCaseBuilder();
OutputActionBuilder actionBuilder = new OutputActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;
/**
- * @author michal.polkorab
+ * OF13PopMplsActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PopMplsActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
PopMplsCaseBuilder caseBuilder = new PopMplsCaseBuilder();
PopMplsActionBuilder mplsBuilder = new PopMplsActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13PopPbbActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PopPbbActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13PopVlanActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PopVlanActionDeserializer extends AbstractActionDeserializer {
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;
/**
- * @author michal.polkorab
+ * OF13PushMplsActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PushMplsActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
PushMplsCaseBuilder caseBuilder = new PushMplsCaseBuilder();
PushMplsActionBuilder mplsBuilder = new PushMplsActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;
/**
- * @author michal.polkorab
+ * OF13PushPbbActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PushPbbActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
PushPbbCaseBuilder caseBuilder = new PushPbbCaseBuilder();
PushPbbActionBuilder pbbBuilder = new PushPbbActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.EtherType;
/**
- * @author michal.polkorab
+ * OF13PushVlanActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13PushVlanActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
PushVlanCaseBuilder caseBuilder = new PushVlanCaseBuilder();
PushVlanActionBuilder vlanBuilder = new PushVlanActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import java.util.ArrayList;
import java.util.List;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntry;
/**
- * @author michal.polkorab
+ * OF13SetFieldActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13SetFieldActionDeserializer extends AbstractActionDeserializer
implements DeserializerRegistryInjector {
@Override
public Action deserialize(ByteBuf input) {
- org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder builder = new ActionBuilder();
- int startIndex = input.readerIndex();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping
+ .ActionBuilder builder = new ActionBuilder();
+ final int startIndex = input.readerIndex();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
- SetFieldCaseBuilder caseBuilder = new SetFieldCaseBuilder();
+ final SetFieldCaseBuilder caseBuilder = new SetFieldCaseBuilder();
SetFieldActionBuilder actionBuilder = new SetFieldActionBuilder();
int oxmClass = input.getUnsignedShort(input.readerIndex());
// get oxm_field & hasMask byte and extract the field value
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13SetMplsTtlActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13SetMplsTtlActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetMplsTtlCaseBuilder caseBuilder = new SetMplsTtlCaseBuilder();
SetMplsTtlActionBuilder actionBuilder = new SetMplsTtlActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.ActionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13SetNwTtlActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13SetNwTtlActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetNwTtlCaseBuilder caseBuilder = new SetNwTtlCaseBuilder();
SetNwTtlActionBuilder actionBuilder = new SetNwTtlActionBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.action;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.ActionChoice;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.action.grouping.action.choice.SetQueueCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.ActionBuilder;
/**
- * @author michal.polkorab
+ * OF13SetQueueActionDeserializer.
*
+ * @author michal.polkorab
*/
public class OF13SetQueueActionDeserializer extends AbstractActionDeserializer {
@Override
public Action deserialize(ByteBuf input) {
- ActionBuilder builder = new ActionBuilder();
+ final ActionBuilder builder = new ActionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
SetQueueCaseBuilder caseBuilder = new SetQueueCaseBuilder();
SetQueueActionBuilder actionBuilder = new SetQueueActionBuilder();
* OF protocol versions: 1.0, 1.3, 1.4, 1.5.
* @author giuseppex.petralia@intel.com
*/
-public class BarrierInputMessageFactory extends VersionAssignableFactory implements OFDeserializer<BarrierInput>{
+public class BarrierInputMessageFactory extends VersionAssignableFactory implements OFDeserializer<BarrierInput> {
@Override
public BarrierInput deserialize(ByteBuf rawMessage) {
* @author michal.polkorab
* @author timotej.kubas
*/
-public class EchoRequestMessageFactory extends VersionAssignableFactory implements OFDeserializer<EchoRequestMessage>{
+public class EchoRequestMessageFactory extends VersionAssignableFactory implements OFDeserializer<EchoRequestMessage> {
@Override
public EchoRequestMessage deserialize(ByteBuf rawMessage) {
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
/**
- * Translates Error messages
+ * Translates Error messages.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
int code = rawMessage.readUnsignedShort();
if (type != null) {
switch (type) {
- case HELLOFAILED:
- {
- HelloFailedCode errorCode = HelloFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case HELLOFAILED:
+ {
+ HelloFailedCode errorCode = HelloFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADREQUEST:
- {
- BadRequestCode errorCode = BadRequestCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADREQUEST:
+ {
+ BadRequestCode errorCode = BadRequestCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADACTION:
- {
- BadActionCode errorCode = BadActionCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADACTION:
+ {
+ BadActionCode errorCode = BadActionCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADINSTRUCTION:
- {
- BadInstructionCode errorCode = BadInstructionCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADINSTRUCTION:
+ {
+ BadInstructionCode errorCode = BadInstructionCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADMATCH:
- {
- BadMatchCode errorCode = BadMatchCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADMATCH:
+ {
+ BadMatchCode errorCode = BadMatchCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case FLOWMODFAILED:
- {
- FlowModFailedCode errorCode = FlowModFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case FLOWMODFAILED:
+ {
+ FlowModFailedCode errorCode = FlowModFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case GROUPMODFAILED:
- {
- GroupModFailedCode errorCode = GroupModFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case GROUPMODFAILED:
+ {
+ GroupModFailedCode errorCode = GroupModFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case PORTMODFAILED:
- {
- PortModFailedCode errorCode = PortModFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case PORTMODFAILED:
+ {
+ PortModFailedCode errorCode = PortModFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case TABLEMODFAILED:
- {
- TableModFailedCode errorCode = TableModFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case TABLEMODFAILED:
+ {
+ TableModFailedCode errorCode = TableModFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case QUEUEOPFAILED:
- {
- QueueOpFailedCode errorCode = QueueOpFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case QUEUEOPFAILED:
+ {
+ QueueOpFailedCode errorCode = QueueOpFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case SWITCHCONFIGFAILED:
- {
- SwitchConfigFailedCode errorCode = SwitchConfigFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case SWITCHCONFIGFAILED:
+ {
+ SwitchConfigFailedCode errorCode = SwitchConfigFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case ROLEREQUESTFAILED:
- {
- RoleRequestFailedCode errorCode = RoleRequestFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case ROLEREQUESTFAILED:
+ {
+ RoleRequestFailedCode errorCode = RoleRequestFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case METERMODFAILED:
- {
- MeterModFailedCode errorCode = MeterModFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case METERMODFAILED:
+ {
+ MeterModFailedCode errorCode = MeterModFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case TABLEFEATURESFAILED:
- {
- TableFeaturesFailedCode errorCode = TableFeaturesFailedCode.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case TABLEFEATURESFAILED:
+ {
+ TableFeaturesFailedCode errorCode = TableFeaturesFailedCode.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- default:
- setUnknownCode(builder, code);
- break;
+ default:
+ setUnknownCode(builder, code);
+ break;
}
} else {
setUnknownCode(builder, code);
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.experimenter.core.ExperimenterDataOfChoice;
/**
- * @author michal.polkorab
+ * Implementation of OFDeserializer for ExperimenterMessages.
*
+ * @author michal.polkorab
*/
public class ExperimenterMessageFactory implements OFDeserializer<ExperimenterMessage>,
DeserializerRegistryInjector {
}
@Override
- public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
- this.deserializerRegistry = deserializerRegistry;
+ public void injectDeserializerRegistry(DeserializerRegistry registry) {
+ this.deserializerRegistry = registry;
}
-}
\ No newline at end of file
+}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.math.BigInteger;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.Capabilities;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutputBuilder;
/**
- * Translates FeaturesReply messages
+ * Translates FeaturesReply messages.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
-public class FeaturesReplyMessageFactory implements OFDeserializer<GetFeaturesOutput>{
+public class FeaturesReplyMessageFactory implements OFDeserializer<GetFeaturesOutput> {
private static final byte PADDING_IN_FEATURES_REPLY_HEADER = 2;
}
private static Capabilities createCapabilities(long input) {
- final Boolean flowStats = (input & (1 << 0)) != 0;
- final Boolean tableStats = (input & (1 << 1)) != 0;
- final Boolean portStats = (input & (1 << 2)) != 0;
- final Boolean groupStats = (input & (1 << 3)) != 0;
- final Boolean ipReasm = (input & (1 << 5)) != 0;
- final Boolean queueStats = (input & (1 << 6)) != 0;
- final Boolean portBlocked = (input & (1 << 8)) != 0;
+ final Boolean flowStats = (input & 1 << 0) != 0;
+ final Boolean tableStats = (input & 1 << 1) != 0;
+ final Boolean portStats = (input & 1 << 2) != 0;
+ final Boolean groupStats = (input & 1 << 3) != 0;
+ final Boolean ipReasm = (input & 1 << 5) != 0;
+ final Boolean queueStats = (input & 1 << 6) != 0;
+ final Boolean portBlocked = (input & 1 << 8) != 0;
return new Capabilities(flowStats, groupStats, ipReasm,
portBlocked, portStats, queueStats, tableStats);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInputBuilder;
/**
- * Translates FlowModInput messages
+ * Translates FlowModInput messages.
*/
public class FlowModInputMessageFactory implements OFDeserializer<FlowModInput>, DeserializerRegistryInjector {
byte[] cookie = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
rawMessage.readBytes(cookie);
builder.setCookie(new BigInteger(1, cookie));
- byte[] cookie_mask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
- rawMessage.readBytes(cookie_mask);
- builder.setCookieMask(new BigInteger(1, cookie_mask));
+ final byte[] cookieMask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
+ rawMessage.readBytes(cookieMask);
+ builder.setCookieMask(new BigInteger(1, cookieMask));
builder.setTableId(new TableId((long) rawMessage.readUnsignedByte()));
builder.setCommand(FlowModCommand.forValue(rawMessage.readUnsignedByte()));
builder.setIdleTimeout(rawMessage.readUnsignedShort());
return builder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static FlowModFlags createFlowModFlagsFromBitmap(int input) {
- final Boolean _oFPFFSENDFLOWREM = (input & (1 << 0)) > 0;
- final Boolean _oFPFFCHECKOVERLAP = (input & (1 << 1)) > 0;
- final Boolean _oFPFFRESETCOUNTS = (input & (1 << 2)) > 0;
- final Boolean _oFPFFNOPKTCOUNTS = (input & (1 << 3)) > 0;
- final Boolean _oFPFFNOBYTCOUNTS = (input & (1 << 4)) > 0;
+ final Boolean _oFPFFSENDFLOWREM = (input & 1 << 0) > 0;
+ final Boolean _oFPFFCHECKOVERLAP = (input & 1 << 1) > 0;
+ final Boolean _oFPFFRESETCOUNTS = (input & 1 << 2) > 0;
+ final Boolean _oFPFFNOPKTCOUNTS = (input & 1 << 3) > 0;
+ final Boolean _oFPFFNOBYTCOUNTS = (input & 1 << 4) > 0;
return new FlowModFlags(_oFPFFCHECKOVERLAP, _oFPFFNOBYTCOUNTS, _oFPFFNOPKTCOUNTS, _oFPFFRESETCOUNTS,
_oFPFFSENDFLOWREM);
}
public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
registry = deserializerRegistry;
}
-}
\ No newline at end of file
+}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.math.BigInteger;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessageBuilder;
/**
- * Translates FlowRemoved messages
+ * Translates FlowRemoved messages.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.util.ArrayList;
import java.util.List;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowRemovedReason;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMaskBuilder;
/**
- * Translates GetAsyncReply messages
+ * Translates GetAsyncReply messages.
+ *
* @author timotej.kubas
* @author michal.polkorab
*/
private static List<PacketInReason> decodePacketInReasons(long input) {
List<PacketInReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(PacketInReason.OFPRNOMATCH);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(PacketInReason.OFPRACTION);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(PacketInReason.OFPRINVALIDTTL);
}
return reasons;
private static List<PortReason> decodePortReasons(long input) {
List<PortReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(PortReason.OFPPRADD);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(PortReason.OFPPRDELETE);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(PortReason.OFPPRMODIFY);
}
return reasons;
private static List<FlowRemovedReason> decodeFlowRemovedReasons(long input) {
List<FlowRemovedReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(FlowRemovedReason.OFPRRIDLETIMEOUT);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(FlowRemovedReason.OFPRRHARDTIMEOUT);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(FlowRemovedReason.OFPRRDELETE);
}
- if ((input & (1 << 3)) != 0) {
+ if ((input & 1 << 3) != 0) {
reasons.add(FlowRemovedReason.OFPRRGROUPDELETE);
}
return reasons;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetAsyncInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates GetAsyncRequest messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class GetAsyncRequestMessageFactory implements OFDeserializer<GetAsyncInput> {
public GetAsyncInput deserialize(ByteBuf rawMessage) {
GetAsyncInputBuilder builder = new GetAsyncInputBuilder();
builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
return builder.build();
}
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates GetQueueConfigInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class GetQueueConfigInputMessageFactory implements OFDeserializer<GetQueueConfigInput> {
public GetQueueConfigInput deserialize(ByteBuf rawMessage) {
GetQueueConfigInputBuilder builder = new GetQueueConfigInputBuilder();
builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
builder.setPort(new PortNumber(rawMessage.readUnsignedInt()));
return builder.build();
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.buckets.grouping.BucketsListBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates GroupModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class GroupModInputMessageFactory implements OFDeserializer<GroupModInput>, DeserializerRegistryInjector {
List<BucketsList> bucketsList = new ArrayList<>();
while (rawMessage.readableBytes() > 0) {
BucketsListBuilder bucketsBuilder = new BucketsListBuilder();
- int bucketsLength = rawMessage.readUnsignedShort();
+ final int bucketsLength = rawMessage.readUnsignedShort();
bucketsBuilder.setWeight(rawMessage.readUnsignedShort());
bucketsBuilder.setWatchPort(new PortNumber(rawMessage.readUnsignedInt()));
bucketsBuilder.setWatchGroup(rawMessage.readUnsignedInt());
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.hello.ElementsBuilder;
/**
- * Translates Hello messages.
- * OF protocol versions: 1.3, 1.4, 1.5.
+ * Translates Hello messages. OF protocol versions: 1.3, 1.4, 1.5.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
return elementsList;
}
- private static List<Boolean> readVersionBitmap(int[] input){
+ private static List<Boolean> readVersionBitmap(int[] input) {
List<Boolean> versionBitmapList = new ArrayList<>();
- for (int i = 0; i < input.length; i++) {
- int mask = input[i];
+ for (int mask : input) {
for (int j = 0; j < Integer.SIZE; j++) {
- versionBitmapList.add((mask & (1 << j)) != 0);
+ versionBitmapList.add((mask & 1 << j) != 0);
}
}
return versionBitmapList;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.mod.BandsBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates MeterModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class MeterModInputMessageFactory implements OFDeserializer<MeterModInput>, DeserializerRegistryInjector {
int bandStartIndex = rawMessage.readerIndex();
int bandType = rawMessage.readUnsignedShort();
switch (bandType) {
- case 1:
- MeterBandDropCaseBuilder bandDropCaseBuilder = new MeterBandDropCaseBuilder();
- MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();
- bandDropBuilder.setType(MeterBandType.forValue(bandType));
- rawMessage.readUnsignedShort();
- bandDropBuilder.setRate(rawMessage.readUnsignedInt());
- bandDropBuilder.setBurstSize(rawMessage.readUnsignedInt());
- rawMessage.skipBytes(PADDING_IN_METER_BAND_DROP_HEADER);
- bandDropCaseBuilder.setMeterBandDrop(bandDropBuilder.build());
- bandsBuilder.setMeterBand(bandDropCaseBuilder.build());
- break;
- case 2:
- MeterBandDscpRemarkCaseBuilder bandDscpRemarkCaseBuilder = new MeterBandDscpRemarkCaseBuilder();
- MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();
- bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));
- rawMessage.readUnsignedShort();
- bandDscpRemarkBuilder.setRate(rawMessage.readUnsignedInt());
- bandDscpRemarkBuilder.setBurstSize(rawMessage.readUnsignedInt());
- bandDscpRemarkBuilder.setPrecLevel(rawMessage.readUnsignedByte());
- rawMessage.skipBytes(PADDING_IN_METER_BAND_DSCP_HEADER);
- bandDscpRemarkCaseBuilder.setMeterBandDscpRemark(bandDscpRemarkBuilder.build());
- bandsBuilder.setMeterBand(bandDscpRemarkCaseBuilder.build());
- break;
- case 0xFFFF:
- long expId = rawMessage
- .getUnsignedInt(rawMessage.readerIndex() + 2 * EncodeConstants.SIZE_OF_INT_IN_BYTES);
- rawMessage.readerIndex(bandStartIndex);
- OFDeserializer<MeterBandExperimenterCase> deserializer = registry
- .getDeserializer(ExperimenterDeserializerKeyFactory
- .createMeterBandDeserializerKey(EncodeConstants.OF13_VERSION_ID, expId));
- bandsBuilder.setMeterBand(deserializer.deserialize(rawMessage));
- break;
+ case 1:
+ final MeterBandDropCaseBuilder bandDropCaseBuilder = new MeterBandDropCaseBuilder();
+ MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();
+ bandDropBuilder.setType(MeterBandType.forValue(bandType));
+ rawMessage.readUnsignedShort();
+ bandDropBuilder.setRate(rawMessage.readUnsignedInt());
+ bandDropBuilder.setBurstSize(rawMessage.readUnsignedInt());
+ rawMessage.skipBytes(PADDING_IN_METER_BAND_DROP_HEADER);
+ bandDropCaseBuilder.setMeterBandDrop(bandDropBuilder.build());
+ bandsBuilder.setMeterBand(bandDropCaseBuilder.build());
+ break;
+ case 2:
+ final MeterBandDscpRemarkCaseBuilder bandDscpRemarkCaseBuilder =
+ new MeterBandDscpRemarkCaseBuilder();
+ MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();
+ bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));
+ rawMessage.readUnsignedShort();
+ bandDscpRemarkBuilder.setRate(rawMessage.readUnsignedInt());
+ bandDscpRemarkBuilder.setBurstSize(rawMessage.readUnsignedInt());
+ bandDscpRemarkBuilder.setPrecLevel(rawMessage.readUnsignedByte());
+ rawMessage.skipBytes(PADDING_IN_METER_BAND_DSCP_HEADER);
+ bandDscpRemarkCaseBuilder.setMeterBandDscpRemark(bandDscpRemarkBuilder.build());
+ bandsBuilder.setMeterBand(bandDscpRemarkCaseBuilder.build());
+ break;
+ case 0xFFFF:
+ long expId = rawMessage.getUnsignedInt(rawMessage.readerIndex()
+ + 2 * EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ rawMessage.readerIndex(bandStartIndex);
+ OFDeserializer<MeterBandExperimenterCase> deserializer = registry
+ .getDeserializer(ExperimenterDeserializerKeyFactory
+ .createMeterBandDeserializerKey(EncodeConstants.OF13_VERSION_ID, expId));
+ bandsBuilder.setMeterBand(deserializer.deserialize(rawMessage));
+ break;
+ default:
+ break;
}
bandsList.add(bandsBuilder.build());
}
return builder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static MeterFlags createMeterFlags(int input) {
- final Boolean mfKBPS = (input & (1 << 0)) != 0;
- final Boolean mfPKTPS = (input & (1 << 1)) != 0;
- final Boolean mfBURST = (input & (1 << 2)) != 0;
- final Boolean mfSTATS = (input & (1 << 3)) != 0;
+ final Boolean mfKBPS = (input & 1 << 0) != 0;
+ final Boolean mfPKTPS = (input & 1 << 1) != 0;
+ final Boolean mfBURST = (input & 1 << 2) != 0;
+ final Boolean mfSTATS = (input & 1 << 3) != 0;
return new MeterFlags(mfBURST, mfKBPS, mfPKTPS, mfSTATS);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.grouping.TableFeaturePropertiesBuilder;
/**
- * Translates MultipartReply messages
+ * Translates MultipartReply messages.
*
* @author timotej.kubas
* @author michal.polkorab
}
private static MultipartReplyDescCase setDesc(final ByteBuf input) {
- MultipartReplyDescCaseBuilder caseBuilder = new MultipartReplyDescCaseBuilder();
+ final MultipartReplyDescCaseBuilder caseBuilder = new MultipartReplyDescCaseBuilder();
MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();
byte[] mfrDescBytes = new byte[DESC_STR_LEN];
input.readBytes(mfrDescBytes);
return caseBuilder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static FlowModFlags createFlowModFlagsFromBitmap(final int input) {
- final Boolean fmfSENDFLOWREM = (input & (1 << 0)) != 0;
- final Boolean fmfCHECKOVERLAP = (input & (1 << 1)) != 0;
- final Boolean fmfRESETCOUNTS = (input & (1 << 2)) != 0;
- final Boolean fmfNOPKTCOUNTS = (input & (1 << 3)) != 0;
- final Boolean fmfNOBYTCOUNTS = (input & (1 << 4)) != 0;
+ final Boolean fmfSENDFLOWREM = (input & 1 << 0) != 0;
+ final Boolean fmfCHECKOVERLAP = (input & 1 << 1) != 0;
+ final Boolean fmfRESETCOUNTS = (input & 1 << 2) != 0;
+ final Boolean fmfNOPKTCOUNTS = (input & 1 << 3) != 0;
+ final Boolean fmfNOBYTCOUNTS = (input & 1 << 4) != 0;
return new FlowModFlags(fmfCHECKOVERLAP, fmfNOBYTCOUNTS, fmfNOPKTCOUNTS, fmfRESETCOUNTS, fmfSENDFLOWREM);
}
private static MultipartReplyAggregateCase setAggregate(final ByteBuf input) {
- MultipartReplyAggregateCaseBuilder caseBuilder = new MultipartReplyAggregateCaseBuilder();
+ final MultipartReplyAggregateCaseBuilder caseBuilder = new MultipartReplyAggregateCaseBuilder();
MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();
byte[] packetCount = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
input.readBytes(packetCount);
List<TableFeatures> features = new ArrayList<>();
while (input.readableBytes() > 0) {
TableFeaturesBuilder featuresBuilder = new TableFeaturesBuilder();
- int length = input.readUnsignedShort();
+ final int length = input.readUnsignedShort();
featuresBuilder.setTableId(input.readUnsignedByte());
input.skipBytes(PADDING_IN_MULTIPART_REPLY_TABLE_FEATURES);
featuresBuilder.setName(ByteBufUtils.decodeNullTerminatedString(input, MAX_TABLE_NAME_LENGTH));
tableFeaturesLength -= propertyLength;
if (type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONS)
|| type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONSMISS)) {
- InstructionRelatedTableFeaturePropertyBuilder insBuilder = new InstructionRelatedTableFeaturePropertyBuilder();
+ InstructionRelatedTableFeaturePropertyBuilder insBuilder =
+ new InstructionRelatedTableFeaturePropertyBuilder();
CodeKeyMaker keyMaker = CodeKeyMakerFactory.createInstructionsKeyMaker(EncodeConstants.OF13_VERSION_ID);
List<Instruction> instructions = ListDeserializer.deserializeHeaders(EncodeConstants.OF13_VERSION_ID,
propertyLength - COMMON_PROPERTY_LENGTH, input, keyMaker, registry);
} else if (type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLES)
|| type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLESMISS)) {
propertyLength -= COMMON_PROPERTY_LENGTH;
- NextTableRelatedTableFeaturePropertyBuilder tableBuilder = new NextTableRelatedTableFeaturePropertyBuilder();
+ NextTableRelatedTableFeaturePropertyBuilder tableBuilder =
+ new NextTableRelatedTableFeaturePropertyBuilder();
List<NextTableIds> ids = new ArrayList<>();
while (propertyLength > 0) {
NextTableIdsBuilder nextTableIdsBuilder = new NextTableIdsBuilder();
List<GroupStats> groupStatsList = new ArrayList<>();
while (input.readableBytes() > 0) {
GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();
- int bodyLength = input.readUnsignedShort();
+ final int bodyLength = input.readUnsignedShort();
input.skipBytes(PADDING_IN_GROUP_HEADER_01);
groupStatsBuilder.setGroupId(new GroupId(input.readUnsignedInt()));
groupStatsBuilder.setRefCount(input.readUnsignedInt());
}
private static MultipartReplyMeterFeaturesCase setMeterFeatures(final ByteBuf input) {
- MultipartReplyMeterFeaturesCaseBuilder caseBuilder = new MultipartReplyMeterFeaturesCaseBuilder();
+ final MultipartReplyMeterFeaturesCaseBuilder caseBuilder = new MultipartReplyMeterFeaturesCaseBuilder();
MultipartReplyMeterFeaturesBuilder builder = new MultipartReplyMeterFeaturesBuilder();
builder.setMaxMeter(input.readUnsignedInt());
builder.setBandTypes(createMeterBandsBitmap(input.readUnsignedInt()));
return caseBuilder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static MeterFlags createMeterFlags(final long input) {
- final Boolean mfKBPS = (input & (1 << 0)) != 0;
- final Boolean mfPKTPS = (input & (1 << 1)) != 0;
- final Boolean mfBURST = (input & (1 << 2)) != 0;
- final Boolean mfSTATS = (input & (1 << 3)) != 0;
+ final Boolean mfKBPS = (input & 1 << 0) != 0;
+ final Boolean mfPKTPS = (input & 1 << 1) != 0;
+ final Boolean mfBURST = (input & 1 << 2) != 0;
+ final Boolean mfSTATS = (input & 1 << 3) != 0;
return new MeterFlags(mfBURST, mfKBPS, mfPKTPS, mfSTATS);
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static MeterBandTypeBitmap createMeterBandsBitmap(final long input) {
- final Boolean mbtDROP = (input & (1 << 1)) != 0;
- final Boolean mbtDSCPREMARK = (input & (1 << 2)) != 0;
+ final Boolean mbtDROP = (input & 1 << 1) != 0;
+ final Boolean mbtDSCPREMARK = (input & 1 << 2) != 0;
return new MeterBandTypeBitmap(mbtDROP, mbtDSCPREMARK);
}
while (input.readableBytes() > 0) {
MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();
meterStatsBuilder.setMeterId(new MeterId(input.readUnsignedInt()));
- int meterStatsBodyLength = input.readUnsignedShort();
+ final int meterStatsBodyLength = input.readUnsignedShort();
input.skipBytes(PADDING_IN_METER_STATS_HEADER);
meterStatsBuilder.setFlowCount(input.readUnsignedInt());
byte[] packetInCount = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
int bandType = input.readUnsignedShort();
switch (bandType) {
case 1:
- MeterBandDropCaseBuilder bandDropCaseBuilder = new MeterBandDropCaseBuilder();
+ final MeterBandDropCaseBuilder bandDropCaseBuilder = new MeterBandDropCaseBuilder();
MeterBandDropBuilder bandDropBuilder = new MeterBandDropBuilder();
bandDropBuilder.setType(MeterBandType.forValue(bandType));
actualLength += input.readUnsignedShort();
bandsBuilder.setMeterBand(bandDropCaseBuilder.build());
break;
case 2:
- MeterBandDscpRemarkCaseBuilder bandDscpRemarkCaseBuilder = new MeterBandDscpRemarkCaseBuilder();
+ final MeterBandDscpRemarkCaseBuilder bandDscpRemarkCaseBuilder =
+ new MeterBandDscpRemarkCaseBuilder();
MeterBandDscpRemarkBuilder bandDscpRemarkBuilder = new MeterBandDscpRemarkBuilder();
bandDscpRemarkBuilder.setType(MeterBandType.forValue(bandType));
actualLength += input.readUnsignedShort();
break;
case 0xFFFF:
actualLength += input.readUnsignedShort();
- long expId = input.getUnsignedInt(input.readerIndex() + 2 * EncodeConstants.SIZE_OF_INT_IN_BYTES);
+ final long expId = input.getUnsignedInt(input.readerIndex()
+ + 2 * EncodeConstants.SIZE_OF_INT_IN_BYTES);
input.readerIndex(bandStartIndex);
OFDeserializer<MeterBandExperimenterCase> deserializer = registry.getDeserializer(
ExperimenterDeserializerKeyFactory.createMeterBandDeserializerKey(
.setExperimenter(new ExperimenterId(expId))
.setExpType(expType)
.setExperimenterDataOfChoice(deserializer.deserialize(input));
- final MultipartReplyExperimenterCaseBuilder mpReplyExperimenterCaseBld = new MultipartReplyExperimenterCaseBuilder()
- .setMultipartReplyExperimenter(mpExperimenterBld.build());
+ final MultipartReplyExperimenterCaseBuilder mpReplyExperimenterCaseBld =
+ new MultipartReplyExperimenterCaseBuilder().setMultipartReplyExperimenter(mpExperimenterBld.build());
return mpReplyExperimenterCaseBld.build();
}
}
private static PortConfig createPortConfig(final long input) {
- final Boolean pcPortDown = ((input) & (1 << 0)) != 0;
- final Boolean pcNRecv = ((input) & (1 << 2)) != 0;
- final Boolean pcNFwd = ((input) & (1 << 5)) != 0;
- final Boolean pcNPacketIn = ((input) & (1 << 6)) != 0;
+ final Boolean pcPortDown = (input & 1 << 0) != 0;
+ final Boolean pcNRecv = (input & 1 << 2) != 0;
+ final Boolean pcNFwd = (input & 1 << 5) != 0;
+ final Boolean pcNPacketIn = (input & 1 << 6) != 0;
return new PortConfig(pcNFwd, pcNPacketIn, pcNRecv, pcPortDown);
}
private static PortState createPortState(final long input) {
- final Boolean psLinkDown = ((input) & (1 << 0)) != 0;
- final Boolean psBlocked = ((input) & (1 << 1)) != 0;
- final Boolean psLive = ((input) & (1 << 2)) != 0;
+ final Boolean psLinkDown = (input & 1 << 0) != 0;
+ final Boolean psBlocked = (input & 1 << 1) != 0;
+ final Boolean psLive = (input & 1 << 2) != 0;
return new PortState(psBlocked, psLinkDown, psLive);
}
private static PortFeatures createPortFeatures(final long input) {
- final Boolean pf10mbHd = ((input) & (1 << 0)) != 0;
- final Boolean pf10mbFd = ((input) & (1 << 1)) != 0;
- final Boolean pf100mbHd = ((input) & (1 << 2)) != 0;
- final Boolean pf100mbFd = ((input) & (1 << 3)) != 0;
- final Boolean pf1gbHd = ((input) & (1 << 4)) != 0;
- final Boolean pf1gbFd = ((input) & (1 << 5)) != 0;
- final Boolean pf10gbFd = ((input) & (1 << 6)) != 0;
- final Boolean pf40gbFd = ((input) & (1 << 7)) != 0;
- final Boolean pf100gbFd = ((input) & (1 << 8)) != 0;
- final Boolean pf1tbFd = ((input) & (1 << 9)) != 0;
- final Boolean pfOther = ((input) & (1 << 10)) != 0;
- final Boolean pfCopper = ((input) & (1 << 11)) != 0;
- final Boolean pfFiber = ((input) & (1 << 12)) != 0;
- final Boolean pfAutoneg = ((input) & (1 << 13)) != 0;
- final Boolean pfPause = ((input) & (1 << 14)) != 0;
- final Boolean pfPauseAsym = ((input) & (1 << 15)) != 0;
+ final Boolean pf10mbHd = (input & 1 << 0) != 0;
+ final Boolean pf10mbFd = (input & 1 << 1) != 0;
+ final Boolean pf100mbHd = (input & 1 << 2) != 0;
+ final Boolean pf100mbFd = (input & 1 << 3) != 0;
+ final Boolean pf1gbHd = (input & 1 << 4) != 0;
+ final Boolean pf1gbFd = (input & 1 << 5) != 0;
+ final Boolean pf10gbFd = (input & 1 << 6) != 0;
+ final Boolean pf40gbFd = (input & 1 << 7) != 0;
+ final Boolean pf100gbFd = (input & 1 << 8) != 0;
+ final Boolean pf1tbFd = (input & 1 << 9) != 0;
+ final Boolean pfOther = (input & 1 << 10) != 0;
+ final Boolean pfCopper = (input & 1 << 11) != 0;
+ final Boolean pfFiber = (input & 1 << 12) != 0;
+ final Boolean pfAutoneg = (input & 1 << 13) != 0;
+ final Boolean pfPause = (input & 1 << 14) != 0;
+ final Boolean pfPauseAsym = (input & 1 << 15) != 0;
return new PortFeatures(pf100gbFd, pf100mbFd, pf100mbHd, pf10gbFd, pf10mbFd, pf10mbHd, pf1gbFd,
pf1gbHd, pf1tbFd, pf40gbFd, pfAutoneg, pfCopper, pfFiber, pfOther, pfPause, pfPauseAsym);
}
private static MultipartReplyGroupFeaturesCase setGroupFeatures(final ByteBuf rawMessage) {
- MultipartReplyGroupFeaturesCaseBuilder caseBuilder = new MultipartReplyGroupFeaturesCaseBuilder();
+ final MultipartReplyGroupFeaturesCaseBuilder caseBuilder = new MultipartReplyGroupFeaturesCaseBuilder();
MultipartReplyGroupFeaturesBuilder featuresBuilder = new MultipartReplyGroupFeaturesBuilder();
featuresBuilder.setTypes(createGroupType(rawMessage.readUnsignedInt()));
featuresBuilder.setCapabilities(createCapabilities(rawMessage.readUnsignedInt()));
return caseBuilder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static ActionType createActionBitmap(final long input) {
- final Boolean atOutput = ((input) & (1 << 0)) != 0;
- final Boolean atCopyTTLout = ((input) & (1 << 11)) != 0;
- final Boolean atCopyTTLin = ((input) & (1 << 12)) != 0;
- final Boolean atSetMplsTTL = ((input) & (1 << 15)) != 0;
- final Boolean atDecMplsTTL = ((input) & (1 << 16)) != 0;
- final Boolean atPushVLAN = ((input) & (1 << 17)) != 0;
- final Boolean atPopVLAN = ((input) & (1 << 18)) != 0;
- final Boolean atPushMPLS = ((input) & (1 << 19)) != 0;
- final Boolean atPopMPLS = ((input) & (1 << 20)) != 0;
- final Boolean atSetQueue = ((input) & (1 << 21)) != 0;
- final Boolean atGroup = ((input) & (1 << 22)) != 0;
- final Boolean atSetNWTTL = ((input) & (1 << 23)) != 0;
- final Boolean atDecNWTTL = ((input) & (1 << 24)) != 0;
- final Boolean atSetField = ((input) & (1 << 25)) != 0;
- final Boolean atPushPBB = ((input) & (1 << 26)) != 0;
- final Boolean atPopPBB = ((input) & (1 << 27)) != 0;
+ final Boolean atOutput = (input & 1 << 0) != 0;
+ final Boolean atCopyTTLout = (input & 1 << 11) != 0;
+ final Boolean atCopyTTLin = (input & 1 << 12) != 0;
+ final Boolean atSetMplsTTL = (input & 1 << 15) != 0;
+ final Boolean atDecMplsTTL = (input & 1 << 16) != 0;
+ final Boolean atPushVLAN = (input & 1 << 17) != 0;
+ final Boolean atPopVLAN = (input & 1 << 18) != 0;
+ final Boolean atPushMPLS = (input & 1 << 19) != 0;
+ final Boolean atPopMPLS = (input & 1 << 20) != 0;
+ final Boolean atSetQueue = (input & 1 << 21) != 0;
+ final Boolean atGroup = (input & 1 << 22) != 0;
+ final Boolean atSetNWTTL = (input & 1 << 23) != 0;
+ final Boolean atDecNWTTL = (input & 1 << 24) != 0;
+ final Boolean atSetField = (input & 1 << 25) != 0;
+ final Boolean atPushPBB = (input & 1 << 26) != 0;
+ final Boolean atPopPBB = (input & 1 << 27) != 0;
final Boolean atExperimenter = false;
return new ActionType(atCopyTTLin, atCopyTTLout, atDecMplsTTL,
atDecNWTTL, atExperimenter, atGroup, atOutput, atPopMPLS,
}
private static GroupCapabilities createCapabilities(final long input) {
- final Boolean gcSelectWeight = ((input) & (1 << 0)) != 0;
- final Boolean gcSelectLiveness = ((input) & (1 << 1)) != 0;
- final Boolean gcChaining = ((input) & (1 << 2)) != 0;
- final Boolean gcChainingChecks = ((input) & (1 << 3)) != 0;
+ final Boolean gcSelectWeight = (input & 1 << 0) != 0;
+ final Boolean gcSelectLiveness = (input & 1 << 1) != 0;
+ final Boolean gcChaining = (input & 1 << 2) != 0;
+ final Boolean gcChainingChecks = (input & 1 << 3) != 0;
return new GroupCapabilities(gcChaining, gcChainingChecks, gcSelectLiveness, gcSelectWeight);
}
private static GroupTypes createGroupType(final long input) {
- final Boolean gtAll = ((input) & (1 << 0)) != 0;
- final Boolean gtSelect = ((input) & (1 << 1)) != 0;
- final Boolean gtIndirect = ((input) & (1 << 2)) != 0;
- final Boolean gtFF = ((input) & (1 << 3)) != 0;
+ final Boolean gtAll = (input & 1 << 0) != 0;
+ final Boolean gtSelect = (input & 1 << 1) != 0;
+ final Boolean gtIndirect = (input & 1 << 2) != 0;
+ final Boolean gtFF = (input & 1 << 3) != 0;
return new GroupTypes(gtAll, gtFF, gtIndirect, gtSelect);
}
List<GroupDesc> groupDescsList = new ArrayList<>();
while (input.readableBytes() > 0) {
GroupDescBuilder groupDescBuilder = new GroupDescBuilder();
- int bodyLength = input.readUnsignedShort();
+ final int bodyLength = input.readUnsignedShort();
groupDescBuilder.setType(GroupType.forValue(input.readUnsignedByte()));
input.skipBytes(PADDING_IN_GROUP_DESC_HEADER);
groupDescBuilder.setGroupId(new GroupId(input.readUnsignedInt()));
List<BucketsList> bucketsList = new ArrayList<>();
while (actualLength < bodyLength) {
BucketsListBuilder bucketsBuilder = new BucketsListBuilder();
- int bucketsLength = input.readUnsignedShort();
+ final int bucketsLength = input.readUnsignedShort();
bucketsBuilder.setWeight(input.readUnsignedShort());
bucketsBuilder.setWatchPort(new PortNumber(input.readUnsignedInt()));
bucketsBuilder.setWatchGroup(input.readUnsignedInt());
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.grouping.TableFeaturePropertiesBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates MultipartRequestInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class MultipartRequestInputMessageFactory
implements OFDeserializer<MultipartRequestInput>, DeserializerRegistryInjector {
builder.setFlags(getMultipartRequestFlags(rawMessage.readUnsignedShort()));
rawMessage.skipBytes(PADDING);
switch (MultipartType.forValue(type)) {
- case OFPMPDESC:
- builder.setMultipartRequestBody(setDesc(rawMessage));
- break;
- case OFPMPFLOW:
- builder.setMultipartRequestBody(setFlow(rawMessage));
- break;
- case OFPMPAGGREGATE:
- builder.setMultipartRequestBody(setAggregate(rawMessage));
- break;
- case OFPMPTABLE:
- builder.setMultipartRequestBody(setTable(rawMessage));
- break;
- case OFPMPTABLEFEATURES:
- builder.setMultipartRequestBody(setTableFeatures(rawMessage));
- break;
- case OFPMPPORTSTATS:
- builder.setMultipartRequestBody(setPortStats(rawMessage));
- break;
- case OFPMPPORTDESC:
- builder.setMultipartRequestBody(setPortDesc(rawMessage));
- break;
- case OFPMPQUEUE:
- builder.setMultipartRequestBody(setQueue(rawMessage));
- break;
- case OFPMPGROUP:
- builder.setMultipartRequestBody(setGroup(rawMessage));
- break;
- case OFPMPGROUPDESC:
- builder.setMultipartRequestBody(setGroupDesc(rawMessage));
- break;
- case OFPMPGROUPFEATURES:
- builder.setMultipartRequestBody(setGroupFeatures(rawMessage));
- break;
- case OFPMPMETER:
- builder.setMultipartRequestBody(setMeter(rawMessage));
- break;
- case OFPMPMETERCONFIG:
- builder.setMultipartRequestBody(setMeterConfig(rawMessage));
- break;
- case OFPMPMETERFEATURES:
- builder.setMultipartRequestBody(setMeterFeatures(rawMessage));
- break;
- case OFPMPEXPERIMENTER:
- builder.setMultipartRequestBody(setExperimenter(rawMessage));
- break;
- default:
- break;
+ case OFPMPDESC:
+ builder.setMultipartRequestBody(setDesc(rawMessage));
+ break;
+ case OFPMPFLOW:
+ builder.setMultipartRequestBody(setFlow(rawMessage));
+ break;
+ case OFPMPAGGREGATE:
+ builder.setMultipartRequestBody(setAggregate(rawMessage));
+ break;
+ case OFPMPTABLE:
+ builder.setMultipartRequestBody(setTable(rawMessage));
+ break;
+ case OFPMPTABLEFEATURES:
+ builder.setMultipartRequestBody(setTableFeatures(rawMessage));
+ break;
+ case OFPMPPORTSTATS:
+ builder.setMultipartRequestBody(setPortStats(rawMessage));
+ break;
+ case OFPMPPORTDESC:
+ builder.setMultipartRequestBody(setPortDesc(rawMessage));
+ break;
+ case OFPMPQUEUE:
+ builder.setMultipartRequestBody(setQueue(rawMessage));
+ break;
+ case OFPMPGROUP:
+ builder.setMultipartRequestBody(setGroup(rawMessage));
+ break;
+ case OFPMPGROUPDESC:
+ builder.setMultipartRequestBody(setGroupDesc(rawMessage));
+ break;
+ case OFPMPGROUPFEATURES:
+ builder.setMultipartRequestBody(setGroupFeatures(rawMessage));
+ break;
+ case OFPMPMETER:
+ builder.setMultipartRequestBody(setMeter(rawMessage));
+ break;
+ case OFPMPMETERCONFIG:
+ builder.setMultipartRequestBody(setMeterConfig(rawMessage));
+ break;
+ case OFPMPMETERFEATURES:
+ builder.setMultipartRequestBody(setMeterFeatures(rawMessage));
+ break;
+ case OFPMPEXPERIMENTER:
+ builder.setMultipartRequestBody(setExperimenter(rawMessage));
+ break;
+ default:
+ break;
}
return builder.build();
return MultipartType.forValue(input);
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static MultipartRequestFlags getMultipartRequestFlags(int input) {
- final Boolean _oFPMPFREQMORE = (input & (1 << 0)) > 0;
+ final Boolean _oFPMPFREQMORE = (input & 1 << 0) > 0;
MultipartRequestFlags flag = new MultipartRequestFlags(_oFPMPFREQMORE);
return flag;
}
List<TableFeatures> features = new ArrayList<>();
while (input.readableBytes() > 0) {
TableFeaturesBuilder featuresBuilder = new TableFeaturesBuilder();
- int length = input.readUnsignedShort();
+ final int length = input.readUnsignedShort();
featuresBuilder.setTableId(input.readUnsignedByte());
input.skipBytes(PADDING_IN_MULTIPART_REQUEST_TABLE_FEATURES);
featuresBuilder.setName(ByteBufUtils.decodeNullTerminatedString(input, MAX_TABLE_NAME_LENGTH));
tableFeaturesLength -= propertyLength;
if (type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONS)
|| type.equals(TableFeaturesPropType.OFPTFPTINSTRUCTIONSMISS)) {
- InstructionRelatedTableFeaturePropertyBuilder insBuilder = new InstructionRelatedTableFeaturePropertyBuilder();
+ InstructionRelatedTableFeaturePropertyBuilder insBuilder =
+ new InstructionRelatedTableFeaturePropertyBuilder();
CodeKeyMaker keyMaker = CodeKeyMakerFactory.createInstructionsKeyMaker(EncodeConstants.OF13_VERSION_ID);
List<Instruction> instructions = ListDeserializer.deserializeHeaders(EncodeConstants.OF13_VERSION_ID,
propertyLength - COMMON_PROPERTY_LENGTH, input, keyMaker, registry);
} else if (type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLES)
|| type.equals(TableFeaturesPropType.OFPTFPTNEXTTABLESMISS)) {
propertyLength -= COMMON_PROPERTY_LENGTH;
- NextTableRelatedTableFeaturePropertyBuilder tableBuilder = new NextTableRelatedTableFeaturePropertyBuilder();
+ NextTableRelatedTableFeaturePropertyBuilder tableBuilder =
+ new NextTableRelatedTableFeaturePropertyBuilder();
List<NextTableIds> ids = new ArrayList<>();
while (propertyLength > 0) {
NextTableIdsBuilder nextTableIdsBuilder = new NextTableIdsBuilder();
}
private MultipartRequestFlowCase setFlow(ByteBuf input) {
- MultipartRequestFlowCaseBuilder caseBuilder = new MultipartRequestFlowCaseBuilder();
+ final MultipartRequestFlowCaseBuilder caseBuilder = new MultipartRequestFlowCaseBuilder();
MultipartRequestFlowBuilder flowBuilder = new MultipartRequestFlowBuilder();
flowBuilder.setTableId(input.readUnsignedByte());
input.skipBytes(FLOW_PADDING_1);
byte[] cookie = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
input.readBytes(cookie);
flowBuilder.setCookie(new BigInteger(1, cookie));
- byte[] cookie_mask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
- input.readBytes(cookie_mask);
- flowBuilder.setCookieMask(new BigInteger(1, cookie_mask));
+ final byte[] cookieMask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
+ input.readBytes(cookieMask);
+ flowBuilder.setCookieMask(new BigInteger(1, cookieMask));
OFDeserializer<Match> matchDeserializer = registry.getDeserializer(
new MessageCodeKey(EncodeConstants.OF13_VERSION_ID, EncodeConstants.EMPTY_VALUE, Match.class));
flowBuilder.setMatch(matchDeserializer.deserialize(input));
}
private MultipartRequestAggregateCase setAggregate(ByteBuf input) {
- MultipartRequestAggregateCaseBuilder caseBuilder = new MultipartRequestAggregateCaseBuilder();
+ final MultipartRequestAggregateCaseBuilder caseBuilder = new MultipartRequestAggregateCaseBuilder();
MultipartRequestAggregateBuilder aggregateBuilder = new MultipartRequestAggregateBuilder();
aggregateBuilder.setTableId(input.readUnsignedByte());
input.skipBytes(AGGREGATE_PADDING_1);
byte[] cookie = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
input.readBytes(cookie);
aggregateBuilder.setCookie(new BigInteger(1, cookie));
- byte[] cookie_mask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
- input.readBytes(cookie_mask);
- aggregateBuilder.setCookieMask(new BigInteger(1, cookie_mask));
+ final byte[] cookieMask = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
+ input.readBytes(cookieMask);
+ aggregateBuilder.setCookieMask(new BigInteger(1, cookieMask));
OFDeserializer<Match> matchDeserializer = registry.getDeserializer(
new MessageCodeKey(EncodeConstants.OF13_VERSION_ID, EncodeConstants.EMPTY_VALUE, Match.class));
aggregateBuilder.setMatch(matchDeserializer.deserialize(input));
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.BadActionCodeV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
/**
- * Translates Error messages (OpenFlow v1.0)
+ * Translates Error messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10ErrorMessageFactory implements OFDeserializer<ErrorMessage> {
int code = rawMessage.readUnsignedShort();
if (type != null) {
switch (type) {
- case HELLOFAILED:
- {
- HelloFailedCodeV10 errorCode = HelloFailedCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case HELLOFAILED:
+ {
+ HelloFailedCodeV10 errorCode = HelloFailedCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADREQUEST:
- {
- BadRequestCodeV10 errorCode = BadRequestCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADREQUEST:
+ {
+ BadRequestCodeV10 errorCode = BadRequestCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case BADACTION:
- {
- BadActionCodeV10 errorCode = BadActionCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case BADACTION:
+ {
+ BadActionCodeV10 errorCode = BadActionCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case FLOWMODFAILED:
- {
- FlowModFailedCodeV10 errorCode = FlowModFailedCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case FLOWMODFAILED:
+ {
+ FlowModFailedCodeV10 errorCode = FlowModFailedCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case PORTMODFAILED:
- {
- PortModFailedCodeV10 errorCode = PortModFailedCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case PORTMODFAILED:
+ {
+ PortModFailedCodeV10 errorCode = PortModFailedCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- case QUEUEOPFAILED:
- {
- QueueOpFailedCodeV10 errorCode = QueueOpFailedCodeV10.forValue(code);
- if (errorCode != null) {
- setCode(builder, errorCode.getIntValue(), errorCode.name());
- } else {
- setUnknownCode(builder, code);
+ case QUEUEOPFAILED:
+ {
+ QueueOpFailedCodeV10 errorCode = QueueOpFailedCodeV10.forValue(code);
+ if (errorCode != null) {
+ setCode(builder, errorCode.getIntValue(), errorCode.name());
+ } else {
+ setUnknownCode(builder, code);
+ }
+ break;
}
- break;
- }
- default:
- setUnknownCode(builder, code);
- break;
+ default:
+ setUnknownCode(builder, code);
+ break;
}
} else {
setUnknownCode(builder, code);
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.features.reply.PhyPortBuilder;
/**
- * Translates FeaturesReply messages (OpenFlow v1.0)
+ * Translates FeaturesReply messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10FeaturesReplyMessageFactory implements OFDeserializer<GetFeaturesOutput> {
}
private static CapabilitiesV10 createCapabilitiesV10(final long input) {
- final Boolean flowStats = (input & (1 << 0)) != 0;
- final Boolean tableStats = (input & (1 << 1)) != 0;
- final Boolean portStats = (input & (1 << 2)) != 0;
- final Boolean stp = (input & (1 << 3)) != 0;
- final Boolean reserved = (input & (1 << 4)) != 0;
- final Boolean ipReasm = (input & (1 << 5)) != 0;
- final Boolean queueStats = (input & (1 << 6)) != 0;
- final Boolean arpMatchIp = (input & (1 << 7)) != 0;
+ final Boolean flowStats = (input & 1 << 0) != 0;
+ final Boolean tableStats = (input & 1 << 1) != 0;
+ final Boolean portStats = (input & 1 << 2) != 0;
+ final Boolean stp = (input & 1 << 3) != 0;
+ final Boolean reserved = (input & 1 << 4) != 0;
+ final Boolean ipReasm = (input & 1 << 5) != 0;
+ final Boolean queueStats = (input & 1 << 6) != 0;
+ final Boolean arpMatchIp = (input & 1 << 7) != 0;
return new CapabilitiesV10(arpMatchIp, flowStats, ipReasm,
portStats, queueStats, reserved, stp, tableStats);
}
private static ActionTypeV10 createActionsV10(final long input) {
- final Boolean output = (input & (1 << 0)) != 0;
- final Boolean setVLANvid = (input & (1 << 1)) != 0;
- final Boolean setVLANpcp = (input & (1 << 2)) != 0;
- final Boolean stripVLAN = (input & (1 << 3)) != 0;
- final Boolean setDLsrc = (input & (1 << 4)) != 0;
- final Boolean setDLdst = (input & (1 << 5)) != 0;
- final Boolean setNWsrc = (input & (1 << 6)) != 0;
- final Boolean setNWdst = (input & (1 << 7)) != 0;
- final Boolean setNWtos = (input & (1 << 8)) != 0;
- final Boolean setTPsrc = (input & (1 << 9)) != 0;
- final Boolean setTPdst = (input & (1 << 10)) != 0;
- final Boolean enqueue = (input & (1 << 11)) != 0;
- final Boolean vendor = (input & (1 << 12)) != 0;
+ final Boolean output = (input & 1 << 0) != 0;
+ final Boolean setVLANvid = (input & 1 << 1) != 0;
+ final Boolean setVLANpcp = (input & 1 << 2) != 0;
+ final Boolean stripVLAN = (input & 1 << 3) != 0;
+ final Boolean setDLsrc = (input & 1 << 4) != 0;
+ final Boolean setDLdst = (input & 1 << 5) != 0;
+ final Boolean setNWsrc = (input & 1 << 6) != 0;
+ final Boolean setNWdst = (input & 1 << 7) != 0;
+ final Boolean setNWtos = (input & 1 << 8) != 0;
+ final Boolean setTPsrc = (input & 1 << 9) != 0;
+ final Boolean setTPdst = (input & 1 << 10) != 0;
+ final Boolean enqueue = (input & 1 << 11) != 0;
+ final Boolean vendor = (input & 1 << 12) != 0;
return new ActionTypeV10(enqueue, output, setDLdst, setDLsrc,
setNWdst, setNWsrc, setNWtos, setTPdst, setTPsrc,
setVLANpcp, setVLANvid, stripVLAN, vendor);
builder.setPeerFeaturesV10(OpenflowUtils.createPortFeatures(rawMessage.readUnsignedInt()));
return builder.build();
}
-}
\ No newline at end of file
+}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates GetFeaturesInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10FeaturesRequestMessageFactory implements OFDeserializer<GetFeaturesInput> {
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates FlowModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10FlowModInputMessageFactory implements OFDeserializer<FlowModInput>, DeserializerRegistryInjector {
return builder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static FlowModFlagsV10 createFlowModFlagsFromBitmap(int input) {
- final Boolean _oFPFFSENDFLOWREM = (input & (1 << 0)) > 0;
- final Boolean _oFPFFCHECKOVERLAP = (input & (1 << 1)) > 0;
- final Boolean _oFPFFEMERG = (input & (1 << 2)) > 0;
+ final Boolean _oFPFFSENDFLOWREM = (input & 1 << 0) > 0;
+ final Boolean _oFPFFCHECKOVERLAP = (input & 1 << 1) > 0;
+ final Boolean _oFPFFEMERG = (input & 1 << 2) > 0;
return new FlowModFlagsV10(_oFPFFCHECKOVERLAP, _oFPFFEMERG, _oFPFFSENDFLOWREM);
}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.math.BigInteger;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessageBuilder;
/**
- * Translates FlowRemoved messages (OpenFlow v1.0)
+ * Translates FlowRemoved messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10FlowRemovedMessageFactory implements OFDeserializer<FlowRemovedMessage>,
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates GetQueueConfigInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10GetQueueConfigInputMessageFactory implements OFDeserializer<GetQueueConfigInput> {
public GetQueueConfigInput deserialize(ByteBuf rawMessage) {
GetQueueConfigInputBuilder builder = new GetQueueConfigInputBuilder();
builder.setVersion((short) EncodeConstants.OF10_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
builder.setPort(new PortNumber((long) rawMessage.readUnsignedShort()));
return builder.build();
}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessageBuilder;
/**
- * Translates Hello messages (OpenFlow v1.0)
+ * Translates Hello messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10HelloMessageFactory implements OFDeserializer<HelloMessage> {
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessageBuilder;
/**
- * Translates PacketIn messages (OpenFlow v1.0)
+ * Translates PacketIn messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10PacketInMessageFactory implements OFDeserializer<PacketInMessage> {
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketOutInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates PacketOutInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10PacketOutInputMessageFactory implements OFDeserializer<PacketOutInput>, DeserializerRegistryInjector {
builder.setXid(rawMessage.readUnsignedInt());
builder.setBufferId(rawMessage.readUnsignedInt());
builder.setInPort(new PortNumber((long) rawMessage.readUnsignedShort()));
- int actions_len = rawMessage.readShort();
+ final int actions_len = rawMessage.readShort();
CodeKeyMaker keyMaker = CodeKeyMakerFactory.createActionsKeyMaker(EncodeConstants.OF10_VERSION_ID);
List<Action> actions = ListDeserializer.deserializeList(EncodeConstants.OF10_VERSION_ID, actions_len,
rawMessage, keyMaker, registry);
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates PortModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10PortModInputMessageFactory implements OFDeserializer<PortModInput> {
}
private static PortConfigV10 createPortConfig(final long input) {
- final Boolean _portDown = ((input) & (1 << 0)) > 0;
- final Boolean _noStp = ((input) & (1 << 1)) > 0;
- final Boolean _noRecv = ((input) & (1 << 2)) > 0;
- final Boolean _noRecvStp = ((input) & (1 << 3)) > 0;
- final Boolean _noFlood = ((input) & (1 << 4)) > 0;
- final Boolean _noFwd = ((input) & (1 << 5)) > 0;
- final Boolean _noPacketIn = ((input) & (1 << 6)) > 0;
+ final Boolean _portDown = (input & 1 << 0) > 0;
+ final Boolean _noStp = (input & 1 << 1) > 0;
+ final Boolean _noRecv = (input & 1 << 2) > 0;
+ final Boolean _noRecvStp = (input & 1 << 3) > 0;
+ final Boolean _noFlood = (input & 1 << 4) > 0;
+ final Boolean _noFwd = (input & 1 << 5) > 0;
+ final Boolean _noPacketIn = (input & 1 << 6) > 0;
return new PortConfigV10(_noFlood, _noFwd, _noPacketIn, _noRecv, _noRecvStp, _noStp, _portDown);
}
private static PortFeaturesV10 createPortFeatures(final long input) {
- final Boolean _10mbHd = ((input) & (1 << 0)) > 0;
- final Boolean _10mbFd = ((input) & (1 << 1)) > 0;
- final Boolean _100mbHd = ((input) & (1 << 2)) > 0;
- final Boolean _100mbFd = ((input) & (1 << 3)) > 0;
- final Boolean _1gbHd = ((input) & (1 << 4)) > 0;
- final Boolean _1gbFd = ((input) & (1 << 5)) > 0;
- final Boolean _10gbFd = ((input) & (1 << 6)) > 0;
- final Boolean _copper = ((input) & (1 << 7)) > 0;
- final Boolean _fiber = ((input) & (1 << 8)) > 0;
- final Boolean _autoneg = ((input) & (1 << 9)) > 0;
- final Boolean _pause = ((input) & (1 << 10)) > 0;
- final Boolean _pauseAsym = ((input) & (1 << 11)) > 0;
+ final Boolean _10mbHd = (input & 1 << 0) > 0;
+ final Boolean _10mbFd = (input & 1 << 1) > 0;
+ final Boolean _100mbHd = (input & 1 << 2) > 0;
+ final Boolean _100mbFd = (input & 1 << 3) > 0;
+ final Boolean _1gbHd = (input & 1 << 4) > 0;
+ final Boolean _1gbFd = (input & 1 << 5) > 0;
+ final Boolean _10gbFd = (input & 1 << 6) > 0;
+ final Boolean _copper = (input & 1 << 7) > 0;
+ final Boolean _fiber = (input & 1 << 8) > 0;
+ final Boolean _autoneg = (input & 1 << 9) > 0;
+ final Boolean _pause = (input & 1 << 10) > 0;
+ final Boolean _pauseAsym = (input & 1 << 11) > 0;
return new PortFeaturesV10(_100mbFd, _100mbHd, _10gbFd, _10mbFd, _10mbHd, _1gbFd, _1gbHd, _autoneg, _copper,
_fiber, _pause, _pauseAsym);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessageBuilder;
/**
- * Translates PortStatus messages (OpenFlow v1.0)
+ * Translates PortStatus messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10PortStatusMessageFactory implements OFDeserializer<PortStatusMessage> {
builder.setSupportedFeaturesV10(OpenflowUtils.createPortFeatures(rawMessage.readUnsignedInt()));
builder.setPeerFeaturesV10(OpenflowUtils.createPortFeatures(rawMessage.readUnsignedInt()));
}
-}
\ No newline at end of file
+}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.util.ArrayList;
import java.util.List;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev150225.RateQueueProperty;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.property.header.QueuePropertyBuilder;
/**
- * Translates QueueGetConfigReply messages (OpenFlow v1.0)
+ * Translates QueueGetConfigReply messages (OpenFlow v1.0).
+ *
* @author michal.polkorab
*/
public class OF10QueueGetConfigReplyMessageFactory implements OFDeserializer<GetQueueConfigOutput> {
public GetQueueConfigOutput deserialize(ByteBuf rawMessage) {
GetQueueConfigOutputBuilder builder = new GetQueueConfigOutputBuilder();
builder.setVersion((short) EncodeConstants.OF10_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
builder.setPort(new PortNumber((long) rawMessage.readUnsignedShort()));
rawMessage.skipBytes(PADDING_IN_QUEUE_GET_CONFIG_REPLY_HEADER);
builder.setQueues(createQueuesList(rawMessage));
return builder.build();
}
- private static List<Queues> createQueuesList(ByteBuf input){
+ private static List<Queues> createQueuesList(ByteBuf input) {
List<Queues> queuesList = new ArrayList<>();
while (input.readableBytes() > 0) {
QueuesBuilder queueBuilder = new QueuesBuilder();
return queuesList;
}
- private static List<QueueProperty> createPropertiesList(ByteBuf input, int length){
+ private static List<QueueProperty> createPropertiesList(ByteBuf input, int length) {
int propertiesLength = length;
List<QueueProperty> propertiesList = new ArrayList<>();
while (propertiesLength > 0) {
}
return propertiesList;
}
-}
\ No newline at end of file
+}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table._case.multipart.reply.table.TableStatsBuilder;
/**
- * Translates StatsReply messages (OpenFlow v1.0)
+ * Translates StatsReply messages (OpenFlow v1.0).
*
* @author michal.polkorab
*/
}
private static MultipartReplyDescCase setDesc(ByteBuf input) {
- MultipartReplyDescCaseBuilder caseBuilder = new MultipartReplyDescCaseBuilder();
+ final MultipartReplyDescCaseBuilder caseBuilder = new MultipartReplyDescCaseBuilder();
MultipartReplyDescBuilder descBuilder = new MultipartReplyDescBuilder();
byte[] mfrDescBytes = new byte[DESC_STR_LEN];
input.readBytes(mfrDescBytes);
List<FlowStats> flowStatsList = new ArrayList<>();
while (input.readableBytes() > 0) {
FlowStatsBuilder flowStatsBuilder = new FlowStatsBuilder();
- int length = input.readUnsignedShort();
+ final int length = input.readUnsignedShort();
flowStatsBuilder.setTableId(input.readUnsignedByte());
input.skipBytes(PADDING_IN_FLOW_STATS_HEADER);
OFDeserializer<MatchV10> matchDeserializer = registry.getDeserializer(
}
private static MultipartReplyAggregateCase setAggregate(ByteBuf input) {
- MultipartReplyAggregateCaseBuilder caseBuilder = new MultipartReplyAggregateCaseBuilder();
+ final MultipartReplyAggregateCaseBuilder caseBuilder = new MultipartReplyAggregateCaseBuilder();
MultipartReplyAggregateBuilder builder = new MultipartReplyAggregateBuilder();
byte[] packetCount = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
input.readBytes(packetCount);
}
private static MultipartReplyTableCase setTable(ByteBuf input) {
- MultipartReplyTableCaseBuilder caseBuilder = new MultipartReplyTableCaseBuilder();
+ final MultipartReplyTableCaseBuilder caseBuilder = new MultipartReplyTableCaseBuilder();
MultipartReplyTableBuilder builder = new MultipartReplyTableBuilder();
List<TableStats> tableStatsList = new ArrayList<>();
// TODO - replace ">= TABLE_STATS_LENGTH" with "> 0" after fix in OVS switch
private MultipartReplyExperimenterCase setExperimenter(ByteBuf input) {
final long expId = input.readUnsignedInt();
- final OFDeserializer<ExperimenterDataOfChoice> deserializer = registry.getDeserializer(ExperimenterDeserializerKeyFactory.createMultipartReplyVendorMessageDeserializerKey(
+ final OFDeserializer<ExperimenterDataOfChoice> deserializer = registry.getDeserializer(
+ ExperimenterDeserializerKeyFactory.createMultipartReplyVendorMessageDeserializerKey(
EncodeConstants.OF10_VERSION_ID, expId));
final MultipartReplyExperimenterBuilder mpExperimenterBld = new MultipartReplyExperimenterBuilder()
.setExperimenter(new ExperimenterId(expId))
.setExperimenterDataOfChoice(deserializer.deserialize(input));
- final MultipartReplyExperimenterCaseBuilder mpReplyExperimenterCaseBld = new MultipartReplyExperimenterCaseBuilder()
- .setMultipartReplyExperimenter(mpExperimenterBld.build());
+ final MultipartReplyExperimenterCaseBuilder mpReplyExperimenterCaseBld =
+ new MultipartReplyExperimenterCaseBuilder().setMultipartReplyExperimenter(mpExperimenterBld.build());
return mpReplyExperimenterCaseBld.build();
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table._case.MultipartRequestTableBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates MultipartRequestInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class OF10StatsRequestInputFactory
implements OFDeserializer<MultipartRequestInput>, DeserializerRegistryInjector {
builder.setType(getMultipartType(type));
builder.setFlags(getMultipartRequestFlags(rawMessage.readUnsignedShort()));
switch (getMultipartType(type)) {
- case OFPMPDESC:
- builder.setMultipartRequestBody(setDesc(rawMessage));
- break;
- case OFPMPFLOW:
- builder.setMultipartRequestBody(setFlow(rawMessage));
- break;
- case OFPMPAGGREGATE:
- builder.setMultipartRequestBody(setAggregate(rawMessage));
- break;
- case OFPMPTABLE:
- builder.setMultipartRequestBody(setTable(rawMessage));
- break;
- case OFPMPPORTSTATS:
- builder.setMultipartRequestBody(setPortStats(rawMessage));
- break;
- case OFPMPQUEUE:
- builder.setMultipartRequestBody(setQueue(rawMessage));
- break;
- case OFPMPEXPERIMENTER:
- builder.setMultipartRequestBody(setExperimenter(rawMessage));
- break;
- default:
- break;
+ case OFPMPDESC:
+ builder.setMultipartRequestBody(setDesc(rawMessage));
+ break;
+ case OFPMPFLOW:
+ builder.setMultipartRequestBody(setFlow(rawMessage));
+ break;
+ case OFPMPAGGREGATE:
+ builder.setMultipartRequestBody(setAggregate(rawMessage));
+ break;
+ case OFPMPTABLE:
+ builder.setMultipartRequestBody(setTable(rawMessage));
+ break;
+ case OFPMPPORTSTATS:
+ builder.setMultipartRequestBody(setPortStats(rawMessage));
+ break;
+ case OFPMPQUEUE:
+ builder.setMultipartRequestBody(setQueue(rawMessage));
+ break;
+ case OFPMPEXPERIMENTER:
+ builder.setMultipartRequestBody(setExperimenter(rawMessage));
+ break;
+ default:
+ break;
}
return builder.build();
}
}
private MultipartRequestQueueCase setQueue(ByteBuf input) {
- MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
+ final MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
MultipartRequestQueueBuilder queueBuilder = new MultipartRequestQueueBuilder();
queueBuilder.setPortNo((long) input.readUnsignedShort());
input.skipBytes(2);
}
private MultipartRequestAggregateCase setAggregate(ByteBuf input) {
- MultipartRequestAggregateCaseBuilder caseBuilder = new MultipartRequestAggregateCaseBuilder();
+ final MultipartRequestAggregateCaseBuilder caseBuilder = new MultipartRequestAggregateCaseBuilder();
MultipartRequestAggregateBuilder aggregateBuilder = new MultipartRequestAggregateBuilder();
OFDeserializer<MatchV10> matchDeserializer = registry.getDeserializer(
new MessageCodeKey(EncodeConstants.OF10_VERSION_ID, EncodeConstants.EMPTY_VALUE, MatchV10.class));
}
private MultipartRequestFlowCase setFlow(ByteBuf input) {
- MultipartRequestFlowCaseBuilder caseBuilder = new MultipartRequestFlowCaseBuilder();
+ final MultipartRequestFlowCaseBuilder caseBuilder = new MultipartRequestFlowCaseBuilder();
MultipartRequestFlowBuilder flowBuilder = new MultipartRequestFlowBuilder();
OFDeserializer<MatchV10> matchDeserializer = registry.getDeserializer(
new MessageCodeKey(EncodeConstants.OF10_VERSION_ID, EncodeConstants.EMPTY_VALUE, MatchV10.class));
return caseBuilder.build();
}
+ @SuppressWarnings("checkstyle:AbbreviationAsWordInName")
private static MultipartRequestFlags getMultipartRequestFlags(int input) {
- final Boolean _oFPMPFREQMORE = (input & (1 << 0)) > 0;
+ final Boolean _oFPMPFREQMORE = (input & 1 << 0) > 0;
MultipartRequestFlags flag = new MultipartRequestFlags(_oFPMPFREQMORE);
return flag;
}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.math.BigInteger;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessageBuilder;
/**
- * Translates PacketIn messages
+ * Translates PacketIn messages.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketOutInputBuilder;
public class PacketOutInputMessageFactory implements OFDeserializer<PacketOutInput>, DeserializerRegistryInjector {
+ private static final byte PADDING = 6;
+
private DeserializerRegistry registry;
- private final byte PADDING = 6;
@Override
public PacketOutInput deserialize(ByteBuf rawMessage) {
builder.setXid(rawMessage.readUnsignedInt());
builder.setBufferId(rawMessage.readUnsignedInt());
builder.setInPort(new PortNumber(rawMessage.readUnsignedInt()));
- int actions_len = rawMessage.readShort();
+ int actionsLen = rawMessage.readShort();
rawMessage.skipBytes(PADDING);
CodeKeyMaker keyMaker = CodeKeyMakerFactory.createActionsKeyMaker(EncodeConstants.OF13_VERSION_ID);
- List<Action> actions = ListDeserializer.deserializeList(EncodeConstants.OF13_VERSION_ID, actions_len,
+ List<Action> actions = ListDeserializer.deserializeList(EncodeConstants.OF13_VERSION_ID, actionsLen,
rawMessage, keyMaker, registry);
builder.setAction(actions);
byte[] data = new byte[rawMessage.readableBytes()];
public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
registry = deserializerRegistry;
}
-}
\ No newline at end of file
+}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates PortModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class PortModInputMessageFactory implements OFDeserializer<PortModInput> {
}
private static PortConfig createPortConfig(final long input) {
- final Boolean pcPortDown = ((input) & (1 << 0)) != 0;
- final Boolean pcNRecv = ((input) & (1 << 2)) != 0;
- final Boolean pcNFwd = ((input) & (1 << 5)) != 0;
- final Boolean pcNPacketIn = ((input) & (1 << 6)) != 0;
+ final Boolean pcPortDown = (input & 1 << 0) != 0;
+ final Boolean pcNRecv = (input & 1 << 2) != 0;
+ final Boolean pcNFwd = (input & 1 << 5) != 0;
+ final Boolean pcNPacketIn = (input & 1 << 6) != 0;
return new PortConfig(pcNFwd, pcNPacketIn, pcNRecv, pcPortDown);
}
private static PortFeatures createPortFeatures(final long input) {
- final Boolean pf10mbHd = ((input) & (1 << 0)) != 0;
- final Boolean pf10mbFd = ((input) & (1 << 1)) != 0;
- final Boolean pf100mbHd = ((input) & (1 << 2)) != 0;
- final Boolean pf100mbFd = ((input) & (1 << 3)) != 0;
- final Boolean pf1gbHd = ((input) & (1 << 4)) != 0;
- final Boolean pf1gbFd = ((input) & (1 << 5)) != 0;
- final Boolean pf10gbFd = ((input) & (1 << 6)) != 0;
- final Boolean pf40gbFd = ((input) & (1 << 7)) != 0;
- final Boolean pf100gbFd = ((input) & (1 << 8)) != 0;
- final Boolean pf1tbFd = ((input) & (1 << 9)) != 0;
- final Boolean pfOther = ((input) & (1 << 10)) != 0;
- final Boolean pfCopper = ((input) & (1 << 11)) != 0;
- final Boolean pfFiber = ((input) & (1 << 12)) != 0;
- final Boolean pfAutoneg = ((input) & (1 << 13)) != 0;
- final Boolean pfPause = ((input) & (1 << 14)) != 0;
- final Boolean pfPauseAsym = ((input) & (1 << 15)) != 0;
+ final Boolean pf10mbHd = (input & 1 << 0) != 0;
+ final Boolean pf10mbFd = (input & 1 << 1) != 0;
+ final Boolean pf100mbHd = (input & 1 << 2) != 0;
+ final Boolean pf100mbFd = (input & 1 << 3) != 0;
+ final Boolean pf1gbHd = (input & 1 << 4) != 0;
+ final Boolean pf1gbFd = (input & 1 << 5) != 0;
+ final Boolean pf10gbFd = (input & 1 << 6) != 0;
+ final Boolean pf40gbFd = (input & 1 << 7) != 0;
+ final Boolean pf100gbFd = (input & 1 << 8) != 0;
+ final Boolean pf1tbFd = (input & 1 << 9) != 0;
+ final Boolean pfOther = (input & 1 << 10) != 0;
+ final Boolean pfCopper = (input & 1 << 11) != 0;
+ final Boolean pfFiber = (input & 1 << 12) != 0;
+ final Boolean pfAutoneg = (input & 1 << 13) != 0;
+ final Boolean pfPause = (input & 1 << 14) != 0;
+ final Boolean pfPauseAsym = (input & 1 << 15) != 0;
return new PortFeatures(pf100gbFd, pf100mbFd, pf100mbHd, pf10gbFd, pf10mbFd, pf10mbHd, pf1gbFd, pf1gbHd,
pf1tbFd, pf40gbFd, pfAutoneg, pfCopper, pfFiber, pfOther, pfPause, pfPauseAsym);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessageBuilder;
/**
- * Translates PortStatus messages
+ * Translates PortStatus messages.
+ *
* @author michal.polkorab
* @author timotej.kubas
*/
return builder.build();
}
- private static PortFeatures createPortFeatures(final long input){
- final Boolean pf10mbHd = ((input) & (1<<0)) != 0;
- final Boolean pf10mbFd = ((input) & (1<<1)) != 0;
- final Boolean pf100mbHd = ((input) & (1<<2)) != 0;
- final Boolean pf100mbFd = ((input) & (1<<3)) != 0;
- final Boolean pf1gbHd = ((input) & (1<<4)) != 0;
- final Boolean pf1gbFd = ((input) & (1<<5)) != 0;
- final Boolean pf10gbFd = ((input) & (1<<6)) != 0;
- final Boolean pf40gbFd = ((input) & (1<<7)) != 0;
- final Boolean pf100gbFd = ((input) & (1<<8)) != 0;
- final Boolean pf1tbFd = ((input) & (1<<9)) != 0;
- final Boolean pfOther = ((input) & (1<<10)) != 0;
- final Boolean pfCopper = ((input) & (1<<11)) != 0;
- final Boolean pfFiber = ((input) & (1<<12)) != 0;
- final Boolean pfAutoneg = ((input) & (1<<13)) != 0;
- final Boolean pfPause = ((input) & (1<<14)) != 0;
- final Boolean pfPauseAsym = ((input) & (1<<15)) != 0;
+ private static PortFeatures createPortFeatures(final long input) {
+ final Boolean pf10mbHd = (input & 1 << 0) != 0;
+ final Boolean pf10mbFd = (input & 1 << 1) != 0;
+ final Boolean pf100mbHd = (input & 1 << 2) != 0;
+ final Boolean pf100mbFd = (input & 1 << 3) != 0;
+ final Boolean pf1gbHd = (input & 1 << 4) != 0;
+ final Boolean pf1gbFd = (input & 1 << 5) != 0;
+ final Boolean pf10gbFd = (input & 1 << 6) != 0;
+ final Boolean pf40gbFd = (input & 1 << 7) != 0;
+ final Boolean pf100gbFd = (input & 1 << 8) != 0;
+ final Boolean pf1tbFd = (input & 1 << 9) != 0;
+ final Boolean pfOther = (input & 1 << 10) != 0;
+ final Boolean pfCopper = (input & 1 << 11) != 0;
+ final Boolean pfFiber = (input & 1 << 12) != 0;
+ final Boolean pfAutoneg = (input & 1 << 13) != 0;
+ final Boolean pfPause = (input & 1 << 14) != 0;
+ final Boolean pfPauseAsym = (input & 1 << 15) != 0;
return new PortFeatures(pf100gbFd, pf100mbFd, pf100mbHd, pf10gbFd, pf10mbFd, pf10mbHd, pf1gbFd,
pf1gbHd, pf1tbFd, pf40gbFd, pfAutoneg, pfCopper, pfFiber, pfOther, pfPause, pfPauseAsym);
}
- private static PortState createPortState(final long input){
- final Boolean psLinkDown = ((input) & (1<<0)) != 0;
- final Boolean psBblocked = ((input) & (1<<1)) != 0;
- final Boolean psLive = ((input) & (1<<2)) != 0;
+ private static PortState createPortState(final long input) {
+ final Boolean psLinkDown = (input & 1 << 0) != 0;
+ final Boolean psBblocked = (input & 1 << 1) != 0;
+ final Boolean psLive = (input & 1 << 2) != 0;
return new PortState(psBblocked, psLinkDown, psLive);
}
- private static PortConfig createPortConfig(final long input){
- final Boolean pcPortDown = ((input) & (1<<0)) != 0;
- final Boolean pcNoRecv = ((input) & (1<<2)) != 0;
- final Boolean pcNoFwd = ((input) & (1<<5)) != 0;
- final Boolean pcNoPacketIn = ((input) & (1<<6)) != 0;
+ private static PortConfig createPortConfig(final long input) {
+ final Boolean pcPortDown = (input & 1 << 0) != 0;
+ final Boolean pcNoRecv = (input & 1 << 2) != 0;
+ final Boolean pcNoFwd = (input & 1 << 5) != 0;
+ final Boolean pcNoPacketIn = (input & 1 << 6) != 0;
return new PortConfig(pcNoFwd, pcNoPacketIn, pcNoRecv, pcPortDown);
}
}
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.util.ArrayList;
import java.util.List;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.property.header.QueuePropertyBuilder;
/**
- * Translates QueueGetConfigReply messages
+ * Translates QueueGetConfigReply messages.
+ *
* @author timotej.kubas
* @author michal.polkorab
*/
public GetQueueConfigOutput deserialize(ByteBuf rawMessage) {
GetQueueConfigOutputBuilder builder = new GetQueueConfigOutputBuilder();
builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
builder.setPort(new PortNumber(rawMessage.readUnsignedInt()));
rawMessage.skipBytes(PADDING_IN_QUEUE_GET_CONFIG_REPLY_HEADER);
builder.setQueues(createQueuesList(rawMessage));
return builder.build();
}
- private List<Queues> createQueuesList(ByteBuf input){
+ private List<Queues> createQueuesList(ByteBuf input) {
List<Queues> queuesList = new ArrayList<>();
while (input.readableBytes() > 0) {
QueuesBuilder queueBuilder = new QueuesBuilder();
return queuesList;
}
- private List<QueueProperty> createPropertiesList(ByteBuf input, int length){
+ private List<QueueProperty> createPropertiesList(ByteBuf input, int length) {
int propertiesLength = length;
List<QueueProperty> propertiesList = new ArrayList<>();
while (propertiesLength > 0) {
package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
import io.netty.buffer.ByteBuf;
-
import java.math.BigInteger;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ControllerRole;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestOutputBuilder;
/**
- * Translates RoleReply messages
+ * Translates RoleReply messages.
+ *
* @author timotej.kubas
* @author michal.polkorab
*/
-public class RoleReplyMessageFactory implements OFDeserializer<RoleRequestOutput>{
+public class RoleReplyMessageFactory implements OFDeserializer<RoleRequestOutput> {
private static final byte PADDING_IN_ROLE_REPLY_HEADER = 4;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates RoleRequestInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class RoleRequestInputMessageFactory implements OFDeserializer<RoleRequestInput> {
public RoleRequestInput deserialize(ByteBuf rawMessage) {
RoleRequestInputBuilder builder = new RoleRequestInputBuilder();
builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
- builder.setXid((rawMessage.readUnsignedInt()));
+ builder.setXid(rawMessage.readUnsignedInt());
builder.setRole(ControllerRole.forValue(rawMessage.readInt()));
rawMessage.skipBytes(PADDING);
byte[] generationId = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMaskBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates SetAsyncInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class SetAsyncInputMessageFactory implements OFDeserializer<SetAsyncInput> {
private static List<PacketInReason> decodePacketInReasons(long input) {
List<PacketInReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(PacketInReason.OFPRNOMATCH);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(PacketInReason.OFPRACTION);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(PacketInReason.OFPRINVALIDTTL);
}
return reasons;
private static List<PortReason> decodePortReasons(long input) {
List<PortReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(PortReason.OFPPRADD);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(PortReason.OFPPRDELETE);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(PortReason.OFPPRMODIFY);
}
return reasons;
private static List<FlowRemovedReason> decodeFlowRemovedReasons(long input) {
List<FlowRemovedReason> reasons = new ArrayList<>();
- if ((input & (1 << 0)) != 0) {
+ if ((input & 1 << 0) != 0) {
reasons.add(FlowRemovedReason.OFPRRIDLETIMEOUT);
}
- if ((input & (1 << 1)) != 0) {
+ if ((input & 1 << 1) != 0) {
reasons.add(FlowRemovedReason.OFPRRHARDTIMEOUT);
}
- if ((input & (1 << 2)) != 0) {
+ if ((input & 1 << 2) != 0) {
reasons.add(FlowRemovedReason.OFPRRDELETE);
}
- if ((input & (1 << 3)) != 0) {
+ if ((input & 1 << 3) != 0) {
reasons.add(FlowRemovedReason.OFPRRGROUPDELETE);
}
return reasons;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.TableModInputBuilder;
/**
- * @author giuseppex.petralia@intel.com
+ * Translates TableModInput messages.
*
+ * @author giuseppex.petralia@intel.com
*/
public class TableModInputMessageFactory implements OFDeserializer<TableModInput> {
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.experimenter.core.ExperimenterDataOfChoice;
/**
+ * Translates ExperimenterMessages.
+ *
* @author michal.polkorab
*/
public class VendorMessageFactory implements OFDeserializer<ExperimenterMessage>,
}
@Override
- public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
- this.deserializerRegistry = deserializerRegistry;
+ public void injectDeserializerRegistry(DeserializerRegistry registry) {
+ this.deserializerRegistry = registry;
}
-}
\ No newline at end of file
+}
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import java.util.List;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev150203.actions.grouping.Action;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.Instruction;
-/**
- * @author michal.polkorab
+/** Base class for an action instruction deserializer.
*
+ * @author michal.polkorab
*/
public abstract class AbstractActionInstructionDeserializer implements OFDeserializer<Instruction>,
DeserializerRegistryInjector {
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.InstructionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for apply actions instruction.
*
+ * @author michal.polkorab
*/
public class ApplyActionsInstructionDeserializer extends AbstractActionInstructionDeserializer
implements HeaderDeserializer<Instruction> {
@Override
public Instruction deserialize(ByteBuf input) {
- InstructionBuilder builder = new InstructionBuilder();
+ final InstructionBuilder builder = new InstructionBuilder();
input.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
int instructionLength = input.readUnsignedShort();
input.skipBytes(InstructionConstants.PADDING_IN_ACTIONS_INSTRUCTION);
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for clear actions instructions.
*
+ * @author michal.polkorab
*/
public class ClearActionsInstructionDeserializer implements OFDeserializer<Instruction>,
HeaderDeserializer<Instruction> {
builder.setInstructionChoice(new ClearActionsCaseBuilder().build());
return builder.build();
}
-}
\ No newline at end of file
+}
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for goto table instructions.
*
+ * @author michal.polkorab
*/
public class GoToTableInstructionDeserializer implements OFDeserializer<Instruction>,
HeaderDeserializer<Instruction> {
@Override
public Instruction deserialize(ByteBuf input) {
- InstructionBuilder builder = new InstructionBuilder();
+ final InstructionBuilder builder = new InstructionBuilder();
GotoTableCaseBuilder caseBuilder = new GotoTableCaseBuilder();
GotoTableBuilder instructionBuilder = new GotoTableBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for meter instructions.
*
+ * @author michal.polkorab
*/
public class MeterInstructionDeserializer implements OFDeserializer<Instruction>,
HeaderDeserializer<Instruction> {
@Override
public Instruction deserialize(ByteBuf input) {
- InstructionBuilder builder = new InstructionBuilder();
+ final InstructionBuilder builder = new InstructionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
MeterCaseBuilder caseBuilder = new MeterCaseBuilder();
MeterBuilder instructionBuilder = new MeterBuilder();
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.InstructionConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for write actions instructions.
*
+ * @author michal.polkorab
*/
public class WriteActionsInstructionDeserializer extends AbstractActionInstructionDeserializer
implements HeaderDeserializer<Instruction> {
@Override
public Instruction deserialize(ByteBuf input) {
- InstructionBuilder builder = new InstructionBuilder();
+ final InstructionBuilder builder = new InstructionBuilder();
input.skipBytes(EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
int instructionLength = input.readUnsignedShort();
input.skipBytes(InstructionConstants.PADDING_IN_ACTIONS_INSTRUCTION);
package org.opendaylight.openflowjava.protocol.impl.deserialization.instruction;
import io.netty.buffer.ByteBuf;
-
import org.opendaylight.openflowjava.protocol.api.extensibility.HeaderDeserializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.instruction.rev130731.instructions.grouping.InstructionBuilder;
/**
- * @author michal.polkorab
+ * Deserializer for write metadata instructions.
*
+ * @author michal.polkorab
*/
public class WriteMetadataInstructionDeserializer implements OFDeserializer<Instruction>,
HeaderDeserializer<Instruction> {
@Override
public Instruction deserialize(ByteBuf input) {
- InstructionBuilder builder = new InstructionBuilder();
+ final InstructionBuilder builder = new InstructionBuilder();
input.skipBytes(2 * EncodeConstants.SIZE_OF_SHORT_IN_BYTES);
input.skipBytes(InstructionConstants.PADDING_IN_WRITE_METADATA);
- WriteMetadataCaseBuilder caseBuilder = new WriteMetadataCaseBuilder();
+ final WriteMetadataCaseBuilder caseBuilder = new WriteMetadataCaseBuilder();
WriteMetadataBuilder metadataBuilder = new WriteMetadataBuilder();
byte[] metadata = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
input.readBytes(metadata);
Code Review / openflowplugin.git / commitdiff