tools/testserver/Connection.java

   1 /* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
   2 /* ***** BEGIN LICENSE BLOCK *****
   3  * Version: MPL 1.1/GPL 2.0/LGPL 2.1
   4  *
   5  * The contents of this file are subject to the Mozilla Public License Version
   6  * 1.1 (the "License"); you may not use this file except in compliance with
   7  * the License. You may obtain a copy of the License at
   8  * http://www.mozilla.org/MPL/
   9  *
  10  * Software distributed under the License is distributed on an "AS IS" basis,
  11  * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
  12  * for the specific language governing rights and limitations under the
  13  * License.
  14  *
  15  * The Original Code is mozilla.org code.
  16  *
  17  * The Initial Developer of the Original Code is
  18  * Netscape Communications Corporation.
  19  * Portions created by the Initial Developer are Copyright (C) 1998
  20  * the Initial Developer. All Rights Reserved.
  21  *
  22  * Contributor(s):
  23  *
  24  * Alternatively, the contents of this file may be used under the terms of
  25  * either the GNU General Public License Version 2 or later (the "GPL"), or
  26  * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
  27  * in which case the provisions of the GPL or the LGPL are applicable instead
  28  * of those above. If you wish to allow use of your version of this file only
  29  * under the terms of either the GPL or the LGPL, and not to allow others to
  30  * use your version of this file under the terms of the MPL, indicate your
  31  * decision by deleting the provisions above and replace them with the notice
  32  * and other provisions required by the GPL or the LGPL. If you do not delete
  33  * the provisions above, a recipient may use your version of this file under
  34  * the terms of any one of the MPL, the GPL or the LGPL.
  35  *
  36  * ***** END LICENSE BLOCK ***** */
  37
  38 import java.io.*;
  39 import java.net.*;
  40
  41 class Connection extends Thread {
  42
  43     public static final boolean DEBUG = true;
  44         public Socket client;
  45         protected BufferedReader in;
  46         protected PrintWriter out;
  47
  48     final static String SERVER = "HTTP Test Server/1.1";
  49
  50     public Connection(Socket client_socket) {
  51                 client = client_socket;
  52
  53                 if (DEBUG)
  54                 {
  55                         System.out.println(
  56                             "---------------------------------------------------------");
  57                         System.out.println(client);
  58                 }
  59                 try {
  60                         in = new BufferedReader(new InputStreamReader(
  61                                 client.getInputStream()));
  62                         out = new PrintWriter(client.getOutputStream());
  63                         this.start();
  64                 }
  65                 catch (IOException e) {
  66                         try {
  67                                 client.close();
  68                         }
  69                         catch (IOException another) {
  70                         }
  71                         System.out.println("Exception while getting socket streams."
  72                                 + e);
  73                 }
  74         }
  75
  76         final public void run() {
  77
  78                 String line = null;
  79                 String firstline = null;
  80                 request = new StringBuffer();
  81
  82                 int len = 0;
  83         int extralen= 0;
  84                 try {
  85                         while(true) {
  86                                 if (!in.ready()) {
  87                                         continue;
  88                             }
  89                 line = in.readLine();
  90                                 if (line == null)
  91                                         break;
  92                                 if (firstline == null)
  93                                     firstline = new String(line);
  94                                 len = line.length();
  95                 if (line.regionMatches(true, 0,
  96                         "Content-length: ", 0, 16)) {
  97                     extralen = Integer.valueOf(line.substring(16,
  98                         line.length())).intValue();
  99                 }
 100                                 if (len == 0)
 101                 {
 102                     // Now read only the extralen if any-
 103                     if (extralen > 0)
 104                     {
 105                         char[] postbuffer = new char[extralen];
 106                         in.read(postbuffer);
 107                         request.append("\n");
 108                         request.append(postbuffer);
 109                         if (DEBUG) {
 110                             System.out.println();
 111                             System.out.println(postbuffer);
 112                         }
 113                     }
 114                     break;
 115                 }
 116                 request.append(line);
 117                                 request.append("\n");
 118                                 if (DEBUG)
 119                                     System.out.println(line);
 120                         }
 121             // This will appropriately write all the stuff based
 122             // on the first line and the script file
 123             ScriptFile sf = new ScriptFile(this, firstline, out);
 124                 out.flush();
 125                 // mark for garbage collect
 126                 sf = null;
 127                 } // try
 128                 catch (IOException e) {
 129                         System.out.println("Some problem while communicating. " + e);
 130                 }
 131                 finally {
 132                         try {
 133                                 client.close();
 134                         }
 135                         catch (IOException e2) {
 136                         }
 137                 }
 138         }
 139         StringBuffer request;
 140 }