home *** CD-ROM | disk | FTP | other *** search
/ S283 Planetary Science &n…he Search for Life DVD 2 / DVD-ROM.iso / install / jre1_3 / lib / rt.jar / sun / net / NetworkServer.class (.txt) < prev    next >
Encoding:
Java Class File  |  1979-12-31  |  2.6 KB  |  104 lines
  1. package sun.net;
  2.  
  3. import java.io.BufferedInputStream;
  4. import java.io.BufferedOutputStream;
  5. import java.io.IOException;
  6. import java.io.InputStream;
  7. import java.io.PrintStream;
  8. import java.net.ServerSocket;
  9. import java.net.Socket;
  10.  
  11. public class NetworkServer implements Runnable, Cloneable {
  12.    public Socket clientSocket = null;
  13.    private Thread serverInstance;
  14.    private ServerSocket serverSocket;
  15.    public PrintStream clientOutput;
  16.    public InputStream clientInput;
  17.  
  18.    public void close() throws IOException {
  19.       this.clientSocket.close();
  20.       this.clientSocket = null;
  21.       this.clientInput = null;
  22.       this.clientOutput = null;
  23.    }
  24.  
  25.    public boolean clientIsOpen() {
  26.       return this.clientSocket != null;
  27.    }
  28.  
  29.    public final void run() {
  30.       if (this.serverSocket != null) {
  31.          Thread.currentThread().setPriority(10);
  32.  
  33.          while(true) {
  34.             try {
  35.                Socket var1 = this.serverSocket.accept();
  36.                NetworkServer var2 = (NetworkServer)this.clone();
  37.                var2.serverSocket = null;
  38.                var2.clientSocket = var1;
  39.                (new Thread(var2)).start();
  40.             } catch (Exception var6) {
  41.                System.out.print("Server failure\n");
  42.                ((Throwable)var6).printStackTrace();
  43.  
  44.                try {
  45.                   this.serverSocket.close();
  46.                } catch (IOException var5) {
  47.                }
  48.  
  49.                System.out.print("cs=" + this.serverSocket + "\n");
  50.                break;
  51.             }
  52.          }
  53.       } else {
  54.          try {
  55.             this.clientOutput = new PrintStream(new BufferedOutputStream(this.clientSocket.getOutputStream()), false);
  56.             this.clientInput = new BufferedInputStream(this.clientSocket.getInputStream());
  57.             this.serviceRequest();
  58.          } catch (Exception var4) {
  59.          }
  60.  
  61.          try {
  62.             this.close();
  63.          } catch (IOException var3) {
  64.          }
  65.       }
  66.  
  67.    }
  68.  
  69.    public final void startServer(int var1) throws IOException {
  70.       this.serverSocket = new ServerSocket(var1, 50);
  71.       this.serverInstance = new Thread(this);
  72.       this.serverInstance.start();
  73.    }
  74.  
  75.    public void serviceRequest() throws IOException {
  76.       byte[] var1 = new byte[300];
  77.       this.clientOutput.print("Echo server " + this.getClass().getName() + "\n");
  78.       this.clientOutput.flush();
  79.  
  80.       int var2;
  81.       while((var2 = this.clientInput.read(var1, 0, var1.length)) >= 0) {
  82.          this.clientOutput.write(var1, 0, var2);
  83.       }
  84.  
  85.    }
  86.  
  87.    public static void main(String[] var0) {
  88.       try {
  89.          (new NetworkServer()).startServer(8888);
  90.       } catch (IOException var2) {
  91.          System.out.print("Server failed: " + var2 + "\n");
  92.       }
  93.  
  94.    }
  95.  
  96.    public Object clone() {
  97.       try {
  98.          return super.clone();
  99.       } catch (CloneNotSupportedException var2) {
  100.          throw new InternalError();
  101.       }
  102.    }
  103. }
  104.