You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by co...@locus.apache.org on 2000/08/14 22:48:12 UTC
cvs commit: jakarta-tomcat/src/share/org/apache/tomcat/service/http HttpInterceptor.java
costin 00/08/14 13:48:12
Added: src/share/org/apache/tomcat/service/http
HttpInterceptor.java
Log:
First "new" connector.
This simplifies tomcat configuration and will add more power to server adapters ( connectors).
It will remove the ugly setProperty() hack, simplify https config,
remove a lot of complexity from adapters.
Revision Changes Path
1.1 jakarta-tomcat/src/share/org/apache/tomcat/service/http/HttpInterceptor.java
Index: HttpInterceptor.java
===================================================================
/*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.tomcat.service.http;
import org.apache.tomcat.service.*;
import java.io.*;
import java.net.*;
import java.util.*;
import org.apache.tomcat.core.*;
import org.apache.tomcat.util.*;
import org.apache.tomcat.net.*;
import org.apache.tomcat.logging.*;
import javax.servlet.*;
import javax.servlet.http.*;
/** Standalone http.
*
* Connector properties:
* - secure - will load a SSL socket factory and act as https server
*
* Properties passed to the net layer:
* - timeout
* - backlog
* - address
* - port
* Thread pool properties:
* - minSpareThreads
* - maxSpareThreads
* - maxThreads
* - poolOn
* Extra properties:
* - serverSocketFactory ( default simple tcp, shortcut: ssl ). Overrides "secure"
*/
public class HttpInterceptor extends BaseInterceptor implements TcpConnectionHandler {
// Tcp stuff
PoolTcpEndpoint ep;
private ServerSocketFactory socketFactory;
private ServerSocket serverSocket;
// properties
int port;
InetAddress address;
boolean secure=false;
ContextManager contextM;
public HttpInterceptor() {
super();
ep=new PoolTcpEndpoint();
}
// -------------------- Properties --------------------
public void setPort( int port ) {
this.port=port;
}
public int getPort() {
return port;
}
public InetAddress getAddress() {
return address;
}
// -------------------- Tomcat plug in --------------------
// Tcp Endoint start/stop
public void engineInit(ContextManager cm) throws TomcatException {
this.contextM=cm;
ep.setConnectionHandler( this );
try {
ep.setPort( port );
ep.startEndpoint();
log( "Starting on " + port );
} catch( Exception ex ) {
throw new TomcatException( ex );
}
}
public void engineShutdown(ContextManager cm) throws TomcatException {
try {
ep.stopEndpoint();
} catch( Exception ex ) {
throw new TomcatException( ex );
}
}
// -------------------- Attributes --------------------
public void setSecure( boolean b ) {
secure=b;
}
// -------------------- Handler implementation --------------------
public void setServer(Object o) {
//XXX deprecated
}
public void setAttribute(String s, Object o) {
//XXX deprecated
}
public Object[] init() {
Object thData[]=new Object[3];
HttpRequestAdapter reqA=new HttpRequestAdapter();
HttpResponseAdapter resA=new HttpResponseAdapter();
contextM.initRequest( reqA, resA );
thData[0]=reqA;
thData[1]=resA;
thData[2]=null;
return thData;
}
public void processConnection(TcpConnection connection, Object thData[]) {
Socket socket=null;
HttpRequestAdapter reqA=null;
HttpResponseAdapter resA=null;
try {
// XXX - Add workarounds for the fact that the underlying
// serverSocket.accept() call can now time out. This whole
// architecture needs some serious review.
if (connection == null)
return;
socket=connection.getSocket();
if (socket == null)
return;
InputStream in=socket.getInputStream();
OutputStream out=socket.getOutputStream();
if( thData != null ) {
reqA=(HttpRequestAdapter)thData[0];
resA=(HttpResponseAdapter)thData[1];
if( reqA!=null ) reqA.recycle();
if( resA!=null ) resA.recycle();
}
if( reqA==null || resA==null ) {
log("No thread data ??");
reqA=new HttpRequestAdapter();
resA=new HttpResponseAdapter();
contextM.initRequest( reqA, resA );
}
reqA.setSocket( socket );
resA.setOutputStream( out );
reqA.readNextRequest(resA);
if( secure ) {
reqA.setScheme( "https" );
}
contextM.service( reqA, resA );
try {
InputStream is = socket.getInputStream();
int available = is.available ();
// XXX on JDK 1.3 just socket.shutdownInput () which
// was added just to deal with such issues.
// skip any unread (bogus) bytes
if (available > 1) {
is.skip (available);
}
}catch(NullPointerException npe) {
// do nothing - we are just cleaning up, this is
// a workaround for Netscape \n\r in POST - it is supposed
// to be ignored
}
}
catch(java.net.SocketException e) {
// SocketExceptions are normal
log( "SocketException reading request, ignored", null, Logger.INFORMATION);
log( "SocketException reading request:", e, Logger.DEBUG);
}
catch (java.io.IOException e) {
// IOExceptions are normal
log( "IOException reading request, ignored", null, Logger.INFORMATION);
log( "IOException reading request:", e, Logger.DEBUG);
}
// Future developers: if you discover any other
// rare-but-nonfatal exceptions, catch them here, and log as
// above.
catch (Throwable e) {
// any other exception or error is odd. Here we log it
// with "ERROR" level, so it will show up even on
// less-than-verbose logs.
log( "Error reading request, ignored", e, Logger.ERROR);
}
finally {
// recycle kernel sockets ASAP
try { if (socket != null) socket.close (); }
catch (IOException e) { /* ignore */ }
}
}
}