Subversion Repositories scarts

/* A class to test my client TCP socket implementation */

import java.net.*;

import java.io.*;

public class ClientSocket extends Object

{

public static void

main(String[] argv) throws IOException

{

  System.out.println("Starting client stream socket test");

  /* Simple connection and read test */

  System.out.println("Test 1: Connection to daytime port on local host");

  try

    {

      InetAddress addr = InetAddress.getByName("127.0.0.1");

      Socket s = new Socket(addr, 13);

      InputStream is = s.getInputStream();

      BufferedReader br = new BufferedReader(new InputStreamReader(is));

      for (String str = br.readLine(); ; str = br.readLine())

       {

         if (str == null)

           break;

         System.out.println(str);

       }

      s.close();

      System.out.println("PASSED: daytime test");

    }

  catch(IOException e)

    {

      System.out.println("FAILED: daytime test: " + e);

    }

  /* Simple connection refused test */

  System.out.println("Test 2: Connection refused test");

  try

    {

      InetAddress addr = InetAddress.getByName("127.0.0.1");

      Socket s = new Socket(addr, 47);

      s.close();

      System.out.print("WARNING: Cannot perform connection refused test");

      System.out.println(" because someone is listening on localhost:47");

    }

  catch(IOException e)

    {

      System.out.println("PASSED: connection refused test: " + e.getMessage());

    }

  /* Socket attributes test */

  System.out.println("Test 3: Connection attributes");

  try

    {

      Socket s = new Socket("www.netscape.com", 80);

      String laddr = s.getLocalAddress().getHostName();

      int lport = s.getLocalPort();

      String raddr = s.getInetAddress().getHostName();

      int rport = s.getPort();

      System.out.println("Local Address is: " + laddr);

      System.out.println("Local Port is: " + lport);

      System.out.println("Remote Address is: " + raddr);

      System.out.println("Remote Port is: " + rport);

      System.out.println("Socket.toString is: " + s);

      if ( (laddr == null) ||

          ((lport < 0) || (lport > 65535)) ||

           (raddr.indexOf("netscape.com") == -1) ||

           (rport != 80))

        System.out.println("FAILED: connection attribute test");

      else

        System.out.println("PASSED: connection attribute test");

      s.close();

    }

  catch(IOException e)

    {

      System.out.println("FAILED: connection attributes test: " + e.getMessage());

    }

  /* Socket options test */

  System.out.println("Test 4: Socket options");

  Socket s = new Socket("127.0.0.1", 23);

  try

    {

      // SO_TIMEOUT

      System.out.println("SO_TIMEOUT = " + s.getSoTimeout());

      System.out.println("Setting SO_TIMEOUT to 142");

      s.setSoTimeout(142);

      System.out.println("SO_TIMEOUT = " + s.getSoTimeout());

      System.out.println("Setting SO_TIMEOUT to 0");

      s.setSoTimeout(0);

      System.out.println("SO_TIMEOUT = " + s.getSoTimeout());

    }

  catch (IOException e)

    {

      System.out.println("WARNING: SO_TIMEOUT problem: " + e.getMessage());

      System.out.println("This is ok on Linux");

    }

  try

    {

      // Try TCP_NODELAY

      System.out.println("TCP_NODELAY = " + s.getTcpNoDelay());

      System.out.println("Setting TCP_NODELAY to true");

      s.setTcpNoDelay(true);

      System.out.println("TCP_NODELAY = " + s.getTcpNoDelay());

      System.out.println("Setting TCP_NODELAY to false");

      s.setTcpNoDelay(false);

      System.out.println("TCP_NODELAY = " + s.getTcpNoDelay());

      // Try SO_LINGER

      System.out.println("SO_LINGER = " + s.getSoLinger());

      System.out.println("Setting SO_LINGER to 100");

      s.setSoLinger(true, 100);

      System.out.println("SO_LINGER = " + s.getSoLinger());

      System.out.println("Setting SO_LINGER to off");

      s.setSoLinger(false, 0);

      System.out.println("SO_LINGER = " + s.getSoLinger());

      System.out.println("PASSED: socket options test");

    }

  catch(IOException e)

    {

      System.out.println("FAILED: socket options test: " + e.getMessage());

    }

  s.close();

  /* Simple read/write test */

  System.out.println("Test 5: Simple read/write test");

  try

    {

      System.out.println("Downloading the Transmeta homepage");

      s = new Socket("www.transmeta.com", 80);

      BufferedReader in = new BufferedReader(new

                          InputStreamReader(s.getInputStream()));

      PrintWriter out = new PrintWriter(new

                          OutputStreamWriter(s.getOutputStream()));

      out.print("GET /\r\n");

      out.flush();

      for (String str = in.readLine(); ; str = in.readLine())

       {

         if (str == null)

           break;

         System.out.println(str);

       }

      s.close();

      System.out.println("PASSED: simple read/write test");

    }

  catch(IOException e)

    {

      System.out.println("FAILED: simple read/write test: " + e.getMessage());

    }

  /* Connect to our server socket */

  System.out.println("Test 6: Connect to ServerSocket");

  try

    {

       s = new Socket("localhost", 9999);

       PrintWriter out = new PrintWriter(new

                             OutputStreamWriter(s.getOutputStream()));

       out.println("Hello, there server socket");

       out.print("I'm dun");

       out.flush();

       s.close();

       System.out.println("PASSED: connect to server socket");

    }

  catch(Exception e)

    {

      System.out.println("FAILED: connect to server socket: " + e);

    }

  System.out.println("Client stream socket test complete");

}

}