openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/OpendaylightQueueStatisticsServiceImpl.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.services;
   9
  10 import com.google.common.util.concurrent.JdkFutureAdapters;
  11 import com.google.common.util.concurrent.ListenableFuture;
  12 import com.google.common.util.concurrent.SettableFuture;
  13 import org.opendaylight.openflowplugin.api.OFConstants;
  14 import org.opendaylight.openflowplugin.api.openflow.device.RequestContext;
  15 import org.opendaylight.openflowplugin.api.openflow.device.Xid;
  16 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
  17 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.module.config.rev141015.SetConfigOutput;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCaseBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueueBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsInput;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsOutput;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortInput;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortOutput;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortInput;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortOutput;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService;
  30 import org.opendaylight.yangtools.yang.common.RpcResult;
  31 import java.util.concurrent.Future;
  32
  33 /**
  34  * @author joe
  35  */
  36 public class OpendaylightQueueStatisticsServiceImpl extends CommonService implements OpendaylightQueueStatisticsService {
  37
  38
  39     @Override
  40     public Future<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> getAllQueuesStatisticsFromAllPorts(
  41             final GetAllQueuesStatisticsFromAllPortsInput input) {
  42         final RequestContext requestContext = rpcContext.createRequestContext();
  43         final SettableFuture<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> result = rpcContext.storeOrFail(requestContext);
  44
  45         if (!result.isDone()) {
  46             final Xid xid = deviceContext.getNextXid();
  47
  48             MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
  49             MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
  50             // Select all ports
  51             mprQueueBuilder.setPortNo(OFConstants.OFPP_ANY);
  52             // Select all the ports
  53             mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
  54             caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
  55
  56             // Set request body to main multipart request
  57             MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(MultipartType.OFPMPQUEUE, xid.getValue(), version);
  58             mprInput.setMultipartRequestBody(caseBuilder.build());
  59             Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext().getConnectionAdapter().multipartRequest(mprInput.build());
  60             ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
  61
  62             final RpcResultConvertor<SetConfigOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext);
  63             rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib, provideWaitTime());
  64         } else {
  65             RequestContextUtil.closeRequstContext(requestContext);
  66         }
  67         return result;
  68     }
  69
  70     @Override
  71     public Future<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> getAllQueuesStatisticsFromGivenPort(
  72             final GetAllQueuesStatisticsFromGivenPortInput input) {
  73         final RequestContext requestContext = rpcContext.createRequestContext();
  74         final SettableFuture<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> result = rpcContext.storeOrFail(requestContext);
  75
  76         if (!result.isDone()) {
  77             final Xid xid = deviceContext.getNextXid();
  78
  79
  80             MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
  81             MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
  82             // Select all queues
  83             mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
  84             // Select specific port
  85             mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
  86                     OpenflowVersion.get(version),
  87                     input.getNodeConnectorId()));
  88             caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
  89
  90             // Set request body to main multipart request
  91             MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(MultipartType.OFPMPQUEUE, xid.getValue(), version);
  92             mprInput.setMultipartRequestBody(caseBuilder.build());
  93             Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext().getConnectionAdapter().multipartRequest(mprInput.build());
  94             ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
  95
  96             final RpcResultConvertor<SetConfigOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext);
  97             rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib, provideWaitTime());
  98         } else {
  99             RequestContextUtil.closeRequstContext(requestContext);
 100         }
 101         return result;
 102     }
 103
 104     @Override
 105     public Future<RpcResult<GetQueueStatisticsFromGivenPortOutput>> getQueueStatisticsFromGivenPort(
 106             final GetQueueStatisticsFromGivenPortInput input) {
 107         final RequestContext requestContext = rpcContext.createRequestContext();
 108         final SettableFuture<RpcResult<GetQueueStatisticsFromGivenPortOutput>> result = rpcContext.storeOrFail(requestContext);
 109
 110         if (!result.isDone()) {
 111             final Xid xid = deviceContext.getNextXid();
 112
 113             MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
 114             MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
 115             // Select specific queue
 116             mprQueueBuilder.setQueueId(input.getQueueId().getValue());
 117             // Select specific port
 118             mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
 119                     OpenflowVersion.get(version),
 120                     input.getNodeConnectorId()));
 121             caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
 122
 123             // Set request body to main multipart request
 124             MultipartRequestInputBuilder mprInput = RequestInputUtils
 125                     .createMultipartHeader(MultipartType.OFPMPQUEUE, xid.getValue(), version);
 126             mprInput.setMultipartRequestBody(caseBuilder.build());
 127             Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
 128                     .getConnectionAdapter().multipartRequest(mprInput.build());
 129             ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
 130
 131             final RpcResultConvertor<SetConfigOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext);
 132             rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib, provideWaitTime());
 133         } else {
 134             RequestContextUtil.closeRequstContext(requestContext);
 135         }
 136         return result;
 137     }
 138
 139 }