aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-java/src/main/java/com/yahoo
diff options
context:
space:
mode:
Diffstat (limited to 'vespaclient-java/src/main/java/com/yahoo')
-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()));
}