diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 22:44:36 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 22:44:36 +0100 |
commit | 94d87e9e76e30867c75a21e7df1bfef164a6708c (patch) | |
tree | a0e1496a55a50a6a05ad228b9b477431546d7bc5 /vespaclient-core | |
parent | 9cee688437c493146eba6959b7b7552b70f8cca8 (diff) |
if someone removes a callback, we must clear pending and signal/prevent anyone from sleeping there.
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java | 5 |
1 files changed, 4 insertions, 1 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 00f5606b93a..949be19c3eb 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java @@ -48,7 +48,10 @@ public class SharedSender implements ReplyHandler { } public void remove(ResultCallback owner) { - activeOwners.remove(owner); + OwnerState state = activeOwners.remove(owner); + if (state != null) { + state.clearPending(); + } } public void shutdown() { |