From 92d9d3374c4718e53c037aa19adccdf694bd3ac0 Mon Sep 17 00:00:00 2001
From: Henning Baldersheim <balder@yahoo-inc.com>
Date: Fri, 3 Feb 2023 11:50:41 +0100
Subject: Add missing error count to report

---
 .../com/yahoo/vespa/feed/perf/SimpleFeeder.java    | 40 +++++++++++-----------
 1 file changed, 20 insertions(+), 20 deletions(-)

(limited to 'vespaclient-java/src/main/java/com/yahoo')

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 7f85f37436b..189ac69ea91 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
@@ -425,25 +425,24 @@ public class SimpleFeeder implements ReplyHandler {
     }
 
     private static Message newMessage(FeedOperation op) {
-        switch (op.getType()) {
-        case DOCUMENT: {
-            PutDocumentMessage message = new PutDocumentMessage(new DocumentPut(op.getDocument()));
-            message.setCondition(op.getCondition());
-            return message;
-        }
-        case REMOVE: {
-            RemoveDocumentMessage message = new RemoveDocumentMessage(op.getRemove());
-            message.setCondition(op.getCondition());
-            return message;
-        }
-        case UPDATE: {
-            UpdateDocumentMessage message = new UpdateDocumentMessage(op.getDocumentUpdate());
-            message.setCondition(op.getCondition());
-            return message;
-        }
-        default:
-            return null;
-        }
+        return switch (op.getType()) {
+            case DOCUMENT -> {
+                PutDocumentMessage message = new PutDocumentMessage(new DocumentPut(op.getDocument()));
+                message.setCondition(op.getCondition());
+                yield message;
+            }
+            case REMOVE -> {
+                RemoveDocumentMessage message = new RemoveDocumentMessage(op.getRemove());
+                message.setCondition(op.getCondition());
+                yield message;
+            }
+            case UPDATE -> {
+                UpdateDocumentMessage message = new UpdateDocumentMessage(op.getDocumentUpdate());
+                message.setCondition(op.getCondition());
+                yield message;
+            }
+            default -> null;
+        };
     }
 
     private static boolean containsFatalErrors(Stream<Error> errors) {
@@ -479,7 +478,8 @@ public class SimpleFeeder implements ReplyHandler {
     }
 
     private synchronized void printReport(PrintStream out) {
-        out.format("%10d, %12d, %11d, %11d, %11d\n", System.currentTimeMillis() - startTime,
+        // Errors will stop feed so we just fake the num errors = 0
+        out.format("%10d, %12d, 0, %11d, %11d, %11d\n", System.currentTimeMillis() - startTime,
                 numReplies.get(), minLatency, maxLatency, sumLatency / Long.max(1, numReplies.get()));
     }
 
-- 
cgit v1.2.3