Fix bug when populating with multiple threads where count would be wa…

…y off.
rustyrazorblade · Apr 25, 2024 · 272cee4 · 272cee4
1 parent c45c3ec
commit 272cee4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/kotlin/com/rustyrazorblade/easycassstress/commands/Run.kt b/src/main/kotlin/com/rustyrazorblade/easycassstress/commands/Run.kt
@@ -395,12 +395,12 @@ class Run(val command: String) : IStressCommand {
                 }
                 option.rows
             }
-        } * threads
+        }
 
-        log.info { "Prepopulating data with $max records per thread" }
+        println("Prepopulating data with $max records per thread ($threads)")
 
         if(max > 0) {
-            ProgressBar("Populate Progress", max, ProgressBarStyle.ASCII).use {
+            ProgressBar("Populate Progress", max * threads, ProgressBarStyle.ASCII).use {
                 // update the timer every second, starting 1 second from now, as a daemon thread
                 val timer = fixedRateTimer("progress-bar", true, 1000, 1000) {
                     it.stepTo(metrics.populate.count)