summaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 22:44:36 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 22:44:36 +0100
commit94d87e9e76e30867c75a21e7df1bfef164a6708c (patch)
treea0e1496a55a50a6a05ad228b9b477431546d7bc5 /vespaclient-core
parent9cee688437c493146eba6959b7b7552b70f8cca8 (diff)
if someone removes a callback, we must clear pending and signal/prevent anyone from sleeping there.
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java5
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() {