diff options
Diffstat (limited to 'vespaclient-core')
| -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); |