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.statistics.services;
10 import com.google.common.base.Function;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.util.concurrent.Future;
13 import org.opendaylight.openflowplugin.api.OFConstants;
14 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
15 import org.opendaylight.openflowplugin.api.openflow.device.RequestContext;
16 import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
17 import org.opendaylight.openflowplugin.api.openflow.device.Xid;
18 import org.opendaylight.openflowplugin.api.openflow.md.util.OpenflowVersion;
19 import org.opendaylight.openflowplugin.impl.services.CommonService;
20 import org.opendaylight.openflowplugin.impl.services.RequestInputUtils;
21 import org.opendaylight.openflowplugin.impl.util.StatisticsServiceUtil;
22 import org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCaseBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueueBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsInput;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsOutput;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortInput;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortOutput;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortInput;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortOutput;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService;
35 import org.opendaylight.yangtools.yang.common.RpcResult;
40 public class OpendaylightQueueStatisticsServiceImpl extends CommonService implements OpendaylightQueueStatisticsService {
42 public OpendaylightQueueStatisticsServiceImpl(final RequestContextStack requestContextStack, DeviceContext deviceContext) {
43 super(requestContextStack, deviceContext);
47 public Future<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> getAllQueuesStatisticsFromAllPorts(
48 final GetAllQueuesStatisticsFromAllPortsInput input) {
49 return this.<GetAllQueuesStatisticsFromAllPortsOutput, Void>handleServiceCall(
50 new Function<RequestContext<GetAllQueuesStatisticsFromAllPortsOutput>, ListenableFuture<RpcResult<Void>>>() {
53 public ListenableFuture<RpcResult<Void>> apply(final RequestContext<GetAllQueuesStatisticsFromAllPortsOutput> requestContext) {
56 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
57 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
59 // Select all the ports
60 mprQueueBuilder.setQueueId(OFConstants.OFPQ_ALL);
61 mprQueueBuilder.setPortNo(OFConstants.OFPP_ANY);
62 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
64 // Set request body to main multipart request
65 final Xid xid = requestContext.getXid();
67 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
68 MultipartType.OFPMPQUEUE, xid.getValue(), getVersion());
69 mprInput.setMultipartRequestBody(caseBuilder.build());
70 MultipartRequestInput multipartRequestInput = mprInput.build();
72 return StatisticsServiceUtil.getRpcResultListenableFuture(xid, multipartRequestInput, getDeviceContext());
79 public Future<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> getAllQueuesStatisticsFromGivenPort(
80 final GetAllQueuesStatisticsFromGivenPortInput input) {
81 return this.<GetAllQueuesStatisticsFromGivenPortOutput, Void>handleServiceCall(
82 new Function<RequestContext<GetAllQueuesStatisticsFromGivenPortOutput>, ListenableFuture<RpcResult<Void>>>() {
85 public ListenableFuture<RpcResult<Void>> apply(final RequestContext<GetAllQueuesStatisticsFromGivenPortOutput> requestContext) {
87 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
88 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
90 // Select specific port
91 final short version = getVersion();
92 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
93 OpenflowVersion.get(version), input.getNodeConnectorId()));
95 mprQueueBuilder.setQueueId(OFConstants.OFPQ_ALL);
96 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
98 // Set request body to main multipart request
99 final Xid xid = requestContext.getXid();
100 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
101 MultipartType.OFPMPQUEUE, xid.getValue(), version);
102 mprInput.setMultipartRequestBody(caseBuilder.build());
103 MultipartRequestInput multipartRequestInput = mprInput.build();
104 return StatisticsServiceUtil.getRpcResultListenableFuture(xid, multipartRequestInput, getDeviceContext());
110 public Future<RpcResult<GetQueueStatisticsFromGivenPortOutput>> getQueueStatisticsFromGivenPort(
111 final GetQueueStatisticsFromGivenPortInput input) {
112 return this.<GetQueueStatisticsFromGivenPortOutput, Void>handleServiceCall(
113 new Function<RequestContext<GetQueueStatisticsFromGivenPortOutput>, ListenableFuture<RpcResult<Void>>>() {
116 public ListenableFuture<RpcResult<Void>> apply(final RequestContext<GetQueueStatisticsFromGivenPortOutput> requestContext) {
118 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
119 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
120 // Select specific queue
121 mprQueueBuilder.setQueueId(input.getQueueId().getValue());
122 // Select specific port
123 final short version = getVersion();
124 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
125 OpenflowVersion.get(version), input.getNodeConnectorId()));
126 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
128 // Set request body to main multipart request
129 final Xid xid = requestContext.getXid();
130 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(
131 MultipartType.OFPMPQUEUE, xid.getValue(), version);
132 mprInput.setMultipartRequestBody(caseBuilder.build());
133 MultipartRequestInput multipartRequestInput = mprInput.build();
134 return StatisticsServiceUtil.getRpcResultListenableFuture(xid, multipartRequestInput, getDeviceContext());