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
9 package org.opendaylight.openflowplugin.impl.statistics.services.direct;
11 import java.util.Optional;
12 import java.util.concurrent.Future;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetFlowStatisticsInput;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetFlowStatisticsOutput;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsInput;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsOutput;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsInput;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsOutput;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetNodeConnectorStatisticsInput;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetNodeConnectorStatisticsOutput;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetQueueStatisticsInput;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetQueueStatisticsOutput;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.OpendaylightDirectStatisticsService;
24 import org.opendaylight.yangtools.yang.binding.DataObject;
25 import org.opendaylight.yangtools.yang.common.RpcError;
26 import org.opendaylight.yangtools.yang.common.RpcResult;
27 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
30 * The Opendaylight direct statistics service.
31 * This service handles RPC requests, sends them to registered handlers and returns their replies.
33 public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDirectStatisticsService {
34 private final OpendaylightDirectStatisticsServiceProvider provider;
37 * Instantiates a new Opendaylight direct statistics service.
39 * @param provider the openflow direct statistics service provider
41 public OpendaylightDirectStatisticsServiceImpl(final OpendaylightDirectStatisticsServiceProvider provider) {
42 this.provider = provider;
46 public Future<RpcResult<GetGroupStatisticsOutput>> getGroupStatistics(GetGroupStatisticsInput input) {
47 final Optional<GroupDirectStatisticsService> service = provider.lookup(GroupDirectStatisticsService.class);
49 if (!service.isPresent()) {
50 return missingImplementation(GroupDirectStatisticsService.class);
53 return service.get().handleAndReply(input);
57 public Future<RpcResult<GetQueueStatisticsOutput>> getQueueStatistics(GetQueueStatisticsInput input) {
58 final Optional<QueueDirectStatisticsService> service = provider.lookup(QueueDirectStatisticsService.class);
60 if (!service.isPresent()) {
61 return missingImplementation(QueueDirectStatisticsService.class);
64 return service.get().handleAndReply(input);
68 public Future<RpcResult<GetFlowStatisticsOutput>> getFlowStatistics(GetFlowStatisticsInput input) {
69 final Optional<FlowDirectStatisticsService> service = provider.lookup(FlowDirectStatisticsService.class);
71 if (!service.isPresent()) {
72 return missingImplementation(FlowDirectStatisticsService.class);
75 return service.get().handleAndReply(input);
79 public Future<RpcResult<GetMeterStatisticsOutput>> getMeterStatistics(GetMeterStatisticsInput input) {
80 final Optional<MeterDirectStatisticsService> service = provider.lookup(MeterDirectStatisticsService.class);
82 if (!service.isPresent()) {
83 return missingImplementation(MeterDirectStatisticsService.class);
86 return service.get().handleAndReply(input);
90 public Future<RpcResult<GetNodeConnectorStatisticsOutput>> getNodeConnectorStatistics(GetNodeConnectorStatisticsInput input) {
91 final Optional<NodeConnectorDirectStatisticsService> service = provider.lookup(NodeConnectorDirectStatisticsService.class);
93 if (!service.isPresent()) {
94 return missingImplementation(NodeConnectorDirectStatisticsService.class);
97 return service.get().handleAndReply(input);
100 private <T extends DataObject> Future<RpcResult<T>> missingImplementation(Class service) {
101 return RpcResultBuilder.<T>failed().withError(
102 RpcError.ErrorType.APPLICATION,
103 String.format("No implementation found for direct statistics service %s.", service.getCanonicalName()))