* 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;
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;
private final List<RoutedRpcBenchInput> 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<InstanceIdentifier<?>> routeIid) {
if (registry != null) {
}
+ @Override
+ public long getRpcOk() {
+ return rpcOk.get();
+ }
+
+ @Override
+ public long getRpcError() {
+ return rpcError.get();
+ }
+
@Override
public void runTest(final int iterations) {
int ok = 0;