Changes:

 * First version

CHANGES

@@ -0,0 +1,3 @@
+nginx_upload_progress release 0.1                                   3 Oct 2007
+
+ * public release

LICENSE

@@ -0,0 +1,25 @@
+/* 
+ * Copyright (C) 2007 Brice FIGUREAU
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ */

README

@@ -0,0 +1,217 @@
+Nginx Upload Progress Module
+============================
+
+
+Introduction
+============
+
+nginx_uploadprogress_module is an implementation of an upload progress system, that monitors
+RFC1867 POST upload as they are transmitted to upstream servers.
+
+It works by tracking the uploads proxied by Nginx to upstream servers without 
+analysing the uploaded content and offers a web API to report upload progress in JSON format.
+It works because Nginx acts as an accelerator of an upstream server, storing uploaded POST content
+on disk, before transmitting it to the upstream server. Each individual POST upload request
+should contain a progress unique identifier.
+
+This module is Copyright (c) 2007 Brice Figureau, and is licensed under the BSD license (see LICENSE).
+ * rbtree and shm_zone code is based on Igor Sysoev limit_zone Nginx module.
+ * expire header code is based on Igor Sysoev header_filter Nginx module.
+
+The JSON idea and the mechanism idea are based on Lighttpd mod_uploadprogress:
+http://blog.lighttpd.net/articles/2006/08/01/mod_uploadprogress-is-back
+
+
+WARNINGS: 
+ * this software has never been tested under load. It only passed a few lab tests.
+ * it is not intended to be deployed on *production systems*.
+ * when compiled with --with-debug, this module will produce high number of log messages.
+
+
+Installation
+============
+
+nginx_uploadprogress_module has been tested with Nginx 0.6.1, 0.6.12 and 0.6.13.
+
+Download the Nginx sources from http://nginx.net/ and unpack it.
+
+To build Nginx, change to the directory which contains the Nginx
+sources, and run the configuration script making sure to add the path
+to the nginx_uploadprogress_module sources using the --add-module option: ::
+
+ $ ./configure --add-module=/path/to/nginx_uploadprogress_module/
+
+Now you can build and install the software:
+
+ $ make
+
+and as root:
+
+ $ make install 
+ 
+ 
+Configuration
+=============
+
+Each upload request should be assigned a unique identifier. This unique identifier will be used
+to store the request and reference it to report.
+This identifier can be transmitted either as a GET argument or as an HTTP header whose name is X-Progress-ID.
+
+upload_progress
++++++++++++++++
+	:Syntax: upload_progress <zone_name> <zone_size>
+	:Default: none
+	:Context: http
+	:Description:
+	This directive enables the upload progress module and reserve <zone_size> bytes to the <zone_name> which
+	will be used to store the per-connection tracking information.
+	
+track_uploads
++++++++++++++
+	:Syntax: track_uploads <zone_name>
+	:Default: none
+	:Context: location
+	:Description:
+	This directive enables tracking uploads for the current location. Each POST landing in this location will register
+	the request in the <zone_name> upload progress tracker.
+	Since Nginx doesn't support yet RFC 1867 upload, the location must be a proxy_pass or fastcgi location.
+	The POST _must_ have a query parameter called X-Progress-ID (or an HTTP header of the same name) whose value is the
+	unique identifier used to get progress information. If the POST has no such information, the upload will not be tracked.
+	
+report_uploads
+++++++++++++++
+	:Syntax: report_uploads <zone_name>
+	:Default: none
+	:Context: location
+	:Description:
+	This directive allows a location to report the upload progress that is tracked by track_uploads for <zone_name>.
+	The returned document is a JSON text with the possible 4 results:
+	  * the upload request hasn't been registered yet or is unknown:			 
+				new Object({ 'state' : 'starting' })
+				
+		* the upload request has ended:
+				new Object({ 'state' : 'done' })
+		
+		* the upload request generated an HTTP 413 error (Request entity too large):
+				new Object({ 'state' : 'error', 'status' : 413 })
+		
+		* the upload request is in progress:
+				new Object({ 'state' : 'uploading', 'received' : <size_received>, 'size' : <total_size>})
+				
+	The HTTP request to this location must have a X-Progress-ID parameter or HTTP header containing a valid
+	unique identifier of an inprogress upload.
+				
+
+Configuration Example:
++++++++++++++++++++++
+
+http {
+	
+	# reserve 1MB under the name 'proxied' to track uploads
+	upload_progress proxied 1m;
+
+  server {
+		listen       127.0.0.1 default;
+		server_name  _ *;
+		
+		root /path/to/root;
+		
+		location / {
+			# proxy to upstream server
+			proxy_pass http://127.0.0.1;
+			proxy_redirect default;
+			
+			# track uploads in the 'proxied' zone
+			track_uploads proxied;
+		}
+		
+		location ^~ /progress {
+			# report uploads tracked in the 'proxied' zone
+			report_uploads proxied;
+		}
+}
+	
+
+Usage Example
+=============
+
+(based on Lighttd mod_uploadprogress module example):
+
+First we need a upload form:
+
+  <form id="upload" enctype="multipart/form-data" 
+    action="/upload.php" method="post" 
+    onsubmit="openProgressBar(); return true;">
+  <input type="hidden" name="MAX_FILE_SIZE" value="30000000"  />
+  <input name="userfile" type="file" label="fileupload" />
+  <input type="submit" value="Send File" />
+  </form>
+
+And a progress bar to visualize the progress:
+
+  <div>
+   <div id="progress" style="width: 400px; border: 1px solid black">
+    <div id="progressbar" 
+       style="width: 1px; background-color: black; border: 1px solid white">
+     &nbsp;
+    </div>
+   </div>
+   <div id="tp">(progress)</div>
+  </div>
+
+Then we need to generate the Unique Identifier and launch the upload on submit
+action. This also will start the ajax progress report mechanism.
+
+ interval = null;
+
+function openProgressBar() {
+ /* generate random progress-id */
+ uuid = "";
+ for (i = 0; i < 32; i++) {
+  uuid += Math.floor(Math.random() * 16).toString(16);
+ }
+ /* patch the form-action tag to include the progress-id */
+ document.getElementById("upload").action="/upload.php?X-Progress-ID=" + uuid;
+
+ /* call the progress-updater every 1000ms */
+ interval = window.setInterval(
+   function () {
+     fetch(uuid);
+   },
+   1000
+ );
+}
+
+function fetch(uuid) {
+ req = new XMLHttpRequest();
+ req.open("GET", "/progress", 1);
+ req.setRequestHeader("X-Progress-ID", uuid);
+ req.onreadystatechange = function () {
+  if (req.readyState == 4) {
+   if (req.status == 200) {
+    /* poor-man JSON parser */
+    var upload = eval(req.responseText);
+
+    document.getElementById('tp').innerHTML = upload.state;
+
+    /* change the width if the inner progress-bar */
+    if (upload.state == 'done' || upload.state == 'uploading') {
+     bar = document.getElementById('progressbar');
+     w = 400 * upload.received / upload.size;
+     bar.style.width = w + 'px';
+    }
+    /* we are done, stop the interval */
+    if (upload.state == 'done') {
+     window.clearTimeout(interval);
+    }
+   }
+  }
+ }
+ req.send(null);
+}
+
+
+
+
+
+

config

@@ -0,0 +1,3 @@
+ngx_addon_name=ngx_http_uploadprogress_module
+HTTP_MODULES="$HTTP_MODULES ngx_http_uploadprogress_module"
+NGX_ADDON_SRCS="$NGX_ADDON_SRCS $ngx_addon_dir/ngx_http_uploadprogress_module.c"

ngx_http_uploadprogress_module.c

@@ -0,0 +1,852 @@
+
+/*
+ * Copyright (C) 2007 Brice Figureau
+ */
+
+#include <ngx_config.h>
+#include <ngx_core.h>
+#include <ngx_http.h>
+
+typedef struct {
+    u_char              color;
+ 		ngx_http_request_t *r;
+    u_char              len;
+    u_char              data[1];
+} ngx_http_uploadprogress_node_t;
+
+
+typedef struct {
+    ngx_shm_zone_t     *shm_zone;
+    ngx_rbtree_node_t  *node;
+} ngx_http_uploadprogress_cleanup_t;
+
+typedef struct {
+    ngx_rbtree_t       *rbtree;
+} ngx_http_uploadprogress_ctx_t;
+
+typedef struct {
+    ngx_shm_zone_t     *shm_zone;
+		u_char							track;
+} ngx_http_uploadprogress_conf_t;
+
+static ngx_int_t ngx_http_reportuploads_handler(ngx_http_request_t *r);
+static ngx_int_t ngx_http_reportuploads_handler(ngx_http_request_t *r);
+static void ngx_http_uploadprogress_cleanup(void *data);
+static char *ngx_http_report_uploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
+static ngx_int_t ngx_http_uploadprogress_init_zone(ngx_shm_zone_t *shm_zone, void *data);
+static ngx_int_t ngx_http_uploadprogress_init(ngx_conf_t *cf);
+static void *ngx_http_uploadprogress_create_loc_conf(ngx_conf_t *cf);
+static char *ngx_http_uploadprogress_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child);
+static char *ngx_http_track_uploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
+static char *ngx_http_report_uploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
+static char *ngx_http_upload_progress(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
+
+static ngx_command_t  ngx_http_uploadprogress_commands[] = {
+
+  { ngx_string("upload_progress"),
+    NGX_HTTP_MAIN_CONF|NGX_CONF_TAKE2,
+    ngx_http_upload_progress,
+    0,
+    0,
+    NULL },
+
+  { ngx_string("track_uploads"),
+	  NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
+	  ngx_http_track_uploads,
+	  NGX_HTTP_LOC_CONF_OFFSET,
+    0,
+    NULL },
+
+  { ngx_string("report_uploads"),
+    NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
+    ngx_http_report_uploads,
+    NGX_HTTP_LOC_CONF_OFFSET,
+    0,
+    NULL },
+
+		ngx_null_command
+};
+
+
+static ngx_http_module_t  ngx_http_uploadprogress_module_ctx = {
+    NULL,                          /* preconfiguration */
+    ngx_http_uploadprogress_init,  /* postconfiguration */
+
+    NULL,  /* create main configuration */
+    NULL,    /* init main configuration */
+
+    NULL,                          /* create server configuration */
+    NULL,                          /* merge server configuration */
+
+    ngx_http_uploadprogress_create_loc_conf,          /* create location configuration */
+    ngx_http_uploadprogress_merge_loc_conf            /* merge location configuration */
+};
+
+
+ngx_module_t  ngx_http_uploadprogress_module = {
+    NGX_MODULE_V1,
+    &ngx_http_uploadprogress_module_ctx,      /* module context */
+    ngx_http_uploadprogress_commands,         /* module directives */
+    NGX_HTTP_MODULE,               /* module type */
+    NULL,                          /* init master */
+    NULL,                          /* init module */
+    NULL,                          /* init process */
+    NULL,                          /* init thread */
+    NULL,                          /* exit thread */
+    NULL,                          /* exit process */
+    NULL,                          /* exit master */
+    NGX_MODULE_V1_PADDING
+};
+
+static ngx_str_t x_progress_id = ngx_string("X-Progress-ID");
+
+static ngx_str_t*
+get_tracking_id(ngx_http_request_t *r)
+{
+	u_char										 *p,*start_p;
+	ngx_uint_t i;
+  ngx_list_part_t              *part;
+  ngx_table_elt_t              *header;
+	ngx_str_t										 *ret;
+
+  part = &r->headers_in.headers.part;
+  header = part->elts;
+
+  for (i = 0; /* void */; i++) {
+
+      if (i >= part->nelts) {
+          if (part->next == NULL) {
+              break;
+          }
+
+          part = part->next;
+          header = part->elts;
+          i = 0;
+      }
+
+			if (header[i].key.len == x_progress_id.len && ngx_strncmp(header[i].key.data, x_progress_id.data,header[i].key.len) == 0)
+			{
+				ret = ngx_pcalloc(r->pool, sizeof(ngx_str_t));
+				ret->data = header[i].value.data;
+				ret->len = header[i].value.len;
+				return ret;
+			}
+  }
+
+	/* not found, check as a reaquest arg */
+	if (r->args.len) {
+		p = (u_char *) ngx_strstr(r->args.data, "X-Progress-ID=");
+
+		if (p) {
+			start_p = p += 14;
+	    while (p < r->args.data + r->args.len) {
+	        if (*p++ != '&') {
+	            continue;
+	        }
+			}
+			
+			ret = ngx_pcalloc(r->pool, sizeof(ngx_str_t));
+			ret->data = start_p;
+			ret->len = p-start_p;
+			return ret;
+		}
+	}
+
+	return NULL;
+}
+
+
+/* This generates the response for the report */
+static ngx_int_t
+ngx_http_reportuploads_handler(ngx_http_request_t *r)
+{
+	ngx_str_t		 *id;
+  ngx_buf_t    *b;
+  ngx_chain_t   out;
+	ngx_http_request_t								 *orig;
+  ngx_int_t                       rc, size;
+  uint32_t                        hash;
+  ngx_slab_pool_t                *shpool;
+  ngx_rbtree_node_t              *node, *sentinel;
+	ngx_http_uploadprogress_conf_t     *lzcf;
+  ngx_http_uploadprogress_ctx_t      *ctx;
+  ngx_http_uploadprogress_node_t     *lz;
+  ngx_table_elt_t  *expires, *cc, **ccp;
+
+  if (r->method != NGX_HTTP_GET && r->method != NGX_HTTP_HEAD) {
+      return NGX_HTTP_NOT_ALLOWED;
+  }
+
+  rc = ngx_http_discard_request_body(r);
+
+  if (rc != NGX_OK) {
+      return rc;
+  }
+
+	/* get the tracking id if any */
+	id = get_tracking_id(r);
+
+
+	if ( id == NULL )
+	{
+	  ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+	                 "reportuploads handler cant find id");
+    return NGX_DECLINED;
+	}
+	
+  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+                 "reportuploads handler found id: %V", id);
+
+  lzcf = ngx_http_get_module_loc_conf(r, ngx_http_uploadprogress_module);
+
+  if (lzcf->shm_zone == NULL) {
+	  	ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+	                 "reportuploads no shm_zone for id: %V", id);
+      return NGX_DECLINED;
+  }
+
+	orig = NULL;
+  ctx = lzcf->shm_zone->data;
+	
+  hash = ngx_crc32_short(id->data, id->len);
+
+	ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+               "reportuploads trying to find block with hash %08XD for id: %V", hash, id);
+
+	/* get the original connection of the upload */
+  shpool = (ngx_slab_pool_t *) lzcf->shm_zone->shm.addr;
+  ngx_shmtx_lock(&shpool->mutex);
+
+	ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+               "reportuploads in mutex lock for hash %08XD for id: %V", hash, id);
+
+  node = ctx->rbtree->root;
+  sentinel = ctx->rbtree->sentinel;
+
+	ngx_log_debug3(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+               "reportuploads root %p, sentinel %p for id: %V", node,sentinel, id);
+
+  while (node != sentinel) {
+
+      if (hash < node->key) {
+          node = node->left;
+          continue;
+      }
+
+      if (hash > node->key) {
+          node = node->right;
+          continue;
+      }
+
+			ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+		               "reportuploads found matching hash %08XD, node %p for id: %V", hash, node, id);
+
+      /* hash == node->key */
+
+      do {
+          lz = (ngx_http_uploadprogress_node_t *) &node->color;
+
+          rc = ngx_memn2cmp(id->data, lz->data, id->len, (size_t) lz->len);
+
+          if (rc == 0) {
+						/* found the right one */
+						/* lz contains the right node*/
+						ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+					               "reportuploads found request: %p", lz->r);
+						orig = lz->r;
+						goto found;
+          }
+
+					ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+				               "reportuploads oops not the same : lz %V != id %V", lz, id);
+
+
+          node = (rc < 0) ? node->left : node->right;
+
+      } while (node != sentinel && hash == node->key);
+
+			lz = NULL;
+			
+			/* couldn't find one */
+			ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+		               "reportuploads not matching request");
+  }
+
+found:
+	ngx_shmtx_unlock(&shpool->mutex);
+
+	/* send the output */
+  r->headers_out.content_type.len = sizeof("text/javascript") - 1;
+  r->headers_out.content_type.data = (u_char *) "text/javascript";
+
+	/* no-cache */
+
+  expires = r->headers_out.expires;
+
+  if (expires == NULL) {
+
+      expires = ngx_list_push(&r->headers_out.headers);
+      if (expires == NULL) {
+          return NGX_HTTP_INTERNAL_SERVER_ERROR;
+      }
+
+      r->headers_out.expires = expires;
+
+      expires->hash = 1;
+      expires->key.len = sizeof("Expires") - 1;
+      expires->key.data = (u_char *) "Expires";
+  }
+
+  len = sizeof("Mon, 28 Sep 1970 06:00:00 GMT");
+  expires->value.len = len - 1;
+
+  ccp = r->headers_out.cache_control.elts;
+  if (ccp == NULL) {
+
+      if (ngx_array_init(&r->headers_out.cache_control, r->pool,
+                         1, sizeof(ngx_table_elt_t *))
+          != NGX_OK)
+      {
+          return NGX_HTTP_INTERNAL_SERVER_ERROR;
+      }
+
+      ccp = ngx_array_push(&r->headers_out.cache_control);
+      if (ccp == NULL) {
+          return NGX_HTTP_INTERNAL_SERVER_ERROR;
+      }
+
+      cc = ngx_list_push(&r->headers_out.headers);
+      if (cc == NULL) {
+          return NGX_HTTP_INTERNAL_SERVER_ERROR;
+      }
+
+      cc->hash = 1;
+      cc->key.len = sizeof("Cache-Control") - 1;
+      cc->key.data = (u_char *) "Cache-Control";
+
+      *ccp = cc;
+
+  } else {
+      for (i = 1; i < r->headers_out.cache_control.nelts; i++) {
+          ccp[i]->hash = 0;
+      }
+
+      cc = ccp[0];
+  }
+
+  expires->value.data = (u_char *) "Thu, 01 Jan 1970 00:00:01 GMT";
+
+  cc->value.len = sizeof("no-cache") - 1;
+  cc->value.data = (u_char *) "no-cache";
+
+
+  if (r->method == NGX_HTTP_HEAD) {
+      r->headers_out.status = NGX_HTTP_OK;
+
+      rc = ngx_http_send_header(r);
+
+      if (rc == NGX_ERROR || rc > NGX_OK || r->header_only) {
+          return rc;
+      }
+  }
+
+	if ( orig == NULL )
+	{
+		if (lz != NULL )
+		{
+			size = sizeof("new Object({ 'state' : 'done' })\r\n");
+  	}
+		else
+		{
+			size = sizeof("new Object({ 'state' : 'starting' })\r\n");
+  	}
+	}
+	else if ( orig->err_status == 413)
+	{
+		size = sizeof("new Object({ 'state' : 'error', 'status' : 413 })\r\n");
+	}
+	else
+	{
+		size = sizeof("new Object({ 'state' : 'uploading', 'received' : ") + NGX_INT_T_LEN + sizeof(" })\r\n");
+		size += sizeof(", 'size' : ") + NGX_INT_T_LEN;
+	}
+
+  b = ngx_create_temp_buf(r->pool, size);
+  if (b == NULL) {
+      return NGX_HTTP_INTERNAL_SERVER_ERROR;
+  }
+
+  out.buf = b;
+  out.next = NULL;
+	
+	if (orig == NULL)
+	{
+		if (lz == NULL )
+		{
+			b->last = ngx_cpymem(b->last, "new Object({ 'state' : 'starting' })\r\n",
+		                       sizeof("new Object({ 'state' : 'starting' })\r\n") - 1);
+			ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+											               "reportuploads returning starting");
+		}
+		else 
+		{
+			b->last = ngx_cpymem(b->last, "new Object({ 'state' : 'done' })\r\n",
+		                       sizeof("new Object({ 'state' : 'done' })\r\n") - 1);
+			ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+		               "reportuploads returning done");
+		}
+	}
+	else if ( orig->err_status == 413)
+	{
+		b->last = ngx_cpymem(b->last, "new Object({ 'state' : 'error', 'status' : 413 })\r\n",
+	                       sizeof("new Object({ 'state' : 'error', 'status' : 413 })\r\n") - 1);
+		ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+	               "reportuploads returning error 413");
+	}
+	else
+	{
+		b->last = ngx_cpymem(b->last,"new Object({ 'state' : 'uploading', 'received' : ", 
+			sizeof("new Object({ 'state' : 'uploading', 'received' : ")-1 );
+			
+		b->last = ngx_sprintf(b->last, "%uO, 'size' : %uO })\r\n", (orig->headers_in.content_length_n - orig->request_body->rest), orig->headers_in.content_length_n);
+
+		ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+	               "reportuploads returning %uO / %uO", (orig->headers_in.content_length_n - orig->request_body->rest), orig->headers_in.content_length_n);
+
+	}
+
+	// force no caching for proxy
+	
+
+	r->headers_out.status = NGX_HTTP_OK;
+	r->headers_out.content_length_n = b->last - b->pos;
+
+	b->last_buf = 1;
+	rc = ngx_http_send_header(r);
+
+	if (rc == NGX_ERROR || rc > NGX_OK || r->header_only) {
+	    return rc;
+	}
+
+	return ngx_http_output_filter(r, &out);;
+}
+
+/* 
+This is the post read phase. It registers the upload connection in the rb tree
+*/
+static ngx_int_t
+ngx_http_uploadprogress_handler(ngx_http_request_t *r)
+{
+  size_t                          n;
+	ngx_str_t 												 *id;
+  ngx_int_t                       rc;
+  uint32_t                        hash;
+  ngx_slab_pool_t                *shpool;
+  ngx_rbtree_node_t              *node, *sentinel;
+	ngx_http_uploadprogress_conf_t     *lzcf;
+  ngx_http_uploadprogress_ctx_t      *ctx;
+  ngx_http_uploadprogress_node_t     *lz;
+	ngx_http_uploadprogress_cleanup_t	 *lzcln;
+  ngx_pool_cleanup_t             *cln;
+
+	id = get_tracking_id(r);
+	if ( id == NULL )
+	{
+		ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+             "trackuploads no id found in POST upload req");
+		return NGX_DECLINED;
+	}
+	
+	ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+           "trackuploads id found: %V", id);
+
+  lzcf = ngx_http_get_module_loc_conf(r, ngx_http_uploadprogress_module);
+
+  if (!lzcf->track) {
+	  	ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+	                 "trackuploads not tracking in this location for id: %V", id);
+      return NGX_DECLINED;
+  }
+
+  if (lzcf->shm_zone == NULL) {
+  	ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+                 "trackuploads no shm_zone for id: %V", id);
+      return NGX_DECLINED;
+  }
+
+  ctx = lzcf->shm_zone->data;
+	
+  hash = ngx_crc32_short(id->data, id->len);
+
+	ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+               "trackuploads hash %08XD for id: %V",hash, id);
+
+  cln = ngx_pool_cleanup_add(r->pool, sizeof(ngx_http_uploadprogress_cleanup_t));
+  if (cln == NULL) {
+      return NGX_HTTP_INTERNAL_SERVER_ERROR;
+  }
+
+  shpool = (ngx_slab_pool_t *) lzcf->shm_zone->shm.addr;
+
+  ngx_shmtx_lock(&shpool->mutex);
+
+  node = ctx->rbtree->root;
+  sentinel = ctx->rbtree->sentinel;
+
+  while (node != sentinel) {
+
+      if (hash < node->key) {
+          node = node->left;
+          continue;
+      }
+
+      if (hash > node->key) {
+          node = node->right;
+          continue;
+      }
+
+      /* hash == node->key */
+
+      do {
+          lz = (ngx_http_uploadprogress_node_t *) &node->color;
+
+          rc = ngx_memn2cmp(id->data, lz->data, id->len, (size_t) lz->len);
+
+          if (rc == 0) {
+							ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+					               "trackuploads already registered: %V",id);
+							/* oops found already one */
+              ngx_shmtx_unlock(&shpool->mutex);
+
+              return NGX_HTTP_SERVICE_UNAVAILABLE;
+          }
+
+          node = (rc < 0) ? node->left : node->right;
+
+      } while (node != sentinel && hash == node->key);
+
+      break;
+  }
+
+  n = offsetof(ngx_rbtree_node_t, color)
+      + offsetof(ngx_http_uploadprogress_node_t, data)
+      + id->len;
+
+  node = ngx_slab_alloc_locked(shpool, n);
+  if (node == NULL) {
+      ngx_shmtx_unlock(&shpool->mutex);
+      return NGX_HTTP_SERVICE_UNAVAILABLE;
+  }
+
+  lz = (ngx_http_uploadprogress_node_t *) &node->color;
+
+  node->key = hash;
+  lz->len = (u_char) id->len;
+	lz->r = r;
+  ngx_memcpy(lz->data, id->data, id->len);
+
+  ngx_rbtree_insert(ctx->rbtree, node);
+  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
+                 "trackuploads: %08XD", node->key);
+
+  ngx_shmtx_unlock(&shpool->mutex);
+
+  cln->handler = ngx_http_uploadprogress_cleanup;
+  lzcln = cln->data;
+
+  lzcln->shm_zone = lzcf->shm_zone;
+  lzcln->node = node;
+
+  return NGX_DECLINED;
+}
+
+static void
+ngx_http_uploadprogress_rbtree_insert_value(ngx_rbtree_node_t *temp,
+    ngx_rbtree_node_t *node, ngx_rbtree_node_t *sentinel)
+{
+    ngx_http_uploadprogress_node_t  *lzn, *lznt;
+
+    for ( ;; ) {
+
+        if (node->key < temp->key) {
+
+            if (temp->left == sentinel) {
+                temp->left = node;
+                break;
+            }
+
+            temp = temp->left;
+
+        } else if (node->key > temp->key) {
+
+            if (temp->right == sentinel) {
+                temp->right = node;
+                break;
+            }
+
+            temp = temp->right;
+
+        } else { /* node->key == temp->key */
+
+            lzn = (ngx_http_uploadprogress_node_t *) &node->color;
+            lznt = (ngx_http_uploadprogress_node_t *) &temp->color;
+
+            if (ngx_memn2cmp(lzn->data, lznt->data, lzn->len, lznt->len) < 0) {
+
+                if (temp->left == sentinel) {
+                    temp->left = node;
+                    break;
+                }
+
+                temp = temp->left;
+
+            } else {
+
+                if (temp->right == sentinel) {
+                    temp->right = node;
+                    break;
+                }
+
+                temp = temp->right;
+            }
+        }
+    }
+
+    node->parent = temp;
+    node->left = sentinel;
+    node->right = sentinel;
+    ngx_rbt_red(node);
+}
+
+/*
+removes the expired node from the upload rbtree
+*/
+static void
+ngx_http_uploadprogress_cleanup(void *data)
+{
+    ngx_http_uploadprogress_cleanup_t  *lzcln = data;
+
+    ngx_slab_pool_t             *shpool;
+    ngx_rbtree_node_t           *node;
+    ngx_http_uploadprogress_ctx_t   *ctx;
+    ngx_http_uploadprogress_node_t  *lz;
+
+		ngx_log_debug0(NGX_LOG_DEBUG_HTTP, lzcln->shm_zone->shm.log, 0,
+	           "uploadprogress cleanup called");
+
+    ctx = lzcln->shm_zone->data;
+    shpool = (ngx_slab_pool_t *) lzcln->shm_zone->shm.addr;
+    node = lzcln->node;
+    lz = (ngx_http_uploadprogress_node_t *) &node->color;
+
+    ngx_shmtx_lock(&shpool->mutex);
+
+    ngx_log_debug1(NGX_LOG_DEBUG_HTTP, lzcln->shm_zone->shm.log, 0,
+                   "upload progress cleanup: %08XD", node->key);
+
+    ngx_rbtree_delete(ctx->rbtree, node);
+    ngx_slab_free_locked(shpool, node);
+    ngx_log_debug1(NGX_LOG_DEBUG_HTTP, lzcln->shm_zone->shm.log, 0,
+			"upload progress cleanup node removed: %08XD", node->key);
+    ngx_shmtx_unlock(&shpool->mutex);
+}
+
+static ngx_int_t
+ngx_http_uploadprogress_init_zone(ngx_shm_zone_t *shm_zone, void *data)
+{
+    ngx_http_uploadprogress_ctx_t  *octx = data;
+
+    ngx_slab_pool_t            *shpool;
+    ngx_rbtree_node_t          *sentinel;
+    ngx_http_uploadprogress_ctx_t  *ctx;
+
+    ctx = shm_zone->data;
+
+    if (octx) {
+        ctx->rbtree = octx->rbtree;
+        return NGX_OK;
+    }
+
+    shpool = (ngx_slab_pool_t *) shm_zone->shm.addr;
+
+    ctx->rbtree = ngx_slab_alloc(shpool, sizeof(ngx_rbtree_t));
+    if (ctx->rbtree == NULL) {
+        return NGX_ERROR;
+    }
+
+    sentinel = ngx_slab_alloc(shpool, sizeof(ngx_rbtree_node_t));
+    if (sentinel == NULL) {
+        return NGX_ERROR;
+    }
+
+    ngx_rbtree_sentinel_init(sentinel);
+
+    ctx->rbtree->root = sentinel;
+    ctx->rbtree->sentinel = sentinel;
+    ctx->rbtree->insert = ngx_http_uploadprogress_rbtree_insert_value;
+
+    return NGX_OK;
+}
+
+
+static ngx_int_t
+ngx_http_uploadprogress_init(ngx_conf_t *cf)
+{
+    ngx_http_handler_pt        *h;
+    ngx_http_core_main_conf_t  *cmcf;
+
+    cmcf = ngx_http_conf_get_module_main_conf(cf, ngx_http_core_module);
+
+    h = ngx_array_push(&cmcf->phases[NGX_HTTP_REWRITE_PHASE].handlers);
+    if (h == NULL) {
+        return NGX_ERROR;
+    }
+
+    *h = ngx_http_uploadprogress_handler;
+    return NGX_OK;
+}
+
+static void *
+ngx_http_uploadprogress_create_loc_conf(ngx_conf_t *cf)
+{
+    ngx_http_uploadprogress_conf_t  *conf;
+
+    conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_uploadprogress_conf_t));
+    if (conf == NULL) {
+        return NGX_CONF_ERROR;
+    }
+    return conf;
+}
+
+
+static char *
+ngx_http_uploadprogress_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child)
+{
+  ngx_http_uploadprogress_conf_t *prev = parent;
+  ngx_http_uploadprogress_conf_t *conf = child;
+
+  if (conf->shm_zone == NULL) {
+      *conf = *prev;
+  }
+
+  return NGX_CONF_OK;
+}
+
+
+static char *
+ngx_http_upload_progress(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
+{
+    ssize_t                     n;
+    ngx_str_t                  *value;
+    ngx_shm_zone_t             *shm_zone;
+    ngx_http_uploadprogress_ctx_t  *ctx;
+
+    value = cf->args->elts;
+
+	  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_upload_progress name: %V", &value[1]);
+
+    ctx = ngx_pcalloc(cf->pool, sizeof(ngx_http_uploadprogress_ctx_t));
+    if (ctx == NULL) {
+        return NGX_CONF_ERROR;
+    }
+
+    n = ngx_parse_size(&value[2]);
+
+    if (n == NGX_ERROR) {
+        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
+                           "invalid size of track_uploads \"%V\"", &value[2]);
+        return NGX_CONF_ERROR;
+    }
+
+    if (n < (ngx_int_t) (8 * ngx_pagesize)) {
+        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
+                           "track_uploads \"%V\" is too small", &value[1]);
+        return NGX_CONF_ERROR;
+    }
+
+    shm_zone = ngx_shared_memory_add(cf, &value[1], n,
+                                     &ngx_http_uploadprogress_module);
+    if (shm_zone == NULL) {
+        return NGX_CONF_ERROR;
+    }
+
+	  ngx_log_debug2(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_upload_progress name: %V, szhm_zone: %p", value[1], shm_zone);
+
+    if (shm_zone->data) {
+        ctx = shm_zone->data;
+
+        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
+                        "track_uploads \"%V\" is already created",
+                        &value[1]);
+        return NGX_CONF_ERROR;
+    }
+
+    shm_zone->init = ngx_http_uploadprogress_init_zone;
+    shm_zone->data = ctx;
+
+    return NGX_CONF_OK;
+}
+
+static char *
+ngx_http_track_uploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
+{
+    ngx_http_uploadprogress_conf_t  *lzcf = conf;
+    ngx_str_t  *value;
+
+	  ngx_log_debug0(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_track_uploads in");
+
+    value = cf->args->elts;
+
+		ngx_log_debug1(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+		                 "ngx_track_uploads name: %V", value[1]);
+
+    lzcf->shm_zone = ngx_shared_memory_add(cf, &value[1], 0,
+                                           &ngx_http_uploadprogress_module);
+    if (lzcf->shm_zone == NULL) {
+        return NGX_CONF_ERROR;
+    }
+
+		lzcf->track = (u_char)1;
+
+	  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_track_uploads name: %V,szhm_zone: %p", value[1], lzcf->shm_zone);
+
+    return NGX_CONF_OK;
+}
+
+
+static char *
+ngx_http_report_uploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
+{
+    ngx_http_uploadprogress_conf_t  *lzcf = conf;
+    ngx_http_core_loc_conf_t  *clcf;
+    ngx_str_t  *value;
+
+	  ngx_log_debug0(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_report_uploads in");
+
+    value = cf->args->elts;
+
+	  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_report_uploads name: %V", value[1]);
+
+    lzcf->shm_zone = ngx_shared_memory_add(cf, &value[1], 0,
+                                           &ngx_http_uploadprogress_module);
+    if (lzcf->shm_zone == NULL) {
+        return NGX_CONF_ERROR;
+    }
+
+	  ngx_log_debug1(NGX_LOG_DEBUG_HTTP, cf->log, 0,
+	                 "ngx_report_uploads name: %V, szhm_zone: %p", value[1], lzcf->shm_zone);
+
+		lzcf->track = (u_char)0;
+
+		/* install our report handler */
+    clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module);
+    clcf->handler = ngx_http_reportuploads_handler;
+
+    return NGX_CONF_OK;
+}

prj/project.tmproj

@@ -0,0 +1,503 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE plist PUBLIC "-//Apple Computer//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
+<plist version="1.0">
+<dict>
+	<key>currentDocument</key>
+	<string>ngx_http_merge_module.c</string>
+	<key>documents</key>
+	<array>
+		<dict>
+			<key>children</key>
+			<array>
+				<dict>
+					<key>filename</key>
+					<string>config</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T11:20:50Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>ngx_http_merge_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:52:53Z</date>
+					<key>selected</key>
+					<true/>
+				</dict>
+			</array>
+			<key>expanded</key>
+			<true/>
+			<key>name</key>
+			<string>nginx_merge_module</string>
+		</dict>
+		<dict>
+			<key>children</key>
+			<array>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_flv_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T11:26:07Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_access_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:04:10Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_auth_basic_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:04:08Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_autoindex_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:04:05Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_browser_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:04:03Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_dav_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:50:24Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_static_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:51:16Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_addition_filter_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:55:43Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_charset_filter_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_chunked_filter_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_empty_gif_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:50:19Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_fastcgi_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_geo_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:49:52Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_gzip_filter_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:50:47Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_headers_filter_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:19:14Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_index_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:10:29Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_limit_zone_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_log_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_map_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_memcached_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:49:23Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_not_modified_filter_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_proxy_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T14:18:36Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_range_filter_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_realip_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_referer_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_rewrite_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_ssi_filter_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T15:34:37Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_ssi_filter_module.h</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_ssl_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_ssl_module.h</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_stub_status_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:52:53Z</date>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_upstream_ip_hash_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/modules/ngx_http_userid_filter_module.c</string>
+				</dict>
+				<dict>
+					<key>filename</key>
+					<string>../nginx-0.5.15/src/http/ngx_http_core_module.c</string>
+					<key>lastUsed</key>
+					<date>2007-05-18T16:51:26Z</date>
+				</dict>
+			</array>
+			<key>expanded</key>
+			<true/>
+			<key>name</key>
+			<string>nginx</string>
+		</dict>
+	</array>
+	<key>fileHierarchyDrawerWidth</key>
+	<integer>250</integer>
+	<key>metaData</key>
+	<dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_addition_filter_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>21</integer>
+				<key>line</key>
+				<integer>37</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>112</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>18</integer>
+				<key>line</key>
+				<integer>37</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>32</integer>
+				<key>line</key>
+				<integer>37</integer>
+			</dict>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_dav_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>1209</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>691</integer>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_empty_gif_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>0</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>0</integer>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_geo_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>0</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>207</integer>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_gzip_filter_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>130</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>104</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>126</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>130</integer>
+			</dict>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_memcached_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>24</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>378</integer>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_ssi_filter_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>15</integer>
+				<key>line</key>
+				<integer>1885</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>2004</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>12</integer>
+				<key>line</key>
+				<integer>1885</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>15</integer>
+				<key>line</key>
+				<integer>1885</integer>
+			</dict>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_static_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>36</integer>
+				<key>line</key>
+				<integer>90</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>9</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>15</integer>
+				<key>line</key>
+				<integer>90</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>36</integer>
+				<key>line</key>
+				<integer>90</integer>
+			</dict>
+		</dict>
+		<key>../nginx-0.5.15/src/http/modules/ngx_http_stub_status_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>22</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>5</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>17</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>0</integer>
+				<key>line</key>
+				<integer>22</integer>
+			</dict>
+		</dict>
+		<key>../nginx-0.5.15/src/http/ngx_http_core_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>55</integer>
+				<key>line</key>
+				<integer>2637</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>2606</integer>
+		</dict>
+		<key>config</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>70</integer>
+				<key>line</key>
+				<integer>2</integer>
+			</dict>
+			<key>columnSelection</key>
+			<false/>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>0</integer>
+			<key>selectFrom</key>
+			<dict>
+				<key>column</key>
+				<integer>47</integer>
+				<key>line</key>
+				<integer>2</integer>
+			</dict>
+			<key>selectTo</key>
+			<dict>
+				<key>column</key>
+				<integer>70</integer>
+				<key>line</key>
+				<integer>2</integer>
+			</dict>
+		</dict>
+		<key>ngx_http_merge_module.c</key>
+		<dict>
+			<key>caret</key>
+			<dict>
+				<key>column</key>
+				<integer>1</integer>
+				<key>line</key>
+				<integer>91</integer>
+			</dict>
+			<key>firstVisibleColumn</key>
+			<integer>0</integer>
+			<key>firstVisibleLine</key>
+			<integer>228</integer>
+		</dict>
+	</dict>
+	<key>openDocuments</key>
+	<array>
+		<string>config</string>
+		<string>ngx_http_merge_module.c</string>
+		<string>../nginx-0.5.15/src/http/ngx_http_core_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_stub_status_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_static_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_empty_gif_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_ssi_filter_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_memcached_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_geo_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_dav_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_addition_filter_module.c</string>
+		<string>../nginx-0.5.15/src/http/modules/ngx_http_gzip_filter_module.c</string>
+	</array>
+	<key>showFileHierarchyDrawer</key>
+	<true/>
+	<key>windowFrame</key>
+	<string>{{299, 34}, {713, 684}}</string>
+</dict>
+</plist>

prj/tmtags

@@ -0,0 +1,19 @@
+!_TAG_FILE_FORMAT	2	/extended format; --format=1 will not append ;" to lines/
+!_TAG_FILE_SORTED	1	/0=unsorted, 1=sorted, 2=foldcase/
+!_TAG_PROGRAM_AUTHOR	Darren Hiebert	/dhiebert@users.sourceforge.net/
+!_TAG_PROGRAM_NAME	Exuberant Ctags	//
+!_TAG_PROGRAM_URL	http://ctags.sourceforge.net	/official site/
+!_TAG_PROGRAM_VERSION	5.5.4	//
+get_tracking_id	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^get_tracking_id(ngx_http_request_t *r)$/;"	function	line:68
+ngx_http_reportuploads	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_reportuploads(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)$/;"	function	line:221
+ngx_http_reportuploads_handler	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_reportuploads_handler(ngx_http_request_t *r)$/;"	function	line:99
+ngx_http_rewrite_loc_conf_t	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^} ngx_http_rewrite_loc_conf_t;$/;"	typedef	line:13
+ngx_http_uploadprogress_commands	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^static ngx_command_t  ngx_http_uploadprogress_commands[] = {$/;"	variable	line:15
+ngx_http_uploadprogress_create_loc_conf	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_uploadprogress_create_loc_conf(ngx_conf_t *cf)$/;"	function	line:209
+ngx_http_uploadprogress_handler	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_uploadprogress_handler(ngx_http_request_t *r)$/;"	function	line:156
+ngx_http_uploadprogress_init	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_uploadprogress_init(ngx_conf_t *cf)$/;"	function	line:191
+ngx_http_uploadprogress_merge_loc_conf	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_http_uploadprogress_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child)$/;"	function	line:234
+ngx_http_uploadprogress_module	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^ngx_module_t  ngx_http_uploadprogress_module = {$/;"	variable	line:51
+ngx_http_uploadprogress_module_ctx	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^static ngx_http_module_t  ngx_http_uploadprogress_module_ctx = {$/;"	variable	line:36
+report_upload	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^    ngx_flag_t    report_upload;$/;"	member	line:12
+track_upload	/Users/brice/devl/nginx_uploadprogress_module/ngx_http_uploadprogress_module.c	/^    ngx_flag_t    track_upload;$/;"	member	line:11