Mercurial > hg > nginx

comparison src/stream/ngx_stream_variables.c @ 6669:164a0824ce20

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Stream: the $session_time variable. The variable keeps time spent on processing the stream session.
author Vladimir Homutov <vl@nginx.com>
date Fri, 26 Aug 2016 15:33:04 +0300
parents 5e2821c2de46
children c6372a40c2a7
comparison
equal deleted inserted replaced
6668:5e2821c2de46 6669:164a0824ce20
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(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_session_time(ngx_stream_session_t *s,
27 ngx_stream_variable_value_t *v, uintptr_t data);
26 static ngx_int_t ngx_stream_variable_connection(ngx_stream_session_t *s, 28 static ngx_int_t ngx_stream_variable_connection(ngx_stream_session_t *s,
27 ngx_stream_variable_value_t *v, uintptr_t data); 29 ngx_stream_variable_value_t *v, uintptr_t data);
28 30
29 static ngx_int_t ngx_stream_variable_nginx_version(ngx_stream_session_t *s, 31 static ngx_int_t ngx_stream_variable_nginx_version(ngx_stream_session_t *s,
30 ngx_stream_variable_value_t *v, uintptr_t data); 32 ngx_stream_variable_value_t *v, uintptr_t data);
60 { ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes, 62 { ngx_string("bytes_sent"), NULL, ngx_stream_variable_bytes,
61 0, 0, 0 }, 63 0, 0, 0 },
62 64
63 { ngx_string("bytes_received"), NULL, ngx_stream_variable_bytes, 65 { ngx_string("bytes_received"), NULL, ngx_stream_variable_bytes,
64 1, 0, 0 }, 66 1, 0, 0 },
67
68 { ngx_string("session_time"), NULL, ngx_stream_variable_session_time,
69 0, NGX_STREAM_VAR_NOCACHEABLE, 0 },
65 70
66 { ngx_string("connection"), NULL, 71 { ngx_string("connection"), NULL,
67 ngx_stream_variable_connection, 0, 0, 0 }, 72 ngx_stream_variable_connection, 0, 0, 0 },
68 73
69 { ngx_string("nginx_version"), NULL, ngx_stream_variable_nginx_version, 74 { ngx_string("nginx_version"), NULL, ngx_stream_variable_nginx_version,
479 484
480 } else { 485 } else {
481 v->len = ngx_sprintf(p, "%O", s->connection->sent) - p; 486 v->len = ngx_sprintf(p, "%O", s->connection->sent) - p;
482 } 487 }
483 488
489 v->valid = 1;
490 v->no_cacheable = 0;
491 v->not_found = 0;
492 v->data = p;
493
494 return NGX_OK;
495 }
496
497
498 static ngx_int_t
499 ngx_stream_variable_session_time(ngx_stream_session_t *s,
500 ngx_stream_variable_value_t *v, uintptr_t data)
501 {
502 u_char *p;
503 ngx_time_t *tp;
504 ngx_msec_int_t ms;
505
506 p = ngx_pnalloc(s->connection->pool, NGX_TIME_T_LEN + 4);
507 if (p == NULL) {
508 return NGX_ERROR;
509 }
510
511 tp = ngx_timeofday();
512
513 ms = (ngx_msec_int_t)
514 ((tp->sec - s->start_sec) * 1000 + (tp->msec - s->start_msec));
515 ms = ngx_max(ms, 0);
516
517 v->len = ngx_sprintf(p, "%T.%03M", (time_t) ms / 1000, ms % 1000) - p;
484 v->valid = 1; 518 v->valid = 1;
485 v->no_cacheable = 0; 519 v->no_cacheable = 0;
486 v->not_found = 0; 520 v->not_found = 0;
487 v->data = p; 521 v->data = p;
488 522