Re: Сбор статистики о файле

[ForJest <forjest@xxxxxxxxx>]

Игорь, я пытаюсь написать модуль для тела ответа, но пока не могу его
активировать.
Т.е. я уже научился компилировать его, включил в конфигурацию и т.п., но
в цепочку судя по логу не попадает.
Остальные дебаг печать попадают нормально.
Пожалуйста посоветуйте - что я делаю неверно?

Я пытаюсь сделать чтобы передавалось имя файла в модуль, и если оно
есть, то активировался этот модуль. Я планирую туда запихать
переменные из rewrite впоследствии.

Ещё вопрос - как правильно включить debug логи? Если просто сделать
error_log debug, то там светися только accept и т.п., мне пришлось
сделать хак небольшой:

log->log_level = NGX_LOG_DEBUG_HTTP | NGX_LOG_DEBUG_EVENT | NGX_LOG_DEBUG_CORE;
Но я вижу
static const char *debug_levels[] = {
    "debug_core", "debug_alloc", "debug_mutex", "debug_event",
    "debug_http", "debug_imap"
};
Но не знаю куда это и как вставить правильно.
On 4/11/06, Igor Sysoev <is@xxxxxxxxxxxxx> wrote:
> On Mon, 10 Apr 2006, ForJest wrote:
>
> > У меня возникла задача собирать статитстику об отдаваемом файле и
> > записывать её в отдельный файл/или передавать какому-нибудь демону,
> > раз, в допустим, 1-2 секунды.
> > Характеристики:
> > - Сколько отдано на данный момент байтов
> > - Скорость последняя отдачи файла
> > - Скорость усреднённая соединения
> > и т.п.
> >
> > Система FreeBSD 5.4, используется ограничение по скорости через 
> > x-limit-rate.
> >
> > Где лучше это вставить/какой модуль ковырять? Я, конечно, со временем
> > разберусь в коде, но думаю Вы можете существенно сократить время моих
> > поисков.
>
> Скорее всего, нужно писать фильтр для тела ответа.
>
>
> Игорь Сысоев
> http://sysoev.ru
>
>
/*
 * Copyright (C) Igor Sysoev
 */


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

typedef struct {
    ngx_str_t   request_stats_filename;
} ngx_http_request_stats_conf_t;

static ngx_int_t ngx_http_request_stats_filter_init(ngx_cycle_t *cycle);
static void *ngx_http_request_stats_create_conf(ngx_conf_t *cf);

static ngx_command_t  ngx_http_request_stats_commands[] = {

    { ngx_string("request_stats_filename"),
      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
      ngx_conf_set_str_slot,
      NGX_HTTP_LOC_CONF_OFFSET,
      offsetof(ngx_http_request_stats_conf_t, request_stats_filename),
      NULL },

      ngx_null_command
};

static ngx_http_module_t  ngx_http_request_stats_filter_module_ctx = {
    NULL,                                  /* preconfiguration */
    NULL,                                  /* postconfiguration */

    NULL,                                  /* create main configuration */
    NULL,                                  /* init main configuration */

    NULL,                                  /* create server configuration */
    NULL,                                  /* merge server configuration */

    ngx_http_request_stats_create_conf,         /* create location
configuration */
    NULL                                   /* merge location configuration */
};


ngx_module_t  ngx_http_request_stats_filter_module = {
    NGX_MODULE_V1,
    &ngx_http_request_stats_filter_module_ctx,  /* module context */
    ngx_http_request_stats_commands,            /* module directives */
    NGX_HTTP_MODULE,                       /* module type */
    NULL,                                  /* init master */
    ngx_http_request_stats_filter_init,         /* init module */
    NULL,                                  /* init process */
    NULL,                                  /* init thread */
    NULL,                                  /* exit thread */
    NULL,                                  /* exit process */
    NULL,                                  /* exit master */
    NGX_MODULE_V1_PADDING
};

static ngx_http_output_body_filter_pt    ngx_http_next_body_filter;

static ngx_int_t
ngx_http_request_stats_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
{
     ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
                   "request stats %d", ngx_time());
     return ngx_http_next_body_filter(r, in);
}

static ngx_int_t
ngx_http_request_stats_filter_init(ngx_cycle_t *cycle)
{
    ngx_http_next_body_filter = ngx_http_top_body_filter;
    ngx_http_top_body_filter = ngx_http_request_stats_body_filter;
    return NGX_OK;
}

static void *
ngx_http_request_stats_create_conf(ngx_conf_t *cf)
{
    ngx_http_request_stats_conf_t  *conf;

    conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_request_stats_conf_t));
    if (conf == NULL) {
        return NGX_CONF_ERROR;
    }
    return conf;
}