2 * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.openflowplugin.impl.services;
10 import com.google.common.base.Function;
11 import java.math.BigInteger;
12 import com.google.common.util.concurrent.JdkFutureAdapters;
13 import org.opendaylight.openflowplugin.api.OFConstants;
14 import org.opendaylight.openflowplugin.api.openflow.device.Xid;
15 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
16 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCaseBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueueBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsInput;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsOutput;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortInput;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortOutput;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortInput;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortOutput;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService;
28 import org.opendaylight.yangtools.yang.common.RpcResult;
29 import java.util.concurrent.Future;
34 public class OpendaylightQueueStatisticsServiceImpl extends CommonService implements OpendaylightQueueStatisticsService {
37 public Future<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> getAllQueuesStatisticsFromAllPorts(
38 final GetAllQueuesStatisticsFromAllPortsInput input) {
39 return this.<GetAllQueuesStatisticsFromAllPortsOutput, Void> handleServiceCall(
40 PRIMARY_CONNECTION, new Function<BigInteger, Future<RpcResult<Void>>>() {
43 public Future<RpcResult<Void>> apply(final BigInteger IDConnection) {
45 final Xid xid = deviceContext.getNextXid();
47 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
48 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
50 mprQueueBuilder.setPortNo(OFConstants.OFPP_ANY);
51 // Select all the ports
52 mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
53 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
55 // Set request body to main multipart request
56 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
57 MultipartType.OFPMPQUEUE, xid.getValue(), version);
58 mprInput.setMultipartRequestBody(caseBuilder.build());
59 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
60 .getConnectionAdapter().multipartRequest(mprInput.build());
61 return JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
68 public Future<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> getAllQueuesStatisticsFromGivenPort(
69 final GetAllQueuesStatisticsFromGivenPortInput input) {
70 return this.<GetAllQueuesStatisticsFromGivenPortOutput, Void> handleServiceCall(
71 PRIMARY_CONNECTION, new Function<BigInteger, Future<RpcResult<Void>>>() {
74 public Future<RpcResult<Void>> apply(final BigInteger IDConnection) {
75 final Xid xid = deviceContext.getNextXid();
77 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
78 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
80 mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
81 // Select specific port
82 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
83 OpenflowVersion.get(version), input.getNodeConnectorId()));
84 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
86 // Set request body to main multipart request
87 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
88 MultipartType.OFPMPQUEUE, xid.getValue(), version);
89 mprInput.setMultipartRequestBody(caseBuilder.build());
90 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
91 .getConnectionAdapter().multipartRequest(mprInput.build());
92 return JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
99 public Future<RpcResult<GetQueueStatisticsFromGivenPortOutput>> getQueueStatisticsFromGivenPort(
100 final GetQueueStatisticsFromGivenPortInput input) {
101 return this.<GetQueueStatisticsFromGivenPortOutput, Void> handleServiceCall(
102 PRIMARY_CONNECTION, new Function<BigInteger, Future<RpcResult<Void>>>() {
105 public Future<RpcResult<Void>> apply(final BigInteger IDConnection) {
106 final Xid xid = deviceContext.getNextXid();
108 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
109 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
110 // Select specific queue
111 mprQueueBuilder.setQueueId(input.getQueueId().getValue());
112 // Select specific port
113 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
114 OpenflowVersion.get(version), input.getNodeConnectorId()));
115 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
117 // Set request body to main multipart request
118 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
119 MultipartType.OFPMPQUEUE, xid.getValue(), version);
120 mprInput.setMultipartRequestBody(caseBuilder.build());
121 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
122 .getConnectionAdapter().multipartRequest(mprInput.build());
123 return JdkFutureAdapters.listenInPoolThread(resultFromOFLib);