aboutsummaryrefslogtreecommitdiff
path: root/src/stream/ngx_stream_variables.c
diff options
context:
space:
mode:
authorVladimir Homutov <vl@nginx.com>2016-08-26 15:33:02 +0300
committerVladimir Homutov <vl@nginx.com>2016-08-26 15:33:02 +0300
commit1258126f0c9070315c494d31b71ae912c9aa82c8 (patch)
tree832d93b81622360716166b7de0d32e6c7303389c /src/stream/ngx_stream_variables.c
parent14b1b6e10a75994a6001a3480901e62f43e05696 (diff)
downloadnginx-1258126f0c9070315c494d31b71ae912c9aa82c8.tar.gz
nginx-1258126f0c9070315c494d31b71ae912c9aa82c8.zip
Stream: the $bytes_received variable.
The variable keeps the number of bytes received from the client.
Diffstat (limited to 'src/stream/ngx_stream_variables.c')
-rw-r--r--src/stream/ngx_stream_variables.c17
1 files changed, 13 insertions, 4 deletions
diff --git a/src/stream/ngx_stream_variables.c b/src/stream/ngx_stream_variables.c
index 10f9c7ecc..147236540 100644
--- a/src/stream/ngx_stream_variables.c
+++ b/src/stream/ngx_stream_variables.c
@@ -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;