Change count type in the cars model

The count type is changed from uint16 to uint32.  For some performance/stress
tests, it is desirable to issue 1E7 transactions to provide an adequate sample
size.  Prior to this change, it was impossible to issue a million transactions
without either invoking the RPC several times or using count=0 and stopping
based on log messages.  This makes perf testing easier.

Change-Id: Icf125e45bd85e14df6ed5ad91ddad92a8dd2151b
Signed-off-by: Ryan Goulding <ryandgoulding@gmail.com>
(cherry picked from commit f36e0782a5bb5409d8dd95e2d08ffdbd65266663)

diff --git a/opendaylight/md-sal/samples/clustering-test-app/model/src/main/yang/car.yang b/opendaylight/md-sal/samples/clustering-test-app/model/src/main/yang/car.yang
index 1732a24093b6a988baaa2215f45392f07e80fe16..475435a07a51795cf46cc6051af28641e56c14e3 100644 (file)
--- a/opendaylight/md-sal/samples/clustering-test-app/model/src/main/yang/car.yang
+++ b/opendaylight/md-sal/samples/clustering-test-app/model/src/main/yang/car.yang
@@ -67,7 +67,7 @@ module car {
             }
 
             leaf count {
-              type uint16;
+              type uint32;
               default 0;
               description "Number of cars to create. Zero implies unlimited cars; use
                            stop-stress-test rpc to stop the test.";

diff --git a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/CarProvider.java b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/CarProvider.java
index fa8322de33d5991c9398a6b99b8633193eb16137..2dfb32b421f3f6e6c7275316091476bb7c69531c 100644 (file)
--- a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/CarProvider.java
+++ b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/CarProvider.java
@@ -90,7 +90,8 @@ public class CarProvider implements CarService {
 
     @Override
     public Future<RpcResult<Void>> stressTest(StressTestInput input) {
-        final int inputRate, inputCount;
+        final int inputRate;
+        final long inputCount;
 
         // If rate is not provided, or given as zero, then just return.
         if ((input.getRate() == null) || (input.getRate() == 0)) {