Convert all use of widened types to proper uint types.
JIRA: OPNFLWPLUG-1099
Change-Id: Iabdcf752965851b29be0162c70f463206d07abaa
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableModFailedCode;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
+import org.opendaylight.yangtools.yang.common.Uint16;
/**
* Translates Error messages.
private static void decodeType(ErrorMessageBuilder builder, ErrorType type, int readValue) {
if (type != null) {
- builder.setType(type.getIntValue());
+ builder.setType(Uint16.valueOf(type.getIntValue()));
builder.setTypeString(type.name());
} else {
- builder.setType(readValue);
+ builder.setType(Uint16.valueOf(readValue));
builder.setTypeString(UNKNOWN_TYPE);
}
}
}
private static void setUnknownCode(ErrorMessageBuilder builder, int readValue) {
- builder.setCode(readValue);
+ builder.setCode(Uint16.valueOf(readValue));
builder.setCodeString(UNKNOWN_CODE);
}
private static void setCode(ErrorMessageBuilder builder, int code, String codeString) {
- builder.setCode(code);
+ builder.setCode(Uint16.valueOf(code));
builder.setCodeString(codeString);
}
Objects.requireNonNull(deserializerRegistry);
final Uint32 xid = readUint32(message);
- final long expId = message.readUnsignedInt();
- final long expType = message.readUnsignedInt();
+ final Uint32 expId = readUint32(message);
+ final Uint32 expType = readUint32(message);
OFDeserializer<ExperimenterDataOfChoice> deserializer = deserializerRegistry.getDeserializer(
ExperimenterDeserializerKeyFactory.createExperimenterMessageDeserializerKey(
- EncodeConstants.OF13_VERSION_ID, expId, expType));
+ EncodeConstants.OF13_VERSION_ID, expId.toJava(), expType.toJava()));
final ExperimenterDataOfChoice vendorData = deserializer.deserialize(message);
ExperimenterMessageBuilder messageBld = new ExperimenterMessageBuilder()
}
private MultipartReplyExperimenterCase setExperimenter(final ByteBuf input) {
- final long expId = input.readUnsignedInt();
- final long expType = input.readUnsignedInt();
+ final Uint32 expId = readUint32(input);
+ final Uint32 expType = readUint32(input);
final OFDeserializer<ExperimenterDataOfChoice> deserializer = registry.getDeserializer(
ExperimenterDeserializerKeyFactory.createMultipartReplyMessageDeserializerKey(
- EncodeConstants.OF13_VERSION_ID, expId, expType));
+ EncodeConstants.OF13_VERSION_ID, expId.toJava(), expType.toJava()));
final MultipartReplyExperimenterBuilder mpExperimenterBld = new MultipartReplyExperimenterBuilder()
.setExperimenter(new ExperimenterId(expId))
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.QueueOpFailedCodeV10;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
+import org.opendaylight.yangtools.yang.common.Uint16;
/**
* Translates Error messages (OpenFlow v1.0).
private static void decodeType(ErrorMessageBuilder builder, ErrorTypeV10 type, int readValue) {
if (type != null) {
- builder.setType(type.getIntValue());
+ builder.setType(Uint16.valueOf(type.getIntValue()));
builder.setTypeString(type.name());
} else {
- builder.setType(readValue);
+ builder.setType(Uint16.valueOf(readValue));
builder.setTypeString(UNKNOWN_TYPE);
}
}
}
private static void setUnknownCode(ErrorMessageBuilder builder, int readValue) {
- builder.setCode(readValue);
+ builder.setCode(Uint16.valueOf(readValue));
builder.setCodeString(UNKNOWN_CODE);
}
private static void setCode(ErrorMessageBuilder builder, int code, String codeString) {
- builder.setCode(code);
+ builder.setCode(Uint16.valueOf(code));
builder.setCodeString(codeString);
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table._case.MultipartReplyTableBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table._case.multipart.reply.table.TableStats;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.table._case.multipart.reply.table.TableStatsBuilder;
+import org.opendaylight.yangtools.yang.common.Uint32;
/**
* Translates StatsReply messages (OpenFlow v1.0).
}
private MultipartReplyExperimenterCase setExperimenter(ByteBuf input) {
- final long expId = input.readUnsignedInt();
+ final Uint32 expId = readUint32(input);
final OFDeserializer<ExperimenterDataOfChoice> deserializer = registry.getDeserializer(
ExperimenterDeserializerKeyFactory.createMultipartReplyVendorMessageDeserializerKey(
- EncodeConstants.OF10_VERSION_ID, expId));
+ EncodeConstants.OF10_VERSION_ID, expId.toJava()));
final MultipartReplyExperimenterBuilder mpExperimenterBld = new MultipartReplyExperimenterBuilder()
.setExperimenter(new ExperimenterId(expId))
Objects.requireNonNull(deserializerRegistry);
final Uint32 xid = readUint32(message);
- final long expId = message.readUnsignedInt();
+ final Uint32 expId = readUint32(message);
OFDeserializer<ExperimenterDataOfChoice> deserializer = deserializerRegistry.getDeserializer(
ExperimenterDeserializerKeyFactory.createVendorMessageDeserializerKey(
- EncodeConstants.OF10_VERSION_ID, expId));
+ EncodeConstants.OF10_VERSION_ID, expId.toJava()));
final ExperimenterDataOfChoice vendorData = deserializer.deserialize(message);
final ExperimenterMessageBuilder messageBld = new ExperimenterMessageBuilder()
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entries.grouping.MatchEntryBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.PbbIsidCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.entry.value.grouping.match.entry.value.pbb.isid._case.PbbIsidBuilder;
+import org.opendaylight.yangtools.yang.common.Uint32;
/**
* Translates OxmPbbIsid messages.
@Override
protected void deserialize(final ByteBuf input, final MatchEntryBuilder builder) {
- final Integer isid = input.readUnsignedMedium();
+ final int isid = input.readUnsignedMedium();
final PbbIsidBuilder isidBuilder = new PbbIsidBuilder()
- .setIsid(isid.longValue());
+ .setIsid(Uint32.valueOf(isid));
if (builder.isHasMask()) {
isidBuilder.setMask(OxmDeserializerHelper.convertMask(input, EncodeConstants.SIZE_OF_3_BYTES));
}
*/
package org.opendaylight.openflowjava.protocol.impl.util;
+import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFGeneralDeserializer;
import org.opendaylight.openflowjava.protocol.api.keys.MessageCodeKey;
+import org.opendaylight.yangtools.yang.common.Uint8;
/**
* Helper class for deserializer registration.
public class SimpleDeserializerRegistryHelper {
private final short version;
+ private final @NonNull Uint8 uintVersion;
private final DeserializerRegistry registry;
/**
public SimpleDeserializerRegistryHelper(final short version, final DeserializerRegistry deserializerRegistry) {
this.version = version;
this.registry = deserializerRegistry;
+ this.uintVersion = Uint8.valueOf(version);
}
/**
registry.registerDeserializer(new MessageCodeKey(version, code, deserializedObjectClass), deserializer);
if (deserializer instanceof VersionAssignableFactory) {
- ((VersionAssignableFactory) deserializer).assignVersion(version);
+ ((VersionAssignableFactory<?>) deserializer).assignVersion(uintVersion);
}
}
}
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
import org.opendaylight.yangtools.yang.binding.DataContainer;
+import org.opendaylight.yangtools.yang.common.Uint8;
/**
* Abstract factory class to support OF protocol version assigning and reading.
*/
public abstract class VersionAssignableFactory<T extends DataContainer> implements OFDeserializer<T> {
- private Short version;
+ private Uint8 version;
/**
* Assigns the version.
*
* @param newVersion OpenFlow protocol version
*/
- public void assignVersion(@NonNull final Short newVersion) {
- if (this.version == null) {
- this.version = newVersion;
- } else {
- throw new IllegalStateException("Version already assigned: " + this.version);
+ public void assignVersion(final @NonNull Uint8 newVersion) {
+ if (version != null) {
+ throw new IllegalStateException("Version already assigned: " + version);
}
+ version = newVersion;
}
/**
* Returns the OpenFlow protocol version.
*/
- protected Short getVersion() {
+ protected final Uint8 getVersion() {
return this.version;
}
}