hgomez      2004/03/01 01:35:26

  Modified:    jk/native2/common jk_worker_ajp13.c
  Log:
  Tab policies
  
  Revision  Changes    Path
  1.61      +38 -38    jakarta-tomcat-connectors/jk/native2/common/jk_worker_ajp13.c
  
  Index: jk_worker_ajp13.c
  ===================================================================
  RCS file: /home/cvs/jakarta-tomcat-connectors/jk/native2/common/jk_worker_ajp13.c,v
  retrieving revision 1.60
  retrieving revision 1.61
  diff -u -r1.60 -r1.61
  --- jk_worker_ajp13.c 27 Feb 2004 09:07:23 -0000      1.60
  +++ jk_worker_ajp13.c 1 Mar 2004 09:35:26 -0000       1.61
  @@ -416,55 +416,55 @@
               /* If we have the service recovery buffer FILLED and we're in first 
attempt */
               /* recopy the recovery buffer in post instead of reading it from client 
*/
               if ( s->reco_status == RECO_FILLED && (attempt==0) ) {
  -                     /* Get in post buf the previously saved POST */
  -                     
  -                     if (s->reco_buf->copy(env, s->reco_buf, e->post) < 0) {
  -                             s->is_recoverable_error = JK_FALSE;
  -                             env->l->jkLog(env, env->l, JK_LOG_ERROR,
  -                                           "ajp13.service() can't use the LB 
recovery buffer, aborting\n");
  -                     return JK_ERR;
  -                     }                       
  +                /* Get in post buf the previously saved POST */
  +                
  +                if (s->reco_buf->copy(env, s->reco_buf, e->post) < 0) {
  +                        s->is_recoverable_error = JK_FALSE;
  +                        env->l->jkLog(env, env->l, JK_LOG_ERROR,
  +                                      "ajp13.service() can't use the LB recovery 
buffer, aborting\n");
  +                    return JK_ERR;
  +                }               
   
                   env->l->jkLog(env, env->l, JK_LOG_DEBUG,
                                 "ajp13.service() using the LB recovery buffer\n");
               }
               else
               {
  -                 if( attempt==0 )
  -                     err=jk2_serialize_postHead( env, e->post, s, e );
  -                 else
  -                     err=JK_OK; /* We already have the initial body chunk */
  -                 
  -                 if( e->worker->mbean->debug > 10 )
  -                     e->request->dump( env, e->request, "Post head" );
  -                 
  -                 if (err != JK_OK ) {
  -                     /* the browser stop sending data, no need to recover */
  -                     /* e->recoverable = JK_FALSE; */
  -                     s->is_recoverable_error = JK_FALSE;
  -                     env->l->jkLog(env, env->l, JK_LOG_ERROR,
  -                                   "ajp13.service() Error receiving initial post %d 
%d %d\n", err, errno, attempt);
  +                if( attempt==0 )
  +                    err=jk2_serialize_postHead( env, e->post, s, e );
  +                else
  +                    err=JK_OK; /* We already have the initial body chunk */
  +                
  +                if( e->worker->mbean->debug > 10 )
  +                    e->request->dump( env, e->request, "Post head" );
  +                
  +                if (err != JK_OK ) {
  +                    /* the browser stop sending data, no need to recover */
  +                    /* e->recoverable = JK_FALSE; */
  +                    s->is_recoverable_error = JK_FALSE;
  +                    env->l->jkLog(env, env->l, JK_LOG_ERROR,
  +                                  "ajp13.service() Error receiving initial post %d 
%d %d\n", err, errno, attempt);
   
                       /* BR #27281 : Should we return HTTP 500 since its the user who 
stop the sending ? */
                       /* may be not, so return another HTTP code -> use PARTIAL 
CONTENT, 206 instead */
                       s->status = 206;
  -                     return JK_ERR;
  -                 }
  +                    return JK_ERR;
  +                }
   
  -                             /* If a recovery buffer exist (LB mode), save here the 
post buf */
  -                             if (s->reco_status == RECO_INITED) {
  -                             /* Save the post for recovery if needed */
  -                             if (e->post->copy(env, e->post, s->reco_buf) < 0) {
  -                             s->is_recoverable_error = JK_FALSE;
  -                             env->l->jkLog(env, env->l, JK_LOG_ERROR,
  -                                           "ajp13.service() can't save the LB 
recovery buffer, aborting\n");
  -                             return JK_ERR;
  -                             }
  -                             else    
  -                                     s->reco_status = RECO_FILLED;
  -                             }
  -                     }
  -                     
  +                /* If a recovery buffer exist (LB mode), save here the post buf */
  +                if (s->reco_status == RECO_INITED) {
  +                    /* Save the post for recovery if needed */
  +                    if (e->post->copy(env, e->post, s->reco_buf) < 0) {
  +                        s->is_recoverable_error = JK_FALSE;
  +                        env->l->jkLog(env, env->l, JK_LOG_ERROR,
  +                                      "ajp13.service() can't save the LB recovery 
buffer, aborting\n");
  +                        return JK_ERR;
  +                    }
  +                    else    
  +                        s->reco_status = RECO_FILLED;
  +                }
  +            }
  +            
               has_post_body=JK_TRUE;
               err= e->worker->channel->send( env, e->worker->channel, e,
                                              e->post );
  
  
  

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

Reply via email to