connectors/webapp/lib/wa_request.c - tomcat55 - Git at Google

 /*
  *  Copyright 1999-2004 The Apache Software Foundation
  *
  *  Licensed under the Apache License, Version 2.0 (the "License");
  *  you may not use this file except in compliance with the License.
  *  You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  *  Unless required by applicable law or agreed to in writing, software
  *  distributed under the License is distributed on an "AS IS" BASIS,
  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */

 /* @version $Id$ */
 #include <wa.h>

 /* Allocate a new request structure. */
 const char *wa_ralloc(wa_request **r, wa_handler *h, void *d) {
     apr_pool_t *pool=NULL;
     wa_request *req=NULL;

     if(apr_pool_create(&pool,wa_pool)!=APR_SUCCESS)
         return("Cannot create request memory pool");
     if((req=apr_palloc(pool,sizeof(wa_request)))==NULL) {
         apr_pool_destroy(pool);
         return("Cannot allocate memory for the request structure");
     }

     if (h==NULL) return("Invalid request handler specified");

     /* Set up the server host data record */
     if((req->serv=apr_palloc(pool,sizeof(wa_hostdata)))==NULL) {
         apr_pool_destroy(pool);
         return("Cannot allocate memory for server host data structure");
     } else {
         req->serv->host=NULL;
         req->serv->addr=NULL;
         req->serv->port=-1;
     }

     /* Set up the server host data record */
     if((req->clnt=apr_palloc(pool,sizeof(wa_hostdata)))==NULL) {
         apr_pool_destroy(pool);
         return("Cannot allocate memory for client host data structure");
     } else {
         req->clnt->host=NULL;
         req->clnt->addr=NULL;
         req->clnt->port=-1;
     }

     /* Set up the headers table */
     req->hdrs=apr_table_make(pool,0);

     /* Set up all other request members */
     req->pool=pool;
     req->hand=h;
     req->data=d;
     req->meth=NULL;
     req->ruri=NULL;
     req->args=NULL;
     req->prot=NULL;
     req->schm=NULL;
     req->user=NULL;
     req->auth=NULL;
     req->ssld=NULL;
     req->clen=0;
     req->ctyp="\0";
     req->rlen=0;

     /* All done */
     *r=req;
     return(NULL);
 }

 /* Clean up and free the memory used by a request structure. */
 const char *wa_rfree(wa_request *r) {
     if (r==NULL) return("Invalid request member");
     apr_pool_destroy(r->pool);
     return(NULL);
 }


 /* Dump headers for wa_rerror */
 static int headers(void *d, const char *key, const char *val) {
     wa_request *r=(wa_request *)d;

     wa_rprintf(r,"   <dd>%s: %s</dd>\n",key,val);
     return(TRUE);
 }

 /* Dump an error response */
 int wa_rerror(const char *file, const int line, wa_request *r, int s,
               const char *fmt, ...) {
     va_list ap;
     char buf[1024];

     va_start(ap,fmt);
     apr_vsnprintf(buf,1024,fmt,ap);
     va_end(ap);

     r->hand->log(r,WA_MARK,buf);

     wa_rsetstatus(r,s,NULL);
     wa_rsetctype(r,"text/html");
     wa_rcommit(r);

     wa_rprintf(r,"<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 3.2 Final//EN\">");
     wa_rprintf(r,"\n\n");
     wa_rprintf(r,"<html>\n");
     wa_rprintf(r," <head>\n");
     wa_rprintf(r,"  <title>WebApp: Error %d (File: %s Line: %d)</title>",s,
                file,line);
     wa_rprintf(r," </head>\n");
     wa_rprintf(r," <body>\n");
     wa_rprintf(r,"  <div align=\"center\">\n");
     wa_rprintf(r,"    <h1>WebApp: Error %d</h1>\n",s);
     wa_rprintf(r,"    <i>(File: %s Line: %d)</i>\n",file,line);
     wa_rprintf(r,"  </div>\n");
     wa_rprintf(r,"  <hr>\n");
     wa_rprintf(r,"  %s\n",buf);
     wa_rprintf(r,"  <hr>\n");
 #ifdef DEBUG
     wa_rprintf(r,"  <dl>\n");
     wa_rprintf(r,"   <dt>Your Request:</dt>\n");
     wa_rprintf(r,"   <dd>Server Host: \"%s\"</dd>\n",r->serv->host);
     wa_rprintf(r,"   <dd>Server Address: \"%s\"</dd>\n",r->serv->addr);
     wa_rprintf(r,"   <dd>Server Port: \"%d\"</dd>\n",r->serv->port);
     wa_rprintf(r,"   <dd>Client Host: \"%s\"</dd>\n",r->clnt->host);
     wa_rprintf(r,"   <dd>Client Address: \"%s\"</dd>\n",r->clnt->addr);
     wa_rprintf(r,"   <dd>Client Port: \"%d\"</dd>\n",r->clnt->port);
     wa_rprintf(r,"   <dd>Request Method: \"%s\"</dd>\n",r->meth);
     wa_rprintf(r,"   <dd>Request URI: \"%s\"</dd>\n",r->ruri);
     wa_rprintf(r,"   <dd>Request Arguments: \"%s\"</dd>\n",r->args);
     wa_rprintf(r,"   <dd>Request Protocol: \"%s\"</dd>\n",r->prot);
     wa_rprintf(r,"   <dd>Request Scheme: \"%s\"</dd>\n",r->schm);
     wa_rprintf(r,"   <dd>Request User: \"%s\"</dd>\n",r->user);
     wa_rprintf(r,"   <dd>Request Authentication Mech.: \"%s\"</dd>\n",r->auth);
     wa_rprintf(r,"   <dd>Request Content-Length: \"%d\"</dd>\n",r->clen);
     wa_rprintf(r,"   <dt>Your Headers:</dt>\n");
     apr_table_do(headers,r,r->hdrs,NULL);
     wa_rprintf(r,"  </dl>\n");
     wa_rprintf(r,"  <hr>\n");
 #endif /* ifdef DEBUG */
     wa_rprintf(r," </body>\n");
     wa_rprintf(r,"</html>\n");
     wa_rflush(r);

     return(s);
 }

 /* Invoke a request in a web application. */
 int wa_rinvoke(wa_request *r, wa_application *a) {
     /*
      * If the application is not yet deployed that could be because
      * Apache was started before Tomcat.
      */
     if (a->depl!=wa_true) {
         wa_log(WA_MARK, "Re-Trying to deploy connections");
         wa_startup();
         if (a->depl!=wa_true)
             return(wa_rerror(WA_MARK,r,404,"Web-application not yet deployed"));
     }
     return(a->conn->prov->handle(r,a));
 }

 void wa_rlog(wa_request *r, const char *f, const int l, const char *fmt, ...) {
     va_list ap;
     char buf[1024];

     va_start(ap,fmt);
     apr_vsnprintf(buf,1024,fmt,ap);
     va_end(ap);

     r->hand->log(r,f,l,buf);
 }

 void wa_rsetstatus(wa_request *r, int status, char *message) {
     r->hand->setstatus(r,status,message);
 }

 void wa_rsetctype(wa_request *r, char *type) {
     r->hand->setctype(r,type);
 }

 void wa_rsetheader(wa_request *r, char *name, char *value) {
     r->hand->setheader(r,name,value);
 }

 void wa_rcommit(wa_request *r) {
     r->hand->commit(r);
 }

 void wa_rflush(wa_request *r) {
     r->hand->flush(r);
 }

 int wa_rread(wa_request *r, char *buf, int len) {
     return(r->hand->read(r,buf,len));
 }

 int wa_rwrite(wa_request *r, char *buf, int len) {
     return(r->hand->write(r,buf,len));
 }

 int wa_rprintf(wa_request *r, const char *fmt, ...) {
     va_list ap;
     char buf[1024];
     int ret=0;

     va_start(ap,fmt);
     ret=apr_vsnprintf(buf,1024,fmt,ap);
     va_end(ap);

     return(r->hand->write(r,buf,ret));
 }
	/*
	* Copyright 1999-2004 The Apache Software Foundation
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	/* @version $Id$ */
	#include <wa.h>

	/* Allocate a new request structure. */
	const char wa_ralloc(wa_request r, wa_handler h, void *d) {
	apr_pool_t *pool=NULL;
	wa_request *req=NULL;

	if(apr_pool_create(&pool,wa_pool)!=APR_SUCCESS)
	return("Cannot create request memory pool");
	if((req=apr_palloc(pool,sizeof(wa_request)))==NULL) {
	apr_pool_destroy(pool);
	return("Cannot allocate memory for the request structure");
	}

	if (h==NULL) return("Invalid request handler specified");

	/* Set up the server host data record */
	if((req->serv=apr_palloc(pool,sizeof(wa_hostdata)))==NULL) {
	apr_pool_destroy(pool);
	return("Cannot allocate memory for server host data structure");
	} else {
	req->serv->host=NULL;
	req->serv->addr=NULL;
	req->serv->port=-1;
	}

	/* Set up the server host data record */
	if((req->clnt=apr_palloc(pool,sizeof(wa_hostdata)))==NULL) {
	apr_pool_destroy(pool);
	return("Cannot allocate memory for client host data structure");
	} else {
	req->clnt->host=NULL;
	req->clnt->addr=NULL;
	req->clnt->port=-1;
	}

	/* Set up the headers table */
	req->hdrs=apr_table_make(pool,0);

	/* Set up all other request members */
	req->pool=pool;
	req->hand=h;
	req->data=d;
	req->meth=NULL;
	req->ruri=NULL;
	req->args=NULL;
	req->prot=NULL;
	req->schm=NULL;
	req->user=NULL;
	req->auth=NULL;
	req->ssld=NULL;
	req->clen=0;
	req->ctyp="\0";
	req->rlen=0;

	/* All done */
	*r=req;
	return(NULL);
	}

	/* Clean up and free the memory used by a request structure. */
	const char wa_rfree(wa_request r) {
	if (r==NULL) return("Invalid request member");
	apr_pool_destroy(r->pool);
	return(NULL);
	}


	/* Dump headers for wa_rerror */
	static int headers(void d, const char key, const char *val) {
	wa_request r=(wa_request )d;

	wa_rprintf(r," <dd>%s: %s</dd>\n",key,val);
	return(TRUE);
	}

	/* Dump an error response */
	int wa_rerror(const char file, const int line, wa_request r, int s,
	const char *fmt, ...) {
	va_list ap;
	char buf[1024];

	va_start(ap,fmt);
	apr_vsnprintf(buf,1024,fmt,ap);
	va_end(ap);

	r->hand->log(r,WA_MARK,buf);

	wa_rsetstatus(r,s,NULL);
	wa_rsetctype(r,"text/html");
	wa_rcommit(r);

	wa_rprintf(r,"<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 3.2 Final//EN\">");
	wa_rprintf(r,"\n\n");
	wa_rprintf(r,"<html>\n");
	wa_rprintf(r," <head>\n");
	wa_rprintf(r," <title>WebApp: Error %d (File: %s Line: %d)</title>",s,
	file,line);
	wa_rprintf(r," </head>\n");
	wa_rprintf(r," <body>\n");
	wa_rprintf(r," <div align=\"center\">\n");
	wa_rprintf(r," <h1>WebApp: Error %d</h1>\n",s);
	wa_rprintf(r," <i>(File: %s Line: %d)</i>\n",file,line);
	wa_rprintf(r," </div>\n");
	wa_rprintf(r," <hr>\n");
	wa_rprintf(r," %s\n",buf);
	wa_rprintf(r," <hr>\n");
	#ifdef DEBUG
	wa_rprintf(r," <dl>\n");
	wa_rprintf(r," <dt>Your Request:</dt>\n");
	wa_rprintf(r," <dd>Server Host: \"%s\"</dd>\n",r->serv->host);
	wa_rprintf(r," <dd>Server Address: \"%s\"</dd>\n",r->serv->addr);
	wa_rprintf(r," <dd>Server Port: \"%d\"</dd>\n",r->serv->port);
	wa_rprintf(r," <dd>Client Host: \"%s\"</dd>\n",r->clnt->host);
	wa_rprintf(r," <dd>Client Address: \"%s\"</dd>\n",r->clnt->addr);
	wa_rprintf(r," <dd>Client Port: \"%d\"</dd>\n",r->clnt->port);
	wa_rprintf(r," <dd>Request Method: \"%s\"</dd>\n",r->meth);
	wa_rprintf(r," <dd>Request URI: \"%s\"</dd>\n",r->ruri);
	wa_rprintf(r," <dd>Request Arguments: \"%s\"</dd>\n",r->args);
	wa_rprintf(r," <dd>Request Protocol: \"%s\"</dd>\n",r->prot);
	wa_rprintf(r," <dd>Request Scheme: \"%s\"</dd>\n",r->schm);
	wa_rprintf(r," <dd>Request User: \"%s\"</dd>\n",r->user);
	wa_rprintf(r," <dd>Request Authentication Mech.: \"%s\"</dd>\n",r->auth);
	wa_rprintf(r," <dd>Request Content-Length: \"%d\"</dd>\n",r->clen);
	wa_rprintf(r," <dt>Your Headers:</dt>\n");
	apr_table_do(headers,r,r->hdrs,NULL);
	wa_rprintf(r," </dl>\n");
	wa_rprintf(r," <hr>\n");
	#endif /* ifdef DEBUG */
	wa_rprintf(r," </body>\n");
	wa_rprintf(r,"</html>\n");
	wa_rflush(r);

	return(s);
	}

	/* Invoke a request in a web application. */
	int wa_rinvoke(wa_request r, wa_application a) {
	/*
	* If the application is not yet deployed that could be because
	* Apache was started before Tomcat.
	*/
	if (a->depl!=wa_true) {
	wa_log(WA_MARK, "Re-Trying to deploy connections");
	wa_startup();
	if (a->depl!=wa_true)
	return(wa_rerror(WA_MARK,r,404,"Web-application not yet deployed"));
	}
	return(a->conn->prov->handle(r,a));
	}

	void wa_rlog(wa_request r, const char f, const int l, const char *fmt, ...) {
	va_list ap;
	char buf[1024];

	va_start(ap,fmt);
	apr_vsnprintf(buf,1024,fmt,ap);
	va_end(ap);

	r->hand->log(r,f,l,buf);
	}

	void wa_rsetstatus(wa_request r, int status, char message) {
	r->hand->setstatus(r,status,message);
	}

	void wa_rsetctype(wa_request r, char type) {
	r->hand->setctype(r,type);
	}

	void wa_rsetheader(wa_request r, char name, char *value) {
	r->hand->setheader(r,name,value);
	}

	void wa_rcommit(wa_request *r) {
	r->hand->commit(r);
	}

	void wa_rflush(wa_request *r) {
	r->hand->flush(r);
	}

	int wa_rread(wa_request r, char buf, int len) {
	return(r->hand->read(r,buf,len));
	}

	int wa_rwrite(wa_request r, char buf, int len) {
	return(r->hand->write(r,buf,len));
	}

	int wa_rprintf(wa_request r, const char fmt, ...) {
	va_list ap;
	char buf[1024];
	int ret=0;

	va_start(ap,fmt);
	ret=apr_vsnprintf(buf,1024,fmt,ap);
	va_end(ap);

	return(r->hand->write(r,buf,ret));
	}