Decompose RPC implementation classes

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / statistics / services / direct / multilayer / MultiGetGroupStatistics.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/GroupDirectStatisticsService.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/MultiGetGroupStatistics.java
similarity index 79%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/GroupDirectStatisticsService.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/MultiGetGroupStatistics.java
index 3b25b34056634db8f6239a8651534f71e0227170..f1b8d5396c1b6c90ad72f83772b8fea22df6ea41 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/GroupDirectStatisticsService.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/multilayer/MultiGetGroupStatistics.java
@@ -15,7 +15,7 @@ import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
 import org.opendaylight.openflowplugin.api.openflow.device.Xid;
 import org.opendaylight.openflowplugin.impl.datastore.MultipartWriterProvider;
 import org.opendaylight.openflowplugin.impl.services.util.RequestInputUtils;
-import org.opendaylight.openflowplugin.impl.statistics.services.direct.AbstractGroupDirectStatisticsService;
+import org.opendaylight.openflowplugin.impl.statistics.services.direct.AbstractGetGroupStatistics;
 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor;
 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionConvertorData;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsInput;
@@ -27,18 +27,15 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev13
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReply;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.MultipartReplyGroupCase;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.MultipartReplyGroup;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupCaseBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.group._case.MultipartRequestGroupBuilder;
 import org.opendaylight.yangtools.yang.binding.util.BindingMap;
 
-public final class GroupDirectStatisticsService extends AbstractGroupDirectStatisticsService<MultipartReply> {
+public final class MultiGetGroupStatistics extends AbstractGetGroupStatistics<MultipartReply> {
     private final VersionConvertorData data;
 
-    public GroupDirectStatisticsService(final RequestContextStack requestContextStack,
-                                        final DeviceContext deviceContext,
-                                        final ConvertorExecutor convertorExecutor,
-                                        final MultipartWriterProvider statisticsWriterProvider) {
+    public MultiGetGroupStatistics(final RequestContextStack requestContextStack, final DeviceContext deviceContext,
+            final ConvertorExecutor convertorExecutor, final MultipartWriterProvider statisticsWriterProvider) {
         super(requestContextStack, deviceContext, convertorExecutor, statisticsWriterProvider);
         data = new VersionConvertorData(getVersion());
     }
@@ -50,9 +47,9 @@ public final class GroupDirectStatisticsService extends AbstractGroupDirectStati
         }
 
         final var groupStats = BindingMap.<GroupStatsKey, GroupStats>orderedBuilder();
-        for (final MultipartReply mpReply : input) {
-            final MultipartReplyGroupCase caseBody = (MultipartReplyGroupCase) mpReply.getMultipartReplyBody();
-            final MultipartReplyGroup replyBody = caseBody.getMultipartReplyGroup();
+        for (var mpReply : input) {
+            final var caseBody = (MultipartReplyGroupCase) mpReply.getMultipartReplyBody();
+            final var replyBody = caseBody.getMultipartReplyGroup();
             final Optional<List<GroupStats>> groupStatsList = getConvertorExecutor().convert(
                 replyBody.getGroupStats(), data);
 
@@ -66,7 +63,7 @@ public final class GroupDirectStatisticsService extends AbstractGroupDirectStati
 
     @Override
     protected OfHeader buildRequest(final Xid xid, final GetGroupStatisticsInput input) {
-        final MultipartRequestGroupBuilder mprGroupBuild = new MultipartRequestGroupBuilder();
+        final var mprGroupBuild = new MultipartRequestGroupBuilder();
 
         if (input.getGroupId() != null) {
             mprGroupBuild.setGroupId(new GroupId(input.getGroupId().getValue()));