diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 23:08:32 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 23:08:32 +0100 |
commit | bdf556ee7378e8cb2a9a8e82844882a12bb9b90f (patch) | |
tree | 589d8432da77b017565e063ce7f5d4650e077543 /vespaclient-core/src/main/java/com/yahoo/feedapi | |
parent | 46afc8534594be2e16efd5befa089fa3c3191cee (diff) |
If the owner is gone, it did not happen....
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java | 3 |
1 files changed, 1 insertions, 2 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 b38f4b4e516..3c4aa494a0d 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java @@ -187,9 +187,9 @@ public class SharedSender implements ReplyHandler { if (owner != null) { metrics.addReply(r); OwnerState state = activeOwners.get(owner); - boolean active = owner.handleReply(r, state.getNumPending() - 1); if (state != null) { + boolean active = owner.handleReply(r, state.getNumPending() - 1); if (log.isLoggable(LogLevel.SPAM)) { log.log(LogLevel.SPAM, "Received reply for file " + owner.toString() + ", count was " + state.getNumPending()); } @@ -208,7 +208,6 @@ public class SharedSender implements ReplyHandler { } } - public static class OwnerState { final AtomicInteger numPending = new AtomicInteger(0); |