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.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.openflow.common.types.rev130731.MultipartType;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCaseBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueueBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsInput;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsOutput;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortInput;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromGivenPortOutput;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortInput;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortOutput;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService;
29 import org.opendaylight.yangtools.yang.common.RpcResult;
30 import java.util.concurrent.Future;
35 public class OpendaylightQueueStatisticsServiceImpl extends CommonService implements OpendaylightQueueStatisticsService {
39 public Future<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> getAllQueuesStatisticsFromAllPorts(
40 final GetAllQueuesStatisticsFromAllPortsInput input) {
41 final RequestContext<GetAllQueuesStatisticsFromAllPortsOutput> requestContext = rpcContext.createRequestContext();
42 final SettableFuture<RpcResult<GetAllQueuesStatisticsFromAllPortsOutput>> result = rpcContext.storeOrFail(requestContext);
44 if (!result.isDone()) {
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(MultipartType.OFPMPQUEUE, xid.getValue(), version);
57 mprInput.setMultipartRequestBody(caseBuilder.build());
58 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext().getConnectionAdapter().multipartRequest(mprInput.build());
59 ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
61 final RpcResultConvertor<GetAllQueuesStatisticsFromAllPortsOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext);
62 rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib);
64 RequestContextUtil.closeRequstContext(requestContext);
70 public Future<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> getAllQueuesStatisticsFromGivenPort(
71 final GetAllQueuesStatisticsFromGivenPortInput input) {
72 final RequestContext<GetAllQueuesStatisticsFromGivenPortOutput> requestContext = rpcContext.createRequestContext();
73 final SettableFuture<RpcResult<GetAllQueuesStatisticsFromGivenPortOutput>> result = rpcContext.storeOrFail(requestContext);
75 if (!result.isDone()) {
76 final Xid xid = deviceContext.getNextXid();
79 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
80 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
82 mprQueueBuilder.setQueueId(OFConstants.OFPQ_ANY);
83 // Select specific port
84 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
85 OpenflowVersion.get(version),
86 input.getNodeConnectorId()));
87 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
89 // Set request body to main multipart request
90 MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader(MultipartType.OFPMPQUEUE, xid.getValue(), version);
91 mprInput.setMultipartRequestBody(caseBuilder.build());
92 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext().getConnectionAdapter().multipartRequest(mprInput.build());
93 ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
95 final RpcResultConvertor<GetAllQueuesStatisticsFromGivenPortOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext);
96 rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib);
98 RequestContextUtil.closeRequstContext(requestContext);
104 public Future<RpcResult<GetQueueStatisticsFromGivenPortOutput>> getQueueStatisticsFromGivenPort(
105 final GetQueueStatisticsFromGivenPortInput input) {
106 final RequestContext<GetQueueStatisticsFromGivenPortOutput> requestContext = rpcContext.createRequestContext();
107 final SettableFuture<RpcResult<GetQueueStatisticsFromGivenPortOutput>> result = rpcContext.storeOrFail(requestContext);
109 if (!result.isDone()) {
110 final Xid xid = deviceContext.getNextXid();
112 MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
113 MultipartRequestQueueBuilder mprQueueBuilder = new MultipartRequestQueueBuilder();
114 // Select specific queue
115 mprQueueBuilder.setQueueId(input.getQueueId().getValue());
116 // Select specific port
117 mprQueueBuilder.setPortNo(InventoryDataServiceUtil.portNumberfromNodeConnectorId(
118 OpenflowVersion.get(version),
119 input.getNodeConnectorId()));
120 caseBuilder.setMultipartRequestQueue(mprQueueBuilder.build());
122 // Set request body to main multipart request
123 MultipartRequestInputBuilder mprInput = RequestInputUtils
124 .createMultipartHeader(MultipartType.OFPMPQUEUE, xid.getValue(), version);
125 mprInput.setMultipartRequestBody(caseBuilder.build());
126 Future<RpcResult<Void>> resultFromOFLib = deviceContext.getPrimaryConnectionContext()
127 .getConnectionAdapter().multipartRequest(mprInput.build());
128 ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(resultFromOFLib);
130 final RpcResultConvertor<GetQueueStatisticsFromGivenPortOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext);
131 rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib);
133 RequestContextUtil.closeRequstContext(requestContext);