Status: added requests count.
This commit is contained in:
@@ -486,6 +486,7 @@ struct nxt_event_engine_s {
|
|||||||
nxt_atomic_uint_t accepted_conns_cnt;
|
nxt_atomic_uint_t accepted_conns_cnt;
|
||||||
nxt_atomic_uint_t idle_conns_cnt;
|
nxt_atomic_uint_t idle_conns_cnt;
|
||||||
nxt_atomic_uint_t closed_conns_cnt;
|
nxt_atomic_uint_t closed_conns_cnt;
|
||||||
|
nxt_atomic_uint_t requests_cnt;
|
||||||
|
|
||||||
nxt_queue_link_t link;
|
nxt_queue_link_t link;
|
||||||
// STUB: router link
|
// STUB: router link
|
||||||
|
|||||||
@@ -278,6 +278,8 @@ nxt_http_request_create(nxt_task_t *task)
|
|||||||
r->resp.content_length_n = -1;
|
r->resp.content_length_n = -1;
|
||||||
r->state = &nxt_http_request_init_state;
|
r->state = &nxt_http_request_init_state;
|
||||||
|
|
||||||
|
task->thread->engine->requests_cnt++;
|
||||||
|
|
||||||
return r;
|
return r;
|
||||||
|
|
||||||
fail:
|
fail:
|
||||||
|
|||||||
@@ -967,6 +967,7 @@ nxt_router_status_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
|
|||||||
report->accepted_conns += engine->accepted_conns_cnt;
|
report->accepted_conns += engine->accepted_conns_cnt;
|
||||||
report->idle_conns += engine->idle_conns_cnt;
|
report->idle_conns += engine->idle_conns_cnt;
|
||||||
report->closed_conns += engine->closed_conns_cnt;
|
report->closed_conns += engine->closed_conns_cnt;
|
||||||
|
report->requests += engine->requests_cnt;
|
||||||
|
|
||||||
} nxt_queue_loop;
|
} nxt_queue_loop;
|
||||||
|
|
||||||
|
|||||||
@@ -23,6 +23,7 @@ nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp)
|
|||||||
static nxt_str_t idle_str = nxt_string("idle");
|
static nxt_str_t idle_str = nxt_string("idle");
|
||||||
static nxt_str_t closed_str = nxt_string("closed");
|
static nxt_str_t closed_str = nxt_string("closed");
|
||||||
static nxt_str_t reqs_str = nxt_string("requests");
|
static nxt_str_t reqs_str = nxt_string("requests");
|
||||||
|
static nxt_str_t total_str = nxt_string("total");
|
||||||
static nxt_str_t apps_str = nxt_string("applications");
|
static nxt_str_t apps_str = nxt_string("applications");
|
||||||
static nxt_str_t procs_str = nxt_string("processes");
|
static nxt_str_t procs_str = nxt_string("processes");
|
||||||
static nxt_str_t run_str = nxt_string("running");
|
static nxt_str_t run_str = nxt_string("running");
|
||||||
@@ -47,13 +48,15 @@ nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp)
|
|||||||
nxt_conf_set_member_integer(obj, &idle_str, report->idle_conns, 2);
|
nxt_conf_set_member_integer(obj, &idle_str, report->idle_conns, 2);
|
||||||
nxt_conf_set_member_integer(obj, &closed_str, report->closed_conns, 3);
|
nxt_conf_set_member_integer(obj, &closed_str, report->closed_conns, 3);
|
||||||
|
|
||||||
obj = nxt_conf_create_object(mp, 0);
|
obj = nxt_conf_create_object(mp, 1);
|
||||||
if (nxt_slow_path(obj == NULL)) {
|
if (nxt_slow_path(obj == NULL)) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
nxt_conf_set_member(status, &reqs_str, obj, 1);
|
nxt_conf_set_member(status, &reqs_str, obj, 1);
|
||||||
|
|
||||||
|
nxt_conf_set_member_integer(obj, &total_str, report->requests, 0);
|
||||||
|
|
||||||
apps = nxt_conf_create_object(mp, report->apps_count);
|
apps = nxt_conf_create_object(mp, report->apps_count);
|
||||||
if (nxt_slow_path(obj == NULL)) {
|
if (nxt_slow_path(obj == NULL)) {
|
||||||
return NULL;
|
return NULL;
|
||||||
|
|||||||
@@ -20,6 +20,7 @@ typedef struct {
|
|||||||
uint64_t accepted_conns;
|
uint64_t accepted_conns;
|
||||||
uint64_t idle_conns;
|
uint64_t idle_conns;
|
||||||
uint64_t closed_conns;
|
uint64_t closed_conns;
|
||||||
|
uint64_t requests;
|
||||||
|
|
||||||
size_t apps_count;
|
size_t apps_count;
|
||||||
nxt_status_app_t apps[];
|
nxt_status_app_t apps[];
|
||||||
|
|||||||
Reference in New Issue
Block a user