Mailing-List: contact tomcat-dev-help@jakarta.apache.org; run by ezmlm
Precedence: bulk
Reply-To: tomcat-dev@jakarta.apache.org
Date: 13 Jul 2001 02:19:48 -0000
Message-ID: <20010713021948.35112.qmail@apache.org>
From: pier@apache.org
To: jakarta-tomcat-connectors-cvs@apache.org
Subject: cvs commit: jakarta-tomcat-connectors/webapp/lib pr_warp.c

pier        01/07/12 19:19:48

  Modified:    webapp/lib pr_warp.c
  Log:
  Reenabling connection handling.
  
  Revision  Changes    Path
  1.5       +15 -1     jakarta-tomcat-connectors/webapp/lib/pr_warp.c
  
  Index: pr_warp.c
  ===================================================================
  RCS file: /home/cvs/jakarta-tomcat-connectors/webapp/lib/pr_warp.c,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- pr_warp.c	2001/07/09 22:11:21	1.4
  +++ pr_warp.c	2001/07/13 02:19:44	1.5
  @@ -55,7 +55,7 @@
    *                                                                           *
    * ========================================================================= */
   
  -/* @version $Id: pr_warp.c,v 1.4 2001/07/09 22:11:21 pier Exp $ */
  +/* @version $Id: pr_warp.c,v 1.5 2001/07/13 02:19:44 pier Exp $ */
   #include <wa.h>
   
   /* ************************************************************************* */
  @@ -154,6 +154,19 @@
   
   /* Notify this provider of its imminent startup. */
   static void warp_startup(void) {
  +    wa_chain *elem=warp_connections;
  +    wa_boolean ret=FALSE;
  +
  +    /* Open all connections having deployed applications */
  +    while (elem!=NULL) {
  +        wa_connection *curr=(wa_connection *)elem->curr;
  +        wa_debug(WA_MARK,"Opening connection \"%s\"",curr->name);
  +        if (n_connect(curr)==TRUE) {
  +            wa_debug(WA_MARK,"Connection \"%s\" opened",curr->name);
  +        } else wa_log(WA_MARK,"Cannot open connection \"%s\"",curr->name);
  +        elem=elem->next;
  +    }
  +
       wa_debug(WA_MARK,"WARP provider started");
   }
   
  @@ -189,6 +202,7 @@
   
       /* Done */
       conf->sock=NULL;
  +    conf->disc=TRUE;
       conn->conf=conf;
       return(NULL);
   }