From dee8195acdc375ab13da79d80b5858e2f2a86090 Mon Sep 17 00:00:00 2001 From: Arne H Juul Date: Thu, 16 Dec 2021 14:09:37 +0000 Subject: call wakeup() after scheduleNow() --- jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java | 1 + jrt/src/com/yahoo/jrt/slobrok/api/Register.java | 3 +++ 2 files changed, 4 insertions(+) (limited to 'jrt/src') 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(); } /** -- cgit v1.2.3