Re: Completely transform a request ( Followup: Example code mod_transform )

Thread: Re: Completely transform a request ( Followup: Example code mod_transform )

Search this list only Search all lists
Re: Completely transform a request ( Followup: Example code mod_transform )
United States	2007-08-22 01:23:20
* HOW TO COMPLETELY TRANSFORM AN INBOUND APACHE REQUEST &nbsp; >Arturo wrote... &gt; >I want to Completely Transform a Request. >100% transformation. > >Based on a certain logic, If an incoming request matches one >of my action triggers, then I want to apply a transformation >to the 100% of the incoming request. I know I can do that when >I just want to modify brigade-by-brigade. But I need to read >the WHOLE request before doing so. Even the METHOD line. >Even the headers. Even the body. All of it. Then, completely >transform that into another request, and have Apache process it. > &gt;With the current input filtering framework, at the connection >level, I should be able to do it. But I can't. >; >If you NEED an example of what I'd like to transform, and into >WHAT i want to transform it, see this post: > >What I'd like to transform: >http://www.mail-archive.com/devhttpd.apache.org/msg37206.html &gt; >Into WHAT I want to transform it: a completely different request >(i.e different method line, different headers and different body, >and I can't do that in stages, I have to read the whole request first). &gt; >Sincerely, > >Arturo "Buanzo" Busleiman - >Consultor Independiente en Seguridad Informatica > > In case you want to take a look, you can check out the filter > function from... &gt; > http://www.buanzo.com.ar/files/openpgp.conn.filter.in.c   I've looked at the code there and you definitely are on the right track. There is nothing fundamentally wrong with your code except, as you discovered, you have to be totally aware of what is actually happening during the input phase or it's easy to trip up and get an "Error reading headers" from inside the ap_get_mime_headers_core() routine. &nbsp; >&gt; Kevin wrote... &gt;> >;> Just to satisfy my own curiosity I worked up >>; a module here that is, in fact, able to do what >> you want. There don't seem to be any fatal flaws >> in the input filtering that would prevent it. > &gt; Arturo responded... > >; Great, Can I take a look? That'd be cool. &nbsp; Sure. Entire filter source code is included below. &nbsp; The following "mod_transform.c" filter does EXACTLY what you are trying to do.   It performs a complete, 100 percent transformation on an inbound Apache request. &nbsp; I tested it with your own sample non-encrypted transformation input test and it works perfectly fine here. &nbsp; The code can certainly be consolidated but I used a STATE HANDLER to make it CLEAR what is happening when and why your code was having problems.   I hope this is of some help and if anyone who knows more than I do about filtering wants to follow up with more pointers please go for it. We all have things to learn. &nbsp; Later... Kevin &nbsp; COMPLETE SOURCE CODE FOR MOD_TRANSFORM.C  ; /* mod_transform.c - Completely transform an inbound request &nbsp;*  ;* Author: Kevin Kiley - 08/12/07 &nbsp;* &nbsp;* There are no configuration commands.  * &nbsp;* To install and run just put mod_transform.so in your server's &nbsp;* ../modules directory and then add the following to the  * HTTPD config file... &nbsp;*  ;* LoadModule transform_module modules/mod_transform.so  *  * The filter will be loaded automatically at runtime. &nbsp;* &nbsp;* See the 'YOUR CODE GOES HERE' comment in the TRANSFORMATION  * section to add any custom transformation(s). &nbsp;*  ;* This demo assumes that the POST data is NOT encrypted and  * is already a fully formed secondary request. It simply &nbsp;* "Transforms" the initial request into the secondary one.  ;*/   #include "httpd.h" #include "http_connection.h" /* Required for ap_hook_pre_xxxx() references */ #include "http_config.h" #include "http_core.h" #include "http_log.h"   /* Globals */   /* The 'trigger string' &nbsp;* If this string is part of the inbound request line  ;* then the transformation will take place. &nbsp;* Case matters. &nbsp;*/ &nbsp; char trigger_string[] = "HTTP_OPENPGP_DECRYPT";   /* Module related items... */   module AP_MODULE_DECLARE_DATA transform_module ;   #define MOD_TRANSFORM_DEFAULT_BUFFERSIZE 8096  ; /* The transformation STATES... */   #define MOD_TRANSFORM_STATE_IDLE &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   0 #define MOD_TRANSFORM_STATE_GET_REQUEST_LINE &nbsp;   ; 1 #define MOD_TRANSFORM_STATE_GET_REQUEST_HEADERS&nbsp;  2 #define MOD_TRANSFORM_STATE_GET_REQUEST_CONTENT&nbsp;  3 #define MOD_TRANSFORM_STATE_DO_THE_TRANSFORMATION 4 #define MOD_TRANSFORM_STATE_PUT_REQUEST_LINE &nbsp;   ; 5 #define MOD_TRANSFORM_STATE_PUT_REQUEST_HEADERS&nbsp;  6 #define MOD_TRANSFORM_STATE_PUT_REQUEST_CONTENT&nbsp;  7   /* Our own filter CONTEXT data... */   typedef struct transform_ctx_t { &nbsp; &nbsp; int &nbsp;   ; &nbsp; &nbsp; &nbsp; state; &nbsp; &nbsp; long   ; &nbsp; &nbsp; &nbsp;  content_length;  ; &nbsp; int &nbsp;   ; &nbsp; &nbsp; &nbsp; content_length_is_known;     ;  /* A flat buffer for transforming the request... */     ;  unsigned char *content_data_buffer;  &nbsp;  long   ; &nbsp; &nbsp; &nbsp;  content_data_buffer_len;  &nbsp;  unsigned char *content_data_buffer_ptr;    ; long   ; &nbsp; &nbsp; &nbsp;  content_data_buffer_bytesleft; &nbsp; } transform_ctx;   /* The input filter function itself... */   static int transform_input_filter( ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) {  &nbsp;  transform_ctx *ctx = f->ctx;  &nbsp;  apr_status_t status; &nbsp; &nbsp; apr_status_t ret;  ; &nbsp; apr_bucket *b;    ; apr_bucket *b2;  ; &nbsp; apr_off_t bytes_to_read = 0;  &nbsp;  unsigned char *p1;  ; &nbsp; unsigned char *p2;  ; &nbsp; const char *buf = 0;  &nbsp;  int return_to_caller = 0;  &nbsp;  int transform_this_request = 0;  &nbsp;  long p2len; &nbsp; &nbsp; long p2maxlen;   ;  long bytes_read = 0;  &nbsp;  long bytes_left = 0;  &nbsp;  long bytes_to_copy = 0;     ;  #define CONTENT_LENGTH_STRING_MAXLEN 90  &nbsp;  char  content_length_string[ CONTENT_LENGTH_STRING_MAXLEN + 2 ];     ;  if ( mode == AP_MODE_EATCRLF )  &nbsp; &nbsp;  {  &nbsp; &nbsp;   /* Not something we are concerned with... */     ; &nbsp; &nbsp; return ap_get_brigade( f->next, bb, mode, block, readbytes );  &nbsp;   ; }   &nbsp;   if ( !ctx )  &nbsp; &nbsp;  {  &nbsp; &nbsp;   ctx = f->ctx = apr_pcalloc( f->c-&gt;pool, sizeof( *ctx ) );     ; &nbsp; &nbsp; if ( ctx )  &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; ctx->state = MOD_TRANSFORM_STATE_GET_REQUEST_LINE;  ;  &nbsp; &nbsp; &nbsp;   ; ctx->content_length = 0;  &nbsp;   ; &nbsp; &nbsp; ctx->content_length_is_known = 0;  &nbsp;   ; &nbsp; &nbsp; ctx->content_data_buffer = 0;  &nbsp;   ; &nbsp; &nbsp; ctx->content_data_buffer_len = 0;  &nbsp;   ; &nbsp; &nbsp; ctx->content_data_buffer_ptr = 0;  &nbsp;   ; &nbsp; &nbsp; ctx->content_data_buffer_bytesleft = 0;  &nbsp;   ; &nbsp;  }  &nbsp; &nbsp;   else /* Whoops! We didn't get the memory we needed */  &nbsp;   ; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; /* TODO: Log an error message */     ; &nbsp; &nbsp; &nbsp;  return( APR_EGENERAL ); /* Abort */  &nbsp;   ; &nbsp;  }   &nbsp;   ;  }/* End 'if( !ctx )' */     ;  for ( ;; ) /* Stay in the state handler until it's OK to exit... */  &nbsp;   ;  {  &nbsp; &nbsp;   ; bytes_read = 0;  &nbsp;   ; &nbsp; buf = NULL; &nbsp;  &nbsp; &nbsp;   ; /* Process the current state... */     ; &nbsp; &nbsp;  switch( ctx->state )  &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp;  case MOD_TRANSFORM_STATE_IDLE:    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; /* Do nothing... */ &nbsp;  &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; return( ap_get_brigade( f->next, bb, mode, block, readbytes ));    &nbsp; &nbsp; &nbsp; &nbsp;   case MOD_TRANSFORM_STATE_GET_REQUEST_LINE:  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ret = ap_get_brigade( f->next, bb, mode, block, readbytes );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( ret == APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; b = APR_BRIGADE_FIRST(bb);   &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Call apr_bucket_read() and get the new request line */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  status = (apr_status_t)    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; apr_bucket_read(b, &buf, &bytes_read, APR_BLOCK_READ); &nbsp;  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( status != APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* Something weird happened. */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  /* Just return to caller... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; return_to_caller = 1;     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; break; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* If we got some data... process it... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  if ( bytes_read > 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* We only check POST requests for now... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; if ( strnicmp( buf, "POST", 4 ) == 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; if ( strstr( buf, trigger_string ) )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  transform_this_request = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; }/* End 'if( POST )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; if ( transform_this_request )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Get all the request headers now... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->state = MOD_TRANSFORM_STATE_GET_REQUEST_HEADERS; &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   apr_bucket_delete( b ); /* Discard the bucket */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  else /* Leave this one alone... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ctx->state = MOD_TRANSFORM_STATE_IDLE;    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  }/* End 'if( bytes_read > 0 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; }/* End 'if ( apr_get_brigade() call SUCCEEDED )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; else /* ap_get_brigade() call FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* TODO: Log an error */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; break; &nbsp;  &nbsp;   ; &nbsp; &nbsp;  case MOD_TRANSFORM_STATE_GET_REQUEST_HEADERS: &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Stay in AP_MODE_GETLINE until "End Of Header" is seen */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; ret = ap_get_brigade( f->next, bb, mode, block, readbytes );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( ret == APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; b = APR_BRIGADE_FIRST(bb);   &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Call apr_bucket_read() and get some data... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  status = (apr_status_t)    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; apr_bucket_read(b, &buf, &bytes_read, APR_BLOCK_READ); &nbsp;  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( status != APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  break; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* If we got some data... process it... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  if ( bytes_read > 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  bytes_left = bytes_read; /* Bytes left to process */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; if ( strnicmp( buf, "Content-length:", 15 ) == 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Get the Content-Length value... */  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; p1 &nbsp; &nbsp;   = (char *) buf;  ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  p1 &nbsp; &nbsp;  += 15;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   p2 &nbsp; &nbsp;   = &content_length_string[0]; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  p2len ; &nbsp; = 0;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; p2maxlen = CONTENT_LENGTH_STRING_MAXLEN; &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   while( *p1!=0 && *p1<33) p1++; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  while( *p1!=0 && *p1>32 && p2len<p2maxlen ) {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; *p2++ = *p1++; p2len++; }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  *p2 = 0; /* Terminate scratch buffer with NULL */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* Get the actual byte count now... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->content_length = (long) &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  atol( content_length_string );  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ctx->content_length_is_known = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  else if ( buf[0]==13 || buf[0]==10 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  /* Is there any content data coming? */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( !ctx->content_length_is_known )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  /* TODO: Create a brigade and read  ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  * into it until "Transfer-encoding" &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; * indicates "End of Data". &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; else if ( ctx->content_length > 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  /* There is content data coming so record it */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;ctx->state = MOD_TRANSFORM_STATE_GET_REQUEST_CONTENT; &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* Allocate a buffer to hold the content data */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  ctx->content_data_buffer = malloc( (ctx->content_length+2) );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  if ( ctx->content_data_buffer )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Reset the memory to all NULLS... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; memset( ctx->content_data_buffer, 0, (ctx->content_length+2) );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Reset the content data work pointer to */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* the start of the allocated buffer... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ctx->content_data_buffer_len&nbsp;   ; &nbsp; = (long) 0L;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->content_data_buffer_bytesleft = (long) 0L;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->content_data_buffer_ptr&nbsp;   ; &nbsp; = ctx->content_data_buffer; &nbsp;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; }/* End 'if( ctx->content_data_buffer )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  else /* Memory allocation FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* We are not going to be able to */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* record the data. */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Drop into IDLE mode... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ctx->state = MOD_TRANSFORM_STATE_IDLE;    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; /* TODO: Log an error */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; return APR_EGENERAL;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; }/* End 'if( ctx->content_length > 0 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   }/* End 'else if ( buf[0]==13 || buf[0]==10 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }/* End 'if( bytes_read > 0 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  apr_bucket_delete( b ); /* Destroy the bucket */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; }/* End 'if ( apr_get_brigade() call SUCCEEDED )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; else /* ap_get_brigade() call FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* TODO: Log an error */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; break; &nbsp;  &nbsp;   ; &nbsp; &nbsp;  case MOD_TRANSFORM_STATE_GET_REQUEST_CONTENT: &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  bytes_to_read =  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; ( ctx->content_length - ctx->content_data_buffer_len );  &nbsp;  ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  ret = ap_get_brigade( f->next, bb, AP_MODE_READBYTES, &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  APR_BLOCK_READ, bytes_to_read );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( ret == APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; b  = APR_BRIGADE_FIRST(bb);   &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Call apr_bucket_read() and get some data... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  status = (apr_status_t)    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; apr_bucket_read(b, &buf, &bytes_read, APR_BLOCK_READ); &nbsp;  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( status != APR_SUCCESS )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* Something weird happened. */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  /* Just return to caller. */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  break; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  /* If we got some data... process it... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  if ( bytes_read > 0 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  bytes_left = bytes_read; /* Bytes left to process */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; p1 = (char *) buf;  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  /* Assume ALL of the bytes are needed... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; bytes_to_copy = bytes_left;   &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; /* Check for overflow. Adjust, if necessary... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; if ( ( ctx->content_data_buffer_len + bytes_to_copy ) > ctx->content_length )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Only copy as many bytes as we need to */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; /* reach the actual 'Content-Length:' value... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; bytes_to_copy = ( ctx->content_length - ctx->content_data_buffer_len );  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Copy the data out of the bucket now... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; memcpy( ctx->content_data_buffer_ptr, buf, bytes_to_copy );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; /* Advance counters and pointers... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; ctx->content_data_buffer_ptr&nbsp;   ; &nbsp; += bytes_to_copy;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  ctx->content_data_buffer_len&nbsp;   ; &nbsp; += bytes_to_copy;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  ctx->content_data_buffer_bytesleft += bytes_to_copy;    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   /* Subtract what was copied from the */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  /* 'bytes_left' counter... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; bytes_left -= bytes_to_copy;    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   /* Are we done? */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; if ( ctx->content_data_buffer_len >= &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->content_length )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; ctx->state = MOD_TRANSFORM_STATE_DO_THE_TRANSFORMATION;   &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; }/* End 'if ( All Content Data Received )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }/* End 'if( bytes_read > 0 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  apr_bucket_delete( b ); /* Destroy the bucket */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; }/* End 'if ( apr_get_brigade() call SUCCEEDED )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; else /* ap_get_brigade() call FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* TODO: Log an error */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  return_to_caller = 1;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; break; &nbsp;  &nbsp;   ; &nbsp; &nbsp;  case MOD_TRANSFORM_STATE_DO_THE_TRANSFORMATION:    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; /* YOUR CODE GOES HERE! &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; * Transform the flat data buffer as needed. &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   *  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  * This demo assumes that the payload data is  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; * NOT encoded and is already a fully formed &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; * secondary request so it just moves on.    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; */    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; /* Start the output phase now... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; ctx->state = MOD_TRANSFORM_STATE_PUT_REQUEST_LINE;  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; break; &nbsp;  &nbsp;   ; &nbsp; &nbsp;  case MOD_TRANSFORM_STATE_PUT_REQUEST_LINE:  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Send the NEW request line now... */  &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; ctx->content_data_buffer_ptr =  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; ctx->content_data_buffer; &nbsp;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   p2 &nbsp;  = ctx->content_data_buffer_ptr;  &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; p2len = 0;     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* Find the end of the new request line */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   /* in the transformed request buffer... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; while( *p2!=0 && *p2!=10 ) { p2len++; p2++; }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( *p2 == 10 ) p2len++; /* Include LF */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* Create a heap bucket to hold the new */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   /* request line... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; b2 = apr_bucket_heap_create(ctx->content_data_buffer_ptr, p2len, NULL, f->c-&gt;bucket_alloc);  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; /* Add the new request line to the brigade... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; APR_BRIGADE_INSERT_TAIL( bb, b2 );     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; ctx->content_data_buffer_ptr&nbsp;   ; &nbsp; += p2len; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  ctx->content_data_buffer_bytesleft -= p2len; &nbsp;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   /* Start sending the headers next... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; ctx->state = MOD_TRANSFORM_STATE_PUT_REQUEST_HEADERS; &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  return_to_caller = 1;     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; break; &nbsp; &nbsp;  &nbsp; &nbsp; &nbsp; &nbsp;   case MOD_TRANSFORM_STATE_PUT_REQUEST_HEADERS: &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  p2 &nbsp;  = ctx->content_data_buffer_ptr;  &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; p2len = 0;     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* Find the next CRLF in our new data buffer... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; while( *p2!=0 && *p2!=10 ) { p2len++; p2++; }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( *p2 == 10 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; p2len++; /* Include LF in the data copy */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; else /* Search terminated on NULL instead of LF... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* We do NOT increment 'p2len' and we keep the */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* character that ended the search. */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* Create a new HEAP bucket to hold the header line... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; b2 = apr_bucket_heap_create(ctx->content_data_buffer_ptr, p2len, NULL, f->c-&gt;bucket_alloc);  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; if ( b2 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* If the bucket was created OK then add it to */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* the end of the brigade... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  APR_BRIGADE_INSERT_TAIL( bb, b2 );  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; else /* apr_bucket_heap_create() FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* TODO: Log an error */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }  &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  ctx->content_data_buffer_ptr&nbsp;   ; &nbsp; += p2len; /* Advance */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ctx->content_data_buffer_bytesleft -= p2len; /* Subtract */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* Are we done adding headers? */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( p2len < 3 ) /* We just added the EOH bucket */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* Advance to the next 'state'... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->state = MOD_TRANSFORM_STATE_PUT_REQUEST_CONTENT; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; return APR_SUCCESS; /* Just return to caller now... */     ; &nbsp; &nbsp; &nbsp; &nbsp; case MOD_TRANSFORM_STATE_PUT_REQUEST_CONTENT: &nbsp;    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; p2 &nbsp;  = ctx->content_data_buffer_ptr;  &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; p2len = ctx->content_data_buffer_bytesleft; &nbsp;  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; /* CHECK 'readbytes' value against 'p2len' value... &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  *  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;  * Make sure we don't 'give back' more than the specified   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  * number of 'readbytes'...    ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( readbytes > 0 ) /* A positive value was passed */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( p2len > readbytes )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  p2len = (long) readbytes; /* Equalize */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* Create a new HEAP bucket to hold the content data... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; b2 = apr_bucket_heap_create(ctx->content_data_buffer_ptr, p2len, NULL, f->c-&gt;bucket_alloc);  ;  &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; if ( b2 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* If the bucket was created OK then add it to */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* the end of the brigade... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  APR_BRIGADE_INSERT_TAIL( bb, b2 );  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp; else /* apr_bucket_heap_create() FAILED... */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; /* TODO: Log an error */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ;  }   &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->content_data_buffer_ptr&nbsp;   ; &nbsp; += p2len; /* Advance */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ctx->content_data_buffer_bytesleft -= p2len; /* Subtract */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; if ( ctx->content_data_buffer_bytesleft < 1 )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; if ( ctx->content_data_buffer )  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp;  free( ctx->content_data_buffer ); &nbsp; &nbsp;   /* Free  memory */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->content_data_buffer ; &nbsp;  = 0; /* Reset pointer */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->content_data_buffer_ptr = 0; /* Reset pointer */  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; ctx->content_data_buffer_len = 0; /* Reset length */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp;  }/* End 'if( ctx->content_data_buffer )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  /* Reset the ctx->content_length value and flag(s)... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->content_length = 0;  &nbsp;   ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; ctx->content_length_is_known = 0;     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  /* Drop into the IDLE state when done... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp;  ctx->state = MOD_TRANSFORM_STATE_IDLE;    &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; &nbsp; &nbsp; }/* End 'if ( ctx->content_data_buffer_bytesleft < 1 )' */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* We can simply return to the caller at this point... */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; return APR_SUCCESS;  &nbsp; &nbsp;   ; &nbsp;   &nbsp; &nbsp; &nbsp;   ;  default: /* Safety catch */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; /* TODO: We should never hit here. Log an error. */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; return_to_caller = 1; /* Just return to the caller */     ; &nbsp; &nbsp; &nbsp; &nbsp;   ; &nbsp; break; &nbsp;  &nbsp;   ; &nbsp; &nbsp; }/* End of switch( ctx->state ) */     ; &nbsp; &nbsp;  if ( return_to_caller )  &nbsp; &nbsp;   ; &nbsp; {  &nbsp; &nbsp;   ; &nbsp;  break; /* Break out of 'for(;;)' loop and return to caller */  &nbsp;   ; &nbsp; &nbsp; }   &nbsp;   ; &nbsp; }/* End 'for(;;)' loop that runs the state handler */     ;  return APR_SUCCESS; }   static int transform_pre_conn(conn_rec *c, void *csd) { &nbsp; &nbsp; ap_add_input_filter("TRANSFORM_INPUT_FILTER", NULL, NULL, c);    &nbsp;  return OK; } &nbsp; static void transform_register_hooks(apr_pool_t *p) { &nbsp;/* NOTE: SSL is CONNECTION +5 so use +3 */     ap_register_input_filter("TRANSFORM_INPUT_FILTER", transform_input_filter,  &nbsp; &nbsp;   ; NULL, AP_FTYPE_CONNECTION + 3) ;   &nbsp; ap_hook_pre_connection(transform_pre_conn, NULL, NULL, APR_HOOK_MIDDLE); } &nbsp; module AP_MODULE_DECLARE_DATA transform_module = {  &nbsp; &nbsp;   ; STANDARD20_MODULE_STUFF,  &nbsp;   ; &nbsp; NULL, &nbsp; &nbsp; &nbsp; &nbsp; NULL, &nbsp; &nbsp; &nbsp; &nbsp; NULL, &nbsp; &nbsp; &nbsp; &nbsp; NULL, &nbsp; &nbsp; &nbsp; &nbsp; NULL, &nbsp; &nbsp; &nbsp; &nbsp; transform_register_hooks }; &nbsp; /* END OF FILE */ Get a sneak peek of the all-new AOL.com.