import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.TableConfig;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestMessage;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestMessageBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregate;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateBuilder;\r
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDescBuilder;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenter;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterBuilder;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlow;\r
*/\r
public class MultipartRequestMessageFactoryTest {\r
private static final byte PADDING_IN_MULTIPART_REQUEST_MESSAGE = 4;\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestFlow());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong flow", message.getMultipartRequestBody(), decodeRequestFlow(out));\r
}\r
- \r
+\r
private static MultipartRequestFlow createRequestFlow() {\r
MultipartRequestFlowBuilder builder = new MultipartRequestFlowBuilder();\r
builder.setTableId((short) 8);\r
//TODO match field\r
return flow;\r
}\r
- \r
+\r
private static MultipartRequestFlow decodeRequestFlow(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_01 = 3;\r
final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY_02 = 4;\r
MultipartRequestFlow flow = builder.build();\r
return flow;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestAggregate());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong aggregate", message.getMultipartRequestBody(), decodeRequestAggregate(out));\r
}\r
- \r
+\r
private static MultipartRequestFlags decodeMultipartRequestFlags(short input){\r
final Boolean _oFPMPFREQMORE = (input & (1 << 0)) > 0;\r
return new MultipartRequestFlags(_oFPMPFREQMORE);\r
}\r
- \r
- \r
+\r
+\r
private static MultipartRequestAggregate createRequestAggregate() {\r
MultipartRequestAggregateBuilder builder = new MultipartRequestAggregateBuilder();\r
builder.setTableId((short) 8);\r
//TODO match field\r
return aggregate;\r
}\r
- \r
+\r
private static MultipartRequestAggregate decodeRequestAggregate(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_AGGREGATE_BODY_01 = 3;\r
final byte PADDING_IN_MULTIPART_REQUEST_AGGREGATE_BODY_02 = 4;\r
MultipartRequestAggregate flow = builder.build();\r
return flow;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
//multipart request for table does not have body\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestPortStats());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong portStatsBody", message.getMultipartRequestBody(), decodeRequestPortStats(out));\r
}\r
- \r
+\r
private static MultipartRequestPortStats createRequestPortStats() {\r
MultipartRequestPortStatsBuilder builder = new MultipartRequestPortStatsBuilder();\r
builder.setPortNo(2251L);\r
MultipartRequestPortStats portStats = builder.build();\r
return portStats;\r
}\r
- \r
+\r
private static MultipartRequestPortStats decodeRequestPortStats(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_PORTSTATS_BODY = 4;\r
MultipartRequestPortStatsBuilder builder = new MultipartRequestPortStatsBuilder();\r
MultipartRequestPortStats portRequest = builder.build();\r
return portRequest;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestQueue());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong queueBody", message.getMultipartRequestBody(), decodeRequestQueue(out));\r
}\r
- \r
+\r
private static MultipartRequestQueue createRequestQueue() {\r
MultipartRequestQueueBuilder builder = new MultipartRequestQueueBuilder();\r
builder.setPortNo(2256L);\r
MultipartRequestQueue queue = builder.build();\r
return queue;\r
}\r
- \r
+\r
private static MultipartRequestQueue decodeRequestQueue(ByteBuf output) {\r
MultipartRequestQueueBuilder builder = new MultipartRequestQueueBuilder();\r
builder.setPortNo(output.readUnsignedInt());\r
MultipartRequestQueue queue = builder.build();\r
return queue;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestGroup());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong groupBody", message.getMultipartRequestBody(), decodeRequestGroup(out));\r
}\r
- \r
+\r
private static MultipartRequestGroup createRequestGroup() {\r
MultipartRequestGroupBuilder builder = new MultipartRequestGroupBuilder();\r
builder.setGroupId(2258L);\r
MultipartRequestGroup group = builder.build();\r
return group;\r
}\r
- \r
+\r
private static MultipartRequestGroup decodeRequestGroup(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_GROUP_BODY = 4;\r
MultipartRequestGroupBuilder builder = new MultipartRequestGroupBuilder();\r
MultipartRequestGroup group = builder.build();\r
return group;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestMeter());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong meterBody", message.getMultipartRequestBody(), decodeRequestMeter(out));\r
}\r
- \r
+\r
private static MultipartRequestMeter createRequestMeter() {\r
MultipartRequestMeterBuilder builder = new MultipartRequestMeterBuilder();\r
builder.setMeterId(1121L);\r
MultipartRequestMeter meter = builder.build();\r
return meter;\r
}\r
- \r
+\r
private static MultipartRequestMeter decodeRequestMeter(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_METER_BODY = 4;\r
MultipartRequestMeterBuilder builder = new MultipartRequestMeterBuilder();\r
MultipartRequestMeter meter = builder.build();\r
return meter;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestMeterConfig());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong meterConfigBody", message.getMultipartRequestBody(), decodeRequestMeterConfig(out));\r
}\r
- \r
+\r
private static MultipartRequestMeterConfig createRequestMeterConfig() {\r
MultipartRequestMeterConfigBuilder builder = new MultipartRequestMeterConfigBuilder();\r
builder.setMeterId(1133L);\r
MultipartRequestMeterConfig meterConfig = builder.build();\r
return meterConfig;\r
}\r
- \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
MultipartRequestMeterConfig meterConfig = builder.build();\r
return meterConfig;\r
}\r
- \r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestExperimenter());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readUnsignedShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
Assert.assertEquals("Wrong experimenterBody", message.getMultipartRequestBody(), decodeRequestExperimenter(out));\r
}\r
- \r
+\r
private static MultipartRequestExperimenter createRequestExperimenter() {\r
MultipartRequestExperimenterBuilder builder = new MultipartRequestExperimenterBuilder();\r
builder.setExperimenter(1133L);\r
MultipartRequestExperimenter experimenter = builder.build();\r
return experimenter;\r
}\r
- \r
+\r
private static MultipartRequestExperimenter decodeRequestExperimenter(ByteBuf output) {\r
MultipartRequestExperimenterBuilder builder = new MultipartRequestExperimenterBuilder();\r
builder.setExperimenter(output.readUnsignedInt());\r
MultipartRequestExperimenter experimenter = builder.build();\r
return experimenter;\r
}\r
- \r
+\r
+ /**\r
+ * @throws Exception\r
+ * Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
+ */\r
+ @Test\r
+ public void testMultipartRequestDescMessageFactory() throws Exception {\r
+ MultipartRequestMessageBuilder builder = new MultipartRequestMessageBuilder();\r
+ BufferHelper.setupHeader(builder);\r
+ builder.setType(MultipartType.forValue(0));\r
+ builder.setFlags(new MultipartRequestFlags(true));\r
+ builder.setMultipartRequestBody(createRequestDesc());\r
+ MultipartRequestMessage message = builder.build();\r
+\r
+ ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
+ MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
+ factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
+\r
+ BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
+ Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readUnsignedShort());\r
+ Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
+ }\r
+\r
+ private MultipartRequestBody createRequestDesc() {\r
+ MultipartRequestDescBuilder builder = new MultipartRequestDescBuilder();\r
+ return builder.build();\r
+ }\r
+\r
/**\r
* @throws Exception\r
* Testing of {@link MultipartRequestMessageFactory} for correct translation from POJO\r
builder.setFlags(new MultipartRequestFlags(true));\r
builder.setMultipartRequestBody(createRequestTableFeatures());\r
MultipartRequestMessage message = builder.build();\r
- \r
+\r
ByteBuf out = UnpooledByteBufAllocator.DEFAULT.buffer();\r
MultipartRequestMessageFactory factory = MultipartRequestMessageFactory.getInstance();\r
factory.messageToBuffer(HelloMessageFactoryTest.VERSION_YET_SUPPORTED, out, message);\r
- \r
+\r
BufferHelper.checkHeaderV13(out, factory.getMessageType(), factory.computeLength(message));\r
Assert.assertEquals("Wrong type", message.getType().getIntValue(), out.readUnsignedShort());\r
Assert.assertEquals("Wrong flags", message.getFlags(), decodeMultipartRequestFlags(out.readShort()));\r
out.skipBytes(PADDING_IN_MULTIPART_REQUEST_MESSAGE);\r
- \r
+\r
MultipartRequestTableFeatures messageTableFeatures = (MultipartRequestTableFeatures) message.getMultipartRequestBody();\r
Assert.assertEquals("Wrong tableFeaturesBody", messageTableFeatures.getTableFeatures(), decodeRequestTableFeatures(out).getTableFeatures());\r
}\r
- \r
+\r
private static MultipartRequestTableFeatures createRequestTableFeatures() {\r
MultipartRequestTableFeaturesBuilder builder = new MultipartRequestTableFeaturesBuilder();\r
List<TableFeatures> tableFeaturesList = new ArrayList<>();\r
- TableFeaturesBuilder tableFeaturesBuilder = new TableFeaturesBuilder(); \r
+ TableFeaturesBuilder tableFeaturesBuilder = new TableFeaturesBuilder();\r
tableFeaturesBuilder.setTableId((short) 8);\r
tableFeaturesBuilder.setName("AAAABBBBCCCCDDDDEEEEFFFFGGGG");\r
tableFeaturesBuilder.setMetadataMatch(new BigInteger(new byte[] {0x00, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01}));\r
MultipartRequestTableFeatures tableFeaturesRequest = builder.build();\r
return tableFeaturesRequest;\r
}\r
- \r
+\r
private static MultipartRequestTableFeatures decodeRequestTableFeatures(ByteBuf output) {\r
final byte PADDING_IN_MULTIPART_REQUEST_TABLE_FEATURES_BODY = 5;\r
final byte OFP_MAX_TABLE_NAME_LEN = 32;\r
MultipartRequestTableFeatures tableFeaturesRequest = builder.build();\r
return tableFeaturesRequest;\r
}\r
- \r
+\r
private static TableConfig decodeTableConfig(int input) {\r
- final Boolean _oFPTCDEPRECATEDMASK = (input & (1 << 3)) > 0; \r
+ final Boolean _oFPTCDEPRECATEDMASK = (input & (1 << 3)) > 0;\r
return new TableConfig(_oFPTCDEPRECATEDMASK);\r
}\r
- \r
+\r
}\r