openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/OpendaylightPortStatisticsServiceImpl.java

   1 /**
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.openflowplugin.impl.statistics.services;
   9
  10 import com.google.common.base.Function;
  11 import com.google.common.util.concurrent.JdkFutureAdapters;
  12 import org.opendaylight.openflowplugin.api.OFConstants;
  13 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
  14 import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
  15 import org.opendaylight.openflowplugin.api.openflow.device.Xid;
  16 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
  17 import org.opendaylight.openflowplugin.impl.services.CommonService;
  18 import org.opendaylight.openflowplugin.impl.services.DataCrate;
  19 import org.opendaylight.openflowplugin.impl.services.RequestInputUtils;
  20 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCaseBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStatsBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetAllNodeConnectorsStatisticsInput;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetAllNodeConnectorsStatisticsOutput;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetNodeConnectorStatisticsInput;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetNodeConnectorStatisticsOutput;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService;
  30 import org.opendaylight.yangtools.yang.common.RpcResult;
  31 import java.util.concurrent.Future;
  32
  33 /**
  34  * @author joe
  35  */
  36 public class OpendaylightPortStatisticsServiceImpl extends CommonService implements OpendaylightPortStatisticsService {
  37
  38     public OpendaylightPortStatisticsServiceImpl(final RequestContextStack requestContextStack, DeviceContext deviceContext) {
  39         super(requestContextStack, deviceContext);
  40     }
  41
  42     @Override
  43     public Future<RpcResult<GetAllNodeConnectorsStatisticsOutput>> getAllNodeConnectorsStatistics(
  44             final GetAllNodeConnectorsStatisticsInput input) {
  45         return this
  46                 .<GetAllNodeConnectorsStatisticsOutput, Void>handleServiceCall(
  47                         PRIMARY_CONNECTION, new Function<DataCrate<GetAllNodeConnectorsStatisticsOutput>, Future<RpcResult<Void>>>() {
  48
  49                             @Override
  50                             public Future<RpcResult<Void>> apply(final DataCrate<GetAllNodeConnectorsStatisticsOutput> data) {
  51
  52                                 MultipartRequestPortStatsCaseBuilder caseBuilder =
  53                                         new MultipartRequestPortStatsCaseBuilder();
  54                                 MultipartRequestPortStatsBuilder mprPortStatsBuilder =
  55                                         new MultipartRequestPortStatsBuilder();
  56                                 // Select all ports
  57                                 mprPortStatsBuilder.setPortNo(OFConstants.OFPP_ANY);
  58                                 caseBuilder.setMultipartRequestPortStats(mprPortStatsBuilder.build());
  59
  60                                 final Xid xid = deviceContext.getNextXid();
  61                                 data.getRequestContext().setXid(xid);
  62                                 MultipartRequestInputBuilder mprInput = RequestInputUtils
  63                                         .createMultipartHeader(MultipartType.OFPMPPORTSTATS, xid.getValue(), version);
  64                                 mprInput.setMultipartRequestBody(caseBuilder.build());
  65                                 Future<RpcResult<Void>> resultFromOFLib = deviceContext
  66                                         .getPrimaryConnectionContext().getConnectionAdapter().multipartRequest(mprInput.build());
  67                                 return JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
  68                             }
  69                         });
  70     }
  71
  72     @Override
  73     public Future<RpcResult<GetNodeConnectorStatisticsOutput>> getNodeConnectorStatistics(
  74             final GetNodeConnectorStatisticsInput input) {
  75         return this
  76                 .<GetNodeConnectorStatisticsOutput, Void>handleServiceCall(
  77                         PRIMARY_CONNECTION, new Function<DataCrate<GetNodeConnectorStatisticsOutput>, Future<RpcResult<Void>>>() {
  78
  79                             @Override
  80                             public Future<RpcResult<Void>> apply(final DataCrate<GetNodeConnectorStatisticsOutput> data) {
  81
  82                                 MultipartRequestPortStatsCaseBuilder caseBuilder =
  83                                         new MultipartRequestPortStatsCaseBuilder();
  84                                 MultipartRequestPortStatsBuilder mprPortStatsBuilder =
  85                                         new MultipartRequestPortStatsBuilder();
  86                                 // Set specific port
  87                                 mprPortStatsBuilder
  88                                         .setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
  89                                                 OpenflowVersion.get(version),
  90                                                 input.getNodeConnectorId()));
  91                                 caseBuilder.setMultipartRequestPortStats(mprPortStatsBuilder.build());
  92
  93                                 final Xid xid = deviceContext.getNextXid();
  94                                 data.getRequestContext().setXid(xid);
  95                                 MultipartRequestInputBuilder mprInput = RequestInputUtils
  96                                         .createMultipartHeader(MultipartType.OFPMPPORTSTATS, xid.getValue(), version);
  97                                 mprInput.setMultipartRequestBody(caseBuilder.build());
  98                                 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
  99                                         .getConnectionAdapter().multipartRequest(mprInput.build());
 100                                 return JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
 101                             }
 102                         });
 103
 104     }
 105
 106 }