+/*
+ * 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.dom.broker.impl;
import java.util.concurrent.atomic.AtomicLong;
import org.opendaylight.controller.sal.core.api.data.DataStore;
import org.opendaylight.yangtools.concepts.Delegator;
import org.opendaylight.yangtools.yang.data.api.CompositeNode;
-import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
public class DataStoreStatsWrapper implements Delegator<DataStore>, DataStore {
}
@Override
- public CompositeNode readConfigurationData(InstanceIdentifier path) {
+ public CompositeNode readConfigurationData(YangInstanceIdentifier path) {
cfgReadCount.incrementAndGet();
final long startTime = System.nanoTime();
try {
}
@Override
- public CompositeNode readOperationalData(InstanceIdentifier path) {
+ public CompositeNode readOperationalData(YangInstanceIdentifier path) {
operReadCount.incrementAndGet();
final long startTime = System.nanoTime();
try {
} finally {
final long endTime = System.nanoTime();
final long runTime = endTime - startTime;
- cfgReadTimeTotal.addAndGet(runTime);
+ operReadTimeTotal.addAndGet(runTime);
}
}
- public DataCommitTransaction<InstanceIdentifier, CompositeNode> requestCommit(
- DataModification<InstanceIdentifier, CompositeNode> modification) {
+ public DataCommitTransaction<YangInstanceIdentifier, CompositeNode> requestCommit(
+ DataModification<YangInstanceIdentifier, CompositeNode> modification) {
requestCommitCount.incrementAndGet();
final long startTime = System.nanoTime();
try {
};
@Override
- public boolean containsConfigurationPath(InstanceIdentifier path) {
+ public boolean containsConfigurationPath(YangInstanceIdentifier path) {
return delegate.containsConfigurationPath(path);
}
- public Iterable<InstanceIdentifier> getStoredConfigurationPaths() {
+ public Iterable<YangInstanceIdentifier> getStoredConfigurationPaths() {
return delegate.getStoredConfigurationPaths();
}
- public Iterable<InstanceIdentifier> getStoredOperationalPaths() {
+ public Iterable<YangInstanceIdentifier> getStoredOperationalPaths() {
return delegate.getStoredOperationalPaths();
}
- public boolean containsOperationalPath(InstanceIdentifier path) {
+ public boolean containsOperationalPath(YangInstanceIdentifier path) {
return delegate.containsOperationalPath(path);
}
return requestCommitCount.get();
}
- public final long getConfigurationReadTotalTime() {
- return cfgReadTimeTotal.get();
+ public final double getConfigurationReadTotalTime() {
+ return cfgReadTimeTotal.get() / 1000.0d;
}
- public final long getOperationalReadTotalTime() {
- return operReadTimeTotal.get();
+ public final double getOperationalReadTotalTime() {
+ return operReadTimeTotal.get() / 1000.0d;
}
- public final long getRequestCommitTotalTime() {
- return requestCommitTimeTotal.get();
+ public final double getRequestCommitTotalTime() {
+ return requestCommitTimeTotal.get() / 1000.0d;
}
- public final long getConfigurationReadAverageTime() {
+ public final double getConfigurationReadAverageTime() {
long readCount = cfgReadCount.get();
if(readCount == 0) {
return 0;
}
- return cfgReadTimeTotal.get() / readCount;
+ return getConfigurationReadTotalTime() / readCount;
}
- public final long getOperationalReadAverageTime() {
+ public final double getOperationalReadAverageTime() {
long readCount = operReadCount.get();
if(readCount == 0) {
return 0;
}
- return operReadTimeTotal.get() / readCount;
+ return getOperationalReadTotalTime() / readCount;
}
- public final long getRequestCommitAverageTime() {
+ public final double getRequestCommitAverageTime() {
long count = requestCommitCount.get();
if(count == 0) {
return 0;
}
- return requestCommitTimeTotal.get() / count;
+ return getRequestCommitTotalTime() / count;
}
}