Everybody's favorite new game show, Name That Thread

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5178 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Charlie Groves
2008-06-11 00:46:02 +00:00
parent 3726a408fa
commit 6abd794182
2 changed files with 7 additions and 5 deletions
@@ -31,7 +31,6 @@ import java.nio.channels.SelectionKey;
import java.nio.channels.Selector; import java.nio.channels.Selector;
import java.nio.channels.SocketChannel; import java.nio.channels.SocketChannel;
import java.net.ConnectException;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
@@ -51,15 +50,12 @@ import com.threerings.io.ObjectOutputStream;
import com.threerings.io.UnreliableObjectInputStream; import com.threerings.io.UnreliableObjectInputStream;
import com.threerings.io.UnreliableObjectOutputStream; import com.threerings.io.UnreliableObjectOutputStream;
import com.threerings.presents.data.AuthCodes;
import com.threerings.presents.dobj.DObjectManager;
import com.threerings.presents.net.AuthRequest; import com.threerings.presents.net.AuthRequest;
import com.threerings.presents.net.AuthResponse; import com.threerings.presents.net.AuthResponse;
import com.threerings.presents.net.AuthResponseData; import com.threerings.presents.net.AuthResponseData;
import com.threerings.presents.net.DownstreamMessage; import com.threerings.presents.net.DownstreamMessage;
import com.threerings.presents.net.LogoffRequest; import com.threerings.presents.net.LogoffRequest;
import com.threerings.presents.net.PingRequest; import com.threerings.presents.net.PingRequest;
import com.threerings.presents.net.PongResponse;
import com.threerings.presents.net.Transport; import com.threerings.presents.net.Transport;
import com.threerings.presents.net.UpstreamMessage; import com.threerings.presents.net.UpstreamMessage;
import com.threerings.presents.util.DatagramSequencer; import com.threerings.presents.util.DatagramSequencer;
@@ -541,6 +537,7 @@ public class BlockingCommunicator extends Communicator
{ {
public Reader () public Reader ()
{ {
super("BlockingCommunicatorReader");
} }
protected void willStart () protected void willStart ()
@@ -675,6 +672,11 @@ public class BlockingCommunicator extends Communicator
*/ */
protected class Writer extends LoopingThread protected class Writer extends LoopingThread
{ {
public Writer(){
super("BlockingCommunicatorWriter");
}
protected void iterate () protected void iterate ()
{ {
// fetch the next message from the queue // fetch the next message from the queue
@@ -170,7 +170,7 @@ public class SignalManager
// make sure the signal dispatcher thread is started // make sure the signal dispatcher thread is started
if (_haveLibrary && _sigdis == null) { if (_haveLibrary && _sigdis == null) {
_sigdis = new Thread() { _sigdis = new Thread("SignalDispatcher") {
public void run () { public void run () {
log.info("Dispatching signals..."); log.info("Dispatching signals...");
dispatchSignals(); dispatchSignals();