Home
last modified time | relevance | path

Searched refs:peers (Results 1 – 22 of 22) sorted by relevance

/f-stack/app/nginx-1.16.1/src/stream/
H A Dngx_stream_upstream_round_robin.c81 peers->number = n; in ngx_stream_upstream_init_round_robin()
210 if (peers == NULL) { in ngx_stream_upstream_init_round_robin()
220 peers->number = n; in ngx_stream_upstream_init_round_robin()
221 peers->weighted = 0; in ngx_stream_upstream_init_round_robin()
274 if (rrp->peers->next && rrp->peers->next->number > n) { in ngx_stream_upstream_init_round_robin_peer()
396 rrp->peers = peers; in ngx_stream_upstream_create_round_robin_peer()
441 peers = rrp->peers; in ngx_stream_upstream_get_round_robin_peer()
484 if (peers->next) { in ngx_stream_upstream_get_round_robin_peer()
488 rrp->peers = peers->next; in ngx_stream_upstream_get_round_robin_peer()
715 peers = rrp->peers; in ngx_stream_upstream_set_round_robin_peer_session()
[all …]
H A Dngx_stream_upstream_round_robin.h83 #define ngx_stream_upstream_rr_peers_rlock(peers) \ argument
85 if (peers->shpool) { \
86 ngx_rwlock_rlock(&peers->rwlock); \
89 #define ngx_stream_upstream_rr_peers_wlock(peers) \ argument
91 if (peers->shpool) { \
116 #define ngx_stream_upstream_rr_peers_rlock(peers) argument
117 #define ngx_stream_upstream_rr_peers_wlock(peers) argument
118 #define ngx_stream_upstream_rr_peers_unlock(peers) argument
119 #define ngx_stream_upstream_rr_peer_lock(peers, peer) argument
120 #define ngx_stream_upstream_rr_peer_unlock(peers, peer) argument
[all …]
H A Dngx_stream_upstream_zone_module.c142 peers = peers->zone_next; in ngx_stream_upstream_init_zone()
171 if (peers == NULL) { in ngx_stream_upstream_init_zone()
175 *peersp = peers; in ngx_stream_upstream_init_zone()
192 if (peers == NULL) { in ngx_stream_upstream_zone_copy_peers()
208 ngx_memcpy(name->data, peers->name->data, peers->name->len); in ngx_stream_upstream_zone_copy_peers()
211 peers->name = name; in ngx_stream_upstream_zone_copy_peers()
213 peers->shpool = shpool; in ngx_stream_upstream_zone_copy_peers()
250 peers->next = backup; in ngx_stream_upstream_zone_copy_peers()
254 uscf->peer.data = peers; in ngx_stream_upstream_zone_copy_peers()
256 return peers; in ngx_stream_upstream_zone_copy_peers()
[all …]
H A Dngx_stream_upstream_random_module.c45 ngx_stream_upstream_rr_peers_t *peers,
128 peers = us->peer.data; in ngx_stream_upstream_update_random()
212 ngx_stream_upstream_rr_peers_t *peers; in ngx_stream_upstream_get_random_peer() local
219 peers = rrp->peers; in ngx_stream_upstream_get_random_peer()
221 ngx_stream_upstream_rr_peers_rlock(peers); in ngx_stream_upstream_get_random_peer()
223 if (rp->tries > 20 || peers->single) { in ngx_stream_upstream_get_random_peer()
313 peers = rrp->peers; in ngx_stream_upstream_get_random2_peer()
315 ngx_stream_upstream_rr_peers_wlock(peers); in ngx_stream_upstream_get_random2_peer()
317 if (rp->tries > 20 || peers->single) { in ngx_stream_upstream_get_random2_peer()
412 x = ngx_random() % peers->total_weight; in ngx_stream_upstream_peek_random_peer()
[all …]
H A Dngx_stream_upstream_least_conn_module.c106 ngx_stream_upstream_rr_peers_t *peers; in ngx_stream_upstream_get_least_conn_peer() local
111 if (rrp->peers->single) { in ngx_stream_upstream_get_least_conn_peer()
119 peers = rrp->peers; in ngx_stream_upstream_get_least_conn_peer()
121 ngx_stream_upstream_rr_peers_wlock(peers); in ngx_stream_upstream_get_least_conn_peer()
131 for (peer = peers->peer, i = 0; in ngx_stream_upstream_get_least_conn_peer()
249 ngx_stream_upstream_rr_peers_unlock(peers); in ngx_stream_upstream_get_least_conn_peer()
255 if (peers->next) { in ngx_stream_upstream_get_least_conn_peer()
259 rrp->peers = peers->next; in ngx_stream_upstream_get_least_conn_peer()
276 ngx_stream_upstream_rr_peers_wlock(peers); in ngx_stream_upstream_get_least_conn_peer()
279 ngx_stream_upstream_rr_peers_unlock(peers); in ngx_stream_upstream_get_least_conn_peer()
[all …]
H A Dngx_stream_upstream_hash_module.c179 ngx_stream_upstream_rr_peers_rlock(hp->rrp.peers); in ngx_stream_upstream_get_hash_peer()
181 if (hp->tries > 20 || hp->rrp.peers->single) { in ngx_stream_upstream_get_hash_peer()
213 w = hp->hash % hp->rrp.peers->total_weight; in ngx_stream_upstream_get_hash_peer()
214 peer = hp->rrp.peers->peer; in ngx_stream_upstream_get_hash_peer()
276 ngx_stream_upstream_rr_peers_unlock(hp->rrp.peers); in ngx_stream_upstream_get_hash_peer()
294 ngx_stream_upstream_rr_peers_t *peers; in ngx_stream_upstream_init_chash() local
308 peers = us->peer.data; in ngx_stream_upstream_init_chash()
309 npoints = peers->total_weight * 160; in ngx_stream_upstream_init_chash()
484 ngx_stream_upstream_rr_peers_rlock(hp->rrp.peers); in ngx_stream_upstream_init_chash_peer()
514 if (hp->tries > 20 || hp->rrp.peers->single) { in ngx_stream_upstream_get_chash_peer()
[all …]
/f-stack/app/nginx-1.16.1/src/http/
H A Dngx_http_upstream_round_robin.c75 peers->number = n; in ngx_http_upstream_init_round_robin()
204 if (peers == NULL) { in ngx_http_upstream_init_round_robin()
214 peers->number = n; in ngx_http_upstream_init_round_robin()
215 peers->weighted = 0; in ngx_http_upstream_init_round_robin()
267 if (rrp->peers->next && rrp->peers->next->number > n) { in ngx_http_upstream_init_round_robin_peer()
386 rrp->peers = peers; in ngx_http_upstream_create_round_robin_peer()
432 peers = rrp->peers; in ngx_http_upstream_get_round_robin_peer()
475 if (peers->next) { in ngx_http_upstream_get_round_robin_peer()
479 rrp->peers = peers->next; in ngx_http_upstream_get_round_robin_peer()
683 peers = rrp->peers; in ngx_http_upstream_set_round_robin_peer_session()
[all …]
H A Dngx_http_upstream_round_robin.h85 #define ngx_http_upstream_rr_peers_rlock(peers) \ argument
87 if (peers->shpool) { \
88 ngx_rwlock_rlock(&peers->rwlock); \
91 #define ngx_http_upstream_rr_peers_wlock(peers) \ argument
93 if (peers->shpool) { \
118 #define ngx_http_upstream_rr_peers_rlock(peers) argument
119 #define ngx_http_upstream_rr_peers_wlock(peers) argument
120 #define ngx_http_upstream_rr_peers_unlock(peers) argument
121 #define ngx_http_upstream_rr_peer_lock(peers, peer) argument
122 #define ngx_http_upstream_rr_peer_unlock(peers, peer) argument
[all …]
/f-stack/app/nginx-1.16.1/src/http/modules/
H A Dngx_http_upstream_zone_module.c145 peers = peers->zone_next; in ngx_http_upstream_init_zone()
174 if (peers == NULL) { in ngx_http_upstream_init_zone()
178 *peersp = peers; in ngx_http_upstream_init_zone()
195 if (peers == NULL) { in ngx_http_upstream_zone_copy_peers()
211 ngx_memcpy(name->data, peers->name->data, peers->name->len); in ngx_http_upstream_zone_copy_peers()
214 peers->name = name; in ngx_http_upstream_zone_copy_peers()
216 peers->shpool = shpool; in ngx_http_upstream_zone_copy_peers()
253 peers->next = backup; in ngx_http_upstream_zone_copy_peers()
257 uscf->peer.data = peers; in ngx_http_upstream_zone_copy_peers()
259 return peers; in ngx_http_upstream_zone_copy_peers()
[all …]
H A Dngx_http_upstream_random_module.c45 ngx_http_upstream_rr_peers_t *peers,
130 peers = us->peer.data; in ngx_http_upstream_update_random()
212 ngx_http_upstream_rr_peers_t *peers; in ngx_http_upstream_get_random_peer() local
219 peers = rrp->peers; in ngx_http_upstream_get_random_peer()
221 ngx_http_upstream_rr_peers_rlock(peers); in ngx_http_upstream_get_random_peer()
223 if (rp->tries > 20 || peers->single) { in ngx_http_upstream_get_random_peer()
313 peers = rrp->peers; in ngx_http_upstream_get_random2_peer()
315 ngx_http_upstream_rr_peers_wlock(peers); in ngx_http_upstream_get_random2_peer()
317 if (rp->tries > 20 || peers->single) { in ngx_http_upstream_get_random2_peer()
412 x = ngx_random() % peers->total_weight; in ngx_http_upstream_peek_random_peer()
[all …]
H A Dngx_http_upstream_least_conn_module.c109 ngx_http_upstream_rr_peers_t *peers; in ngx_http_upstream_get_least_conn_peer() local
114 if (rrp->peers->single) { in ngx_http_upstream_get_least_conn_peer()
123 peers = rrp->peers; in ngx_http_upstream_get_least_conn_peer()
125 ngx_http_upstream_rr_peers_wlock(peers); in ngx_http_upstream_get_least_conn_peer()
135 for (peer = peers->peer, i = 0; in ngx_http_upstream_get_least_conn_peer()
253 ngx_http_upstream_rr_peers_unlock(peers); in ngx_http_upstream_get_least_conn_peer()
259 if (peers->next) { in ngx_http_upstream_get_least_conn_peer()
263 rrp->peers = peers->next; in ngx_http_upstream_get_least_conn_peer()
280 ngx_http_upstream_rr_peers_wlock(peers); in ngx_http_upstream_get_least_conn_peer()
283 ngx_http_upstream_rr_peers_unlock(peers); in ngx_http_upstream_get_least_conn_peer()
[all …]
H A Dngx_http_upstream_ip_hash_module.c164 ngx_http_upstream_rr_peers_rlock(iphp->rrp.peers); in ngx_http_upstream_get_ip_hash_peer()
166 if (iphp->tries > 20 || iphp->rrp.peers->single) { in ngx_http_upstream_get_ip_hash_peer()
167 ngx_http_upstream_rr_peers_unlock(iphp->rrp.peers); in ngx_http_upstream_get_ip_hash_peer()
184 w = hash % iphp->rrp.peers->total_weight; in ngx_http_upstream_get_ip_hash_peer()
185 peer = iphp->rrp.peers->peer; in ngx_http_upstream_get_ip_hash_peer()
204 ngx_http_upstream_rr_peer_lock(iphp->rrp.peers, peer); in ngx_http_upstream_get_ip_hash_peer()
207 ngx_http_upstream_rr_peer_unlock(iphp->rrp.peers, peer); in ngx_http_upstream_get_ip_hash_peer()
215 ngx_http_upstream_rr_peer_unlock(iphp->rrp.peers, peer); in ngx_http_upstream_get_ip_hash_peer()
229 ngx_http_upstream_rr_peers_unlock(iphp->rrp.peers); in ngx_http_upstream_get_ip_hash_peer()
246 ngx_http_upstream_rr_peer_unlock(iphp->rrp.peers, peer); in ngx_http_upstream_get_ip_hash_peer()
[all …]
H A Dngx_http_upstream_hash_module.c179 ngx_http_upstream_rr_peers_rlock(hp->rrp.peers); in ngx_http_upstream_get_hash_peer()
181 if (hp->tries > 20 || hp->rrp.peers->single) { in ngx_http_upstream_get_hash_peer()
214 w = hp->hash % hp->rrp.peers->total_weight; in ngx_http_upstream_get_hash_peer()
215 peer = hp->rrp.peers->peer; in ngx_http_upstream_get_hash_peer()
277 ngx_http_upstream_rr_peers_unlock(hp->rrp.peers); in ngx_http_upstream_get_hash_peer()
294 ngx_http_upstream_rr_peers_t *peers; in ngx_http_upstream_init_chash() local
308 peers = us->peer.data; in ngx_http_upstream_init_chash()
309 npoints = peers->total_weight * 160; in ngx_http_upstream_init_chash()
482 ngx_http_upstream_rr_peers_rlock(hp->rrp.peers); in ngx_http_upstream_init_chash_peer()
512 if (hp->tries > 20 || hp->rrp.peers->single) { in ngx_http_upstream_get_chash_peer()
[all …]
/f-stack/dpdk/drivers/net/mlx5/
H A Dmlx5_trigger.c264 txq_ctrl->hairpin_conf.peers[0].queue); in mlx5_hairpin_auto_bind()
270 txq_ctrl->hairpin_conf.peers[0].queue); in mlx5_hairpin_auto_bind()
274 rxq_ctrl->hairpin_conf.peers[0].queue != i) { in mlx5_hairpin_auto_bind()
278 i, txq_ctrl->hairpin_conf.peers[0].queue); in mlx5_hairpin_auto_bind()
286 txq_ctrl->hairpin_conf.peers[0].queue); in mlx5_hairpin_auto_bind()
723 if (conf->peers[0].port == rx_port) { in mlx5_hairpin_bind_single_port()
760 rx_queue = txq_ctrl->hairpin_conf.peers[0].queue; in mlx5_hairpin_bind_single_port()
806 rx_queue = txq_ctrl->hairpin_conf.peers[0].queue; in mlx5_hairpin_bind_single_port()
984 pp = txq_ctrl->hairpin_conf.peers[0].port; in mlx5_hairpin_get_peer_ports()
1005 pp = rxq_ctrl->hairpin_conf.peers[0].port; in mlx5_hairpin_get_peer_ports()
[all …]
H A Dmlx5_txq.c431 if (hairpin_conf->peers[0].port == dev->data->port_id) { in mlx5_tx_hairpin_queue_setup()
432 if (hairpin_conf->peers[0].queue >= priv->rxqs_n) { in mlx5_tx_hairpin_queue_setup()
437 hairpin_conf->peers[0].queue, priv->txqs_n); in mlx5_tx_hairpin_queue_setup()
447 hairpin_conf->peers[0].port, in mlx5_tx_hairpin_queue_setup()
H A Dmlx5_rxq.c827 if (hairpin_conf->peers[0].port == dev->data->port_id) { in mlx5_rx_hairpin_queue_setup()
828 if (hairpin_conf->peers[0].queue >= priv->txqs_n) { in mlx5_rx_hairpin_queue_setup()
833 hairpin_conf->peers[0].queue, priv->txqs_n); in mlx5_rx_hairpin_queue_setup()
843 hairpin_conf->peers[0].port, in mlx5_rx_hairpin_queue_setup()
/f-stack/dpdk/app/test-flow-perf/
H A Dmain.c1380 hairpin_conf.peers[0].port = port_id; in init_port()
1381 hairpin_conf.peers[0].queue = in init_port()
1395 hairpin_conf.peers[0].port = port_id; in init_port()
1396 hairpin_conf.peers[0].queue = in init_port()
/f-stack/dpdk/app/test-pmd/
H A Dtestpmd.c2413 hairpin_conf.peers[0].port = peer_rx_port; in setup_hairpin_queues()
2414 hairpin_conf.peers[0].queue = i + nb_rxq; in setup_hairpin_queues()
2436 hairpin_conf.peers[0].port = peer_tx_port; in setup_hairpin_queues()
2437 hairpin_conf.peers[0].queue = i + nb_txq; in setup_hairpin_queues()
/f-stack/dpdk/doc/guides/testpmd_app_ug/
H A Drun_app.rst129 * ``--eth-peers-configfile=name``
H A Dtestpmd_funcs.rst327 …'eth-peers-configfile' command-line options. It is not currently possible to specify a specific so…
/f-stack/dpdk/lib/librte_ethdev/
H A Drte_ethdev.h1140 struct rte_eth_hairpin_peer peers[RTE_ETH_MAX_HAIRPIN_PEERS]; member
/f-stack/freebsd/contrib/dev/acpica/
H A Dchanges.txt15657 first in the parent's child list, and had additional peers (not