print the sleep and idle wait duration while SBK Starting.

Signed-off-by: Keshava Munegowda <keshava.gowda@gmail.com>
kmgowda · Aug 18, 2024 · 299ae0b · 299ae0b
1 parent 4ec67eb
commit 299ae0b
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 9 deletions.
diff --git a/perl/src/main/java/io/perl/api/impl/PerformanceRecorderIdleBusyWait.java b/perl/src/main/java/io/perl/api/impl/PerformanceRecorderIdleBusyWait.java
@@ -58,7 +58,7 @@ public void run(final long secondsToRun, final long totalRecords) {
         long recordsCnt = 0;
         boolean notFound;
         TimeStamp t;
-        PerlPrinter.log.info("PerformanceRecorderIdleBusyWait Started");
+        PerlPrinter.log.info("PerformanceRecorderIdleBusyWait Started : {} nanoseconds idle busy wait", this.idleNS);
         periodicRecorder.start(startTime);
         periodicRecorder.startWindow(startTime);
         while (doWork) {

diff --git a/perl/src/main/java/io/perl/api/impl/PerformanceRecorderIdleSleep.java b/perl/src/main/java/io/perl/api/impl/PerformanceRecorderIdleSleep.java
@@ -50,7 +50,8 @@ public void run(final long secondsToRun, final long totalRecords) {
         long recordsCnt = 0;
         boolean notFound;
         TimeStamp t;
-        PerlPrinter.log.info("PerformanceRecorderIdleSleep Started");
+        PerlPrinter.log.info("PerformanceRecorderIdleSleep Started : {} milliseconds idle sleep",
+                this.sleepMS);
         periodicRecorder.start(startTime);
         periodicRecorder.startWindow(startTime);
         while (doWork) {

diff --git a/sbk-gem/src/main/java/io/gem/params/impl/SbkGemParameters.java b/sbk-gem/src/main/java/io/gem/params/impl/SbkGemParameters.java
@@ -62,11 +62,11 @@ public final class SbkGemParameters extends SbkDriversParameters implements GemP
     /**
      * This Constructor is responsible for initializing all values.
      *
-     * @param name    String
-     * @param drivers String[]
+     * @param name                     String
+     * @param drivers                  String[]
      * @param loggers
-     * @param config  NotNull GemConfig
-     * @param sbmPort int
+     * @param config                   NotNull GemConfig
+     * @param sbmPort                  int
      * @param sbmIdleSleepMilliSeconds int
      */
     public SbkGemParameters(String name, String[] drivers, String[] loggers, @NotNull GemConfig config, int sbmPort,
@@ -95,7 +95,8 @@ public SbkGemParameters(String name, String[] drivers, String[] loggers, @NotNul
         addOption("delete", true, "Delete SBK package after benchmark; default: " + config.delete);
         addOption("localhost", true, "this local SBM host name, default: " + localHost);
         addOption("sbmport", true, "SBM port number; default: " + this.sbmPort);
-        addOption("sbmsleepms", true, "SBM idle milliseconds to sleep; default: " + this.sbmIdleSleepMilliSeconds);
+        addOption("sbmsleepms", true, "SBM idle milliseconds to sleep; default: " + this.sbmIdleSleepMilliSeconds +
+                " ms");
         this.optionsArgs = new String[]{"-nodes", "-gemuser", "-gempass", "-gemport", "-sbkdir", "-sbkcommand",
                 "-copy", "-delete", "-localhost", "-sbmPort", "-sbmsleepms"};
         this.parsedArgs = null;

diff --git a/sbm/src/main/java/io/sbm/api/impl/SbmLatencyBenchmark.java b/sbm/src/main/java/io/sbm/api/impl/SbmLatencyBenchmark.java
@@ -72,7 +72,7 @@ void run() throws InterruptedException {
         MessageLatenciesRecord record;
         boolean doWork = true;
         boolean notFound;
-        Printer.log.info("SbmLatencyBenchmark Started");
+        Printer.log.info("SbmLatencyBenchmark Started : {} milliseconds idle sleep", this.idleMS);
         long currentTime = time.getCurrentTime();
         window.start(currentTime);
         window.startWindow(currentTime);

diff --git a/sbm/src/main/java/io/sbm/params/impl/SbmParameters.java b/sbm/src/main/java/io/sbm/params/impl/SbmParameters.java
@@ -75,7 +75,7 @@ public SbmParameters(String name, int port, int maxConnections, int idleMS, Stri
                             default: r""");
         addOption("port", true, "SBM port number; default: " + this.port);
         addOption("max", true, "Maximum number of connections; default: " + maxConnections);
-        addOption("millisecsleep", true, "Idle sleep in milliseconds; default: " + idleMS);
+        addOption("millisecsleep", true, "Idle sleep in milliseconds; default: " + idleMS+" ms");
     }