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.AbstractPortDirectStatisticsService;
+import org.opendaylight.openflowplugin.impl.statistics.services.direct.AbstractGetNodeConnectorStatistics;
import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor;
import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetNodeConnectorStatisticsInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetNodeConnectorStatisticsOutput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.multipart.request.multipart.request.body.MultipartRequestPortStatsBuilder;
import org.opendaylight.yangtools.yang.binding.util.BindingMap;
-public class PortDirectStatisticsService extends AbstractPortDirectStatisticsService<MultipartReply> {
-
- public PortDirectStatisticsService(final RequestContextStack requestContextStack,
- final DeviceContext deviceContext,
- final ConvertorExecutor convertorExecutor,
- final MultipartWriterProvider statisticsWriterProvider) {
+public final class SingleGetNodeConnectorStatistics extends AbstractGetNodeConnectorStatistics<MultipartReply> {
+ public SingleGetNodeConnectorStatistics(final RequestContextStack requestContextStack,
+ final DeviceContext deviceContext, final ConvertorExecutor convertorExecutor,
+ final MultipartWriterProvider statisticsWriterProvider) {
super(requestContextStack, deviceContext, convertorExecutor, statisticsWriterProvider);
}
@Override
protected GetNodeConnectorStatisticsOutput buildReply(final List<MultipartReply> input, final boolean success) {
- final var map = input.stream()
- .flatMap(multipartReply -> ((MultipartReplyPortStats) multipartReply.getMultipartReplyBody())
- .nonnullNodeConnectorStatisticsAndPortNumberMap().values().stream())
- .collect(BindingMap.toOrderedMap());
-
return new GetNodeConnectorStatisticsOutputBuilder()
- .setNodeConnectorStatisticsAndPortNumberMap(map)
+ .setNodeConnectorStatisticsAndPortNumberMap(input.stream()
+ .flatMap(multipartReply -> ((MultipartReplyPortStats) multipartReply.getMultipartReplyBody())
+ .nonnullNodeConnectorStatisticsAndPortNumberMap().values().stream())
+ .collect(BindingMap.toOrderedMap()))
.build();
}
@Override
- protected OfHeader buildRequest(final Xid xid,
- final GetNodeConnectorStatisticsInput input) {
+ protected OfHeader buildRequest(final Xid xid, final GetNodeConnectorStatisticsInput input) {
return new MultipartRequestBuilder()
.setXid(xid.getValue())
.setVersion(getVersion())
.build())
.build();
}
-
}