type oft:group-type;\r
}\r
leaf group-id {\r
- type uint32;\r
+ type oft:group-id;\r
}\r
\r
uses buckets;\r
}\r
case multipart-request-group {\r
leaf group-id {\r
- type uint32;\r
+ type oft:group-id;\r
}\r
}\r
case multipart-request-group-desc {\r
}\r
case multipart-request-meter {\r
leaf meter-id {\r
- type uint32;\r
+ type oft:meter-id;\r
}\r
}\r
case multipart-request-meter-config {\r
leaf meter-id {\r
- type uint32;\r
+ type oft:meter-id;\r
}\r
}\r
case multipart-request-meter-features {\r
case multipart-reply-group {\r
list group-stats {\r
leaf group-id {\r
- type uint32;\r
+ type oft:group-id;\r
}\r
leaf ref-count {\r
type uint32;\r
type oft:group-type;\r
}\r
leaf group-id {\r
- type uint32;\r
+ type oft:group-id;\r
}\r
uses buckets;\r
}\r
case multipart-reply-meter {\r
list meter-stats {\r
leaf meter-id {\r
- type uint32;\r
+ type oft:meter-id;\r
}\r
leaf flow-count {\r
type uint32;\r
type oft:meter-flags;\r
}\r
leaf meter-id {\r
- type uint32;\r
+ type oft:meter-id;\r
}\r
list bands {\r
uses meter-band-header;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ActionType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupCapabilities;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupTypes;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterBandType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterBandTypeBitmap;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterFlags;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterId;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortConfig;\r
GroupStatsBuilder groupStatsBuilder = new GroupStatsBuilder();\r
int bodyLength = input.readUnsignedShort();\r
input.skipBytes(PADDING_IN_GROUP_HEADER_01);\r
- groupStatsBuilder.setGroupId(input.readUnsignedInt());\r
+ groupStatsBuilder.setGroupId(new GroupId(input.readUnsignedInt()));\r
groupStatsBuilder.setRefCount(input.readUnsignedInt());\r
input.skipBytes(PADDING_IN_GROUP_HEADER_02);\r
byte[] packetCount = new byte[Long.SIZE/Byte.SIZE];\r
List<MeterStats> meterStatsList = new ArrayList<>();\r
while (input.readableBytes() > 0) {\r
MeterStatsBuilder meterStatsBuilder = new MeterStatsBuilder();\r
- meterStatsBuilder.setMeterId(input.readUnsignedInt());\r
+ meterStatsBuilder.setMeterId(new MeterId(input.readUnsignedInt()));\r
int meterStatsBodyLength = input.readUnsignedShort();\r
input.skipBytes(PADDING_IN_METER_STATS_HEADER);\r
meterStatsBuilder.setFlowCount(input.readUnsignedInt());\r
MeterConfigBuilder meterConfigBuilder = new MeterConfigBuilder();\r
int meterConfigBodyLength = input.readUnsignedShort();\r
meterConfigBuilder.setFlags(createMeterFlags(input.readUnsignedShort()));\r
- meterConfigBuilder.setMeterId(input.readUnsignedInt());\r
+ meterConfigBuilder.setMeterId(new MeterId(input.readUnsignedInt()));\r
int actualLength = METER_CONFIG_LENGTH;\r
List<Bands> bandsList = new ArrayList<>();\r
while (actualLength < meterConfigBodyLength) {\r
int bodyLength = input.readUnsignedShort();\r
groupDescBuilder.setType(GroupType.forValue(input.readUnsignedByte()));\r
input.skipBytes(PADDING_IN_GROUP_DESC_HEADER);\r
- groupDescBuilder.setGroupId(input.readUnsignedInt());\r
+ groupDescBuilder.setGroupId(new GroupId(input.readUnsignedInt()));\r
int actualLength = GROUP_DESC_HEADER_LENGTH;\r
List<BucketsList> bucketsList = new ArrayList<>();\r
while (actualLength < bodyLength) {\r
out.writeShort(message.getCommand().getIntValue());\r
out.writeByte(message.getType().getIntValue());\r
ByteBufUtils.padBuffer(PADDING_IN_GROUP_MOD_MESSAGE, out);\r
- out.writeInt(message.getGroupId().intValue());\r
+ out.writeInt(message.getGroupId().getValue().intValue());\r
encodeBuckets(message.getBucketsList(), out);\r
}\r
\r
\r
private static void encodeGroupStatsBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
MultipartRequestGroup groupStats = (MultipartRequestGroup) multipartRequestBody;\r
- output.writeInt(groupStats.getGroupId().intValue());\r
+ output.writeInt(groupStats.getGroupId().getValue().intValue());\r
ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_GROUP_BODY, output);\r
}\r
\r
private static void encodeMeterBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
MultipartRequestMeter meter = (MultipartRequestMeter) multipartRequestBody;\r
- output.writeInt(meter.getMeterId().intValue());\r
+ output.writeInt(meter.getMeterId().getValue().intValue());\r
ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_METER_BODY, output);\r
}\r
\r
private static void encodeMeterConfigBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
MultipartRequestMeterConfig meterConfig = (MultipartRequestMeterConfig) multipartRequestBody;\r
- output.writeInt(meterConfig.getMeterId().intValue());\r
+ output.writeInt(meterConfig.getMeterId().getValue().intValue());\r
ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_METER_CONFIG_BODY, output);\r
}\r
\r
\r
MultipartReplyGroup message = (MultipartReplyGroup) builtByFactory.getMultipartReplyBody();\r
\r
- Assert.assertEquals("Wrong groupId", 16, message.getGroupStats().get(0).getGroupId().intValue());\r
+ Assert.assertEquals("Wrong groupId", 16, message.getGroupStats().get(0).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong refCount", 18, message.getGroupStats().get(0).getRefCount().intValue());\r
Assert.assertEquals("Wrong packetCount", \r
new BigInteger(new byte[]{0x00, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01}), \r
new BigInteger(new byte[]{0x00, 0x02, 0x02, 0x02, 0x02, 0x02, 0x02, 0x02}), \r
message.getGroupStats().get(0).getBucketStats().get(1).getByteCount());\r
\r
- Assert.assertEquals("Wrong groupId_2", 16, message.getGroupStats().get(1).getGroupId().intValue());\r
+ Assert.assertEquals("Wrong groupId_2", 16, message.getGroupStats().get(1).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong refCount_2", 18, message.getGroupStats().get(1).getRefCount().intValue());\r
Assert.assertEquals("Wrong packetCount_2", \r
new BigInteger(new byte[]{0x00, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01}), \r
MultipartReplyMeter message = (MultipartReplyMeter) builtByFactory.getMultipartReplyBody();\r
\r
Assert.assertEquals("Wrong meterId", 9, \r
- message.getMeterStats().get(0).getMeterId().intValue());\r
+ message.getMeterStats().get(0).getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong flowCount", 7, \r
message.getMeterStats().get(0).getFlowCount().intValue());\r
Assert.assertEquals("Wrong packetInCount", \r
MultipartReplyMeter message = (MultipartReplyMeter) builtByFactory.getMultipartReplyBody();\r
\r
Assert.assertEquals("Wrong meterId", 9, \r
- message.getMeterStats().get(0).getMeterId().intValue());\r
+ message.getMeterStats().get(0).getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong flowCount", 7, \r
message.getMeterStats().get(0).getFlowCount().intValue());\r
Assert.assertEquals("Wrong packetInCount", \r
message.getMeterStats().get(0).getMeterBandStats().get(2).getByteBandCount());\r
\r
Assert.assertEquals("Wrong meterId", 8, \r
- message.getMeterStats().get(1).getMeterId().intValue());\r
+ message.getMeterStats().get(1).getMeterId().getValue().intValue());\r
Assert.assertEquals("Wrong flowCount", 7, \r
message.getMeterStats().get(1).getFlowCount().intValue());\r
Assert.assertEquals("Wrong packetInCount", \r
Assert.assertEquals("Wrong flags", new MeterFlags(false, false, true, true),\r
message.getMeterConfig().get(0).getFlags());\r
Assert.assertEquals("Wrong meterId", 9, \r
- message.getMeterConfig().get(0).getMeterId().intValue());\r
+ message.getMeterConfig().get(0).getMeterId().getValue().intValue());\r
\r
MeterBandDrop meterBandDrop = (MeterBandDrop) message.getMeterConfig().get(0).getBands().get(0).getMeterBand(); \r
Assert.assertEquals("Wrong meterBandDrop.type", 1, meterBandDrop.getType().getIntValue()); \r
Assert.assertEquals("Wrong flags", new MeterFlags(true, false, true, false), \r
message.getMeterConfig().get(0).getFlags());\r
Assert.assertEquals("Wrong meterId", 9, \r
- message.getMeterConfig().get(0).getMeterId().intValue());\r
+ message.getMeterConfig().get(0).getMeterId().getValue().intValue());\r
\r
MeterBandDrop meterBandDrop = (MeterBandDrop) message.getMeterConfig().get(0).getBands().get(0).getMeterBand(); \r
Assert.assertEquals("Wrong meterBandDrop.type", 1, meterBandDrop.getType().getIntValue()); \r
Assert.assertEquals("Wrong flags01", new MeterFlags(false, true, true, false),\r
message.getMeterConfig().get(1).getFlags());\r
Assert.assertEquals("Wrong meterId01", 7, \r
- message.getMeterConfig().get(1).getMeterId().intValue());\r
+ message.getMeterConfig().get(1).getMeterId().getValue().intValue());\r
\r
MeterBandDscpRemark meterBandDscp01 = (MeterBandDscpRemark) message.getMeterConfig().get(1).getBands().get(0).getMeterBand(); \r
Assert.assertEquals("Wrong meterBandDscp01.type", 2, meterBandDscp01.getType().getIntValue()); \r
Assert.assertEquals("Wrong type", 1, \r
message.getGroupDesc().get(0).getType().getIntValue());\r
Assert.assertEquals("Wrong groupId", 8, \r
- message.getGroupDesc().get(0).getGroupId().intValue());\r
+ message.getGroupDesc().get(0).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong bucketWeight", 6, \r
message.getGroupDesc().get(0).getBucketsList().get(0).getWeight().intValue());\r
Assert.assertEquals("Wrong bucketWatchPort", 5, \r
Assert.assertEquals("Wrong type", 1, \r
message.getGroupDesc().get(0).getType().getIntValue());\r
Assert.assertEquals("Wrong groupId", 8, \r
- message.getGroupDesc().get(0).getGroupId().intValue());\r
+ message.getGroupDesc().get(0).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong bucketWeight", 6, \r
message.getGroupDesc().get(0).getBucketsList().get(0).getWeight().intValue());\r
Assert.assertEquals("Wrong bucketWatchPort", 5, \r
Assert.assertEquals("Wrong type", 1, \r
message.getGroupDesc().get(0).getType().getIntValue());\r
Assert.assertEquals("Wrong groupId", 8, \r
- message.getGroupDesc().get(0).getGroupId().intValue());\r
+ message.getGroupDesc().get(0).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong bucketWeight", 6, \r
message.getGroupDesc().get(0).getBucketsList().get(0).getWeight().intValue());\r
Assert.assertEquals("Wrong bucketWatchPort", 5, \r
Assert.assertEquals("Wrong type", 1, \r
message.getGroupDesc().get(0).getType().getIntValue());\r
Assert.assertEquals("Wrong groupId", 8, \r
- message.getGroupDesc().get(0).getGroupId().intValue());\r
+ message.getGroupDesc().get(0).getGroupId().getValue().intValue());\r
Assert.assertEquals("Wrong bucketWeight", 6, \r
message.getGroupDesc().get(0).getBucketsList().get(0).getWeight().intValue());\r
Assert.assertEquals("Wrong bucketWatchPort", 5, \r
import org.opendaylight.openflowjava.protocol.impl.deserialization.factories.HelloMessageFactoryTest;\r
import org.opendaylight.openflowjava.protocol.impl.util.BufferHelper;\r
import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupModCommand;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortNumber;\r
BufferHelper.setupHeader(builder, EncodeConstants.OF13_VERSION_ID);\r
builder.setCommand(GroupModCommand.forValue(2));\r
builder.setType(GroupType.forValue(3));\r
- builder.setGroupId(256L);\r
+ builder.setGroupId(new GroupId(256L));\r
List<BucketsList> exp = createBucketsList();\r
builder.setBucketsList(exp);\r
GroupModInput message = builder.build();\r
Assert.assertEquals("Wrong command", message.getCommand().getIntValue(), out.readUnsignedShort());\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readUnsignedByte());\r
out.skipBytes(PADDING_IN_GROUP_MOD_MESSAGE);\r
- Assert.assertEquals("Wrong groupId", message.getGroupId().intValue(), out.readUnsignedInt());\r
+ Assert.assertEquals("Wrong groupId", message.getGroupId().getValue().intValue(), out.readUnsignedInt());\r
List<BucketsList> rec = createBucketsListFromBufer(out);\r
Assert.assertArrayEquals("Wrong bucketList", exp.toArray(), rec.toArray());\r
}\r
import org.opendaylight.openflowjava.protocol.impl.deserialization.factories.HelloMessageFactoryTest;\r
import org.opendaylight.openflowjava.protocol.impl.util.BufferHelper;\r
import org.opendaylight.openflowjava.protocol.impl.util.EncodeConstants;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.GroupId;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MeterId;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableConfig;\r
\r
private static MultipartRequestGroup createRequestGroup() {\r
MultipartRequestGroupBuilder builder = new MultipartRequestGroupBuilder();\r
- builder.setGroupId(2258L);\r
+ builder.setGroupId(new GroupId(2258L));\r
MultipartRequestGroup group = builder.build();\r
return group;\r
}\r
private static MultipartRequestGroup decodeRequestGroup(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_GROUP_BODY = 4;\r
MultipartRequestGroupBuilder builder = new MultipartRequestGroupBuilder();\r
- builder.setGroupId(output.readUnsignedInt());\r
+ builder.setGroupId(new GroupId(output.readUnsignedInt()));\r
output.skipBytes(PADDING_IN_MULTIPART_REQUEST_GROUP_BODY);\r
MultipartRequestGroup group = builder.build();\r
return group;\r
\r
private static MultipartRequestMeter createRequestMeter() {\r
MultipartRequestMeterBuilder builder = new MultipartRequestMeterBuilder();\r
- builder.setMeterId(1121L);\r
+ builder.setMeterId(new MeterId(1121L));\r
MultipartRequestMeter meter = builder.build();\r
return meter;\r
}\r
private static MultipartRequestMeter decodeRequestMeter(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_METER_BODY = 4;\r
MultipartRequestMeterBuilder builder = new MultipartRequestMeterBuilder();\r
- builder.setMeterId(output.readUnsignedInt());\r
+ builder.setMeterId(new MeterId(output.readUnsignedInt()));\r
output.skipBytes(PADDING_IN_MULTIPART_REQUEST_METER_BODY);\r
MultipartRequestMeter meter = builder.build();\r
return meter;\r
\r
private static MultipartRequestMeterConfig createRequestMeterConfig() {\r
MultipartRequestMeterConfigBuilder builder = new MultipartRequestMeterConfigBuilder();\r
- builder.setMeterId(1133L);\r
+ builder.setMeterId(new MeterId(1133L));\r
MultipartRequestMeterConfig meterConfig = builder.build();\r
return meterConfig;\r
}\r
private static MultipartRequestMeterConfig decodeRequestMeterConfig(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_METER_CONFIG_BODY = 4;\r
MultipartRequestMeterConfigBuilder builder = new MultipartRequestMeterConfigBuilder();\r
- builder.setMeterId(output.readUnsignedInt());\r
+ builder.setMeterId(new MeterId(output.readUnsignedInt()));\r
output.skipBytes(PADDING_IN_MULTIPART_REQUEST_METER_CONFIG_BODY);\r
MultipartRequestMeterConfig meterConfig = builder.build();\r
return meterConfig;\r