PUT и POST module handler

[rba]

Здравствуйте.
Почитал форум, посмотрел исходники и сообразил до некоторого порядка
обработки данных запросов. Остались некоторые вопросы. Понимаю что ответы
можно найти в исходниках(echo,dav и.т.д.)  но силы и терпение на исходе
поэтому прошу помощи.

На малых запросах всё работает, вопросы связаны с тем что будет на больших
запросах при реальной нагрузке
/**********************************************************
Вопросы в контексте кода модуля типа «hello word» 
**********************************************************/

#include <ngx_config.h>
#include <ngx_core.h>
#include <ngx_http.h>

static ngx_command_t  ngx_http_rbsample_commands[] = {
  { ngx_string("rbsample_pqtest"),
    NGX_HTTP_LOC_CONF|NGX_CONF_NOARGS,
    ngx_http_rbsample,
    0,
    0,
    NULL },
    ngx_null_command
};

static ngx_http_module_t  ngx_http_rbsample_module_ctx = {
  NULL,
  ...
  NULL
};

ngx_module_t ngx_http_rbsample_module = {
  NGX_MODULE_V1,
  &ngx_http_rbsample_module_ctx, /* module context */
  ngx_http_rbsample_commands,    /* module directives */
  NGX_HTTP_MODULE,               /* module type */
  NULL,                          /* init master */
  ...
  NULL,                          /* exit master */
  NGX_MODULE_V1_PADDING
};


static 
ngx_int_t ngx_http_rbsample_other_handler(ngx_http_request_t *r)
{/*...*/}

static void
ngx_http_rbsample_debug(ngx_http_request_t *r, u_char *buffer, int nbytes)
{//Это заглушка, в будущем некоторая неблокирующая функция отправляющая в
специфичный бэкенд
/**********************************************************
1. ngx_log_debug1 вроде выводит buffer и без завершения \0 или стоит
дополнять конструкцией типа
        u_char       *p;
        p = ngx_pnalloc(r->pool, nbytes+1);
        p = ngx_cpymem(p, buffer, nbytes+1);
        p[nbytes+1]='\0';
    ...и выводить p
**********************************************************/
    ngx_log_debug1(NGX_LOG_DEBUG_EVENT, r->connection->log, 0, "RBSAMPLE 2.
put/post: \"%s\"", buffer);
}

static void
ngx_http_rbsample_post_handler(ngx_http_request_t *r)
{
    size_t        len;
    ngx_buf_t    *buf;
    ngx_chain_t  *cl;

    if (r->request_body == NULL && r->request_body->temp_file == NULL) {
        ngx_log_debug(NGX_LOG_DEBUG_EVENT, r->connection->log, 0, "RBSAMPLE
999. error put/post!!!!");
        ngx_http_finalize_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
        return;
    }
    ngx_log_debug(NGX_LOG_DEBUG_EVENT, r->connection->log, 0, "RBSAMPLE 1.
put/post!!!!");

/**********************************************************
  2. Не блокернёт ли следующий цикл воркер непрерывным чтением большого
буфера, если ngx_http_rbsample_debug(сейчас заглушка) не блокирующая, 
        или желательно после каждого cl->next как-то отдавать управление? 
  3. Будет ли порядок обработки тем же, если nginx положит тело запроса в
файл?
  4. Как можно отдать управление воркеру(что вернуть из текущего хэндлера) и
отложить обработку ngx_http_rbsample_debug, не трогая буфер, не завершая
запрос и не передавая обработку остальным хэндлерам в текущем запросе?
  4.1. Чтобы в новом витке воркера вернуться к текущему запросу и cl, нужно
его(cl) выносить в глобальное пространство(есть ли какие-то особенности в
nginx?) или есть иные принятые в nginx способы?
**********************************************************/
    cl = r->request_body->bufs;
    do {
        buf = cl->buf;
        len = buf->last - buf->pos;
        ngx_http_rbsample_debug(r, buf->pos, len);        

        cl = cl->next;
    } while (cl);

    if(!r->request_body->rest) {
        ngx_http_finalize_request(r, 0);;
    }
    return;
}

static ngx_int_t
ngx_http_rbsample_handler(ngx_http_request_t *r)
{
    ngx_int_t                 rc;
    ngx_log_debug(NGX_LOG_DEBUG_EVENT, r->connection->log, 0, "rbsample 0.
ngx_http_rbsample_handler!");

    if(r->method == NGX_HTTP_PUT || r->method == NGX_HTTP_POST) {
        r->request_body_in_file_only = 0;
        r->request_body_in_single_buf=1;

/*********************************************************
5. Корректно ли так подключать обработчик POST/PUT в таком контексте, или
лучше его делать фазовым?
**********************************************************/
        rc = ngx_http_read_client_request_body(r,
ngx_http_rbsample_post_handler);
        if (rc >= NGX_HTTP_SPECIAL_RESPONSE) {
            return rc;
        }
        return NGX_DONE;
    }
    return ngx_http_rbsample_other_handler(r);
}

static char *
ngx_http_rbsample(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_core_loc_conf_t *clcf;
    clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module);
    clcf->handler = ngx_http_rbsample_handler;
    return NGX_CONF_OK;
}

Posted at Nginx Forum: http://forum.nginx.org/read.php?21,262136,262136#msg-262136