IntenseWebs/nginx
3
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-12-22 15:13:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Stream: the $protocol variable.

Browse Source 
The variable keeps protocol used by the client, "TCP" or "UDP".
This commit is contained in:
Vladimir Homutov 2016-08-26 15:33:07 +03:00
parent f04b65358e
commit 048ee94130
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/stream/ngx_stream_variables.c
View File

@ -40,6 +40,8 @@ static ngx_int_t ngx_stream_variable_time_iso8601(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data); ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_stream_variable_time_local(ngx_stream_session_t *s, static ngx_int_t ngx_stream_variable_time_local(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data); ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_stream_variable_protocol(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_stream_variable_t ngx_stream_core_variables[] = { static ngx_stream_variable_t ngx_stream_core_variables[] = {
@ -89,6 +91,9 @@ static ngx_stream_variable_t ngx_stream_core_variables[] = {
{ ngx_string("time_local"), NULL, ngx_stream_variable_time_local, { ngx_string("time_local"), NULL, ngx_stream_variable_time_local,
0, NGX_STREAM_VAR_NOCACHEABLE, 0 }, 0, NGX_STREAM_VAR_NOCACHEABLE, 0 },
{ ngx_string("protocol"), NULL,
ngx_stream_variable_protocol, 0, 0, 0 },
{ ngx_null_string, NULL, NULL, 0, 0, 0 } { ngx_null_string, NULL, NULL, 0, 0, 0 }
}; };
@ -665,6 +670,20 @@ ngx_stream_variable_time_local(ngx_stream_session_t *s,
} }
static ngx_int_t
ngx_stream_variable_protocol(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data)
{
v->len = 3;
v->valid = 1;
v->no_cacheable = 0;
v->not_found = 0;
v->data = (u_char *) (s->connection->type == SOCK_DGRAM ? "UDP" : "TCP");
return NGX_OK;
}
void * void *
ngx_stream_map_find(ngx_stream_session_t *s, ngx_stream_map_t *map, ngx_stream_map_find(ngx_stream_session_t *s, ngx_stream_map_t *map,
ngx_str_t *match) ngx_str_t *match)