details: http://hg.nginx.org/nginx/rev/164a0824ce20
branches:
changeset: 6669:164a0824ce20
user: Vladimir Homutov <vl@nginx.com>
date: Fri Aug 26 15:33:04 2016 +0300
description:
Stream: the $session_time variable.

The variable keeps time spent on processing the stream session.

diffstat:

src/stream/ngx_stream.h | 2 ++
src/stream/ngx_stream_handler.c | 5 +++++
src/stream/ngx_stream_variables.c | 34 ++++++++++++++++++++++++++++++++++
3 files changed, 41 insertions(+), 0 deletions(-)

diffs (92 lines):

diff -r 5e2821c2de46 -r 164a0824ce20 src/stream/ngx_stream.h
--- a/src/stream/ngx_stream.h Fri Aug 26 15:33:02 2016 +0300
+++ b/src/stream/ngx_stream.h Fri Aug 26 15:33:04 2016 +0300
@@ -155,6 +155,8 @@ struct ngx_stream_session_s {
ngx_connection_t *connection;

off_t received;
+ time_t start_sec;
+ ngx_msec_t start_msec;

ngx_log_handler_pt log_handler;

diff -r 5e2821c2de46 -r 164a0824ce20 src/stream/ngx_stream_handler.c
--- a/src/stream/ngx_stream_handler.c Fri Aug 26 15:33:02 2016 +0300
+++ b/src/stream/ngx_stream_handler.c Fri Aug 26 15:33:04 2016 +0300
@@ -28,6 +28,7 @@ ngx_stream_init_connection(ngx_connectio
size_t len;
ngx_int_t rc;
ngx_uint_t i;
+ ngx_time_t *tp;
struct sockaddr *sa;
ngx_stream_port_t *port;
struct sockaddr_in *sin;
@@ -158,6 +159,10 @@ ngx_stream_init_connection(ngx_connectio
return;
}

+ tp = ngx_timeofday();
+ s->start_sec = tp->sec;
+ s->start_msec = tp->msec;
+
if (cmcf->limit_conn_handler) {
rc = cmcf->limit_conn_handler(s);

diff -r 5e2821c2de46 -r 164a0824ce20 src/stream/ngx_stream_variables.c
--- a/src/stream/ngx_stream_variables.c Fri Aug 26 15:33:02 2016 +0300
+++ b/src/stream/ngx_stream_variables.c Fri Aug 26 15:33:04 2016 +0300
@@ -23,6 +23,8 @@ static ngx_int_t ngx_stream_variable_ser
ngx_stream_variable_value_t *v, uintptr_t data);
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_session_time(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);

@@ -63,6 +65,9 @@ static ngx_stream_variable_t ngx_stream
{ ngx_string("bytes_received"), NULL, ngx_stream_variable_bytes,
1, 0, 0 },

+ { ngx_string("session_time"), NULL, ngx_stream_variable_session_time,
+ 0, NGX_STREAM_VAR_NOCACHEABLE, 0 },
+
{ ngx_string("connection"), NULL,
ngx_stream_variable_connection, 0, 0, 0 },

@@ -491,6 +496,35 @@ ngx_stream_variable_bytes(ngx_stream_ses


static ngx_int_t
+ngx_stream_variable_session_time(ngx_stream_session_t *s,
+ ngx_stream_variable_value_t *v, uintptr_t data)
+{
+ u_char *p;
+ ngx_time_t *tp;
+ ngx_msec_int_t ms;
+
+ p = ngx_pnalloc(s->connection->pool, NGX_TIME_T_LEN + 4);
+ if (p == NULL) {
+ return NGX_ERROR;
+ }
+
+ tp = ngx_timeofday();
+
+ ms = (ngx_msec_int_t)
+ ((tp->sec - s->start_sec) * 1000 + (tp->msec - s->start_msec));
+ ms = ngx_max(ms, 0);
+
+ v->len = ngx_sprintf(p, "%T.%03M", (time_t) ms / 1000, ms % 1000) - p;
+ v->valid = 1;
+ v->no_cacheable = 0;
+ v->not_found = 0;
+ v->data = p;
+
+ return NGX_OK;
+}
+
+
+static ngx_int_t
ngx_stream_variable_connection(ngx_stream_session_t *s,
ngx_stream_variable_value_t *v, uintptr_t data)
{

_______________________________________________
nginx-devel mailing list
nginx-devel@nginx.org
http://mailman.nginx.org/mailman/listinfo/nginx-devel