| /f-stack/app/nginx-1.16.1/src/stream/ |
| H A D | ngx_stream_upstream_round_robin.c | 357 peers->peer = peer; in ngx_stream_upstream_create_round_robin_peer()
445 peer = peers->peer; in ngx_stream_upstream_get_round_robin_peer()
451 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_round_robin_peer()
534 for (peer = rrp->peers->peer, i = 0; in ngx_stream_upstream_get_peer()
536 peer = peer->next, i++) in ngx_stream_upstream_get_peer()
550 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_peer()
556 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_peer()
629 peer->effective_weight -= peer->weight / peer->max_fails; in ngx_stream_upstream_free_round_robin_peer()
631 if (peer->fails >= peer->max_fails) { in ngx_stream_upstream_free_round_robin_peer()
649 if (peer->accessed < peer->checked) { in ngx_stream_upstream_free_round_robin_peer()
[all …]
|
| H A D | ngx_stream_upstream_least_conn_module.c | 131 for (peer = peers->peer, i = 0; in ngx_stream_upstream_get_least_conn_peer()
132 peer; in ngx_stream_upstream_get_least_conn_peer()
133 peer = peer->next, i++) in ngx_stream_upstream_get_least_conn_peer()
147 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_least_conn_peer()
148 && now - peer->checked <= peer->fail_timeout) in ngx_stream_upstream_get_least_conn_peer()
153 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_least_conn_peer()
188 peer = peer->next, i++) in ngx_stream_upstream_get_least_conn_peer()
206 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_least_conn_peer()
212 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_least_conn_peer()
216 peer->current_weight += peer->effective_weight; in ngx_stream_upstream_get_least_conn_peer()
[all …]
|
| H A D | ngx_stream_upstream_random_module.c | 139 for (peer = peers->peer, i = 0; peer; peer = peer->next, i++) { in ngx_stream_upstream_update_random()
140 ranges[i].peer = peer; in ngx_stream_upstream_update_random()
237 peer = rp->conf->ranges[i].peer; in ngx_stream_upstream_get_random_peer()
254 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_random_peer()
255 && now - peer->checked <= peer->fail_timeout) in ngx_stream_upstream_get_random_peer()
261 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_random_peer()
278 if (now - peer->checked > peer->fail_timeout) { in ngx_stream_upstream_get_random_peer()
337 peer = rp->conf->ranges[i].peer; in ngx_stream_upstream_get_random2_peer()
355 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_random2_peer()
361 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_random2_peer()
[all …]
|
| H A D | ngx_stream_upstream_hash_module.c | 214 peer = hp->rrp.peers->peer; in ngx_stream_upstream_get_hash_peer()
219 peer = peer->next; in ngx_stream_upstream_get_hash_peer()
241 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_hash_peer()
242 && now - peer->checked <= peer->fail_timeout) in ngx_stream_upstream_get_hash_peer()
248 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_stream_upstream_get_hash_peer()
271 if (now - peer->checked > peer->fail_timeout) { in ngx_stream_upstream_get_hash_peer()
321 for (peer = peers->peer; peer; peer = peer->next) { in ngx_stream_upstream_init_chash()
538 for (peer = hp->rrp.peers->peer, i = 0; in ngx_stream_upstream_get_chash_peer()
540 peer = peer->next, i++) in ngx_stream_upstream_get_chash_peer()
554 && peer->fails >= peer->max_fails in ngx_stream_upstream_get_chash_peer()
[all …]
|
| H A D | ngx_stream_upstream_zone_module.c | 141 uscf->peer.data = peers; in ngx_stream_upstream_init_zone()
188 ngx_stream_upstream_rr_peer_t *peer, **peerp; in ngx_stream_upstream_zone_copy_peers() local
215 for (peerp = &peers->peer; *peerp; peerp = &peer->next) { in ngx_stream_upstream_zone_copy_peers()
217 peer = ngx_stream_upstream_zone_copy_peer(peers, *peerp); in ngx_stream_upstream_zone_copy_peers()
218 if (peer == NULL) { in ngx_stream_upstream_zone_copy_peers()
222 *peerp = peer; in ngx_stream_upstream_zone_copy_peers()
240 for (peerp = &backup->peer; *peerp; peerp = &peer->next) { in ngx_stream_upstream_zone_copy_peers()
242 peer = ngx_stream_upstream_zone_copy_peer(backup, *peerp); in ngx_stream_upstream_zone_copy_peers()
243 if (peer == NULL) { in ngx_stream_upstream_zone_copy_peers()
247 *peerp = peer; in ngx_stream_upstream_zone_copy_peers()
[all …]
|
| H A D | ngx_stream_upstream_round_robin.h | 77 ngx_stream_upstream_rr_peer_t *peer; member
102 #define ngx_stream_upstream_rr_peer_lock(peers, peer) \ argument
105 ngx_rwlock_wlock(&peer->lock); \
108 #define ngx_stream_upstream_rr_peer_unlock(peers, peer) \ argument
111 ngx_rwlock_unlock(&peer->lock); \
119 #define ngx_stream_upstream_rr_peer_lock(peers, peer) argument
120 #define ngx_stream_upstream_rr_peer_unlock(peers, peer) argument
|
| H A D | ngx_stream_proxy_module.c | 414 u->peer.log = c->log; in ngx_stream_proxy_handler()
684 u->peer.local = addr; in ngx_stream_proxy_set_local()
736 u->state->peer = u->peer.name; in ngx_stream_proxy_connect()
841 if (u->peer.notify) { in ngx_stream_proxy_init_upstream()
842 u->peer.notify(&u->peer, u->peer.data, in ngx_stream_proxy_init_upstream()
1055 if (u->peer.set_session(&u->peer, u->peer.data) != NGX_OK) { in ngx_stream_proxy_ssl_init_connection()
1137 u->peer.save_session(&u->peer, u->peer.data); in ngx_stream_proxy_ssl_save_session()
1815 u->peer.free(&u->peer, u->peer.data, NGX_PEER_FAILED); in ngx_stream_proxy_next_upstream()
1889 if (u->peer.free && u->peer.sockaddr) { in ngx_stream_proxy_finalize()
1898 u->peer.free(&u->peer, u->peer.data, state); in ngx_stream_proxy_finalize()
[all …]
|
| /f-stack/app/nginx-1.16.1/src/http/ |
| H A D | ngx_http_upstream_round_robin.c | 347 peers->peer = peer; in ngx_http_upstream_create_round_robin_peer()
436 peer = peers->peer; in ngx_http_upstream_get_round_robin_peer()
442 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_round_robin_peer()
460 peer, peer->current_weight); in ngx_http_upstream_get_round_robin_peer()
525 for (peer = rrp->peers->peer, i = 0; in ngx_http_upstream_get_peer()
527 peer = peer->next, i++) in ngx_http_upstream_get_peer()
541 && peer->fails >= peer->max_fails in ngx_http_upstream_get_peer()
547 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_peer()
623 peer->effective_weight -= peer->weight / peer->max_fails; in ngx_http_upstream_free_round_robin_peer()
625 if (peer->fails >= peer->max_fails) { in ngx_http_upstream_free_round_robin_peer()
[all …]
|
| H A D | ngx_http_upstream_round_robin.h | 79 ngx_http_upstream_rr_peer_t *peer; member
104 #define ngx_http_upstream_rr_peer_lock(peers, peer) \ argument
107 ngx_rwlock_wlock(&peer->lock); \
110 #define ngx_http_upstream_rr_peer_unlock(peers, peer) \ argument
113 ngx_rwlock_unlock(&peer->lock); \
121 #define ngx_http_upstream_rr_peer_lock(peers, peer) argument
122 #define ngx_http_upstream_rr_peer_unlock(peers, peer) argument
|
| H A D | ngx_http_upstream.c | 1542 u->state->peer = u->peer.name; in ngx_http_upstream_connect()
1557 c = u->peer.connection; in ngx_http_upstream_connect()
1693 if (u->peer.set_session(&u->peer, u->peer.data) != NGX_OK) { in ngx_http_upstream_ssl_init_connection()
1813 u->peer.save_session(&u->peer, u->peer.data); in ngx_http_upstream_ssl_save_session()
4156 u->peer.free(&u->peer, u->peer.data, state); in ngx_http_upstream_next()
4167 u->peer.tries++; in ngx_http_upstream_next()
4338 if (u->peer.free && u->peer.sockaddr) { in ngx_http_upstream_finalize_request()
4339 u->peer.free(&u->peer, u->peer.data, 0); in ngx_http_upstream_finalize_request()
5309 p = ngx_cpymem(p, state[i].peer->data, state[i].peer->len); in ngx_http_upstream_addr_variable()
6226 u->peer.local = addr; in ngx_http_upstream_set_local()
[all …]
|
| /f-stack/app/nginx-1.16.1/src/core/ |
| H A D | ngx_syslog.c | 81 cln->data = peer; in ngx_syslog_process_conf()
238 pri = peer->facility * 8 + peer->severity; in ngx_syslog_add_header()
240 if (peer->nohostname) { in ngx_syslog_add_header()
256 ngx_syslog_peer_t *peer; in ngx_syslog_writer() local
258 peer = log->wdata; in ngx_syslog_writer()
260 if (peer->busy) { in ngx_syslog_writer()
264 peer->busy = 1; in ngx_syslog_writer()
280 peer->busy = 0; in ngx_syslog_writer()
338 if (connect(fd, peer->server.sockaddr, peer->server.socklen) == -1) { in ngx_syslog_init_peer()
344 peer->conn.fd = fd; in ngx_syslog_init_peer()
[all …]
|
| H A D | ngx_syslog.h | 23 char *ngx_syslog_process_conf(ngx_conf_t *cf, ngx_syslog_peer_t *peer);
24 u_char *ngx_syslog_add_header(ngx_syslog_peer_t *peer, u_char *buf);
27 ssize_t ngx_syslog_send(ngx_syslog_peer_t *peer, u_char *buf, size_t len);
|
| /f-stack/app/nginx-1.16.1/src/http/modules/ |
| H A D | ngx_http_upstream_least_conn_module.c | 135 for (peer = peers->peer, i = 0; in ngx_http_upstream_get_least_conn_peer()
136 peer; in ngx_http_upstream_get_least_conn_peer()
137 peer = peer->next, i++) in ngx_http_upstream_get_least_conn_peer()
151 && peer->fails >= peer->max_fails in ngx_http_upstream_get_least_conn_peer()
152 && now - peer->checked <= peer->fail_timeout) in ngx_http_upstream_get_least_conn_peer()
157 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_least_conn_peer()
192 peer = peer->next, i++) in ngx_http_upstream_get_least_conn_peer()
210 && peer->fails >= peer->max_fails in ngx_http_upstream_get_least_conn_peer()
216 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_least_conn_peer()
220 peer->current_weight += peer->effective_weight; in ngx_http_upstream_get_least_conn_peer()
[all …]
|
| H A D | ngx_http_upstream_random_module.c | 141 for (peer = peers->peer, i = 0; peer; peer = peer->next, i++) { in ngx_http_upstream_update_random()
142 ranges[i].peer = peer; in ngx_http_upstream_update_random()
237 peer = rp->conf->ranges[i].peer; in ngx_http_upstream_get_random_peer()
254 && peer->fails >= peer->max_fails in ngx_http_upstream_get_random_peer()
255 && now - peer->checked <= peer->fail_timeout) in ngx_http_upstream_get_random_peer()
261 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_random_peer()
278 if (now - peer->checked > peer->fail_timeout) { in ngx_http_upstream_get_random_peer()
337 peer = rp->conf->ranges[i].peer; in ngx_http_upstream_get_random2_peer()
355 && peer->fails >= peer->max_fails in ngx_http_upstream_get_random2_peer()
361 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_random2_peer()
[all …]
|
| H A D | ngx_http_upstream_ip_hash_module.c | 185 peer = iphp->rrp.peers->peer; in ngx_http_upstream_get_ip_hash_peer()
190 peer = peer->next; in ngx_http_upstream_get_ip_hash_peer()
206 if (peer->down) { in ngx_http_upstream_get_ip_hash_peer()
211 if (peer->max_fails in ngx_http_upstream_get_ip_hash_peer()
212 && peer->fails >= peer->max_fails in ngx_http_upstream_get_ip_hash_peer()
213 && now - peer->checked <= peer->fail_timeout) in ngx_http_upstream_get_ip_hash_peer()
219 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_ip_hash_peer()
238 pc->name = &peer->name; in ngx_http_upstream_get_ip_hash_peer()
240 peer->conns++; in ngx_http_upstream_get_ip_hash_peer()
242 if (now - peer->checked > peer->fail_timeout) { in ngx_http_upstream_get_ip_hash_peer()
[all …]
|
| H A D | ngx_http_upstream_hash_module.c | 215 peer = hp->rrp.peers->peer; in ngx_http_upstream_get_hash_peer()
220 peer = peer->next; in ngx_http_upstream_get_hash_peer()
242 && peer->fails >= peer->max_fails in ngx_http_upstream_get_hash_peer()
243 && now - peer->checked <= peer->fail_timeout) in ngx_http_upstream_get_hash_peer()
249 if (peer->max_conns && peer->conns >= peer->max_conns) { in ngx_http_upstream_get_hash_peer()
272 if (now - peer->checked > peer->fail_timeout) { in ngx_http_upstream_get_hash_peer()
321 for (peer = peers->peer; peer; peer = peer->next) { in ngx_http_upstream_init_chash()
537 for (peer = hp->rrp.peers->peer, i = 0; in ngx_http_upstream_get_chash_peer()
539 peer = peer->next, i++) in ngx_http_upstream_get_chash_peer()
553 && peer->fails >= peer->max_fails in ngx_http_upstream_get_chash_peer()
[all …]
|
| H A D | ngx_http_upstream_zone_module.c | 144 uscf->peer.data = peers; in ngx_http_upstream_init_zone()
191 ngx_http_upstream_rr_peer_t *peer, **peerp; in ngx_http_upstream_zone_copy_peers() local
218 for (peerp = &peers->peer; *peerp; peerp = &peer->next) { in ngx_http_upstream_zone_copy_peers()
220 peer = ngx_http_upstream_zone_copy_peer(peers, *peerp); in ngx_http_upstream_zone_copy_peers()
221 if (peer == NULL) { in ngx_http_upstream_zone_copy_peers()
225 *peerp = peer; in ngx_http_upstream_zone_copy_peers()
243 for (peerp = &backup->peer; *peerp; peerp = &peer->next) { in ngx_http_upstream_zone_copy_peers()
245 peer = ngx_http_upstream_zone_copy_peer(backup, *peerp); in ngx_http_upstream_zone_copy_peers()
246 if (peer == NULL) { in ngx_http_upstream_zone_copy_peers()
250 *peerp = peer; in ngx_http_upstream_zone_copy_peers()
[all …]
|
| H A D | ngx_http_upstream_keepalive_module.c | 159 kcf->original_init_peer = us->peer.init; in ngx_http_upstream_init_keepalive()
161 us->peer.init = ngx_http_upstream_init_keepalive_peer; in ngx_http_upstream_init_keepalive()
207 kp->data = r->upstream->peer.data; in ngx_http_upstream_init_keepalive_peer()
208 kp->original_get_peer = r->upstream->peer.get; in ngx_http_upstream_init_keepalive_peer()
209 kp->original_free_peer = r->upstream->peer.free; in ngx_http_upstream_init_keepalive_peer()
211 r->upstream->peer.data = kp; in ngx_http_upstream_init_keepalive_peer()
212 r->upstream->peer.get = ngx_http_upstream_get_keepalive_peer; in ngx_http_upstream_init_keepalive_peer()
216 kp->original_set_session = r->upstream->peer.set_session; in ngx_http_upstream_init_keepalive_peer()
217 kp->original_save_session = r->upstream->peer.save_session; in ngx_http_upstream_init_keepalive_peer()
554 kcf->original_init_upstream = uscf->peer.init_upstream in ngx_http_upstream_keepalive()
[all …]
|
| /f-stack/dpdk/lib/librte_eal/common/ |
| H A D | hotplug_mp.c | 19 void *peer; member
63 const void *peer) in send_response_to_secondary() argument
76 ret = rte_mp_reply(&mp_resp, peer); in send_response_to_secondary()
179 free(bundle->peer); in __handle_secondary_request()
203 bundle->peer = strdup(peer); in handle_secondary_request()
204 if (bundle->peer == NULL) { in handle_secondary_request()
217 free(bundle->peer); in handle_secondary_request()
300 free(bundle->peer); in __handle_primary_request()
336 bundle->peer = (void *)strdup(peer); in handle_primary_request()
337 if (bundle->peer == NULL) { in handle_primary_request()
[all …]
|
| /f-stack/tools/ngctl/ |
| H A D | show.c | 123 struct nodeinfo *const peer = &hlist->link[k].nodeinfo; in ShowCmd() local
126 if (!*peer->name) { in ShowCmd()
127 snprintf(peer->name, sizeof(peer->name), in ShowCmd()
130 snprintf(idbuf, sizeof(idbuf), "%08x", peer->id); in ShowCmd()
131 printf(FMT, link->ourhook, peer->name, in ShowCmd()
132 peer->type, idbuf, link->peerhook); in ShowCmd()
|
| /f-stack/app/nginx-1.16.1/src/mail/ |
| H A D | ngx_mail_auth_http_module.c | 16 ngx_addr_t *peer; member
197 ctx->peer.sockaddr = ahcf->peer->sockaddr; in ngx_mail_auth_http_init()
198 ctx->peer.socklen = ahcf->peer->socklen; in ngx_mail_auth_http_init()
199 ctx->peer.name = &ahcf->peer->name; in ngx_mail_auth_http_init()
207 if (ctx->peer.connection) { in ngx_mail_auth_http_init()
216 ctx->peer.connection->data = s; in ngx_mail_auth_http_init()
470 ngx_addr_t *peer; in ngx_mail_auth_http_process_headers() local
776 if (peer == NULL) { in ngx_mail_auth_http_process_headers()
1449 if (conf->peer == NULL) { in ngx_mail_auth_http_merge_conf()
1450 conf->peer = prev->peer; in ngx_mail_auth_http_merge_conf()
[all …]
|
| /f-stack/dpdk/drivers/net/mlx5/linux/ |
| H A D | mlx5_mp_os.c | 22 mlx5_mp_os_primary_handle(const struct rte_mp_msg *mp_msg, const void *peer) in mlx5_mp_os_primary_handle() argument
51 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
58 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
64 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
70 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
76 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
82 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
88 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_primary_handle()
111 mlx5_mp_os_secondary_handle(const struct rte_mp_msg *mp_msg, const void *peer) in mlx5_mp_os_secondary_handle() argument
137 ret = rte_mp_reply(&mp_res, peer); in mlx5_mp_os_secondary_handle()
[all …]
|
| /f-stack/dpdk/drivers/net/mlx5/ |
| H A D | mlx5_utils.h | 846 typeof(elem) peer; \
851 (peer) = mlx5_ipool_get(pool, *(head)); \
852 if (peer) \
853 (peer)->field.prev = (idx); \
860 typeof(elem) peer; \
864 (peer) = mlx5_ipool_get \
866 if (peer) \
867 (peer)->field.next = (elem)->field.next;\
870 (peer) = mlx5_ipool_get \
872 if (peer) \
[all …]
|
| /f-stack/dpdk/drivers/net/hns3/ |
| H A D | hns3_mp.c | 53 const void *peer __rte_unused) in mp_primary_handle()
70 mp_secondary_handle(const struct rte_mp_msg *mp_msg, const void *peer) in mp_secondary_handle() argument
93 ret = rte_mp_reply(&mp_res, peer); in mp_secondary_handle()
102 ret = rte_mp_reply(&mp_res, peer); in mp_secondary_handle()
|
| /f-stack/dpdk/drivers/net/mlx4/ |
| H A D | mlx4_mp.c | 52 mp_primary_handle(const struct rte_mp_msg *mp_msg, const void *peer) in mp_primary_handle() argument
78 ret = rte_mp_reply(&mp_res, peer); in mp_primary_handle()
85 ret = rte_mp_reply(&mp_res, peer); in mp_primary_handle()
107 mp_secondary_handle(const struct rte_mp_msg *mp_msg, const void *peer) in mp_secondary_handle() argument
131 ret = rte_mp_reply(&mp_res, peer); in mp_secondary_handle()
140 ret = rte_mp_reply(&mp_res, peer); in mp_secondary_handle()
|