cvs commit: jakarta-tomcat/src/share/org/apache/tomcat/modules/server Ajp12Interceptor.java

[nacho]

nacho       00/11/19 07:54:29

  Modified:    src/share/org/apache/tomcat/modules/server
                        Ajp12Interceptor.java
  Log:
  Need to recycle the internal http10 of AJP12Response
  
  Revision  Changes    Path
  1.5       +9 -3      
jakarta-tomcat/src/share/org/apache/tomcat/modules/server/Ajp12Interceptor.java
  
  Index: Ajp12Interceptor.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat/src/share/org/apache/tomcat/modules/server/Ajp12Interceptor.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- Ajp12Interceptor.java     2000/09/29 21:09:46     1.4
  +++ Ajp12Interceptor.java     2000/11/19 15:54:29     1.5
  @@ -119,7 +119,7 @@
   
            AJP12Request reqA=null;
            AJP12Response resA=null;
  -         
  +
            if( thData != null ) {
                reqA=(AJP12Request)thData[0];
                resA=(AJP12Response)thData[1];
  @@ -163,7 +163,7 @@
       public void readNextRequest() throws IOException {
        ajp12.readNextRequest( this );
       }
  -    
  +
       public void setSocket( Socket s ) throws IOException {
        ajp12.setSocket( s );
       }
  @@ -175,6 +175,7 @@
       public  int doRead( byte b[], int off, int len ) throws IOException {
        return ajp12.doRead( b,off,len);
       }
  +
   }
   
   
  @@ -182,10 +183,15 @@
   class AJP12Response extends Response {
       Http10 http=new Http10();
   
  +    public void recycle() {
  +        super.recycle();
  +        http.recycle();
  +    }
  +
       public void setSocket( Socket s ) throws IOException {
        http.setSocket( s );
       }
  -    
  +
       public void endHeaders()  throws IOException {
        super.endHeaders();
        sendStatus( status, RequestUtil.getMessage( status ));