aboutsummaryrefslogtreecommitdiffstats
path: root/vespa_feed_perf
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-10-20 14:03:37 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2021-10-20 14:03:37 +0200
commit985494a2c3f4696832e2735323228ac147eeeea6 (patch)
treeb364918f7319b7d456c73448fa3fe1cee7b85280 /vespa_feed_perf
parente5573dc7279c54cefe47cc5eb450ff9018196145 (diff)
Ignore test and set errors
Diffstat (limited to 'vespa_feed_perf')
-rw-r--r--vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
index 4f8129dc76d..167e9b338a9 100644
--- a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
+++ b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
@@ -56,6 +56,7 @@ import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
import java.util.logging.Level;
import java.util.logging.Logger;
+import java.util.stream.Stream;
/**
* @author Simon Thoresen Hult
@@ -441,12 +442,16 @@ public class SimpleFeeder implements ReplyHandler {
}
}
+ private static boolean containsFatalErrors(Stream<Error> errors) {
+ return errors.anyMatch(e -> e.getCode() != DocumentProtocol.ERROR_TEST_AND_SET_CONDITION_FAILED);
+ }
+
@Override
public void handleReply(Reply reply) {
if (failure.get() != null) {
return;
}
- if (reply.hasErrors()) {
+ if (containsFatalErrors(reply.getErrors())) {
failure.compareAndSet(null, new IOException(formatErrors(reply)));
return;
}