costin      2003/01/20 15:47:05

  Modified:    http11/src/java/org/apache/coyote/http11
                        Http11Processor.java Http11Protocol.java
  Log:
  Update for RequestInfo and new group info.
  
  Revision  Changes    Path
  1.57      +1 -0      
jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Processor.java
  
  Index: Http11Processor.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Processor.java,v
  retrieving revision 1.56
  retrieving revision 1.57
  diff -u -r1.56 -r1.57
  --- Http11Processor.java      16 Jan 2003 22:29:51 -0000      1.56
  +++ Http11Processor.java      20 Jan 2003 23:47:05 -0000      1.57
  @@ -577,6 +577,7 @@
   
           while (started && !error && keepAlive) {
               try {
  +                request.setStartTime(System.currentTimeMillis());
                   if( !disableUploadTimeout && keptAlive && soTimeout > 0 ) {
                       socket.setSoTimeout(soTimeout);
                   }
  
  
  
  1.20      +9 -1      
jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Protocol.java
  
  Index: Http11Protocol.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Protocol.java,v
  retrieving revision 1.19
  retrieving revision 1.20
  diff -u -r1.19 -r1.20
  --- Http11Protocol.java       16 Jan 2003 22:29:51 -0000      1.19
  +++ Http11Protocol.java       20 Jan 2003 23:47:05 -0000      1.20
  @@ -349,6 +349,7 @@
       static class Http11ConnectionHandler implements TcpConnectionHandler {
           Http11Protocol proto;
           static int count=0;
  +        RequestGroupInfo global=null;
   
           Http11ConnectionHandler( Http11Protocol proto ) {
               this.proto=proto;
  @@ -381,7 +382,14 @@
   
               if( proto.getDomain() != null ) {
                   try {
  -                    RequestProcessor rp=new 
RequestProcessor(processor.getRequest());
  +                    if( global==null ) {
  +                        global=new RequestGroupInfo();
  +                        Registry.getRegistry().registerComponent( global,
  +                                proto.getDomain(), "GlobalRequestProcessor",
  +                                "type=GlobalRequestProcessor,name=http");
  +                    }
  +                    RequestInfo rp=processor.getRequest().getRequestProcessor();
  +                    rp.setGlobalProcessor(global);
                       Registry.getRegistry().registerComponent( rp,
                               proto.getDomain(), "RequestProcessor",
                               "type=RequestProcessor,name=HttpRequest" + count++ );
  
  
  

--
To unsubscribe, e-mail:   <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>

Reply via email to