+ final int inputRate, inputCount;
+
+ // If rate is not provided, or given as zero, then just return.
+ if ((input.getRate() == null) || (input.getRate() == 0)) {
+ log.info("Exiting stress test as no rate is given.");
+ return Futures.immediateFuture(RpcResultBuilder.<Void>failed()
+ .withError(ErrorType.PROTOCOL, "invalid rate")
+ .build());
+ } else {
+ inputRate = input.getRate();
+ }
+
+ if (input.getCount() != null) {
+ inputCount = input.getCount();
+ } else {
+ inputCount = 0;
+ }
+
+ log.info("Stress test starting : rate: {} count: {}", inputRate, inputCount);