X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=benchmark%2Frpcbenchmark%2Fsrc%2Fmain%2Fjava%2Frpcbenchmark%2Fimpl%2FRoutedBindingRTClient.java;h=ab03fb2a5ef8418dbeceebc7ae6e532ad0dacded;hb=2611e6a728e586ea34dd891f30a473bf54d6cbd8;hp=cc388a33cd676b5f5d268c3c1c5611666cb70dec;hpb=aaea3e9a92ae9d6fac04c4a065db4b35cbca9ed0;p=controller.git diff --git a/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/RoutedBindingRTClient.java b/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/RoutedBindingRTClient.java index cc388a33cd..ab03fb2a5e 100644 --- a/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/RoutedBindingRTClient.java +++ b/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/RoutedBindingRTClient.java @@ -5,7 +5,6 @@ * 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 rpcbenchmark.impl; import java.util.ArrayList; @@ -14,7 +13,7 @@ import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.atomic.AtomicLong; -import org.opendaylight.controller.sal.binding.api.RpcConsumerRegistry; +import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry; import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.RoutedRpcBenchInput; import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.RoutedRpcBenchInputBuilder; import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.RoutedRpcBenchOutput; @@ -34,16 +33,6 @@ public class RoutedBindingRTClient implements RTCClient { private final List inVal; private final int inSize; - @Override - public long getRpcOk() { - return rpcOk.get(); - } - - @Override - public long getRpcError() { - return rpcError.get(); - } - public RoutedBindingRTClient(final RpcConsumerRegistry registry, final int inSize, final List> routeIid) { if (registry != null) { @@ -65,6 +54,16 @@ public class RoutedBindingRTClient implements RTCClient { } + @Override + public long getRpcOk() { + return rpcOk.get(); + } + + @Override + public long getRpcError() { + return rpcError.get(); + } + @Override public void runTest(final int iterations) { int ok = 0;