-
Notifications
You must be signed in to change notification settings - Fork 455
/
ngx_http_vhost_traffic_status_node.h
180 lines (146 loc) · 8.77 KB
/
ngx_http_vhost_traffic_status_node.h
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
/*
* Copyright (C) YoungJoo Kim (vozlt)
*/
#ifndef _NGX_HTTP_VTS_NODE_H_INCLUDED_
#define _NGX_HTTP_VTS_NODE_H_INCLUDED_
#define NGX_HTTP_VHOST_TRAFFIC_STATUS_DEFAULT_QUEUE_LEN 64
#define NGX_HTTP_VHOST_TRAFFIC_STATUS_DEFAULT_BUCKET_LEN 32
typedef struct {
ngx_msec_t time;
ngx_msec_int_t msec;
} ngx_http_vhost_traffic_status_node_time_t;
typedef struct {
ngx_http_vhost_traffic_status_node_time_t times[NGX_HTTP_VHOST_TRAFFIC_STATUS_DEFAULT_QUEUE_LEN];
ngx_int_t front;
ngx_int_t rear;
ngx_int_t len;
} ngx_http_vhost_traffic_status_node_time_queue_t;
typedef struct {
ngx_msec_int_t msec;
ngx_atomic_t counter;
} ngx_http_vhost_traffic_status_node_histogram_t;
typedef struct {
ngx_http_vhost_traffic_status_node_histogram_t buckets[NGX_HTTP_VHOST_TRAFFIC_STATUS_DEFAULT_BUCKET_LEN];
ngx_int_t len;
} ngx_http_vhost_traffic_status_node_histogram_bucket_t;
typedef struct {
/* unsigned type:5 */
unsigned type;
ngx_atomic_t response_time_counter;
ngx_msec_t response_time;
ngx_http_vhost_traffic_status_node_time_queue_t response_times;
ngx_http_vhost_traffic_status_node_histogram_bucket_t response_buckets;
} ngx_http_vhost_traffic_status_node_upstream_t;
typedef struct {
u_char color;
ngx_atomic_t stat_request_counter;
ngx_atomic_t stat_in_bytes;
ngx_atomic_t stat_out_bytes;
ngx_atomic_t stat_1xx_counter;
ngx_atomic_t stat_2xx_counter;
ngx_atomic_t stat_3xx_counter;
ngx_atomic_t stat_4xx_counter;
ngx_atomic_t stat_5xx_counter;
ngx_atomic_t stat_request_time_counter;
ngx_msec_t stat_request_time;
ngx_http_vhost_traffic_status_node_time_queue_t stat_request_times;
ngx_http_vhost_traffic_status_node_histogram_bucket_t stat_request_buckets;
/* deals with the overflow of variables */
ngx_atomic_t stat_request_counter_oc;
ngx_atomic_t stat_in_bytes_oc;
ngx_atomic_t stat_out_bytes_oc;
ngx_atomic_t stat_1xx_counter_oc;
ngx_atomic_t stat_2xx_counter_oc;
ngx_atomic_t stat_3xx_counter_oc;
ngx_atomic_t stat_4xx_counter_oc;
ngx_atomic_t stat_5xx_counter_oc;
ngx_atomic_t stat_request_time_counter_oc;
ngx_atomic_t stat_response_time_counter_oc;
#if (NGX_HTTP_CACHE)
ngx_atomic_t stat_cache_max_size;
ngx_atomic_t stat_cache_used_size;
ngx_atomic_t stat_cache_miss_counter;
ngx_atomic_t stat_cache_bypass_counter;
ngx_atomic_t stat_cache_expired_counter;
ngx_atomic_t stat_cache_stale_counter;
ngx_atomic_t stat_cache_updating_counter;
ngx_atomic_t stat_cache_revalidated_counter;
ngx_atomic_t stat_cache_hit_counter;
ngx_atomic_t stat_cache_scarce_counter;
/* deals with the overflow of variables */
ngx_atomic_t stat_cache_miss_counter_oc;
ngx_atomic_t stat_cache_bypass_counter_oc;
ngx_atomic_t stat_cache_expired_counter_oc;
ngx_atomic_t stat_cache_stale_counter_oc;
ngx_atomic_t stat_cache_updating_counter_oc;
ngx_atomic_t stat_cache_revalidated_counter_oc;
ngx_atomic_t stat_cache_hit_counter_oc;
ngx_atomic_t stat_cache_scarce_counter_oc;
#endif
ngx_http_vhost_traffic_status_node_upstream_t stat_upstream;
size_t len;
u_char data[1];
} ngx_http_vhost_traffic_status_node_t;
ngx_int_t ngx_http_vhost_traffic_status_node_generate_key(ngx_pool_t *pool,
ngx_str_t *buf, ngx_str_t *dst, unsigned type);
ngx_int_t ngx_http_vhost_traffic_status_node_position_key(ngx_str_t *buf,
size_t pos);
ngx_rbtree_node_t *ngx_http_vhost_traffic_status_node_lookup(
ngx_rbtree_t *rbtree, ngx_str_t *key, uint32_t hash);
void ngx_http_vhost_traffic_status_node_zero(
ngx_http_vhost_traffic_status_node_t *vtsn);
void ngx_http_vhost_traffic_status_node_init(ngx_http_request_t *r,
ngx_http_vhost_traffic_status_node_t *vtsn);
void ngx_http_vhost_traffic_status_node_set(ngx_http_request_t *r,
ngx_http_vhost_traffic_status_node_t *vtsn);
void ngx_http_vhost_traffic_status_node_update(ngx_http_request_t *r,
ngx_http_vhost_traffic_status_node_t *vtsn, ngx_msec_int_t ms);
void ngx_http_vhost_traffic_status_node_time_queue_zero(
ngx_http_vhost_traffic_status_node_time_queue_t *q);
void ngx_http_vhost_traffic_status_node_time_queue_init(
ngx_http_vhost_traffic_status_node_time_queue_t *q);
void ngx_http_vhost_traffic_status_node_time_queue_insert(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_msec_int_t x);
ngx_int_t ngx_http_vhost_traffic_status_node_time_queue_push(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_msec_int_t x);
ngx_int_t ngx_http_vhost_traffic_status_node_time_queue_pop(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_http_vhost_traffic_status_node_time_t *x);
ngx_int_t ngx_http_vhost_traffic_status_node_time_queue_rear(
ngx_http_vhost_traffic_status_node_time_queue_t *q);
ngx_msec_t ngx_http_vhost_traffic_status_node_time_queue_average(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_int_t method, ngx_msec_t period);
ngx_msec_t ngx_http_vhost_traffic_status_node_time_queue_amm(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_msec_t period);
ngx_msec_t ngx_http_vhost_traffic_status_node_time_queue_wma(
ngx_http_vhost_traffic_status_node_time_queue_t *q,
ngx_msec_t period);
void ngx_http_vhost_traffic_status_node_time_queue_merge(
ngx_http_vhost_traffic_status_node_time_queue_t *a,
ngx_http_vhost_traffic_status_node_time_queue_t *b,
ngx_msec_t period);
void ngx_http_vhost_traffic_status_node_histogram_bucket_init(
ngx_http_request_t *r,
ngx_http_vhost_traffic_status_node_histogram_bucket_t *b);
void ngx_http_vhost_traffic_status_node_histogram_observe(
ngx_http_vhost_traffic_status_node_histogram_bucket_t *b,
ngx_msec_int_t x);
void ngx_http_vhost_traffic_status_find_name(ngx_http_request_t *r,
ngx_str_t *buf);
ngx_rbtree_node_t *ngx_http_vhost_traffic_status_find_node(ngx_http_request_t *r,
ngx_str_t *key, unsigned type, uint32_t key_hash);
ngx_rbtree_node_t *ngx_http_vhost_traffic_status_find_lru(ngx_http_request_t *r);
ngx_rbtree_node_t *ngx_http_vhost_traffic_status_find_lru_node(ngx_http_request_t *r,
ngx_rbtree_node_t *a, ngx_rbtree_node_t *b);
ngx_rbtree_node_t *ngx_http_vhost_traffic_status_find_lru_node_cmp(ngx_http_request_t *r,
ngx_rbtree_node_t *a, ngx_rbtree_node_t *b);
ngx_int_t ngx_http_vhost_traffic_status_node_member_cmp(ngx_str_t *member, const char *name);
ngx_atomic_uint_t ngx_http_vhost_traffic_status_node_member(
ngx_http_vhost_traffic_status_node_t *vtsn,
ngx_str_t *member);
#endif /* _NGX_HTTP_VTS_NODE_H_INCLUDED_ */
/* vi:set ft=c ts=4 sw=4 et fdm=marker: */