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