diff options
author | Arne H Juul <arnej@yahooinc.com> | 2021-12-16 14:09:37 +0000 |
---|---|---|
committer | Arne H Juul <arnej@yahooinc.com> | 2021-12-16 14:09:37 +0000 |
commit | dee8195acdc375ab13da79d80b5858e2f2a86090 (patch) | |
tree | c44d334faf0bbeb4a7c61a5cf8adcfb199a5dad6 /jrt/src | |
parent | f3815285d89f687857f827a53f228814f00340fa (diff) |
call wakeup() after scheduleNow()
Diffstat (limited to 'jrt/src')
-rw-r--r-- | jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java | 1 | ||||
-rw-r--r-- | jrt/src/com/yahoo/jrt/slobrok/api/Register.java | 3 |
2 files changed, 4 insertions, 0 deletions
diff --git a/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java b/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java index 2946a9c6297..63de287486e 100644 --- a/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java +++ b/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java @@ -67,6 +67,7 @@ public class Mirror implements IMirror { public void handleRequestDone(Request req) { requestDone = true; updateTask.scheduleNow(); + transportThread.wakeup_if_not_self(); } }; startFetchRequest(); diff --git a/jrt/src/com/yahoo/jrt/slobrok/api/Register.java b/jrt/src/com/yahoo/jrt/slobrok/api/Register.java index a02527eee25..14afea396bf 100644 --- a/jrt/src/com/yahoo/jrt/slobrok/api/Register.java +++ b/jrt/src/com/yahoo/jrt/slobrok/api/Register.java @@ -87,6 +87,7 @@ public class Register { public void handleRequestDone(Request req) { reqDone = true; updateTask.scheduleNow(); + transportThread.wakeup_if_not_self(); } }; m_list = new Method("slobrok.callback.listNamesServed", @@ -159,6 +160,7 @@ public class Register { pending.add(name); discard(unreg, name); updateTask.scheduleNow(); + transportThread.wakeup(); } /** @@ -171,6 +173,7 @@ public class Register { discard(pending, name); unreg.add(name); updateTask.scheduleNow(); + transportThread.wakeup(); } /** |