19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2007 The Android Open Source Project 39066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 49066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Licensed under the Apache License, Version 2.0 (the "License"); 59066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * you may not use this file except in compliance with the License. 69066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * You may obtain a copy of the License at 79066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 89066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 99066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Unless required by applicable law or agreed to in writing, software 119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * See the License for the specific language governing permissions and 149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * limitations under the License. 159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpackage android.core; 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.util.Log; 209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.io.*; 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.lang.Thread; 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.net.*; 249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport java.util.*; 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * TestWebServer is a simulated controllable test server that 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * can respond to requests from HTTP clients. 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The server can be controlled to change how it reacts to any 319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * requests, and can be told to simulate various events (such as 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * network failure) that would happen in a real environment. 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectclass TestWebServer implements HttpConstants { 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* static class data/methods */ 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* The ANDROID_LOG_TAG */ 399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private final static String LOGTAG = "httpsv"; 409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Where worker threads stand idle */ 429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Vector threads = new Vector(); 439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* List of all active worker threads */ 459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Vector activeThreads = new Vector(); 469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* timeout on client connections */ 489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int timeout = 0; 499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* max # worker threads */ 519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int workers = 5; 529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Default port for this server to listen on */ 549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project final static int DEFAULT_PORT = 8080; 559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Default socket timeout value */ 579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project final static int DEFAULT_TIMEOUT = 5000; 589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Version string (configurable) */ 609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected String HTTP_VERSION_STRING = "HTTP/1.1"; 619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Indicator for whether this server is configured as a HTTP/1.1 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * or HTTP/1.0 server 649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean http11 = true; 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* The thread handling new requests from clients */ 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private AcceptThread acceptT; 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* timeout on client connections */ 719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int mTimeout; 729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Server port */ 749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int mPort; 759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Switch on/off logging */ 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean mLog = false; 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If set, this will keep connections alive after a request has been 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * processed. 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean keepAlive = true; 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If set, this will cause response data to be sent in 'chunked' format */ 859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean chunked = false; 869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If set, this will indicate a new redirection host */ 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String redirectHost = null; 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* If set, this indicates the reason for redirection */ 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int redirectCode = -1; 929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Set the number of connections the server will accept before shutdown */ 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int acceptLimit = 100; 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Count of number of accepted connections */ 979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int acceptedConnections = 0; 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public TestWebServer() { 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Initialize a new server with default port and timeout. 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param log Set true if you want trace output 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void initServer(boolean log) throws Exception { 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project initServer(DEFAULT_PORT, DEFAULT_TIMEOUT, log); 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Initialize a new server with default timeout. 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param port Sets the server to listen on this port 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param log Set true if you want trace output 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void initServer(int port, boolean log) throws Exception { 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project initServer(port, DEFAULT_TIMEOUT, log); 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Initialize a new server with default port and timeout. 1219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param port Sets the server to listen on this port 1229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param timeout Indicates the period of time to wait until a socket is 1239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * closed 1249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param log Set true if you want trace output 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void initServer(int port, int timeout, boolean log) throws Exception { 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mPort = port; 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mTimeout = timeout; 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mLog = log; 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project keepAlive = true; 1319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (acceptT == null) { 1339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptT = new AcceptThread(); 1349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptT.init(); 1359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptT.start(); 1369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Print to the log file (if logging enabled) 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param s String to send to the log 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project protected void log(String s) { 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mLog) { 1459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Log.d(LOGTAG, s); 1469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Set the server to be an HTTP/1.0 or HTTP/1.1 server. 1519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * This should be called prior to any requests being sent 1529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to the server. 1539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param set True for the server to be HTTP/1.1, false for HTTP/1.0 1549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setHttpVersion11(boolean set) { 1569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project http11 = set; 1579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (set) { 1589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HTTP_VERSION_STRING = "HTTP/1.1"; 1599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 1609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project HTTP_VERSION_STRING = "HTTP/1.0"; 1619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Call this to determine whether server connection should remain open 1669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param value Set true to keep connections open after a request 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * completes 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setKeepAlive(boolean value) { 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project keepAlive = value; 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Call this to indicate whether chunked data should be used 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param value Set true to make server respond with chunk encoded 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * content data. 1779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setChunked(boolean value) { 1799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project chunked = value; 1809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Call this to specify the maximum number of sockets to accept 1849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param limit The number of sockets to accept 1859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setAcceptLimit(int limit) { 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptLimit = limit; 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Call this to indicate redirection port requirement. 1929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * When this value is set, the server will respond to a request with 1939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * a redirect code with the Location response header set to the value 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * specified. 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param redirect The location to be redirected to 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param redirectCode The code to send when redirecting 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void setRedirect(String redirect, int code) { 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project redirectHost = redirect; 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project redirectCode = code; 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Server will redirect output to "+redirect+" code "+code); 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Cause the thread accepting connections on the server socket to close 2069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void close() { 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Stop the Accept thread */ 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (acceptT != null) { 2109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Closing AcceptThread"+acceptT); 2119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptT.close(); 2129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptT = null; 2139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The AcceptThread is responsible for initiating worker threads 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * to handle incoming requests from clients. 2189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project class AcceptThread extends Thread { 2209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ServerSocket ss = null; 2229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean running = false; 2239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void init() { 2259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Networking code doesn't support ServerSocket(port) yet 2269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InetSocketAddress ia = new InetSocketAddress(mPort); 2279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (true) { 2289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ss = new ServerSocket(); 2309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Socket timeout functionality is not available yet 2319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project //ss.setSoTimeout(5000); 2329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ss.setReuseAddress(true); 2339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ss.bind(ia); 2349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 2359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 2369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("IOException in AcceptThread.init()"); 2379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e.printStackTrace(); 2389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // wait and retry 2399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Thread.sleep(1000); 2419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException e1) { 2429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // TODO Auto-generated catch block 2439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e1.printStackTrace(); 2449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 2509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Main thread responding to new connections 2519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 2529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void run() { 2539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = true; 2549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (running) { 2569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Log.d(LOGTAG, "TestWebServer run() calling accept()"); 2579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Socket s = ss.accept(); 2589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project acceptedConnections++; 2599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (acceptedConnections >= acceptLimit) { 2609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = false; 2619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Worker w = null; 2649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (threads) { 2659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (threads.isEmpty()) { 2669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Worker ws = new Worker(); 2679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ws.setSocket(s); 2689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project activeThreads.addElement(ws); 2699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project (new Thread(ws, "additional worker")).start(); 2709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 2719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project w = (Worker) threads.elementAt(0); 2729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project threads.removeElementAt(0); 2739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project w.setSocket(s); 2749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (SocketException e) { 2789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("SocketException in AcceptThread: probably closed during accept"); 2799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = false; 2809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 2819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("IOException in AcceptThread"); 2829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e.printStackTrace(); 2839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = false; 2849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("AcceptThread terminated" + this); 2869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Close this socket 2899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void close() { 2909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = false; 2929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Stop server socket from processing further. Currently 2939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this does not cause the SocketException from ss.accept 2949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project therefore the acceptLimit functionality has been added 2959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project to circumvent this limitation */ 2969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ss.close(); 2979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Stop worker threads from continuing 2999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (Enumeration e = activeThreads.elements(); e.hasMoreElements();) { 3009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Worker w = (Worker)e.nextElement(); 3019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project w.close(); 3029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project activeThreads.clear(); 3049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 3069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* We are shutting down the server, so we expect 3079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * things to die. Don't propagate. 3089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("IOException caught by server socket close"); 3109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Size of buffer for reading from the connection 3159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project final static int BUF_SIZE = 2048; 3169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* End of line byte sequence */ 3189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project static final byte[] EOL = {(byte)'\r', (byte)'\n' }; 3199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The worker thread handles all interactions with a current open 3229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connection. If pipelining is turned on, this will allow this 3239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * thread to continuously operate on numerous requests before the 3249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * connection is closed. 3259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project class Worker implements HttpConstants, Runnable { 3279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* buffer to use to hold request data */ 3299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project byte[] buf; 3309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Socket to client we're handling */ 3329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Socket s; 3339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Reference to current request method ID */ 3359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int requestMethod; 3369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Reference to current requests test file/data */ 3389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private String testID; 3399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Reference to test number from testID */ 3419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int testNum; 3429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Reference to whether new request has been initiated yet */ 3449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean readStarted; 3459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Indicates whether current request has any data content */ 3479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean hasContent = false; 3489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project boolean running = false; 3509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Request headers are stored here */ 3529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private Hashtable<String, String> headers = new Hashtable<String, String>(); 3539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* Create a new worker thread */ 3559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Worker() { 3569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf = new byte[BUF_SIZE]; 3579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s = null; 3589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Called by the AcceptThread to unblock this Worker to process 3629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * a request. 3639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param s The socket on which the connection has been made 3649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized void setSocket(Socket s) { 3669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project this.s = s; 3679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project notify(); 3689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Called by the accept thread when it's closing. Potentially unblocks 3729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * the worker thread to terminate properly 3739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized void close() { 3759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = false; 3769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project notify(); 3779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 3799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 3809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Main worker thread. This will wait until a request has 3819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * been identified by the accept thread upon which it will 3829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * service the thread. 3839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 3849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public synchronized void run() { 3859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project running = true; 3869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while(running) { 3879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (s == null) { 3889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* nothing to do */ 3899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 3909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log(this+" Moving to wait state"); 3919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project wait(); 3929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (InterruptedException e) { 3939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* should not happen */ 3949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project continue; 3959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!running) break; 3979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 3989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 3999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project handleClient(); 4009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (Exception e) { 4019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e.printStackTrace(); 4029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* go back in wait queue if there's fewer 4049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * than numHandler connections. 4059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s = null; 4079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Vector pool = threads; 4089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project synchronized (pool) { 4099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (pool.size() >= workers) { 4109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* too many threads, exit this one */ 4119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project activeThreads.remove(this); 4129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 4139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 4149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project pool.addElement(this); 4159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log(this+" terminated"); 4199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Zero out the buffer from last time 4239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private void clearBuffer() { 4259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project for (int i = 0; i < BUF_SIZE; i++) { 4269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[i] = 0; 4279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Utility method to read a line of data from the input stream 4329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Inputstream to read 4339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 4349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int readOneLine(InputStream is) { 4369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int read = 0; 4389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project clearBuffer(); 4409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 4419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Reading one line: started ="+readStarted+" avail="+is.available()); 4429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while ((!readStarted) || (is.available() > 0)) { 4439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int data = is.read(); 4449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // We shouldn't get EOF but we need tdo check 4459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (data == -1) { 4469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("EOF returned"); 4479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 4489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[read] = (byte)data; 4519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project System.out.print((char)data); 4539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project readStarted = true; 4559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (buf[read++]==(byte)'\n') { 4569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project System.out.println(); 4579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return read; 4589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 4619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("IOException from readOneLine"); 4629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e.printStackTrace(); 4639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return read; 4659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Read a chunk of data 4699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Stream from which to read data 4709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param length Amount of data to read 4719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 4729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int readData(InputStream is, int length) { 4749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int read = 0; 4759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int count; 4769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // At the moment we're only expecting small data amounts 4779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project byte[] buf = new byte[length]; 4789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 4809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (is.available() > 0) { 4819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project count = is.read(buf, read, length-read); 4829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project read += count; 4839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (IOException e) { 4859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("IOException from readData"); 4869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project e.printStackTrace(); 4879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return read; 4899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 4909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 4919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 4929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Read the status line from the input stream extracting method 4939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * information. 4949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Inputstream to read 4959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 4969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 4979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int parseStatusLine(InputStream is) { 4989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int index; 4999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int nread = 0; 5009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Parse status line"); 5029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Check for status line first 5039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread = readOneLine(is); 5049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Bomb out if stream closes prematurely 5059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (nread == -1) { 5069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = UNKNOWN_METHOD; 5079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 5089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (buf[0] == (byte)'G' && 5119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[1] == (byte)'E' && 5129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[2] == (byte)'T' && 5139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[3] == (byte)' ') { 5149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = GET_METHOD; 5159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("GET request"); 5169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project index = 4; 5179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (buf[0] == (byte)'H' && 5189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[1] == (byte)'E' && 5199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[2] == (byte)'A' && 5209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[3] == (byte)'D' && 5219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[4] == (byte)' ') { 5229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = HEAD_METHOD; 5239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("HEAD request"); 5249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project index = 5; 5259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (buf[0] == (byte)'P' && 5269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[1] == (byte)'O' && 5279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[2] == (byte)'S' && 5289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[3] == (byte)'T' && 5299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project buf[4] == (byte)' ') { 5309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = POST_METHOD; 5319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("POST request"); 5329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project index = 5; 5339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 5349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Unhandled request 5359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = UNKNOWN_METHOD; 5369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 5379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // A valid method we understand 5409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (requestMethod > UNKNOWN_METHOD) { 5419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Read file name 5429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int i = index; 5439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (buf[i] != (byte)' ') { 5449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // There should be HTTP/1.x at the end 5459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ((buf[i] == (byte)'\n') || (buf[i] == (byte)'\r')) { 5469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = UNKNOWN_METHOD; 5479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 5489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project i++; 5509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project testID = new String(buf, 0, index, i-index); 5539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (testID.startsWith("/")) { 5549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project testID = testID.substring(1); 5559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return nread; 5589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 5609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 5639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Read a header from the input stream 5649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Inputstream to read 5659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 5669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 5679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int parseHeader(InputStream is) { 5689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int index = 0; 5699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int nread = 0; 5709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Parse a header"); 5719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Check for status line first 5729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread = readOneLine(is); 5739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Bomb out if stream closes prematurely 5749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (nread == -1) { 5759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project requestMethod = UNKNOWN_METHOD; 5769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 5779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Read header entry 'Header: data' 5799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int i = index; 5809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (buf[i] != (byte)':') { 5819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // There should be an entry after the header 5829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ((buf[i] == (byte)'\n') || (buf[i] == (byte)'\r')) { 5849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return UNKNOWN_METHOD; 5859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project i++; 5879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String headerName = new String(buf, 0, i); 5909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project i++; // Over ':' 5919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (buf[i] == ' ') { 5929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project i++; 5939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String headerValue = new String(buf, i, nread-1); 5959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 5969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project headers.put(headerName, headerValue); 5979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return nread; 5989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 5999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 6019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Read all headers from the input stream 6029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Inputstream to read 6039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 6049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int readHeaders(InputStream is) { 6069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int nread = 0; 6079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Read headers"); 6089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Headers should be terminated by empty CRLF line 6099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project while (true) { 6109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int headerLen = 0; 6119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project headerLen = parseHeader(is); 6129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (headerLen == -1) 6139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return -1; 6149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread += headerLen; 6159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (headerLen <= 2) { 6169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return nread; 6179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 6229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Read content data from the input stream 6239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param is Inputstream to read 6249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return number of bytes read 6259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int readContent(InputStream is) { 6279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int nread = 0; 6289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Read content"); 6299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project String lengthString = headers.get(requestHeaders[REQ_CONTENT_LENGTH]); 6309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int length = new Integer(lengthString).intValue(); 6319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Read content 6339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project length = readData(is, length); 6349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return length; 6359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 6389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * The main loop, reading requests. 6399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void handleClient() throws IOException { 6419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project InputStream is = new BufferedInputStream(s.getInputStream()); 6429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project PrintStream ps = new PrintStream(s.getOutputStream()); 6439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int nread = 0; 6449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* we will only block in read for this many milliseconds 6469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * before we fail with java.io.InterruptedIOException, 6479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * at which point we will abandon the connection. 6489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 6499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s.setSoTimeout(mTimeout); 6509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s.setTcpNoDelay(true); 6519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project do { 6539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread = parseStatusLine(is); 6549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (requestMethod != UNKNOWN_METHOD) { 6559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // If status line found, read any headers 6579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread = readHeaders(is); 6589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Then read content (if any) 6609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // TODO handle chunked encoding from the client 6619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (headers.get(requestHeaders[REQ_CONTENT_LENGTH]) != null) { 6629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project nread = readContent(is); 6639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 6659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (nread > 0) { 6669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /* we don't support this method */ 6679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.print(HTTP_VERSION_STRING + " " + HTTP_BAD_METHOD + 6689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project " unsupported method type: "); 6699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.write(buf, 0, 5); 6709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.write(EOL); 6719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.flush(); 6729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 6739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!keepAlive || nread <= 0) { 6759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project headers.clear(); 6769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project readStarted = false; 6779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("SOCKET CLOSED"); 6799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s.close(); 6809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 6819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 6839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Reset test number prior to outputing data 6859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project testNum = -1; 6869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Write out the data 6889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project printStatus(ps); 6899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project printHeaders(ps); 6909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Write line between headers and body 6929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 6939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 6949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Write the body 6959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (redirectCode == -1) { 6969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project switch (requestMethod) { 6979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case GET_METHOD: 6989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ((testNum < 0) || (testNum > TestWebData.tests.length - 1)) { 6999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project send404(ps); 7009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 7019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project sendFile(ps); 7029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case HEAD_METHOD: 7059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Nothing to do 7069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case POST_METHOD: 7089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Post method write body data 7099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ((testNum > 0) || (testNum < TestWebData.tests.length - 1)) { 7109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project sendFile(ps); 7119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project default: 7159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { // Redirecting 7189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project switch (redirectCode) { 7199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case 301: 7209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Seems 301 needs a body by neon (although spec 7219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // says SHOULD). 7229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, TestWebData.testServerResponse[TestWebData.REDIRECT_301]); 7239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case 302: 7259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // 7269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, TestWebData.testServerResponse[TestWebData.REDIRECT_302]); 7279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case 303: 7299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, TestWebData.testServerResponse[TestWebData.REDIRECT_303]); 7309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project case 307: 7329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, TestWebData.testServerResponse[TestWebData.REDIRECT_307]); 7339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project default: 7359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project break; 7369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.flush(); 7409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Reset for next request 7429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project readStarted = false; 7439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project headers.clear(); 7449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } while (keepAlive); 7469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("SOCKET CLOSED"); 7489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project s.close(); 7499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Print string to log and output stream 7529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void psPrint(PrintStream ps, String s) throws IOException { 7539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log(s); 7549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.print(s); 7559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Print bytes to log and output stream 7589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void psWrite(PrintStream ps, byte[] bytes, int len) throws IOException { 7599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log(new String(bytes)); 7609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.write(bytes, 0, len); 7619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Print CRLF to log and output stream 7649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void psWriteEOL(PrintStream ps) throws IOException { 7659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("CRLF"); 7669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.write(EOL); 7679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Print status to log and output stream 7719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void printStatus(PrintStream ps) throws IOException { 7729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Handle redirects first. 7739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (redirectCode != -1) { 7749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("REDIRECTING TO "+redirectHost+" status "+redirectCode); 7759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, HTTP_VERSION_STRING + " " + redirectCode +" Moved permanently"); 7769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 7779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Location: " + redirectHost); 7789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 7799066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return; 7809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (testID.startsWith("test")) { 7849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project testNum = Integer.valueOf(testID.substring(4))-1; 7859066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7869066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if ((testNum < 0) || (testNum > TestWebData.tests.length - 1)) { 7889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, HTTP_VERSION_STRING + " " + HTTP_NOT_FOUND + " not found"); 7899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 7909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 7919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, HTTP_VERSION_STRING + " " + HTTP_OK+" OK"); 7929066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 7939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 7959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Status sent"); 7969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 7979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 7989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Create the server response and output to the stream 7999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param ps The PrintStream to output response headers and data to 8009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 8019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void printHeaders(PrintStream ps) throws IOException { 8029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps,"Server: TestWebServer"+mPort); 8039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Date: " + (new Date())); 8059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Connection: " + ((keepAlive) ? "Keep-Alive" : "Close")); 8079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Yuk, if we're not redirecting, we add the file details 8109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (redirectCode == -1) { 8119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (!TestWebData.testParams[testNum].testDir) { 8139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (chunked) { 8149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Transfer-Encoding: chunked"); 8159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Content-length: "+TestWebData.testParams[testNum].testLength); 8179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8209066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps,"Last Modified: " + (new 8219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Date(TestWebData.testParams[testNum].testLastModified))); 8229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8249066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Content-type: " + TestWebData.testParams[testNum].testType); 8259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Content-type: text/html"); 8289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8319066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Content-length of 301, 302, 303, 307 are the same. 8329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "Content-length: "+(TestWebData.testServerResponse[TestWebData.REDIRECT_301]).length()); 8339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project log("Headers sent"); 8379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8389066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8399066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 8419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Sends the 404 not found message 8429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param ps The PrintStream to write to 8439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 8449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void send404(PrintStream ps) throws IOException { 8459066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project ps.println("Not Found\n\n"+ 8469066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project "The requested resource was not found.\n"); 8479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8489066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 8499066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 8509066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Sends the data associated with the headers 8519066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @param ps The PrintStream to write to 8529066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 8539066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project void sendFile(PrintStream ps) throws IOException { 8549066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // For now just make a chunk with the whole of the test data 8559066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // It might be worth making this multiple chunks for large 8569066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // test data to test multiple chunks. 8579066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project int dataSize = TestWebData.tests[testNum].length; 8589066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (chunked) { 8599066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, Integer.toHexString(dataSize)); 8609066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8619066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWrite(ps, TestWebData.tests[testNum], dataSize); 8629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psPrint(ps, "0"); 8649066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWriteEOL(ps); 8669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 8679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project psWrite(ps, TestWebData.tests[testNum], dataSize); 8689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 8719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 872