If the owner is gone, it did not happen....
@@ -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);
