FileDocCategorySizeDatePackage
TalkServerThread.javaAPI DocExample3025Tue Dec 12 18:57:28 GMT 2000None

TalkServerThread

public class TalkServerThread extends Thread

(Omit source code)

Fields Summary
public Socket
socket
public DataInputStream
is
public DataOutputStream
os
TalkServer
server
boolean
DEBUG
Constructors Summary
TalkServerThread(Socket socket, TalkServer server)

        super("TalkServer");

        is = new DataInputStream(socket.getInputStream());
        os = new DataOutputStream(socket.getOutputStream());

        if (is == null) {
            System.err.println("TalkServerThread: Input stream seemed "
                               + "to be created successfully, but it's null.");
            throw new IOException();
        }

        if (os == null) {
            System.err.println("TalkServerThread: Output stream seemed "
                               + "to be created successfully, but it's null.");
            throw new IOException();
        }

        this.socket = socket;
        this.server = server;
Methods Summary
voidcleanup()

        try {
            if (is != null) {
                is.close();
                is = null;
            }
        } catch (Exception e) {} //Ignore errors.

        try {
            if (os != null) {
                os.close();
                os = null;
            }
        } catch (Exception e) {} //Ignore errors.

        try {
            if (socket != null) {
                socket.close();
                socket = null;
            }
        } catch (Exception e) {} //Ignore errors.
protected voidfinalize()

        cleanup();
public voidrun()

        while (socket != null) {
            try {
                //Read data.
                String str = is.readUTF();

                //Pass it on.
                if (str != null) {
                    server.forwardString(str, this);
                }
            } catch (EOFException e) { //No more data on this socket...
                server.forwardString("SERVER SAYS other applet disconnected",
                                     this);
                cleanup();
                return;
            } catch (NullPointerException e) { //Socket doesn't exist...
                server.forwardString("SERVER SAYS no socket to other applet",
                                     this);
                cleanup();
                return;
            } catch (IOException e) { //Read problem..
                server.forwardString("SERVER SAYS socket trouble with other applet",
                                     this);
                cleanup();
                return;
            } catch (Exception e) { //Unknown exception. Complain and quit.
                System.err.println("Exception on is.readUTF():");
                e.printStackTrace();
                cleanup();
                return;
            }
        }
public java.lang.StringtoString()


       
        return "TalkServerThread: socket = " + socket
               + "; is = " + is
               + "; os = " + os;