1   /*
2    * $Header: /home/jerenkrantz/tmp/commons/commons-convert/cvs/home/cvs/jakarta-commons//httpclient/src/test/org/apache/commons/httpclient/server/SimpleConnectionThread.java,v 1.3 2004/11/13 22:38:27 mbecke Exp $
3    * $Revision: 224451 $
4    * $Date: 2005-07-23 06:23:59 -0400 (Sat, 23 Jul 2005) $
5    *
6    * ====================================================================
7    *
8    *  Copyright 1999-2004 The Apache Software Foundation
9    *
10   *  Licensed under the Apache License, Version 2.0 (the "License");
11   *  you may not use this file except in compliance with the License.
12   *  You may obtain a copy of the License at
13   *
14   *      http://www.apache.org/licenses/LICENSE-2.0
15   *
16   *  Unless required by applicable law or agreed to in writing, software
17   *  distributed under the License is distributed on an "AS IS" BASIS,
18   *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
19   *  See the License for the specific language governing permissions and
20   *  limitations under the License.
21   * ====================================================================
22   *
23   * This software consists of voluntary contributions made by many
24   * individuals on behalf of the Apache Software Foundation.  For more
25   * information on the Apache Software Foundation, please see
26   * <http://www.apache.org/>.
27   *
28   */
29  
30  package org.apache.commons.httpclient.server;
31  
32  import java.io.IOException;
33  import java.io.InterruptedIOException;
34  
35  import org.apache.commons.logging.Log;
36  import org.apache.commons.logging.LogFactory;
37  
38  /***
39   * Simple HTTP connection thread.
40   * 
41   * @author Christian Kohlschuetter
42   * @author Oleg Kalnichevski
43   */
44  public class SimpleConnectionThread extends Thread {
45  
46      private static final Log LOG = LogFactory.getLog(SimpleConnectionThread.class);
47      
48      public static final String DEFAULT_CONTENT_CHARSET = "ISO-8859-1";
49  
50      private SimpleHttpServerConnection conn = null;
51      private SimpleConnSet connpool = null;    
52      private HttpRequestHandler handler = null;
53      transient boolean stopped; 
54  
55      public SimpleConnectionThread(
56              final ThreadGroup tg,
57              final String name,
58              final SimpleHttpServerConnection conn,
59              final SimpleConnSet connpool,
60              final HttpRequestHandler handler) 
61      throws IOException {
62          super(tg, name);
63          if (conn == null) {
64              throw new IllegalArgumentException("Connection may not be null");
65          }
66          if (connpool == null) {
67              throw new IllegalArgumentException("Connection pool not be null");
68          }
69          if (handler == null) {
70              throw new IllegalArgumentException("Request handler may not be null");
71          }
72          this.conn = conn;
73          this.connpool = connpool;
74          this.handler = handler;
75          this.stopped = false; 
76      }
77  
78      public synchronized void destroy() {
79          if (this.stopped) {
80              return;
81          }
82          this.stopped = true; 
83          if (conn != null) {
84              conn.close();
85              conn = null;
86          }
87          interrupt();
88      }
89  
90      public void run() {
91          try {
92              do {
93                  this.conn.setKeepAlive(false);
94                  SimpleRequest request = this.conn.readRequest();
95                  if (request != null) {
96                      this.handler.processRequest(this.conn, request);
97                  }
98              } while (this.conn.isKeepAlive());
99          } catch (InterruptedIOException e) {
100         } catch (IOException e) {
101             if (!this.stopped && !isInterrupted() && LOG.isWarnEnabled()) {
102                 LOG.warn("[" + getName() + "] I/O error: " + e.getMessage());
103             }
104         } finally {
105             destroy();
106             this.connpool.removeConnection(this.conn);
107         }
108     }
109 
110 }
111