diff --git a/src/main/java/com/threerings/presents/client/ClientCommunicator.java b/src/main/java/com/threerings/presents/client/ClientCommunicator.java index 9fa0f101d..287879476 100644 --- a/src/main/java/com/threerings/presents/client/ClientCommunicator.java +++ b/src/main/java/com/threerings/presents/client/ClientCommunicator.java @@ -140,7 +140,7 @@ public class ClientCommunicator extends BlockingCommunicator protected class PrefPortInterval extends Interval { public PrefPortInterval (String key, int thisPort, int nextPort) { - super(); + super(Interval.RUN_DIRECT); _key = key; _thisPort = thisPort; _nextPort = nextPort; diff --git a/src/main/java/com/threerings/presents/server/RebootManager.java b/src/main/java/com/threerings/presents/server/RebootManager.java index dadcbdaad..0855bd9f9 100644 --- a/src/main/java/com/threerings/presents/server/RebootManager.java +++ b/src/main/java/com/threerings/presents/server/RebootManager.java @@ -266,7 +266,7 @@ public abstract class RebootManager broadcast("m.rebooting_now"); // wait 1 second, then do it - new Interval() { // Note: This interval does not run on the dobj thread + new Interval(Interval.RUN_DIRECT) { @Override public void expired () { _server.queueShutdown(); // this posts a LongRunnable }