diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-20 14:03:37 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-20 14:03:37 +0200 |
commit | 985494a2c3f4696832e2735323228ac147eeeea6 (patch) | |
tree | b364918f7319b7d456c73448fa3fe1cee7b85280 /vespa_feed_perf | |
parent | e5573dc7279c54cefe47cc5eb450ff9018196145 (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.java | 7 |
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; } |