/*
** Rachel  - Resource Loading Toolkit for Web Start/JNLP
** Copyright (c) 2001, 2002 by Gerald Bauer
**
** This program is free software.
**
** You may redistribute it and/or modify it under the terms of the GNU
** General Public License as published by the Free Software Foundation.
** Version 2 of the license should be included with this distribution in
** the file LICENSE, as well as License.html. If the license is not
** included with this distribution, you may find a copy at the FSF web
** site at 'www.gnu.org' or 'www.fsf.org', or you may write to the
** Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139 USA.
**
** THIS SOFTWARE IS PROVIDED AS-IS WITHOUT WARRANTY OF ANY KIND,
** NOT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY. THE AUTHOR
** OF THIS SOFTWARE, ASSUMES _NO_ RESPONSIBILITY FOR ANY
** CONSEQUENCE RESULTING FROM THE USE, MODIFICATION, OR
** REDISTRIBUTION OF THIS SOFTWARE.
**
*/

package rachel.http;

import java.io.*;
import java.net.*;
import java.util.*;
import houston.*;
import rachel.http.loader.*;
import rachel.util.*;

public class WebServer extends Thread
{
   static Logger T = Logger.getLogger( WebServer.class );
   private WebResourceLoader _loader;
   private int _numThreads = 10;

   private ServerSocket _server;

   public WebServer( int port, WebResourceLoader loader )
          throws IOException
   {
      _loader = loader;
      _server = new ServerSocket( port );

      setPriority( 4 );
      setDaemon( true );
   }

   public void run()
   {
      ThreadGroup tg = new ThreadGroup( "http" );

      for( int i = 0; i < _numThreads; i++ )
      {
         Thread t = new Thread( tg, new RequestProcessor( _loader ), "http-" + ( i + 1 ) );

         t.setPriority( 4 );
         t.setDaemon( true );
         t.start();
      }

      T.debug( "accepting connections on port " + _server.getLocalPort() );

      while( true )
      {
         try
         {
            Socket request = _server.accept();
            RequestProcessor.processRequest( request );
         }
         catch( IOException ioex )
         {
            Status.error( ioex.toString() );
         }
      }
   }
}