+++ /dev/null
-/*
- * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.sal.restconf.impl;
-
-import java.math.BigInteger;
-import java.util.concurrent.atomic.AtomicLong;
-import javax.ws.rs.core.Response;
-import javax.ws.rs.core.Response.Status;
-import javax.ws.rs.core.UriInfo;
-import org.opendaylight.controller.sal.rest.api.RestconfService;
-
-public class StatisticsRestconfServiceWrapper implements RestconfService {
-
- AtomicLong operationalGet = new AtomicLong();
- AtomicLong configGet = new AtomicLong();
- AtomicLong rpc = new AtomicLong();
- AtomicLong configPost = new AtomicLong();
- AtomicLong configPut = new AtomicLong();
- AtomicLong configDelete = new AtomicLong();
- AtomicLong successGetConfig = new AtomicLong();
- AtomicLong successGetOperational = new AtomicLong();
- AtomicLong successPost = new AtomicLong();
- AtomicLong successPut = new AtomicLong();
- AtomicLong successDelete = new AtomicLong();
- AtomicLong failureGetConfig = new AtomicLong();
- AtomicLong failureGetOperational = new AtomicLong();
- AtomicLong failurePost = new AtomicLong();
- AtomicLong failurePut = new AtomicLong();
- AtomicLong failureDelete = new AtomicLong();
-
- private static final StatisticsRestconfServiceWrapper INSTANCE = new StatisticsRestconfServiceWrapper(RestconfImpl.getInstance());
-
- final RestconfService delegate;
-
- private StatisticsRestconfServiceWrapper(final RestconfService delegate) {
- this.delegate = delegate;
- }
-
- public static StatisticsRestconfServiceWrapper getInstance() {
- return INSTANCE;
- }
-
- @Override
- public Object getRoot() {
- return delegate.getRoot();
- }
-
- @Override
- public NormalizedNodeContext getModules(final UriInfo uriInfo) {
- return delegate.getModules(uriInfo);
- }
-
- @Override
- public NormalizedNodeContext getModules(final String identifier, final UriInfo uriInfo) {
- return delegate.getModules(identifier, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext getModule(final String identifier, final UriInfo uriInfo) {
- return delegate.getModule(identifier, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext getOperations(final UriInfo uriInfo) {
- return delegate.getOperations(uriInfo);
- }
-
- @Override
- public NormalizedNodeContext getOperations(final String identifier, final UriInfo uriInfo) {
- return delegate.getOperations(identifier, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext invokeRpc(final String identifier, final NormalizedNodeContext payload, final UriInfo uriInfo) {
- rpc.incrementAndGet();
- return delegate.invokeRpc(identifier, payload, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext invokeRpc(final String identifier, final String noPayload, final UriInfo uriInfo) {
- rpc.incrementAndGet();
- return delegate.invokeRpc(identifier, noPayload, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext readConfigurationData(final String identifier, final UriInfo uriInfo) {
- configGet.incrementAndGet();
- NormalizedNodeContext normalizedNodeContext = null;
- try {
- normalizedNodeContext = delegate.readConfigurationData(identifier, uriInfo);
- if (normalizedNodeContext.getData() != null) {
- successGetConfig.incrementAndGet();
- }
- else {
- failureGetConfig.incrementAndGet();
- }
- } catch (Exception e) {
- failureGetConfig.incrementAndGet();
- throw e;
- }
- return normalizedNodeContext;
- }
-
- @Override
- public NormalizedNodeContext readOperationalData(final String identifier, final UriInfo uriInfo) {
- operationalGet.incrementAndGet();
- NormalizedNodeContext normalizedNodeContext = null;
- try {
- normalizedNodeContext = delegate.readOperationalData(identifier, uriInfo);
- if (normalizedNodeContext.getData() != null) {
- successGetOperational.incrementAndGet();
- }
- else {
- failureGetOperational.incrementAndGet();
- }
- } catch (Exception e) {
- failureGetOperational.incrementAndGet();
- throw e;
- }
- return normalizedNodeContext;
- }
-
- @Override
- public Response updateConfigurationData(final String identifier, final NormalizedNodeContext payload) {
- configPut.incrementAndGet();
- Response response = null;
- try {
- response = delegate.updateConfigurationData(identifier, payload);
- if (response.getStatus() == Status.OK.getStatusCode()) {
- successPut.incrementAndGet();
- }
- else {
- failurePut.incrementAndGet();
- }
- } catch (Exception e) {
- failurePut.incrementAndGet();
- throw e;
- }
- return response;
- }
-
- @Override
- public Response createConfigurationData(final String identifier, final NormalizedNodeContext payload, final UriInfo uriInfo) {
- configPost.incrementAndGet();
- Response response = null;
- try {
- response = delegate.createConfigurationData(identifier, payload, uriInfo);
- if (response.getStatus() == Status.OK.getStatusCode()) {
- successPost.incrementAndGet();
- }
- else {
- failurePost.incrementAndGet();
- }
- } catch (Exception e) {
- failurePost.incrementAndGet();
- throw e;
- }
- return response;
- }
-
- @Override
- public Response createConfigurationData(final NormalizedNodeContext payload, final UriInfo uriInfo) {
- configPost.incrementAndGet();
- Response response = null;
- try {
- response = delegate.createConfigurationData(payload, uriInfo);
- if (response.getStatus() == Status.OK.getStatusCode()) {
- successPost.incrementAndGet();
- }
- else {
- failurePost.incrementAndGet();
- }
- }catch (Exception e) {
- failurePost.incrementAndGet();
- throw e;
- }
- return response;
- }
-
- @Override
- public Response deleteConfigurationData(final String identifier) {
- configDelete.incrementAndGet();
- Response response = null;
- try {
- response = delegate.deleteConfigurationData(identifier);
- if (response.getStatus() == Status.OK.getStatusCode()) {
- successDelete.incrementAndGet();
- }
- else {
- failureDelete.incrementAndGet();
- }
- } catch (Exception e) {
- failureDelete.incrementAndGet();
- throw e;
- }
- return response;
- }
-
- @Override
- public Response subscribeToStream(final String identifier, final UriInfo uriInfo) {
- return delegate.subscribeToStream(identifier, uriInfo);
- }
-
- @Override
- public NormalizedNodeContext getAvailableStreams(final UriInfo uriInfo) {
- return delegate.getAvailableStreams(uriInfo);
- }
-
- public BigInteger getConfigDelete() {
- return BigInteger.valueOf(configDelete.get());
- }
-
- public BigInteger getConfigGet() {
- return BigInteger.valueOf(configGet.get());
- }
-
- public BigInteger getConfigPost() {
- return BigInteger.valueOf(configPost.get());
- }
-
- public BigInteger getConfigPut() {
- return BigInteger.valueOf(configPut.get());
- }
-
- public BigInteger getOperationalGet() {
- return BigInteger.valueOf(operationalGet.get());
- }
-
- public BigInteger getRpc() {
- return BigInteger.valueOf(rpc.get());
- }
-
- public BigInteger getSuccessGetConfig() {
- return BigInteger.valueOf(successGetConfig.get());
- }
-
- public BigInteger getSuccessGetOperational() {
- return BigInteger.valueOf(successGetOperational.get());
- }
-
- public BigInteger getSuccessPost() {
- return BigInteger.valueOf(successPost.get());
- }
-
- public BigInteger getSuccessPut() {
- return BigInteger.valueOf(successPut.get());
- }
-
- public BigInteger getSuccessDelete() {
- return BigInteger.valueOf(successDelete.get());
- }
-
- public BigInteger getFailureGetConfig() {
- return BigInteger.valueOf(failureGetConfig.get());
- }
-
- public BigInteger getFailureGetOperational() {
- return BigInteger.valueOf(failureGetOperational.get());
- }
-
- public BigInteger getFailurePost() {
- return BigInteger.valueOf(failurePost.get());
- }
-
- public BigInteger getFailurePut() {
- return BigInteger.valueOf(failurePut.get());
- }
-
- public BigInteger getFailureDelete() {
- return BigInteger.valueOf(failureDelete.get());
- }
-}
\ No newline at end of file