import rpcbenchmark.impl.RpcbenchmarkProvider;
public class RpcbenchmarkModule extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rpcbenchmark.impl.rev141210.AbstractRpcbenchmarkModule {
- public RpcbenchmarkModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
+ public RpcbenchmarkModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
super(identifier, dependencyResolver);
}
- public RpcbenchmarkModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rpcbenchmark.impl.rev141210.RpcbenchmarkModule oldModule, java.lang.AutoCloseable oldInstance) {
+ public RpcbenchmarkModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rpcbenchmark.impl.rev141210.RpcbenchmarkModule oldModule, final java.lang.AutoCloseable oldInstance) {
super(identifier, dependencyResolver, oldModule, oldInstance);
}
return rpcError.get();
}
- public GlobalBindingRTCClient(RpcConsumerRegistry registry, int inSize) {
+ public GlobalBindingRTCClient(final RpcConsumerRegistry registry, final int inSize) {
if (registry != null) {
this.service = registry.getRpcService(RpcbenchPayloadService.class);
} else {
inVal = new GlobalRpcBenchInputBuilder().setPayload(listVals).build();
}
- public void runTest(int iterations) {
+ public void runTest(final int iterations) {
int rpcOk = 0;
int rpcError = 0;
@Override
public Future<RpcResult<GlobalRpcBenchOutput>> globalRpcBench(
- GlobalRpcBenchInput input) {
+ final GlobalRpcBenchInput input) {
GlobalRpcBenchOutput output = new GlobalRpcBenchOutputBuilder(input).build();
RpcResult<GlobalRpcBenchOutput> result = RpcResultBuilder.success(output).build();
numRpcs++;
@Override
public Future<RpcResult<RoutedRpcBenchOutput>> routedRpcBench(
- RoutedRpcBenchInput input) {
+ final RoutedRpcBenchInput input) {
RoutedRpcBenchOutput output = new RoutedRpcBenchOutputBuilder(input).build();
RpcResult<RoutedRpcBenchOutput> result = RpcResultBuilder.success(output).build();
numRpcs++;
return rpcError.get();
}
- public RoutedBindingRTClient(RpcConsumerRegistry registry, int inSize, List<InstanceIdentifier<?>> routeIid) {
+ public RoutedBindingRTClient(final RpcConsumerRegistry registry, final int inSize, final List<InstanceIdentifier<?>> routeIid) {
if (registry != null) {
this.service = registry.getRpcService(RpcbenchPayloadService.class);
} else {
}
- public void runTest(int iterations) {
+ public void runTest(final int iterations) {
int rpcOk = 0;
int rpcError = 0;
private RpcProviderRegistry providerRegistry;
@Override
- public void onSessionInitiated(ProviderContext session) {
+ public void onSessionInitiated(final ProviderContext session) {
LOG.debug("RpcbenchmarkProvider Session Initiated");
consumerRegistry = session.getSALService(RpcConsumerRegistry.class);
providerRegistry = session.getSALService(RpcProviderRegistry.class);
executor.shutdown();
try {
executor.awaitTermination(testTimeout, TimeUnit.MINUTES);
- } catch (InterruptedException e) {
+ } catch (final InterruptedException e) {
LOG.error("Out of time: test did not finish within the {} min deadline ", testTimeout);
}