diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-07 20:34:02 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-07 20:34:02 +0100 |
commit | c9f0294aca146f3992b98831929ecb0b926b7c51 (patch) | |
tree | 4c3b95ee95c8dbfa04fb2e7d89989c91d8dad6d2 /vespaclient-core/src/main/java/com/yahoo/feedapi | |
parent | 5f1810bb95b2abf141c599f27413f1a48d8d8e7d (diff) |
Keep the old interface.
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java index b0e52357a64..00f5606b93a 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java @@ -182,8 +182,8 @@ public class SharedSender implements ReplyHandler { if (owner != null) { metrics.addReply(r); - boolean active = owner.handleReply(r); OwnerState state = activeOwners.get(owner); + boolean active = owner.handleReply(r, state.getNumPending() - 1); if (state != null) { if (log.isLoggable(LogLevel.SPAM)) { @@ -192,8 +192,8 @@ public class SharedSender implements ReplyHandler { if (!active) { state.clearPending(); activeOwners.remove(owner); - } else if ((state.decPending(1) <= 0)) { - activeOwners.remove(owner); + } else { + state.decPending(1); } } else { // TODO: should be debug level if at all. @@ -269,7 +269,7 @@ public class SharedSender implements ReplyHandler { public interface ResultCallback { /** Return true if we should continue waiting for replies for this sender. */ - boolean handleReply(Reply r); + boolean handleReply(Reply r, int numPending); /** * Returns true if feeding has been aborted. No more feeding is allowed with this |