mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-11-25 06:26:48 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Stream: the $bytes_received variable.

Browse Source 
The variable keeps the number of bytes received from the client.
This commit is contained in:
Vladimir Homutov 2016-08-26 15:33:02 +03:00
parent 14b1b6e10a
commit 1258126f0c
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/stream/ngx_stream_variables.c
View File

@ -21,7 +21,7 @@ static ngx_int_t ngx_stream_variable_server_addr(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_stream_variable_server_port(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_stream_variable_bytes_sent(ngx_stream_session_t *s,
static ngx_int_t ngx_stream_variable_bytes(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_stream_variable_connection(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data);
@ -57,9 +57,12 @@ static ngx_stream_variable_t ngx_stream_core_variables[] = {
{ ngx_string("server_port"), NULL,
ngx_stream_variable_server_port, 0, 0, 0 },
{ ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes_sent,
{ ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes,
0, 0, 0 },
{ ngx_string("bytes_received"), NULL, ngx_stream_variable_bytes,
1, 0, 0 },
{ ngx_string("connection"), NULL,
ngx_stream_variable_connection, 0, 0, 0 },
@ -461,7 +464,7 @@ ngx_stream_variable_server_port(ngx_stream_session_t *s,
static ngx_int_t
ngx_stream_variable_bytes_sent(ngx_stream_session_t *s,
ngx_stream_variable_bytes(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data)
{
u_char *p;
@ -471,7 +474,13 @@ ngx_stream_variable_bytes_sent(ngx_stream_session_t *s,
return NGX_ERROR;
}
v->len = ngx_sprintf(p, "%O", s->connection->sent) - p;
if (data == 1) {
v->len = ngx_sprintf(p, "%O", s->received) - p;
} else {
v->len = ngx_sprintf(p, "%O", s->connection->sent) - p;
}
v->valid = 1;
v->no_cacheable = 0;
v->not_found = 0;