diff -ur nginx-1.2.1/src/core/nginx.h nginx-1.2.1-patched/src/core/nginx.h --- nginx-1.2.1/src/core/nginx.h 2011-08-29 17:30:22.000000000 +0800 +++ nginx-1.2.1-patched/src/core/nginx.h 2011-09-13 12:11:03.135622101 +0800 @@ -10,7 +10,7 @@ #define nginx_version 1002001 #define NGINX_VERSION "1.2.1" -#define NGINX_VER "ngx_openresty/" NGINX_VERSION ".unknown" +#define NGINX_VER "ngx_openresty/" NGINX_VERSION ".unknown (no pool)" #define NGINX_VAR "NGINX" diff -urx '*~' -x '*.swp' nginx-1.2.1/src/core/ngx_array.c nginx-1.2.1-patched/src/core/ngx_array.c --- nginx-1.2.1/src/core/ngx_array.c 2012-02-06 04:02:59.000000000 +0800 +++ nginx-1.2.1-patched/src/core/ngx_array.c 2012-06-04 20:11:32.494144287 +0800 @@ -40,13 +40,11 @@ p = a->pool; - if ((u_char *) a->elts + a->size * a->nalloc == p->d.last) { - p->d.last -= a->size * a->nalloc; + if (a->elts) { + ngx_pfree(p, a->elts); } - if ((u_char *) a + sizeof(ngx_array_t) == p->d.last) { - p->d.last = (u_char *) a; - } + ngx_pfree(p, a); } @@ -65,29 +63,19 @@ p = a->pool; - if ((u_char *) a->elts + size == p->d.last - && p->d.last + a->size <= p->d.end) - { - /* - * the array allocation is the last in the pool - * and there is space for new allocation - */ - - p->d.last += a->size; - a->nalloc++; - - } else { - /* allocate a new array */ - - new = ngx_palloc(p, 2 * size); - if (new == NULL) { - return NULL; - } - - ngx_memcpy(new, a->elts, size); - a->elts = new; - a->nalloc *= 2; + /* allocate a new array */ + + new = ngx_palloc(p, 2 * size); + if (new == NULL) { + return NULL; } + + ngx_memcpy(new, a->elts, size); + + ngx_pfree(p, a->elts); + + a->elts = new; + a->nalloc *= 2; } elt = (u_char *) a->elts + a->size * a->nelts; @@ -101,43 +89,28 @@ ngx_array_push_n(ngx_array_t *a, ngx_uint_t n) { void *elt, *new; - size_t size; ngx_uint_t nalloc; ngx_pool_t *p; - size = n * a->size; - if (a->nelts + n > a->nalloc) { /* the array is full */ p = a->pool; - if ((u_char *) a->elts + a->size * a->nalloc == p->d.last - && p->d.last + size <= p->d.end) - { - /* - * the array allocation is the last in the pool - * and there is space for new allocation - */ - - p->d.last += size; - a->nalloc += n; - - } else { - /* allocate a new array */ - - nalloc = 2 * ((n >= a->nalloc) ? n : a->nalloc); - - new = ngx_palloc(p, nalloc * a->size); - if (new == NULL) { - return NULL; - } - - ngx_memcpy(new, a->elts, a->nelts * a->size); - a->elts = new; - a->nalloc = nalloc; + nalloc = 2 * ((n >= a->nalloc) ? n : a->nalloc); + + new = ngx_palloc(p, nalloc * a->size); + if (new == NULL) { + return NULL; } + + ngx_memcpy(new, a->elts, a->nelts * a->size); + + ngx_pfree(p, a->elts); + + a->elts = new; + a->nalloc = nalloc; } elt = (u_char *) a->elts + a->size * a->nelts; diff -urx '*~' -x '*.swp' nginx-1.2.1/src/core/ngx_palloc.c nginx-1.2.1-patched/src/core/ngx_palloc.c --- nginx-1.2.1/src/core/ngx_palloc.c 2012-02-06 04:02:59.000000000 +0800 +++ nginx-1.2.1-patched/src/core/ngx_palloc.c 2012-06-04 20:02:26.667925891 +0800 @@ -9,32 +9,23 @@ #include -static void *ngx_palloc_block(ngx_pool_t *pool, size_t size); -static void *ngx_palloc_large(ngx_pool_t *pool, size_t size); - - ngx_pool_t * ngx_create_pool(size_t size, ngx_log_t *log) { - ngx_pool_t *p; + ngx_pool_t *p; - p = ngx_memalign(NGX_POOL_ALIGNMENT, size, log); + size = sizeof(ngx_pool_t); + p = ngx_alloc(size, log); if (p == NULL) { return NULL; } - p->d.last = (u_char *) p + sizeof(ngx_pool_t); - p->d.end = (u_char *) p + size; - p->d.next = NULL; - p->d.failed = 0; + ngx_memzero(p, size); size = size - sizeof(ngx_pool_t); p->max = (size < NGX_MAX_ALLOC_FROM_POOL) ? size : NGX_MAX_ALLOC_FROM_POOL; p->current = p; - p->chain = NULL; - p->large = NULL; - p->cleanup = NULL; p->log = log; return p; @@ -44,8 +35,7 @@ void ngx_destroy_pool(ngx_pool_t *pool) { - ngx_pool_t *p, *n; - ngx_pool_large_t *l; + ngx_pool_data_t *d, *n; ngx_pool_cleanup_t *c; for (c = pool->cleanup; c; c = c->next) { @@ -56,13 +46,9 @@ } } - for (l = pool->large; l; l = l->next) { - - ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, pool->log, 0, "free: %p", l->alloc); - - if (l->alloc) { - ngx_free(l->alloc); - } + if (pool->d == NULL) { + ngx_free(pool); + return; } #if (NGX_DEBUG) @@ -72,9 +58,9 @@ * so we cannot use this log while free()ing the pool */ - for (p = pool, n = pool->d.next; /* void */; p = n, n = n->d.next) { + for (d = pool->d, n = d->next; ; d = n, n = n->next) { ngx_log_debug2(NGX_LOG_DEBUG_ALLOC, pool->log, 0, - "free: %p, unused: %uz", p, p->d.end - p->d.last); + "free: %p, unused: %d", d, 0); if (n == NULL) { break; @@ -83,172 +69,82 @@ #endif - for (p = pool, n = pool->d.next; /* void */; p = n, n = n->d.next) { - ngx_free(p); + for (d = pool->d, n = d->next; ; d = n, n = n->next) { + ngx_free(d->alloc); + ngx_free(d); if (n == NULL) { break; } } -} + pool->d = NULL; -void -ngx_reset_pool(ngx_pool_t *pool) -{ - ngx_pool_t *p; - ngx_pool_large_t *l; - - for (l = pool->large; l; l = l->next) { - if (l->alloc) { - ngx_free(l->alloc); - } - } - - pool->large = NULL; - - for (p = pool; p; p = p->d.next) { - p->d.last = (u_char *) p + sizeof(ngx_pool_t); - } + ngx_free(pool); } -void * -ngx_palloc(ngx_pool_t *pool, size_t size) +void +ngx_reset_pool(ngx_pool_t *pool) { - u_char *m; - ngx_pool_t *p; - - if (size <= pool->max) { + ngx_pool_data_t *d, *n; + ngx_pool_data_t *saved = NULL; - p = pool->current; - - do { - m = ngx_align_ptr(p->d.last, NGX_ALIGNMENT); - - if ((size_t) (p->d.end - m) >= size) { - p->d.last = m + size; - - return m; + if (pool->d) { + for (d = pool->d, n = d->next; ; d = n, n = n->next) { + if (d->alloc == pool->log) { + saved = d; + continue; } - p = p->d.next; - - } while (p); - - return ngx_palloc_block(pool, size); - } - - return ngx_palloc_large(pool, size); -} - + ngx_free(d->alloc); + ngx_free(d); -void * -ngx_pnalloc(ngx_pool_t *pool, size_t size) -{ - u_char *m; - ngx_pool_t *p; - - if (size <= pool->max) { - - p = pool->current; - - do { - m = p->d.last; - - if ((size_t) (p->d.end - m) >= size) { - p->d.last = m + size; - - return m; + if (n == NULL) { + break; } + } - p = p->d.next; - - } while (p); - - return ngx_palloc_block(pool, size); + pool->d = saved; } - - return ngx_palloc_large(pool, size); } -static void * -ngx_palloc_block(ngx_pool_t *pool, size_t size) +void * +ngx_malloc(ngx_pool_t *pool, size_t size) { - u_char *m; - size_t psize; - ngx_pool_t *p, *new, *current; + ngx_pool_data_t *new; + void *m; - psize = (size_t) (pool->d.end - (u_char *) pool); - - m = ngx_memalign(NGX_POOL_ALIGNMENT, psize, pool->log); + m = ngx_alloc(size, pool->log); if (m == NULL) { return NULL; } - new = (ngx_pool_t *) m; - - new->d.end = m + psize; - new->d.next = NULL; - new->d.failed = 0; - - m += sizeof(ngx_pool_data_t); - m = ngx_align_ptr(m, NGX_ALIGNMENT); - new->d.last = m + size; - - current = pool->current; - - for (p = current; p->d.next; p = p->d.next) { - if (p->d.failed++ > 4) { - current = p->d.next; - } + new = ngx_alloc(sizeof(ngx_pool_data_t), pool->log); + if (new == NULL){ + ngx_free(m); + return NULL; } - p->d.next = new; - - pool->current = current ? current : new; - + new->alloc = m; + new->next = pool->d; + pool->d = new; return m; } -static void * -ngx_palloc_large(ngx_pool_t *pool, size_t size) +void * +ngx_palloc(ngx_pool_t *pool, size_t size) { - void *p; - ngx_uint_t n; - ngx_pool_large_t *large; - - p = ngx_alloc(size, pool->log); - if (p == NULL) { - return NULL; - } - - n = 0; - - for (large = pool->large; large; large = large->next) { - if (large->alloc == NULL) { - large->alloc = p; - return p; - } - - if (n++ > 3) { - break; - } - } - - large = ngx_palloc(pool, sizeof(ngx_pool_large_t)); - if (large == NULL) { - ngx_free(p); - return NULL; - } + return ngx_malloc(pool, size); +} - large->alloc = p; - large->next = pool->large; - pool->large = large; - return p; +void * +ngx_pnalloc(ngx_pool_t *pool, size_t size) +{ + return ngx_malloc(pool, size); } @@ -263,7 +159,7 @@ return NULL; } - large = ngx_palloc(pool, sizeof(ngx_pool_large_t)); + large = ngx_malloc(pool, sizeof(ngx_pool_large_t)); if (large == NULL) { ngx_free(p); return NULL; @@ -278,16 +174,27 @@ ngx_int_t -ngx_pfree(ngx_pool_t *pool, void *p) +ngx_pfree(ngx_pool_t *pool, void *data) { - ngx_pool_large_t *l; + ngx_pool_data_t *p, *d; - for (l = pool->large; l; l = l->next) { - if (p == l->alloc) { - ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, pool->log, 0, - "free: %p", l->alloc); - ngx_free(l->alloc); - l->alloc = NULL; + p = NULL; + for (d = pool->d; d; p = d, d = d->next) { + if (data == d->alloc) { + + ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, pool->log, 0, "free: %p", d->alloc); + + ngx_free(d->alloc); + d->alloc = NULL; + + if (p) { + p->next = d->next; + + } else { + pool->d = d->next; + } + + ngx_free(d); return NGX_OK; } diff -urx '*~' -x '*.swp' nginx-1.2.1/src/core/ngx_palloc.h nginx-1.2.1-patched/src/core/ngx_palloc.h --- nginx-1.2.1/src/core/ngx_palloc.h 2012-02-06 04:02:59.000000000 +0800 +++ nginx-1.2.1-patched/src/core/ngx_palloc.h 2012-06-04 19:39:32.803578356 +0800 @@ -39,6 +39,8 @@ typedef struct ngx_pool_large_s ngx_pool_large_t; +typedef struct ngx_pool_data_s ngx_pool_data_t; + struct ngx_pool_large_s { ngx_pool_large_t *next; @@ -46,16 +48,14 @@ }; -typedef struct { - u_char *last; - u_char *end; - ngx_pool_t *next; - ngx_uint_t failed; -} ngx_pool_data_t; +struct ngx_pool_data_s { + ngx_pool_data_t *next; + void *alloc; +}; struct ngx_pool_s { - ngx_pool_data_t d; + ngx_pool_data_t *d; size_t max; ngx_pool_t *current; ngx_chain_t *chain;