diff options
author | osa <osa@FreeBSD.org> | 2011-12-08 21:03:33 +0800 |
---|---|---|
committer | osa <osa@FreeBSD.org> | 2011-12-08 21:03:33 +0800 |
commit | e51cde2599f3dfe7436347cb9e3d298fedf9f628 (patch) | |
tree | 02f5fd3d0f0c2b16f93451bd241883294dc3b4fa | |
parent | 412ab17cc6bf515905fd8487c0ace2dc29e6be5c (diff) | |
download | freebsd-ports-gnome-e51cde2599f3dfe7436347cb9e3d298fedf9f628.tar.gz freebsd-ports-gnome-e51cde2599f3dfe7436347cb9e3d298fedf9f628.tar.zst freebsd-ports-gnome-e51cde2599f3dfe7436347cb9e3d298fedf9f628.zip |
Merge latest changes for third-party udplog module from upstream
at https://raw.github.com/vkholodkov/nginx-udplog-module/.
Do not bump PORTREVISION because this module disabled by default.
Feature safe: yes
PR: 163023
-rw-r--r-- | www/nginx-devel/files/extra-patch-ngx_http_udplog_module.c | 416 | ||||
-rw-r--r-- | www/nginx/files/extra-patch-ngx_http_udplog_module.c | 416 |
2 files changed, 824 insertions, 8 deletions
diff --git a/www/nginx-devel/files/extra-patch-ngx_http_udplog_module.c b/www/nginx-devel/files/extra-patch-ngx_http_udplog_module.c index 3a369c21a272..a97325abfa31 100644 --- a/www/nginx-devel/files/extra-patch-ngx_http_udplog_module.c +++ b/www/nginx-devel/files/extra-patch-ngx_http_udplog_module.c @@ -1,6 +1,161 @@ ---- ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c.orig 2010-01-11 19:16:46.000000000 +0300 -+++ ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c 2010-01-11 19:20:17.000000000 +0300 -@@ -280,7 +280,7 @@ +--- ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c.orig 2010-01-05 20:20:35.000000000 +0100 ++++ ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c 2011-12-02 18:31:18.000000000 +0100 +@@ -1,4 +1,3 @@ +- + /* + * Copyright (C) 2010 Valery Kholodkov + * +@@ -45,6 +44,12 @@ + } ngx_http_log_fmt_t; + + typedef struct { ++ ngx_str_t value; ++ ngx_array_t *lengths; ++ ngx_array_t *values; ++} ngx_http_log_tag_template_t; ++ ++typedef struct { + ngx_array_t formats; /* array of ngx_http_log_fmt_t */ + ngx_uint_t combined_used; /* unsigned combined_used:1 */ + } ngx_http_log_main_conf_t; +@@ -64,8 +69,7 @@ + typedef struct { + ngx_udp_endpoint_t *endpoint; + ngx_http_log_fmt_t *format; +- ngx_uint_t facility; +- ngx_uint_t severity; ++ ngx_uint_t bare:1; + } ngx_http_udplog_t; + + typedef struct { +@@ -73,8 +77,11 @@ + } ngx_http_udplog_main_conf_t; + + typedef struct { +- ngx_array_t *logs; /* array of ngx_http_udplog_t */ +- unsigned off; ++ ngx_array_t *logs; /* array of ngx_http_udplog_t */ ++ unsigned off; ++ ngx_http_log_tag_template_t *tag; ++ ngx_uint_t facility; ++ ngx_uint_t severity; + } ngx_http_udplog_conf_t; + + ngx_int_t ngx_udp_connect(ngx_udp_connection_t *uc); +@@ -88,6 +95,8 @@ + void *child); + + static char *ngx_http_udplog_set_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); ++static char *ngx_http_udplog_set_priority(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); ++static char *ngx_http_udplog_set_tag(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); + + static ngx_int_t ngx_http_udplog_init(ngx_conf_t *cf); + +@@ -96,12 +105,26 @@ + + { ngx_string("access_udplog"), + NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_HTTP_LIF_CONF +- |NGX_HTTP_LMT_CONF|NGX_CONF_TAKE123, ++ |NGX_HTTP_LMT_CONF|NGX_CONF_TAKE1234, + ngx_http_udplog_set_log, + NGX_HTTP_LOC_CONF_OFFSET, + 0, + NULL }, + ++ { ngx_string("udplog_priority"), ++ NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE12, ++ ngx_http_udplog_set_priority, ++ NGX_HTTP_LOC_CONF_OFFSET, ++ 0, ++ NULL }, ++ ++ { ngx_string("udplog_tag"), ++ NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ++ ngx_http_udplog_set_tag, ++ NGX_HTTP_LOC_CONF_OFFSET, ++ offsetof(ngx_http_udplog_conf_t, tag), ++ NULL }, ++ + ngx_null_command + }; + +@@ -166,7 +189,7 @@ + { ngx_null_string, 0 } + }; + +-static ngx_udplog_severity_t ngx_udplog_severity[] = { ++static ngx_udplog_severity_t ngx_udplog_severities[] = { + { ngx_string("emerg"), 0 }, + { ngx_string("alert"), 1 }, + { ngx_string("crit"), 2 }, +@@ -190,6 +213,7 @@ + u_char *line, *p; + size_t len; + ngx_uint_t i, l, pri; ++ ngx_str_t tag; + ngx_http_udplog_t *log; + ngx_http_log_op_t *op; + ngx_http_udplog_conf_t *ulcf; +@@ -205,12 +229,31 @@ + return NGX_OK; + } + ++ if(ulcf->tag != NULL) ++ { ++ if(ulcf->tag->lengths == NULL) { ++ tag = ulcf->tag->value; ++ } ++ else{ ++ if (ngx_http_script_run(r, &tag, ulcf->tag->lengths->elts, 0, ulcf->tag->values->elts) ++ == NULL) ++ { ++ return NGX_ERROR; ++ } ++ } ++ } ++ else { ++ tag.data = (u_char*)"nginx"; ++ tag.len = sizeof("nginx") - 1; ++ } ++ + time = ngx_time(); + ngx_gmtime(time, &tm); + + log = ulcf->logs->elts; ++ pri = ulcf->facility * 8 + ulcf->severity; ++ + for (l = 0; l < ulcf->logs->nelts; l++) { +- pri = log[l].facility * 8 + log[l].severity; + + if(pri > 255) { + pri = NGX_UDPLOG_FACILITY_LOCAL7 * 8 + NGX_UDPLOG_SEVERITY_INFO; +@@ -231,7 +274,8 @@ + } + } + +- len += sizeof("<255>") - 1 + sizeof("Jan 31 00:00:00") - 1 + 1 + ngx_cycle->hostname.len + 1; ++ len += sizeof("<255>") - 1 + sizeof("Jan 31 00:00:00") - 1 + 1 + ngx_cycle->hostname.len + 1 ++ + tag.len + 2; + + #if defined nginx_version && nginx_version >= 7003 + line = ngx_pnalloc(r->pool, len); +@@ -245,9 +289,12 @@ + /* + * BSD syslog message header (see RFC 3164) + */ +- p = ngx_sprintf(line, "<%ui>%s %2d %02d:%02d:%02d %V ", pri, months[tm.ngx_tm_mon - 1], tm.ngx_tm_mday, +- tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec, &ngx_cycle->hostname); +- ++ if(!log[l].bare){ ++ p = ngx_sprintf(line, "<%ui>%s %2d %02d:%02d:%02d %V %V: ", pri, months[tm.ngx_tm_mon - 1], tm.ngx_tm_mday, ++ tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec, &ngx_cycle->hostname, &tag); ++ }else{ ++ p = line; ++ } + for (i = 0; i < log[l].format->ops->nelts; i++) { + p = op[i].run(r, p, &op[i]); + } +@@ -280,10 +327,15 @@ uc->sockaddr = endpoint->peer_addr.sockaddr; uc->socklen = endpoint->peer_addr.socklen; uc->server = endpoint->peer_addr.name; @@ -9,7 +164,27 @@ uc->log = &cf->cycle->new_log; #else uc->log = cf->cycle->new_log; -@@ -335,7 +335,11 @@ ++#if defined nginx_version && nginx_version >= 8032 ++ uc->log.handler = NULL; ++ uc->log.data = NULL; ++ uc->log.action = "logging"; ++#endif + #endif + + return NGX_OK; +@@ -320,6 +372,11 @@ + + if (uc->connection == NULL) { + if(ngx_udp_connect(uc) != NGX_OK) { ++ if(uc->connection != NULL) { ++ ngx_free_connection(uc->connection); ++ uc->connection = NULL; ++ } ++ + return NGX_ERROR; + } + +@@ -335,7 +392,11 @@ } if ((size_t) n != (size_t) len) { @@ -21,3 +196,236 @@ return NGX_ERROR; } +@@ -364,6 +425,9 @@ + if (conf == NULL) { + return NGX_CONF_ERROR; + } ++ conf->off = 1; ++ conf->facility = NGX_CONF_UNSET_UINT; ++ conf->severity = NGX_CONF_UNSET_UINT; + + return conf; + } +@@ -374,37 +438,21 @@ + ngx_http_udplog_conf_t *prev = parent; + ngx_http_udplog_conf_t *conf = child; + +- ngx_http_udplog_t *log; +- ngx_http_log_fmt_t *fmt; +- ngx_http_log_main_conf_t *lmcf; +- +- if(conf->logs || conf->off) { +- return NGX_CONF_OK; ++ if(conf->tag == NULL) { ++ conf->tag = prev->tag; + } + +- conf->logs = prev->logs; +- conf->off = prev->off; ++ ngx_conf_merge_uint_value(conf->facility, ++ prev->facility, NGX_UDPLOG_FACILITY_LOCAL7); ++ ngx_conf_merge_uint_value(conf->severity, ++ prev->severity, NGX_UDPLOG_SEVERITY_INFO); + + if(conf->logs || conf->off) { + return NGX_CONF_OK; + } + +- conf->logs = ngx_array_create(cf->pool, 2, sizeof(ngx_http_udplog_t)); +- if(conf->logs == NULL) { +- return NGX_CONF_ERROR; +- } +- +- log = ngx_array_push(conf->logs); +- if(log == NULL) { +- return NGX_CONF_ERROR; +- } +- +- lmcf = ngx_http_conf_get_module_main_conf(cf, ngx_http_log_module); +- fmt = lmcf->formats.elts; +- +- /* the default "combined" format */ +- log->format = &fmt[0]; +- lmcf->combined_used = 1; ++ conf->logs = prev->logs; ++ conf->off = prev->off; + + return NGX_CONF_OK; + } +@@ -434,12 +482,6 @@ + return endpoint; + } + +-static ngx_int_t +-ngx_http_udplog_set_facility_and_severity(ngx_http_udplog_t *log, ngx_str_t *value) +-{ +- return NGX_OK; +-} +- + static char * + ngx_http_udplog_set_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) + { +@@ -458,6 +500,7 @@ + ulcf->off = 1; + return NGX_CONF_OK; + } ++ ulcf->off = 0; + + if (ulcf->logs == NULL) { + ulcf->logs = ngx_array_create(cf->pool, 2, sizeof(ngx_http_udplog_t)); +@@ -483,10 +526,11 @@ + + ngx_memzero(&u, sizeof(ngx_url_t)); + +- u.host = value[1]; +- u.port = 514; ++ u.url = value[1]; ++ u.default_port = 514; ++ u.no_resolve = 0; + +- if(ngx_inet_resolve_host(cf->pool, &u) != NGX_OK) { ++ if(ngx_parse_url(cf->pool, &u) != NGX_OK) { + ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "%V: %s", &u.host, u.err); + return NGX_CONF_ERROR; + } +@@ -496,7 +540,7 @@ + if(log->endpoint == NULL) { + return NGX_CONF_ERROR; + } +- ++ log->bare = 0; + if (cf->args->nelts >= 3) { + name = value[2]; + +@@ -508,14 +552,18 @@ + name.data = (u_char *) "combined"; + lmcf->combined_used = 1; + } +- ++ if (cf->args->nelts >= 4) { ++ if (ngx_strcmp(value[3].data, "bare") == 0) { ++ log->bare = 1; ++ } ++ } + fmt = lmcf->formats.elts; + for (i = 0; i < lmcf->formats.nelts; i++) { + if (fmt[i].name.len == name.len + && ngx_strcasecmp(fmt[i].name.data, name.data) == 0) + { + log->format = &fmt[i]; +- goto facility; ++ goto done; + } + } + +@@ -523,12 +571,105 @@ + "unknown log format \"%V\"", &name); + return NGX_CONF_ERROR; + +-facility: +- log->facility = NGX_UDPLOG_FACILITY_LOCAL7; +- log->severity = NGX_UDPLOG_SEVERITY_INFO; ++done: ++ ++ return NGX_CONF_OK; ++} ++ ++ ++static char * ++ngx_http_udplog_set_priority(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) ++{ ++ ngx_http_udplog_conf_t *ulcf = conf; ++ ngx_str_t *value; ++ ngx_udplog_facility_t *f; ++ ngx_udplog_severity_t *s; ++ ++ value = cf->args->elts; ++ ++ f = ngx_udplog_facilities; ++ ++ while(f->name.data != NULL) { ++ if(ngx_strncmp(f->name.data, value[1].data, f->name.len) == 0) ++ break; ++ ++ f++; ++ } ++ ++ if(f->name.data != NULL) { ++ ulcf->facility = f->number; ++ } ++ else { ++ ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, ++ "unknown facility \"%V\"", &value[1]); ++ return NGX_CONF_ERROR; ++ } ++ ++ if (cf->args->nelts == 3) { ++ s = ngx_udplog_severities; ++ ++ while(s->name.data != NULL) { ++ if(ngx_strncmp(s->name.data, value[2].data, s->name.len) == 0) ++ break; ++ ++ s++; ++ } ++ ++ if(s->name.data != NULL) { ++ ulcf->severity = s->number; ++ } ++ else { ++ ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, ++ "unknown severity \"%V\"", &value[2]); ++ return NGX_CONF_ERROR; ++ } ++ } ++ ++ return NGX_CONF_OK; ++} ++ ++static char * ++ngx_http_udplog_set_tag(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) ++{ ++ ngx_int_t n; ++ ngx_str_t *value; ++ ngx_http_script_compile_t sc; ++ ngx_http_log_tag_template_t **field, *h; ++ ++ field = (ngx_http_log_tag_template_t**) (((u_char*)conf) + cmd->offset); ++ ++ value = cf->args->elts; ++ ++ if (*field == NULL) { ++ *field = ngx_palloc(cf->pool, sizeof(ngx_http_log_tag_template_t)); ++ if (*field == NULL) { ++ return NGX_CONF_ERROR; ++ } ++ } ++ ++ h = *field; ++ ++ h->value = value[1]; ++ h->lengths = NULL; ++ h->values = NULL; ++ ++ /* ++ * Compile field name ++ */ ++ n = ngx_http_script_variables_count(&value[1]); ++ ++ if (n > 0) { ++ ngx_memzero(&sc, sizeof(ngx_http_script_compile_t)); ++ ++ sc.cf = cf; ++ sc.source = &value[1]; ++ sc.lengths = &h->lengths; ++ sc.values = &h->values; ++ sc.variables = n; ++ sc.complete_lengths = 1; ++ sc.complete_values = 1; + +- if(cf->args->nelts == 4) { +- if(ngx_http_udplog_set_facility_and_severity(log, &value[3]) != NGX_OK) { ++ if (ngx_http_script_compile(&sc) != NGX_OK) { + return NGX_CONF_ERROR; + } + } diff --git a/www/nginx/files/extra-patch-ngx_http_udplog_module.c b/www/nginx/files/extra-patch-ngx_http_udplog_module.c index 3a369c21a272..a97325abfa31 100644 --- a/www/nginx/files/extra-patch-ngx_http_udplog_module.c +++ b/www/nginx/files/extra-patch-ngx_http_udplog_module.c @@ -1,6 +1,161 @@ ---- ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c.orig 2010-01-11 19:16:46.000000000 +0300 -+++ ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c 2010-01-11 19:20:17.000000000 +0300 -@@ -280,7 +280,7 @@ +--- ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c.orig 2010-01-05 20:20:35.000000000 +0100 ++++ ../nginx_udplog_module-1.0.0/ngx_http_udplog_module.c 2011-12-02 18:31:18.000000000 +0100 +@@ -1,4 +1,3 @@ +- + /* + * Copyright (C) 2010 Valery Kholodkov + * +@@ -45,6 +44,12 @@ + } ngx_http_log_fmt_t; + + typedef struct { ++ ngx_str_t value; ++ ngx_array_t *lengths; ++ ngx_array_t *values; ++} ngx_http_log_tag_template_t; ++ ++typedef struct { + ngx_array_t formats; /* array of ngx_http_log_fmt_t */ + ngx_uint_t combined_used; /* unsigned combined_used:1 */ + } ngx_http_log_main_conf_t; +@@ -64,8 +69,7 @@ + typedef struct { + ngx_udp_endpoint_t *endpoint; + ngx_http_log_fmt_t *format; +- ngx_uint_t facility; +- ngx_uint_t severity; ++ ngx_uint_t bare:1; + } ngx_http_udplog_t; + + typedef struct { +@@ -73,8 +77,11 @@ + } ngx_http_udplog_main_conf_t; + + typedef struct { +- ngx_array_t *logs; /* array of ngx_http_udplog_t */ +- unsigned off; ++ ngx_array_t *logs; /* array of ngx_http_udplog_t */ ++ unsigned off; ++ ngx_http_log_tag_template_t *tag; ++ ngx_uint_t facility; ++ ngx_uint_t severity; + } ngx_http_udplog_conf_t; + + ngx_int_t ngx_udp_connect(ngx_udp_connection_t *uc); +@@ -88,6 +95,8 @@ + void *child); + + static char *ngx_http_udplog_set_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); ++static char *ngx_http_udplog_set_priority(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); ++static char *ngx_http_udplog_set_tag(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); + + static ngx_int_t ngx_http_udplog_init(ngx_conf_t *cf); + +@@ -96,12 +105,26 @@ + + { ngx_string("access_udplog"), + NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_HTTP_LIF_CONF +- |NGX_HTTP_LMT_CONF|NGX_CONF_TAKE123, ++ |NGX_HTTP_LMT_CONF|NGX_CONF_TAKE1234, + ngx_http_udplog_set_log, + NGX_HTTP_LOC_CONF_OFFSET, + 0, + NULL }, + ++ { ngx_string("udplog_priority"), ++ NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE12, ++ ngx_http_udplog_set_priority, ++ NGX_HTTP_LOC_CONF_OFFSET, ++ 0, ++ NULL }, ++ ++ { ngx_string("udplog_tag"), ++ NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ++ ngx_http_udplog_set_tag, ++ NGX_HTTP_LOC_CONF_OFFSET, ++ offsetof(ngx_http_udplog_conf_t, tag), ++ NULL }, ++ + ngx_null_command + }; + +@@ -166,7 +189,7 @@ + { ngx_null_string, 0 } + }; + +-static ngx_udplog_severity_t ngx_udplog_severity[] = { ++static ngx_udplog_severity_t ngx_udplog_severities[] = { + { ngx_string("emerg"), 0 }, + { ngx_string("alert"), 1 }, + { ngx_string("crit"), 2 }, +@@ -190,6 +213,7 @@ + u_char *line, *p; + size_t len; + ngx_uint_t i, l, pri; ++ ngx_str_t tag; + ngx_http_udplog_t *log; + ngx_http_log_op_t *op; + ngx_http_udplog_conf_t *ulcf; +@@ -205,12 +229,31 @@ + return NGX_OK; + } + ++ if(ulcf->tag != NULL) ++ { ++ if(ulcf->tag->lengths == NULL) { ++ tag = ulcf->tag->value; ++ } ++ else{ ++ if (ngx_http_script_run(r, &tag, ulcf->tag->lengths->elts, 0, ulcf->tag->values->elts) ++ == NULL) ++ { ++ return NGX_ERROR; ++ } ++ } ++ } ++ else { ++ tag.data = (u_char*)"nginx"; ++ tag.len = sizeof("nginx") - 1; ++ } ++ + time = ngx_time(); + ngx_gmtime(time, &tm); + + log = ulcf->logs->elts; ++ pri = ulcf->facility * 8 + ulcf->severity; ++ + for (l = 0; l < ulcf->logs->nelts; l++) { +- pri = log[l].facility * 8 + log[l].severity; + + if(pri > 255) { + pri = NGX_UDPLOG_FACILITY_LOCAL7 * 8 + NGX_UDPLOG_SEVERITY_INFO; +@@ -231,7 +274,8 @@ + } + } + +- len += sizeof("<255>") - 1 + sizeof("Jan 31 00:00:00") - 1 + 1 + ngx_cycle->hostname.len + 1; ++ len += sizeof("<255>") - 1 + sizeof("Jan 31 00:00:00") - 1 + 1 + ngx_cycle->hostname.len + 1 ++ + tag.len + 2; + + #if defined nginx_version && nginx_version >= 7003 + line = ngx_pnalloc(r->pool, len); +@@ -245,9 +289,12 @@ + /* + * BSD syslog message header (see RFC 3164) + */ +- p = ngx_sprintf(line, "<%ui>%s %2d %02d:%02d:%02d %V ", pri, months[tm.ngx_tm_mon - 1], tm.ngx_tm_mday, +- tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec, &ngx_cycle->hostname); +- ++ if(!log[l].bare){ ++ p = ngx_sprintf(line, "<%ui>%s %2d %02d:%02d:%02d %V %V: ", pri, months[tm.ngx_tm_mon - 1], tm.ngx_tm_mday, ++ tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec, &ngx_cycle->hostname, &tag); ++ }else{ ++ p = line; ++ } + for (i = 0; i < log[l].format->ops->nelts; i++) { + p = op[i].run(r, p, &op[i]); + } +@@ -280,10 +327,15 @@ uc->sockaddr = endpoint->peer_addr.sockaddr; uc->socklen = endpoint->peer_addr.socklen; uc->server = endpoint->peer_addr.name; @@ -9,7 +164,27 @@ uc->log = &cf->cycle->new_log; #else uc->log = cf->cycle->new_log; -@@ -335,7 +335,11 @@ ++#if defined nginx_version && nginx_version >= 8032 ++ uc->log.handler = NULL; ++ uc->log.data = NULL; ++ uc->log.action = "logging"; ++#endif + #endif + + return NGX_OK; +@@ -320,6 +372,11 @@ + + if (uc->connection == NULL) { + if(ngx_udp_connect(uc) != NGX_OK) { ++ if(uc->connection != NULL) { ++ ngx_free_connection(uc->connection); ++ uc->connection = NULL; ++ } ++ + return NGX_ERROR; + } + +@@ -335,7 +392,11 @@ } if ((size_t) n != (size_t) len) { @@ -21,3 +196,236 @@ return NGX_ERROR; } +@@ -364,6 +425,9 @@ + if (conf == NULL) { + return NGX_CONF_ERROR; + } ++ conf->off = 1; ++ conf->facility = NGX_CONF_UNSET_UINT; ++ conf->severity = NGX_CONF_UNSET_UINT; + + return conf; + } +@@ -374,37 +438,21 @@ + ngx_http_udplog_conf_t *prev = parent; + ngx_http_udplog_conf_t *conf = child; + +- ngx_http_udplog_t *log; +- ngx_http_log_fmt_t *fmt; +- ngx_http_log_main_conf_t *lmcf; +- +- if(conf->logs || conf->off) { +- return NGX_CONF_OK; ++ if(conf->tag == NULL) { ++ conf->tag = prev->tag; + } + +- conf->logs = prev->logs; +- conf->off = prev->off; ++ ngx_conf_merge_uint_value(conf->facility, ++ prev->facility, NGX_UDPLOG_FACILITY_LOCAL7); ++ ngx_conf_merge_uint_value(conf->severity, ++ prev->severity, NGX_UDPLOG_SEVERITY_INFO); + + if(conf->logs || conf->off) { + return NGX_CONF_OK; + } + +- conf->logs = ngx_array_create(cf->pool, 2, sizeof(ngx_http_udplog_t)); +- if(conf->logs == NULL) { +- return NGX_CONF_ERROR; +- } +- +- log = ngx_array_push(conf->logs); +- if(log == NULL) { +- return NGX_CONF_ERROR; +- } +- +- lmcf = ngx_http_conf_get_module_main_conf(cf, ngx_http_log_module); +- fmt = lmcf->formats.elts; +- +- /* the default "combined" format */ +- log->format = &fmt[0]; +- lmcf->combined_used = 1; ++ conf->logs = prev->logs; ++ conf->off = prev->off; + + return NGX_CONF_OK; + } +@@ -434,12 +482,6 @@ + return endpoint; + } + +-static ngx_int_t +-ngx_http_udplog_set_facility_and_severity(ngx_http_udplog_t *log, ngx_str_t *value) +-{ +- return NGX_OK; +-} +- + static char * + ngx_http_udplog_set_log(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) + { +@@ -458,6 +500,7 @@ + ulcf->off = 1; + return NGX_CONF_OK; + } ++ ulcf->off = 0; + + if (ulcf->logs == NULL) { + ulcf->logs = ngx_array_create(cf->pool, 2, sizeof(ngx_http_udplog_t)); +@@ -483,10 +526,11 @@ + + ngx_memzero(&u, sizeof(ngx_url_t)); + +- u.host = value[1]; +- u.port = 514; ++ u.url = value[1]; ++ u.default_port = 514; ++ u.no_resolve = 0; + +- if(ngx_inet_resolve_host(cf->pool, &u) != NGX_OK) { ++ if(ngx_parse_url(cf->pool, &u) != NGX_OK) { + ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "%V: %s", &u.host, u.err); + return NGX_CONF_ERROR; + } +@@ -496,7 +540,7 @@ + if(log->endpoint == NULL) { + return NGX_CONF_ERROR; + } +- ++ log->bare = 0; + if (cf->args->nelts >= 3) { + name = value[2]; + +@@ -508,14 +552,18 @@ + name.data = (u_char *) "combined"; + lmcf->combined_used = 1; + } +- ++ if (cf->args->nelts >= 4) { ++ if (ngx_strcmp(value[3].data, "bare") == 0) { ++ log->bare = 1; ++ } ++ } + fmt = lmcf->formats.elts; + for (i = 0; i < lmcf->formats.nelts; i++) { + if (fmt[i].name.len == name.len + && ngx_strcasecmp(fmt[i].name.data, name.data) == 0) + { + log->format = &fmt[i]; +- goto facility; ++ goto done; + } + } + +@@ -523,12 +571,105 @@ + "unknown log format \"%V\"", &name); + return NGX_CONF_ERROR; + +-facility: +- log->facility = NGX_UDPLOG_FACILITY_LOCAL7; +- log->severity = NGX_UDPLOG_SEVERITY_INFO; ++done: ++ ++ return NGX_CONF_OK; ++} ++ ++ ++static char * ++ngx_http_udplog_set_priority(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) ++{ ++ ngx_http_udplog_conf_t *ulcf = conf; ++ ngx_str_t *value; ++ ngx_udplog_facility_t *f; ++ ngx_udplog_severity_t *s; ++ ++ value = cf->args->elts; ++ ++ f = ngx_udplog_facilities; ++ ++ while(f->name.data != NULL) { ++ if(ngx_strncmp(f->name.data, value[1].data, f->name.len) == 0) ++ break; ++ ++ f++; ++ } ++ ++ if(f->name.data != NULL) { ++ ulcf->facility = f->number; ++ } ++ else { ++ ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, ++ "unknown facility \"%V\"", &value[1]); ++ return NGX_CONF_ERROR; ++ } ++ ++ if (cf->args->nelts == 3) { ++ s = ngx_udplog_severities; ++ ++ while(s->name.data != NULL) { ++ if(ngx_strncmp(s->name.data, value[2].data, s->name.len) == 0) ++ break; ++ ++ s++; ++ } ++ ++ if(s->name.data != NULL) { ++ ulcf->severity = s->number; ++ } ++ else { ++ ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, ++ "unknown severity \"%V\"", &value[2]); ++ return NGX_CONF_ERROR; ++ } ++ } ++ ++ return NGX_CONF_OK; ++} ++ ++static char * ++ngx_http_udplog_set_tag(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) ++{ ++ ngx_int_t n; ++ ngx_str_t *value; ++ ngx_http_script_compile_t sc; ++ ngx_http_log_tag_template_t **field, *h; ++ ++ field = (ngx_http_log_tag_template_t**) (((u_char*)conf) + cmd->offset); ++ ++ value = cf->args->elts; ++ ++ if (*field == NULL) { ++ *field = ngx_palloc(cf->pool, sizeof(ngx_http_log_tag_template_t)); ++ if (*field == NULL) { ++ return NGX_CONF_ERROR; ++ } ++ } ++ ++ h = *field; ++ ++ h->value = value[1]; ++ h->lengths = NULL; ++ h->values = NULL; ++ ++ /* ++ * Compile field name ++ */ ++ n = ngx_http_script_variables_count(&value[1]); ++ ++ if (n > 0) { ++ ngx_memzero(&sc, sizeof(ngx_http_script_compile_t)); ++ ++ sc.cf = cf; ++ sc.source = &value[1]; ++ sc.lengths = &h->lengths; ++ sc.values = &h->values; ++ sc.variables = n; ++ sc.complete_lengths = 1; ++ sc.complete_values = 1; + +- if(cf->args->nelts == 4) { +- if(ngx_http_udplog_set_facility_and_severity(log, &value[3]) != NGX_OK) { ++ if (ngx_http_script_compile(&sc) != NGX_OK) { + return NGX_CONF_ERROR; + } + } |