Update AeronStat.java

Author: pjfanning

remote/src/test/java/org/apache/pekko/remote/artery/aeron/AeronStat.java

@@ -91,83 +91,6 @@ public class AeronStat {
   /** Channel filter to be used for position counters. */
   private static final String COUNTER_CHANNEL = "channel";
 
-  /**
-   * Main method for launching the process.
-   *
-   * @param args passed to the process.
-   * @throws IOException if an error occurs writing to the console.
-   * @throws InterruptedException if the thread sleep delay is interrupted.
-   */
-  public static void main(final String[] args) throws IOException, InterruptedException {
-    long delayMs = 1000L;
-    boolean watch = true;
-    Pattern typeFilter = null;
-    Pattern identityFilter = null;
-    Pattern sessionFilter = null;
-    Pattern streamFilter = null;
-    Pattern channelFilter = null;
-
-    if (0 != args.length) {
-      checkForHelp(args);
-
-      for (final String arg : args) {
-        final int equalsIndex = arg.indexOf('=');
-        if (-1 == equalsIndex) {
-          System.out.println("Arguments must be in name=pattern format: Invalid '" + arg + "'");
-          return;
-        }
-
-        final String argName = arg.substring(0, equalsIndex);
-        final String argValue = arg.substring(equalsIndex + 1);
-
-        switch (argName) {
-          case WATCH:
-            watch = Boolean.parseBoolean(argValue);
-            break;
-
-          case DELAY:
-            delayMs = Long.parseLong(argValue) * 1000L;
-            break;
-
-          case COUNTER_TYPE_ID:
-            typeFilter = Pattern.compile(argValue);
-            break;
-
-          case COUNTER_IDENTITY:
-            identityFilter = Pattern.compile(argValue);
-            break;
-
-          case COUNTER_SESSION_ID:
-            sessionFilter = Pattern.compile(argValue);
-            break;
-
-          case COUNTER_STREAM_ID:
-            streamFilter = Pattern.compile(argValue);
-            break;
-
-          case COUNTER_CHANNEL:
-            channelFilter = Pattern.compile(argValue);
-            break;
-
-          default:
-            System.out.println("Unrecognised argument: '" + arg + "'");
-            return;
-        }
-      }
-    }
-
-    final CncFileReader cncFileReader = CncFileReader.map();
-
-    final CounterFilter counterFilter =
-        new CounterFilter(typeFilter, identityFilter, sessionFilter, streamFilter, channelFilter);
-
-    if (watch) {
-      workLoop(delayMs, () -> printOutput(cncFileReader, counterFilter));
-    } else {
-      printOutput(cncFileReader, counterFilter);
-    }
-  }
-
   @SuppressWarnings("try")
   private static void workLoop(final long delayMs, final Runnable outputPrinter)
       throws IOException, InterruptedException {
@@ -181,54 +104,6 @@ private static void workLoop(final long delayMs, final Runnable outputPrinter)
     }
   }
 
-  private static void printOutput(
-      final CncFileReader cncFileReader, final CounterFilter counterFilter) {
-    System.out.print(DATE_FORMAT.format(new Date()));
-    System.out.println(
-        " - Aeron Stat (CnC v"
-            + cncFileReader.semanticVersion()
-            + ")"
-            + ", pid "
-            + cncFileReader.driverPid()
-            + ", heartbeat age "
-            + cncFileReader.driverHeartbeatAgeMs()
-            + "ms");
-    System.out.println("======================================================================");
-
-    final CountersReader counters = cncFileReader.countersReader();
-    final int maxIdWidth = AsciiEncoding.digitCount(counters.maxCounterId());
-    final String formatString = "%" + maxIdWidth + "d: %,26d - %s%n";
-
-    counters.forEach(
-        (counterId, typeId, keyBuffer, label) -> {
-          if (counterFilter.filter(typeId, keyBuffer)) {
-            final long value = counters.getCounterValue(counterId);
-            System.out.format(formatString, counterId, value, label);
-          }
-        });
-
-    System.out.println("--");
-  }
-
-  private static void checkForHelp(final String[] args) {
-    for (final String arg : args) {
-      if ("-?".equals(arg) || "-h".equals(arg) || "-help".equals(arg)) {
-        System.out.format(
-            "Usage: [-Daeron.dir=<directory containing CnC file>] AeronStat%n"
-                + "\t[delay=<seconds between updates>]%n"
-                + "\t[watch=<true|false>]%n"
-                + "filter by optional regex patterns:%n"
-                + "\t[type=<pattern>]%n"
-                + "\t[identity=<pattern>]%n"
-                + "\t[session=<pattern>]%n"
-                + "\t[stream=<pattern>]%n"
-                + "\t[channel=<pattern>]%n");
-
-        System.exit(0);
-      }
-    }
-  }
-
   private static void clearScreen() throws IOException, InterruptedException {
     if (SystemUtil.isWindows()) {
       new ProcessBuilder("C:\\Windows\\System32\\cmd.exe", "/c", "cls")