cvs commit: jakarta-tomcat-connectors/ajp/proxy proxy_util.c

[mturk]

mturk       2004/08/05 09:26:02

  Modified:    ajp/proxy proxy_util.c
  Log:
  Change the way the prefork connection is created.
  Use the same constructor as for theaded mpm's.
  Added API's for destroying and closing connections
  
  Revision  Changes    Path
  1.14      +48 -14    jakarta-tomcat-connectors/ajp/proxy/proxy_util.c
  
  Index: proxy_util.c
  ===================================================================
  RCS file: /home/cvs/jakarta-tomcat-connectors/ajp/proxy/proxy_util.c,v
  retrieving revision 1.13
  retrieving revision 1.14
  diff -u -r1.13 -r1.14
  --- proxy_util.c      5 Aug 2004 14:41:10 -0000       1.13
  +++ proxy_util.c      5 Aug 2004 16:26:02 -0000       1.14
  @@ -1358,12 +1358,30 @@
       server_rec *s = (server_rec *)params;
       
       apr_pool_destroy(conn->pool);
  -    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s,
  -                 "proxy: socket is destructed");
  +    if (s != NULL)
  +        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s,
  +                     "proxy: socket is destructed");
   
       return APR_SUCCESS;
   }
   
  +/* Destroy the connection */
  +PROXY_DECLARE(apr_status_t) ap_proxy_destroy_connection(proxy_conn_rec *conn)
  +{
  +    return connection_destructor(conn, NULL, NULL);
  +}
  +
  +/* Destroy the connection */
  +PROXY_DECLARE(apr_status_t) ap_proxy_close_connection(proxy_conn_rec *conn)
  +{
  +    apr_status_t rv = APR_EOF;
  +    /* Close the socket */
  +    if (conn->sock)
  +        rv = apr_socket_close(conn->sock);
  +    conn->sock = NULL;
  +    return rv;
  +}
  +
   /* low level connection acquire/release functions
    * they are hiding apr_reslist for nothreaded or prefork servers.
    */
  @@ -1378,6 +1396,7 @@
   #endif
       {
           *conn = worker->cp->conn;
  +        worker->cp->conn = NULL;
           rv = APR_SUCCESS;
       }
       return rv;
  @@ -1390,7 +1409,11 @@
       if (worker->hmax) {
           rv = apr_reslist_release(worker->cp->res, (void *)conn);
       }
  +    else
   #endif
  +    {
  +        worker->cp->conn = conn;
  +    }
       return rv;
   }
   
  @@ -1414,18 +1437,8 @@
       else
   #endif
       {
  -        worker->cp->conn = apr_pcalloc(worker->cp->pool, sizeof(proxy_conn_rec));
  -        /* register the pool cleanup.
  -         * The cleanup is registered on conn_pool pool, so that
  -         * the same mechanism (apr_pool_cleanup) can be used
  -         * for both nonthreaded and threaded servers when closing
  -         * the entire worker.
  -         */
  -        apr_pool_cleanup_register(worker->cp->pool, (void *)worker->cp->conn,
  -                                  proxy_conn_cleanup, apr_pool_cleanup_null);      
  -
  -        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s,
  -                     "proxy: socket is created");
  +        
  +        connection_constructor((void **)&(worker->cp->conn), s, worker->cp->pool);
           rv = APR_SUCCESS;
       }
       return rv;
  @@ -1514,4 +1527,25 @@
                                "Connect to remote machine blocked");
       }
       return OK;
  +}
  +
  +static int is_socket_connected(apr_socket_t *sock)
  +
  +{
  +    apr_size_t buffer_len = 1;
  +    char test_buffer[1]; 
  +    apr_status_t socket_status;
  +    apr_interval_time_t current_timeout;
  +
  +    /* save timeout */
  +    apr_socket_timeout_get(sock, &current_timeout);
  +    /* set no timeout */
  +    apr_socket_timeout_set(sock, 0);
  +    socket_status = apr_socket_recv(sock, test_buffer, &buffer_len);
  +    /* put back old timeout */
  +    apr_socket_timeout_set(sock, current_timeout);
  +    if (APR_STATUS_IS_EOF(socket_status))
  +        return 0;
  +    else
  +        return 1;
   }
  
  
  

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