From a04341ef7745a5f8f29b269cdf5c4368a745d22e Mon Sep 17 00:00:00 2001
From: Harald Musum <musum@yahooinc.com>
Date: Tue, 12 Mar 2024 11:29:15 +0100
Subject: Indent two characters for every line in output

---
 .../com/yahoo/vespa/feed/perf/SimpleFeeder.java    | 22 ++++++++++++----------
 .../yahoo/vespa/feed/perf/SimpleFeederTest.java    | 14 +++++++-------
 2 files changed, 19 insertions(+), 17 deletions(-)

diff --git a/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java b/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
index b41bb29376b..3a7fe8f75c6 100644
--- a/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
+++ b/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
@@ -2,7 +2,6 @@
 package com.yahoo.vespa.feed.perf;
 
 import com.yahoo.concurrent.ThreadFactoryFactory;
-import com.yahoo.config.subscription.ConfigSubscriber;
 import com.yahoo.document.Document;
 import com.yahoo.document.DocumentId;
 import com.yahoo.document.DocumentPut;
@@ -66,7 +65,6 @@ import java.util.stream.Stream;
 public class SimpleFeeder implements ReplyHandler {
 
     private final DocumentTypeManager docTypeMgr = new DocumentTypeManager();
-    private final ConfigSubscriber documentTypeConfigSubscriber;
     private final List<InputStream> inputStreams;
     private final PrintStream out;
     private final RPCMessageBus mbus;
@@ -200,16 +198,18 @@ public class SimpleFeeder implements ReplyHandler {
         }
 
         private void addCommaAndNewline() {
-            if (! isFirst) {
-                try {
+            try {
+                if (isFirst) {
+                    outputStream.write(' ');
+                    outputStream.write(' ');
+                    isFirst = false;
+                } else {
                     outputStream.write(',');
                     outputStream.write('\n');
-                } catch (IOException e) {
-                    failure.set(e);
+                    outputStream.write(' ');
                 }
-            }
-            else {
-                isFirst = false;
+            } catch (IOException e) {
+                failure.set(e);
             }
         }
 
@@ -391,7 +391,7 @@ public class SimpleFeeder implements ReplyHandler {
         numMessagesToSend = params.getNumMessagesToSend();
         mbus = newMessageBus(docTypeMgr, params);
         session = newSession(mbus, this, params);
-        documentTypeConfigSubscriber = DocumentTypeManagerConfigurer.configure(docTypeMgr, params.getConfigId());
+        DocumentTypeManagerConfigurer.configure(docTypeMgr, params.getConfigId());
         benchmarkMode = params.isBenchmarkMode();
         destination = (params.getDumpStream() != null)
                 ? createDumper(params)
@@ -482,6 +482,7 @@ public class SimpleFeeder implements ReplyHandler {
         numReplies.incrementAndGet();
         accumulateReplies(now, latency);
     }
+
     private synchronized void accumulateReplies(long now, long latency) {
         minLatency = Math.min(minLatency, latency);
         maxLatency = Math.max(maxLatency, latency);
@@ -492,6 +493,7 @@ public class SimpleFeeder implements ReplyHandler {
             nextReport += REPORT_INTERVAL;
         }
     }
+
     private static void printHeader(PrintStream out) {
         out.println("# Time used, num ok, num error, min latency, max latency, average latency");
     }
diff --git a/vespaclient-java/src/test/java/com/yahoo/vespa/feed/perf/SimpleFeederTest.java b/vespaclient-java/src/test/java/com/yahoo/vespa/feed/perf/SimpleFeederTest.java
index 28859d0e7c4..2810303fad3 100644
--- a/vespaclient-java/src/test/java/com/yahoo/vespa/feed/perf/SimpleFeederTest.java
+++ b/vespaclient-java/src/test/java/com/yahoo/vespa/feed/perf/SimpleFeederTest.java
@@ -87,11 +87,11 @@ public class SimpleFeederTest {
                 "",
                 "(.+\n)+" +
                         "\\s*\\d+,\\s*3,.+\n");
-        assertEquals(93, dump.size());
+        assertEquals(96, dump.size());
         assertEquals("""
                              [
-                             {"id":"id:simple:simple::0","fields":{"my_str":"foo"}},
-                              {"remove":"id:simple:simple::2"}
+                               {"id":"id:simple:simple::0","fields":{"my_str":"foo"}},
+                               {"remove":"id:simple:simple::2"}
                              ]""",
                      dump.toString());
     }
@@ -121,12 +121,12 @@ public class SimpleFeederTest {
                 "",
                 "(.+\n)+" +
                         "\\s*\\d+,\\s*3,.+\n");
-        assertEquals(150, dump.size());
+        assertEquals(154, dump.size());
         assertEquals("""
                          [
-                         {"id":"id:simple:simple::0","fields":{"my_str":"foo"}},
-                          {"id":"id:simple:simple::1","fields":{"my_str":"bar"}},
-                          {"remove":"id:simple:simple::2"}
+                           {"id":"id:simple:simple::0","fields":{"my_str":"foo"}},
+                           {"id":"id:simple:simple::1","fields":{"my_str":"bar"}},
+                           {"remove":"id:simple:simple::2"}
                          ]""",
                      dump.toString());
         assertFeed(dump.toString(),
-- 
cgit v1.2.3