1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/*
* Copyright (C) NGINX, Inc.
*/
#include <nxt_main.h>
#include <nxt_conf.h>
#include <nxt_status.h>
nxt_conf_value_t *
nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp)
{
size_t i;
nxt_str_t name;
nxt_int_t ret;
nxt_status_app_t *app;
nxt_conf_value_t *status, *obj, *apps, *app_obj;
static nxt_str_t conns_str = nxt_string("connections");
static nxt_str_t acc_str = nxt_string("accepted");
static nxt_str_t active_str = nxt_string("active");
static nxt_str_t idle_str = nxt_string("idle");
static nxt_str_t closed_str = nxt_string("closed");
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 procs_str = nxt_string("processes");
static nxt_str_t run_str = nxt_string("running");
static nxt_str_t start_str = nxt_string("starting");
status = nxt_conf_create_object(mp, 3);
if (nxt_slow_path(status == NULL)) {
return NULL;
}
obj = nxt_conf_create_object(mp, 4);
if (nxt_slow_path(obj == NULL)) {
return NULL;
}
nxt_conf_set_member(status, &conns_str, obj, 0);
nxt_conf_set_member_integer(obj, &acc_str, report->accepted_conns, 0);
nxt_conf_set_member_integer(obj, &active_str, report->accepted_conns
- report->closed_conns
- report->idle_conns, 1);
nxt_conf_set_member_integer(obj, &idle_str, report->idle_conns, 2);
nxt_conf_set_member_integer(obj, &closed_str, report->closed_conns, 3);
obj = nxt_conf_create_object(mp, 1);
if (nxt_slow_path(obj == NULL)) {
return NULL;
}
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);
if (nxt_slow_path(apps == NULL)) {
return NULL;
}
nxt_conf_set_member(status, &apps_str, apps, 2);
for (i = 0; i < report->apps_count; i++) {
app = &report->apps[i];
app_obj = nxt_conf_create_object(mp, 2);
if (nxt_slow_path(app_obj == NULL)) {
return NULL;
}
name.length = app->name.length;
name.start = nxt_pointer_to(report, (uintptr_t) app->name.start);
ret = nxt_conf_set_member_dup(apps, mp, &name, app_obj, i);
if (nxt_slow_path(ret != NXT_OK)) {
return NULL;
}
obj = nxt_conf_create_object(mp, 3);
if (nxt_slow_path(obj == NULL)) {
return NULL;
}
nxt_conf_set_member(app_obj, &procs_str, obj, 0);
nxt_conf_set_member_integer(obj, &run_str, app->processes, 0);
nxt_conf_set_member_integer(obj, &start_str, app->pending_processes, 1);
nxt_conf_set_member_integer(obj, &idle_str, app->idle_processes, 2);
obj = nxt_conf_create_object(mp, 1);
if (nxt_slow_path(obj == NULL)) {
return NULL;
}
nxt_conf_set_member(app_obj, &reqs_str, obj, 1);
nxt_conf_set_member_integer(obj, &active_str, app->active_requests, 0);
}
return status;
}
|
