call wakeup() after scheduleNow()

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();
     }
 
     /**