import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStatsBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupCase;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.group._case.MultipartRequestGroup;
+import org.opendaylight.yangtools.yang.common.Uint32;
public class GroupDirectStatisticsServiceTest extends AbstractDirectStatisticsServiceTest {
- static final Long GROUP_NO = 1L;
+ static final Uint32 GROUP_NO = Uint32.ONE;
private GroupDirectStatisticsService service;
@Override
- public void setUp() throws Exception {
+ public void setUp() {
service = new GroupDirectStatisticsService(requestContextStack,
deviceContext,
convertorManager,
}
@Override
- public void testBuildRequestBody() throws Exception {
+ public void testBuildRequestBody() {
final GetGroupStatisticsInput input = mock(GetGroupStatisticsInput.class);
lenient().when(input.getNode()).thenReturn(createNodeRef(NODE_ID));
when(input.getGroupId()).thenReturn(new GroupId(GROUP_NO));
final MultipartRequestGroupCase body = (MultipartRequestGroupCase) ((MultipartRequestInput) service
- .buildRequest(new Xid(42L), input))
+ .buildRequest(new Xid(Uint32.valueOf(42)), input))
.getMultipartRequestBody();
final MultipartRequestGroup group = body.getMultipartRequestGroup();
}
@Override
- public void testBuildReply() throws Exception {
+ public void testBuildReply() {
final MultipartReply reply = mock(MultipartReply.class);
final MultipartReplyGroupCase groupCase = mock(MultipartReplyGroupCase.class);
final MultipartReplyGroup group = mock(MultipartReplyGroup.class);
assertTrue(output.getGroupStats().size() > 0);
final org.opendaylight.yang.gen.v1.urn
- .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats stats = output.getGroupStats().get(0);
+ .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats stats =
+ output.nonnullGroupStats().values().iterator().next();
assertEquals(stats.getGroupId().getValue(), GROUP_NO);
}
@Override
- public void testStoreStatistics() throws Exception {
- final org.opendaylight.yang.gen.v1.urn
- .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats stat =
- mock(org.opendaylight.yang.gen.v1.urn
- .opendaylight.group.types.rev131018.group.statistics.reply.GroupStats.class);
- when(stat.getGroupId()).thenReturn(new GroupId(GROUP_NO));
-
- final List<org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply
- .GroupStats>
- stats = Collections.singletonList(stat);
+ public void testStoreStatistics() {
+ final var stat = new org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply
+ .GroupStatsBuilder().setGroupId(new GroupId(GROUP_NO)).build();
+
final GetGroupStatisticsOutput output = mock(GetGroupStatisticsOutput.class);
- when(output.getGroupStats()).thenReturn(stats);
+ when(output.nonnullGroupStats()).thenReturn(Collections.singletonMap(stat.key(), stat));
multipartWriterProvider.lookup(MultipartType.OFPMPGROUP).get().write(output, true);
verify(deviceContext).writeToTransactionWithParentsSlow(eq(LogicalDatastoreType.OPERATIONAL), any(), any());