    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: 480424 $
    4    * $Date: 2006-11-29 06:56:49 +0100 (Wed, 29 Nov 2006) $
    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