diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-07 19:02:09 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-01-07 19:02:09 +0100 |
| commit | aff1c35130802ea17946c6e61576e73e40e70f6b (patch) | |
| tree | e3134b9a2730bcff8579ff1e9e046d9b41fcbdbb /vespaclient-core/src/main/java/com/yahoo/feedhandler | |
| parent | a24919194a205573200e7a8955f40384fbaedafb (diff) | |
Revert "Revert "Revert "Revert "Revert "Balder/avoid costly notifyall in sharedsender"""""
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedhandler')
| -rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java index f5d717d35e0..cdd4ac76c4c 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/FeedResponse.java @@ -101,7 +101,7 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res return ""; } - public boolean handleReply(Reply reply) { + public boolean handleReply(Reply reply, int numPending) { metrics.addReply(reply); if (reply.getTrace().getLevel() > 0) { String str = reply.getTrace().toString(); @@ -126,7 +126,7 @@ public final class FeedResponse extends HttpResponse implements SharedSender.Res isAborted = abortOnError; return !abortOnError; } - return true; + return numPending > 0; } public void done() { |