Mercurial > hg > nginx

comparison src/stream/ngx_stream_variables.c @ 6668:5e2821c2de46

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Stream: the $bytes_received variable. The variable keeps the number of bytes received from the client.
author Vladimir Homutov <vl@nginx.com>
date Fri, 26 Aug 2016 15:33:02 +0300
parents eb4293155e87
children 164a0824ce20
comparison
equal deleted inserted replaced
6667:33d075b9097d 6668:5e2821c2de46
19 ngx_stream_variable_value_t *v, uintptr_t data); 19 ngx_stream_variable_value_t *v, uintptr_t data);
20 static ngx_int_t ngx_stream_variable_server_addr(ngx_stream_session_t *s, 20 static ngx_int_t ngx_stream_variable_server_addr(ngx_stream_session_t *s,
21 ngx_stream_variable_value_t *v, uintptr_t data); 21 ngx_stream_variable_value_t *v, uintptr_t data);
22 static ngx_int_t ngx_stream_variable_server_port(ngx_stream_session_t *s, 22 static ngx_int_t ngx_stream_variable_server_port(ngx_stream_session_t *s,
23 ngx_stream_variable_value_t *v, uintptr_t data); 23 ngx_stream_variable_value_t *v, uintptr_t data);
24 static ngx_int_t ngx_stream_variable_bytes_sent(ngx_stream_session_t *s, 24 static ngx_int_t ngx_stream_variable_bytes(ngx_stream_session_t *s,
25 ngx_stream_variable_value_t *v, uintptr_t data); 25 ngx_stream_variable_value_t *v, uintptr_t data);
26 static ngx_int_t ngx_stream_variable_connection(ngx_stream_session_t *s, 26 static ngx_int_t ngx_stream_variable_connection(ngx_stream_session_t *s,
27 ngx_stream_variable_value_t *v, uintptr_t data); 27 ngx_stream_variable_value_t *v, uintptr_t data);
28 28
29 static ngx_int_t ngx_stream_variable_nginx_version(ngx_stream_session_t *s, 29 static ngx_int_t ngx_stream_variable_nginx_version(ngx_stream_session_t *s,
55 ngx_stream_variable_server_addr, 0, 0, 0 }, 55 ngx_stream_variable_server_addr, 0, 0, 0 },
56 56
57 { ngx_string("server_port"), NULL, 57 { ngx_string("server_port"), NULL,
58 ngx_stream_variable_server_port, 0, 0, 0 }, 58 ngx_stream_variable_server_port, 0, 0, 0 },
59 59
60 { ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes_sent, 60 { ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes,
61 0, 0, 0 }, 61 0, 0, 0 },
62
63 { ngx_string("bytes_received"), NULL, ngx_stream_variable_bytes,
64 1, 0, 0 },
62 65
63 { ngx_string("connection"), NULL, 66 { ngx_string("connection"), NULL,
64 ngx_stream_variable_connection, 0, 0, 0 }, 67 ngx_stream_variable_connection, 0, 0, 0 },
65 68
66 { ngx_string("nginx_version"), NULL, ngx_stream_variable_nginx_version, 69 { ngx_string("nginx_version"), NULL, ngx_stream_variable_nginx_version,
459 return NGX_OK; 462 return NGX_OK;
460 } 463 }
461 464
462 465
463 static ngx_int_t 466 static ngx_int_t
464 ngx_stream_variable_bytes_sent(ngx_stream_session_t *s, 467 ngx_stream_variable_bytes(ngx_stream_session_t *s,
465 ngx_stream_variable_value_t *v, uintptr_t data) 468 ngx_stream_variable_value_t *v, uintptr_t data)
466 { 469 {
467 u_char *p; 470 u_char *p;
468 471
469 p = ngx_pnalloc(s->connection->pool, NGX_OFF_T_LEN); 472 p = ngx_pnalloc(s->connection->pool, NGX_OFF_T_LEN);
470 if (p == NULL) { 473 if (p == NULL) {
471 return NGX_ERROR; 474 return NGX_ERROR;
472 } 475 }
473 476
474 v->len = ngx_sprintf(p, "%O", s->connection->sent) - p; 477 if (data == 1) {
478 v->len = ngx_sprintf(p, "%O", s->received) - p;
479
480 } else {
481 v->len = ngx_sprintf(p, "%O", s->connection->sent) - p;
482 }
483
475 v->valid = 1; 484 v->valid = 1;
476 v->no_cacheable = 0; 485 v->no_cacheable = 0;
477 v->not_found = 0; 486 v->not_found = 0;
478 v->data = p; 487 v->data = p;
479 488