Mercurial > hg > nginx-quic
view src/core/ngx_hunk.c @ 164:84036764e215
nginx-0.0.1-2003-10-29-11:30:44 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 29 Oct 2003 08:30:44 +0000 |
parents | e7e094d34162 |
children | 389d7ee9fa60 |
line wrap: on
line source
#include <ngx_config.h> #include <ngx_core.h> ngx_hunk_t *ngx_create_temp_hunk(ngx_pool_t *pool, int size, int before, int after) { ngx_hunk_t *h; ngx_test_null(h, ngx_palloc(pool, sizeof(ngx_hunk_t)), NULL); ngx_test_null(h->pre_start, ngx_palloc(pool, size + before + after), NULL); h->start = h->pos = h->last = h->pre_start + before; h->file_pos = h->file_last = 0; h->end = h->last + size; h->post_end = h->end + after; h->type = NGX_HUNK_TEMP|NGX_HUNK_IN_MEMORY; h->file = NULL; h->shadow = NULL; h->tag = 0; return h; } ngx_chain_t *ngx_create_chain_of_hunks(ngx_pool_t *pool, ngx_bufs_t *bufs) { int i; char *p; ngx_hunk_t *h; ngx_chain_t *chain, *cl, **ll; ngx_test_null(p, ngx_palloc(pool, bufs->num * bufs->size), NULL); ll = &chain; for (i = 0; i < bufs->num; i++) { ngx_test_null(h, ngx_alloc_hunk(pool), NULL); h->pos = p; h->last = p; h->file_pos = 0; h->file_last = 0; h->type = NGX_HUNK_IN_MEMORY|NGX_HUNK_TEMP; h->start = p; p += bufs->size; h->end = p; h->file = NULL; h->shadow = NULL; h->tag = 0; ngx_test_null(cl, ngx_alloc_chain_link(pool), NULL); cl->hunk = h; *ll = cl; ll = &cl->next; } *ll = NULL; return chain; } ngx_hunk_t *ngx_create_hunk_before(ngx_pool_t *pool, ngx_hunk_t *hunk, int size) { ngx_hunk_t *h; ngx_test_null(h, ngx_palloc(pool, sizeof(ngx_hunk_t)), NULL); if (hunk->type & NGX_HUNK_TEMP && hunk->pos - hunk->pre_start >= size) { /* keep hunk->start unchanged - used in restore */ h->pre_start = hunk->pre_start; h->end = h->post_end = hunk->pre_start = hunk->pos; h->start = h->pos = h->last = h->end - size; h->file_pos = h->file_last = 0; h->type = NGX_HUNK_TEMP|NGX_HUNK_IN_MEMORY; h->file = NULL; h->shadow = NULL; h->tag = 0; } else { ngx_test_null(h->pre_start, ngx_palloc(pool, size), NULL); h->start = h->pos = h->last = h->pre_start; h->end = h->post_end = h->start + size; h->file_pos = h->file_last = 0; h->type = NGX_HUNK_TEMP|NGX_HUNK_IN_MEMORY; h->file = NULL; h->shadow = NULL; h->tag = 0; } return h; } ngx_hunk_t *ngx_create_hunk_after(ngx_pool_t *pool, ngx_hunk_t *hunk, int size) { ngx_hunk_t *h; ngx_test_null(h, ngx_palloc(pool, sizeof(ngx_hunk_t)), NULL); if (hunk->type & NGX_HUNK_TEMP && hunk->last == hunk->end && hunk->post_end - hunk->end >= size) { h->post_end = hunk->post_end; h->pre_start = h->start = h->pos = h->last = hunk->post_end = hunk->last; h->file_pos = h->file_last = 0; h->type = NGX_HUNK_TEMP|NGX_HUNK_IN_MEMORY; h->file = NULL; h->shadow = NULL; h->tag = 0; } else { ngx_test_null(h->pre_start, ngx_palloc(pool, size), NULL); h->start = h->pos = h->last = h->pre_start; h->end = h->post_end = h->start + size; h->file_pos = h->file_last = 0; h->type = NGX_HUNK_TEMP|NGX_HUNK_IN_MEMORY; h->file = NULL; h->shadow = NULL; h->tag = 0; } return h; } int ngx_chain_add_copy(ngx_pool_t *pool, ngx_chain_t **chain, ngx_chain_t *in) { ngx_chain_t *cl, **ll; ll = chain; for (cl = *chain; cl; cl = cl->next) { ll = &cl->next; } while (in) { ngx_test_null(cl, ngx_alloc_chain_link(pool), NGX_ERROR); cl->hunk = in->hunk; *ll = cl; ll = &cl->next; in = in->next; } *ll = NULL; return NGX_OK; } void ngx_chain_update_chains(ngx_chain_t **free, ngx_chain_t **busy, ngx_chain_t **out, ngx_hunk_tag_t tag) { ngx_chain_t *te; if (*busy == NULL) { *busy = *out; } else { for (te = *busy; /* void */ ; te = te->next) { if (te->next == NULL) { te->next = *out; break; } } } *out = NULL; while (*busy) { if (ngx_hunk_size((*busy)->hunk) > 0) { break; } #if (HAVE_WRITE_ZEROCOPY) if ((*busy)->hunk->type & NGX_HUNK_ZEROCOPY_BUSY) { break; } #endif if ((*busy)->hunk->tag != tag) { *busy = (*busy)->next; continue; } (*busy)->hunk->pos = (*busy)->hunk->last = (*busy)->hunk->start; te = *busy; *busy = (*busy)->next; te->next = *free; *free = te; } }