summaryrefslogtreecommitdiffstats
path: root/vespaclient-java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-02-03 11:50:41 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-02-03 11:50:41 +0100
commit92d9d3374c4718e53c037aa19adccdf694bd3ac0 (patch)
tree64c03c76b7838290d925381f07de9865392f97a9 /vespaclient-java
parent97a9d25154b863baac946e11d95a8fa63d97a738 (diff)
Add missing error count to report
Diffstat (limited to 'vespaclient-java')
-rw-r--r--vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java40
1 files changed, 20 insertions, 20 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 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()));
}