summaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 23:08:32 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 23:08:32 +0100
commitbdf556ee7378e8cb2a9a8e82844882a12bb9b90f (patch)
tree589d8432da77b017565e063ce7f5d4650e077543 /vespaclient-core
parent46afc8534594be2e16efd5befa089fa3c3191cee (diff)
If the owner is gone, it did not happen....
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java3
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);