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.statistics.services.direct.AbstractMeterDirectStatisticsService;
+import org.opendaylight.openflowplugin.impl.statistics.services.direct.AbstractGetMeterStatistics;
import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor;
import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsOutput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
import org.opendaylight.yangtools.yang.binding.util.BindingMap;
-public class MeterDirectStatisticsService extends AbstractMeterDirectStatisticsService<MultipartReply> {
-
- public MeterDirectStatisticsService(final RequestContextStack requestContextStack,
- final DeviceContext deviceContext,
- final ConvertorExecutor convertorExecutor,
- final MultipartWriterProvider statisticsWriterProvider) {
+public final class SingleGetMeterStatistics extends AbstractGetMeterStatistics<MultipartReply> {
+ public SingleGetMeterStatistics(final RequestContextStack requestContextStack, final DeviceContext deviceContext,
+ final ConvertorExecutor convertorExecutor, final MultipartWriterProvider statisticsWriterProvider) {
super(requestContextStack, deviceContext, convertorExecutor, statisticsWriterProvider);
}
@Override
protected GetMeterStatisticsOutput buildReply(final List<MultipartReply> input, final boolean success) {
- final var map = input.stream()
- .flatMap(multipartReply -> ((MultipartReplyMeterStats) multipartReply.getMultipartReplyBody())
- .nonnullMeterStats().values().stream())
- .collect(BindingMap.toOrderedMap());
-
return new GetMeterStatisticsOutputBuilder()
- .setMeterStats(map)
+ .setMeterStats(input.stream()
+ .flatMap(multipartReply -> ((MultipartReplyMeterStats) multipartReply.getMultipartReplyBody())
+ .nonnullMeterStats().values().stream())
+ .collect(BindingMap.toOrderedMap()))
.build();
}
.build())
.build();
}
-
}