import org.junit.Test;
import org.opendaylight.openflowplugin.api.OFConstants;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmMatchType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCase;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStats;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueue;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table.features._case.MultipartRequestTableFeatures;
+import org.opendaylight.yangtools.yang.binding.DataContainer;
/**
* Test for {@link MultipartRequestInputFactory}.
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestDescCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(), MultipartRequestDescCase.class);
}
@Test
Assert.assertNotNull(mpRq.getMatch());
Assert.assertNull(mpRq.getMatchV10());
- final String EMPTY_MATCH_DUMP =
- "Match{_type=class org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmMatchType, "
- + "augmentation=[]}";
- Assert.assertEquals(EMPTY_MATCH_DUMP, String.valueOf(mpRq.getMatch()));
+ Assert.assertEquals(OxmMatchType.class, mpRq.getMatch().getType());
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestAggregateCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestAggregateCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestTableCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(), MultipartRequestTableCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestGroupDescCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestGroupDescCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestGroupFeaturesCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestGroupFeaturesCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestMeterFeaturesCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestMeterFeaturesCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestPortDescCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestPortDescCase.class);
}
@Test
final MultipartRequestInput mpRqInput =
(MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
checkHeader(mpRqInput, mpType);
- checkEmptyBody(mpRqInput.getMultipartRequestBody(), MultipartRequestExperimenterCase.class);
+ checkEmptyBody(mpRqInput.getMultipartRequestBody().getImplementedInterface(),
+ MultipartRequestExperimenterCase.class);
}
private void checkHeader(MultipartRequestInput mpRqInput, MultipartType mpType) {
Assert.assertEquals(xid, mpRqInput.getXid().longValue());
}
- private void checkEmptyBody(MultipartRequestBody mpRqBody, Class<? extends
+ private void checkEmptyBody(Class<? extends DataContainer> mpRqBody, Class<? extends
MultipartRequestBody> expectedMpRqBodyClass) throws Exception {
- Assert.assertTrue(expectedMpRqBodyClass.isAssignableFrom(mpRqBody.getImplementedInterface()));
- final String expectedDump = expectedMpRqBodyClass.getSimpleName() + "{augmentation=[]}";
- Assert.assertEquals(expectedDump, String.valueOf(mpRqBody));
+ Assert.assertTrue(expectedMpRqBodyClass.isAssignableFrom(mpRqBody));
+ Assert.assertEquals(expectedMpRqBodyClass, mpRqBody);
}
}
final TransmitPacketInput transmitPacketInput = transmitPacketInputBuilder.build();
- short version = (short) 0x04;
+ Short version = (short) 0x04;
byte[] datapathIdByte = new byte[EncodeConstants.SIZE_OF_LONG_IN_BYTES];
for (int i = 0; i < datapathIdByte.length; i++) {
datapathIdByte[i] = 1;
data.setDatapathId(datapathId);
PacketOutInput message = convert(transmitPacketInput, data);
- Assert.assertEquals(transmitPacketInput.getBufferId(),
- message.getBufferId());
- Assert.assertEquals("PortNumber{_value=" + inPort + "}", message
- .getInPort().toString());
- Assert.assertEquals((Object) version,
- Short.valueOf(message.getVersion()));
+ Assert.assertEquals(transmitPacketInput.getBufferId(), message.getBufferId());
+ Assert.assertEquals(Long.valueOf(inPort), message.getInPort().getValue());
+ Assert.assertEquals(version, message.getVersion());
Assert.assertEquals(xid, message.getXid());
ActionConvertorData actionConvertorData = new ActionConvertorData(version);
actionConvertorData.setDatapathId(datapathId);
- Optional<List<Action>> actionsOptional = convertorManager.convert(
- actionList, actionConvertorData);
+ Optional<List<Action>> actionsOptional = convertorManager.convert(actionList, actionConvertorData);
List<Action> actions = actionsOptional.orElse(Collections.emptyList());
Assert.assertEquals(actions, message.getAction());