peer 85 http/modules/ngx_http_upstream_ip_hash_module.c us->peer.init = ngx_http_upstream_init_ip_hash_peer; peer 104 http/modules/ngx_http_upstream_ip_hash_module.c r->upstream->peer.data = &iphp->rrp; peer 110 http/modules/ngx_http_upstream_ip_hash_module.c r->upstream->peer.get = ngx_http_upstream_get_ip_hash_peer; peer 144 http/modules/ngx_http_upstream_ip_hash_module.c ngx_http_upstream_rr_peer_t *peer; peer 178 http/modules/ngx_http_upstream_ip_hash_module.c peer = &iphp->rrp.peers->peer[p]; peer 182 http/modules/ngx_http_upstream_ip_hash_module.c if (!peer->down) { peer 184 http/modules/ngx_http_upstream_ip_hash_module.c if (peer->max_fails == 0 || peer->fails < peer->max_fails) { peer 188 http/modules/ngx_http_upstream_ip_hash_module.c if (now - peer->accessed > peer->fail_timeout) { peer 189 http/modules/ngx_http_upstream_ip_hash_module.c peer->fails = 0; peer 208 http/modules/ngx_http_upstream_ip_hash_module.c pc->sockaddr = peer->sockaddr; peer 209 http/modules/ngx_http_upstream_ip_hash_module.c pc->socklen = peer->socklen; peer 210 http/modules/ngx_http_upstream_ip_hash_module.c pc->name = &peer->name; peer 228 http/modules/ngx_http_upstream_ip_hash_module.c uscf->peer.init_upstream = ngx_http_upstream_init_ip_hash; peer 3123 http/ngx_http_request.c if (u && u->peer.name) { peer 3128 http/ngx_http_request.c if (u->peer.sockaddr && u->peer.sockaddr->sa_family == AF_UNIX) { peer 3134 http/ngx_http_request.c &u->schema, u->peer.name, peer 389 http/ngx_http_upstream.c u->peer.log = r->connection->log; peer 390 http/ngx_http_upstream.c u->peer.log_error = NGX_ERROR_ERR; peer 392 http/ngx_http_upstream.c u->peer.lock = &r->connection->lock; peer 493 http/ngx_http_upstream.c u->peer.local = u->conf->local; peer 622 http/ngx_http_upstream.c if (uscf->peer.init(r, uscf) != NGX_OK) { peer 977 http/ngx_http_upstream.c if (!u->cacheable && u->peer.connection) { peer 990 http/ngx_http_upstream.c if (u->peer.connection == NULL) { peer 1040 http/ngx_http_upstream.c if (!u->cacheable && u->peer.connection) { peer 1052 http/ngx_http_upstream.c if (u->peer.connection == NULL) { peer 1089 http/ngx_http_upstream.c rc = ngx_event_connect_peer(&u->peer); peer 1100 http/ngx_http_upstream.c u->state->peer = u->peer.name; peer 1115 http/ngx_http_upstream.c c = u->peer.connection; peer 1215 http/ngx_http_upstream.c if (u->peer.set_session(&u->peer, u->peer.data) != NGX_OK) { peer 1247 http/ngx_http_upstream.c u->peer.save_session(&u->peer, u->peer.data); peer 1335 http/ngx_http_upstream.c c = u->peer.connection; peer 1421 http/ngx_http_upstream.c c = u->peer.connection; peer 1459 http/ngx_http_upstream.c c = u->peer.connection; peer 1542 http/ngx_http_upstream.c u->peer.cached = 0; peer 1653 http/ngx_http_upstream.c if (u->peer.tries > 1 && (u->conf->next_upstream & un->mask)) { peer 1939 http/ngx_http_upstream.c c = u->peer.connection; peer 2107 http/ngx_http_upstream.c if (u->peer.connection->read->ready) { peer 2209 http/ngx_http_upstream.c p->upstream = u->peer.connection; peer 2337 http/ngx_http_upstream.c c = u->peer.connection; peer 2368 http/ngx_http_upstream.c upstream = u->peer.connection; peer 2593 http/ngx_http_upstream.c c = u->peer.connection; peer 2626 http/ngx_http_upstream.c if (u->peer.connection) { peer 2693 http/ngx_http_upstream.c if (!u->cacheable && !u->store && u->peer.connection) { peer 2805 http/ngx_http_upstream.c u->peer.free(&u->peer, u->peer.data, state); peer 2813 http/ngx_http_upstream.c if (u->peer.cached && ft_type == NGX_HTTP_UPSTREAM_FT_ERROR) { peer 2850 http/ngx_http_upstream.c if (u->peer.tries == 0 || !(u->conf->next_upstream & ft_type)) { peer 2876 http/ngx_http_upstream.c if (u->peer.connection) { peer 2879 http/ngx_http_upstream.c u->peer.connection->fd); peer 2882 http/ngx_http_upstream.c if (u->peer.connection->ssl) { peer 2883 http/ngx_http_upstream.c u->peer.connection->ssl->no_wait_shutdown = 1; peer 2884 http/ngx_http_upstream.c u->peer.connection->ssl->no_send_shutdown = 1; peer 2886 http/ngx_http_upstream.c (void) ngx_ssl_shutdown(u->peer.connection); peer 2890 http/ngx_http_upstream.c ngx_close_connection(u->peer.connection); peer 2956 http/ngx_http_upstream.c if (u->peer.free) { peer 2957 http/ngx_http_upstream.c u->peer.free(&u->peer, u->peer.data, 0); peer 2960 http/ngx_http_upstream.c if (u->peer.connection) { peer 2966 http/ngx_http_upstream.c if (u->peer.connection->ssl) { peer 2974 http/ngx_http_upstream.c u->peer.connection->ssl->no_wait_shutdown = 1; peer 2976 http/ngx_http_upstream.c (void) ngx_ssl_shutdown(u->peer.connection); peer 2982 http/ngx_http_upstream.c u->peer.connection->fd); peer 2984 http/ngx_http_upstream.c ngx_close_connection(u->peer.connection); peer 2987 http/ngx_http_upstream.c u->peer.connection = NULL; peer 3658 http/ngx_http_upstream.c if (state[i].peer) { peer 3659 http/ngx_http_upstream.c len += state[i].peer->len + 2; peer 3676 http/ngx_http_upstream.c if (state[i].peer) { peer 3677 http/ngx_http_upstream.c p = ngx_cpymem(p, state[i].peer->data, state[i].peer->len); peer 3684 http/ngx_http_upstream.c if (state[i].peer) { peer 3749 http/ngx_http_upstream.c if (state[i].peer) { peer 3818 http/ngx_http_upstream.c if (state[i].peer) { peer 3878 http/ngx_http_upstream.c if (state[i].peer) { peer 4485 http/ngx_http_upstream.c init = uscfp[i]->peer.init_upstream ? uscfp[i]->peer.init_upstream: peer 58 http/ngx_http_upstream.h ngx_str_t *peer; peer 104 http/ngx_http_upstream.h ngx_http_upstream_peer_t peer; peer 253 http/ngx_http_upstream.h ngx_peer_connection_t peer; peer 27 http/ngx_http_upstream_round_robin.c us->peer.init = ngx_http_upstream_init_round_robin_peer; peer 60 http/ngx_http_upstream_round_robin.c peers->peer[n].sockaddr = server[i].addrs[j].sockaddr; peer 61 http/ngx_http_upstream_round_robin.c peers->peer[n].socklen = server[i].addrs[j].socklen; peer 62 http/ngx_http_upstream_round_robin.c peers->peer[n].name = server[i].addrs[j].name; peer 63 http/ngx_http_upstream_round_robin.c peers->peer[n].max_fails = server[i].max_fails; peer 64 http/ngx_http_upstream_round_robin.c peers->peer[n].fail_timeout = server[i].fail_timeout; peer 65 http/ngx_http_upstream_round_robin.c peers->peer[n].down = server[i].down; peer 66 http/ngx_http_upstream_round_robin.c peers->peer[n].weight = server[i].down ? 0 : server[i].weight; peer 67 http/ngx_http_upstream_round_robin.c peers->peer[n].current_weight = peers->peer[n].weight; peer 72 http/ngx_http_upstream_round_robin.c us->peer.data = peers; peer 74 http/ngx_http_upstream_round_robin.c ngx_sort(&peers->peer[0], (size_t) n, peer 113 http/ngx_http_upstream_round_robin.c backup->peer[n].sockaddr = server[i].addrs[j].sockaddr; peer 114 http/ngx_http_upstream_round_robin.c backup->peer[n].socklen = server[i].addrs[j].socklen; peer 115 http/ngx_http_upstream_round_robin.c backup->peer[n].name = server[i].addrs[j].name; peer 116 http/ngx_http_upstream_round_robin.c backup->peer[n].weight = server[i].weight; peer 117 http/ngx_http_upstream_round_robin.c backup->peer[n].current_weight = server[i].weight; peer 118 http/ngx_http_upstream_round_robin.c backup->peer[n].max_fails = server[i].max_fails; peer 119 http/ngx_http_upstream_round_robin.c backup->peer[n].fail_timeout = server[i].fail_timeout; peer 120 http/ngx_http_upstream_round_robin.c backup->peer[n].down = server[i].down; peer 127 http/ngx_http_upstream_round_robin.c ngx_sort(&backup->peer[0], (size_t) n, peer 172 http/ngx_http_upstream_round_robin.c peers->peer[i].sockaddr = u.addrs[i].sockaddr; peer 173 http/ngx_http_upstream_round_robin.c peers->peer[i].socklen = u.addrs[i].socklen; peer 174 http/ngx_http_upstream_round_robin.c peers->peer[i].name = u.addrs[i].name; peer 175 http/ngx_http_upstream_round_robin.c peers->peer[i].weight = 1; peer 176 http/ngx_http_upstream_round_robin.c peers->peer[i].current_weight = 1; peer 177 http/ngx_http_upstream_round_robin.c peers->peer[i].max_fails = 1; peer 178 http/ngx_http_upstream_round_robin.c peers->peer[i].fail_timeout = 10; peer 181 http/ngx_http_upstream_round_robin.c us->peer.data = peers; peer 208 http/ngx_http_upstream_round_robin.c rrp = r->upstream->peer.data; peer 216 http/ngx_http_upstream_round_robin.c r->upstream->peer.data = rrp; peer 219 http/ngx_http_upstream_round_robin.c rrp->peers = us->peer.data; peer 236 http/ngx_http_upstream_round_robin.c r->upstream->peer.get = ngx_http_upstream_get_round_robin_peer; peer 237 http/ngx_http_upstream_round_robin.c r->upstream->peer.free = ngx_http_upstream_free_round_robin_peer; peer 238 http/ngx_http_upstream_round_robin.c r->upstream->peer.tries = rrp->peers->number; peer 240 http/ngx_http_upstream_round_robin.c r->upstream->peer.set_session = peer 242 http/ngx_http_upstream_round_robin.c r->upstream->peer.save_session = peer 261 http/ngx_http_upstream_round_robin.c rrp = r->upstream->peer.data; peer 269 http/ngx_http_upstream_round_robin.c r->upstream->peer.data = rrp; peer 283 http/ngx_http_upstream_round_robin.c peers->peer[0].sockaddr = ur->sockaddr; peer 284 http/ngx_http_upstream_round_robin.c peers->peer[0].socklen = ur->socklen; peer 285 http/ngx_http_upstream_round_robin.c peers->peer[0].name = ur->host; peer 286 http/ngx_http_upstream_round_robin.c peers->peer[0].weight = 1; peer 287 http/ngx_http_upstream_round_robin.c peers->peer[0].current_weight = 1; peer 288 http/ngx_http_upstream_round_robin.c peers->peer[0].max_fails = 1; peer 289 http/ngx_http_upstream_round_robin.c peers->peer[0].fail_timeout = 10; peer 314 http/ngx_http_upstream_round_robin.c peers->peer[i].sockaddr = (struct sockaddr *) sin; peer 315 http/ngx_http_upstream_round_robin.c peers->peer[i].socklen = sizeof(struct sockaddr_in); peer 316 http/ngx_http_upstream_round_robin.c peers->peer[i].name.len = len; peer 317 http/ngx_http_upstream_round_robin.c peers->peer[i].name.data = p; peer 318 http/ngx_http_upstream_round_robin.c peers->peer[i].weight = 1; peer 319 http/ngx_http_upstream_round_robin.c peers->peer[i].current_weight = 1; peer 320 http/ngx_http_upstream_round_robin.c peers->peer[i].max_fails = 1; peer 321 http/ngx_http_upstream_round_robin.c peers->peer[i].fail_timeout = 10; peer 342 http/ngx_http_upstream_round_robin.c r->upstream->peer.get = ngx_http_upstream_get_round_robin_peer; peer 343 http/ngx_http_upstream_round_robin.c r->upstream->peer.free = ngx_http_upstream_free_round_robin_peer; peer 344 http/ngx_http_upstream_round_robin.c r->upstream->peer.tries = rrp->peers->number; peer 346 http/ngx_http_upstream_round_robin.c r->upstream->peer.set_session = peer 348 http/ngx_http_upstream_round_robin.c r->upstream->peer.save_session = peer 366 http/ngx_http_upstream_round_robin.c ngx_http_upstream_rr_peer_t *peer; peer 400 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[0]; peer 418 http/ngx_http_upstream_round_robin.c rrp->peers->peer[rrp->current].current_weight); peer 424 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[rrp->current]; peer 426 http/ngx_http_upstream_round_robin.c if (!peer->down) { peer 428 http/ngx_http_upstream_round_robin.c if (peer->max_fails == 0 peer 429 http/ngx_http_upstream_round_robin.c || peer->fails < peer->max_fails) peer 434 http/ngx_http_upstream_round_robin.c if (now - peer->accessed > peer->fail_timeout) { peer 435 http/ngx_http_upstream_round_robin.c peer->fails = 0; peer 439 http/ngx_http_upstream_round_robin.c peer->current_weight = 0; peer 460 http/ngx_http_upstream_round_robin.c peer->current_weight--; peer 472 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[rrp->current]; peer 474 http/ngx_http_upstream_round_robin.c if (!peer->down) { peer 476 http/ngx_http_upstream_round_robin.c if (peer->max_fails == 0 peer 477 http/ngx_http_upstream_round_robin.c || peer->fails < peer->max_fails) peer 482 http/ngx_http_upstream_round_robin.c if (now - peer->accessed > peer->fail_timeout) { peer 483 http/ngx_http_upstream_round_robin.c peer->fails = 0; peer 487 http/ngx_http_upstream_round_robin.c peer->current_weight = 0; peer 514 http/ngx_http_upstream_round_robin.c peer->current_weight--; peer 520 http/ngx_http_upstream_round_robin.c pc->sockaddr = peer->sockaddr; peer 521 http/ngx_http_upstream_round_robin.c pc->socklen = peer->socklen; peer 522 http/ngx_http_upstream_round_robin.c pc->name = &peer->name; peer 567 http/ngx_http_upstream_round_robin.c peers->peer[i].fails = 0; peer 582 http/ngx_http_upstream_round_robin.c ngx_http_upstream_rr_peer_t *peer; peer 584 http/ngx_http_upstream_round_robin.c peer = &peers->peer[0]; peer 590 http/ngx_http_upstream_round_robin.c if (peer[i].current_weight <= 0) { peer 600 http/ngx_http_upstream_round_robin.c if (peer[i].current_weight <= 0) { peer 604 http/ngx_http_upstream_round_robin.c if (peer[n].current_weight * 1000 / peer[i].current_weight peer 605 http/ngx_http_upstream_round_robin.c > peer[n].weight * 1000 / peer[i].weight) peer 613 http/ngx_http_upstream_round_robin.c if (peer[i].current_weight > 0) { peer 621 http/ngx_http_upstream_round_robin.c peer[i].current_weight = peer[i].weight; peer 634 http/ngx_http_upstream_round_robin.c ngx_http_upstream_rr_peer_t *peer; peer 653 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[rrp->current]; peer 657 http/ngx_http_upstream_round_robin.c peer->fails++; peer 658 http/ngx_http_upstream_round_robin.c peer->accessed = now; peer 660 http/ngx_http_upstream_round_robin.c if (peer->max_fails) { peer 661 http/ngx_http_upstream_round_robin.c peer->current_weight -= peer->weight / peer->max_fails; peer 666 http/ngx_http_upstream_round_robin.c rrp->current, peer->current_weight); peer 668 http/ngx_http_upstream_round_robin.c if (peer->current_weight < 0) { peer 669 http/ngx_http_upstream_round_robin.c peer->current_weight = 0; peer 699 http/ngx_http_upstream_round_robin.c ngx_http_upstream_rr_peer_t *peer; peer 701 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[rrp->current]; peer 706 http/ngx_http_upstream_round_robin.c ssl_session = peer->ssl_session; peer 727 http/ngx_http_upstream_round_robin.c ngx_http_upstream_rr_peer_t *peer; peer 738 http/ngx_http_upstream_round_robin.c peer = &rrp->peers->peer[rrp->current]; peer 743 http/ngx_http_upstream_round_robin.c old_ssl_session = peer->ssl_session; peer 744 http/ngx_http_upstream_round_robin.c peer->ssl_session = ssl_session; peer 52 http/ngx_http_upstream_round_robin.h ngx_http_upstream_rr_peer_t peer[1]; peer 397 mail/ngx_mail.h void ngx_mail_proxy_init(ngx_mail_session_t *s, ngx_addr_t *peer); peer 15 mail/ngx_mail_auth_http_module.c ngx_addr_t *peer; peer 38 mail/ngx_mail_auth_http_module.c ngx_peer_connection_t peer; peer 187 mail/ngx_mail_auth_http_module.c ctx->peer.sockaddr = ahcf->peer->sockaddr; peer 188 mail/ngx_mail_auth_http_module.c ctx->peer.socklen = ahcf->peer->socklen; peer 189 mail/ngx_mail_auth_http_module.c ctx->peer.name = &ahcf->peer->name; peer 190 mail/ngx_mail_auth_http_module.c ctx->peer.get = ngx_event_get_peer; peer 191 mail/ngx_mail_auth_http_module.c ctx->peer.log = s->connection->log; peer 192 mail/ngx_mail_auth_http_module.c ctx->peer.log_error = NGX_ERROR_ERR; peer 194 mail/ngx_mail_auth_http_module.c rc = ngx_event_connect_peer(&ctx->peer); peer 197 mail/ngx_mail_auth_http_module.c if (ctx->peer.connection) { peer 198 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 206 mail/ngx_mail_auth_http_module.c ctx->peer.connection->data = s; peer 207 mail/ngx_mail_auth_http_module.c ctx->peer.connection->pool = s->connection->pool; peer 210 mail/ngx_mail_auth_http_module.c ctx->peer.connection->read->handler = ngx_mail_auth_http_read_handler; peer 211 mail/ngx_mail_auth_http_module.c ctx->peer.connection->write->handler = ngx_mail_auth_http_write_handler; peer 215 mail/ngx_mail_auth_http_module.c ngx_add_timer(ctx->peer.connection->read, ahcf->timeout); peer 216 mail/ngx_mail_auth_http_module.c ngx_add_timer(ctx->peer.connection->write, ahcf->timeout); peer 219 mail/ngx_mail_auth_http_module.c ngx_mail_auth_http_write_handler(ctx->peer.connection->write); peer 244 mail/ngx_mail_auth_http_module.c "auth http server %V timed out", ctx->peer.name); peer 307 mail/ngx_mail_auth_http_module.c "auth http server %V timed out", ctx->peer.name); peer 426 mail/ngx_mail_auth_http_module.c ctx->peer.name); peer 427 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 460 mail/ngx_mail_auth_http_module.c ngx_addr_t *peer; peer 534 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 599 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 621 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 659 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 680 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 698 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 750 mail/ngx_mail_auth_http_module.c ctx->peer.name); peer 761 mail/ngx_mail_auth_http_module.c ctx->peer.name); peer 767 mail/ngx_mail_auth_http_module.c peer = ngx_pcalloc(s->connection->pool, sizeof(ngx_addr_t)); peer 768 mail/ngx_mail_auth_http_module.c if (peer == NULL) { peer 790 mail/ngx_mail_auth_http_module.c ctx->peer.name, &ctx->port); peer 803 mail/ngx_mail_auth_http_module.c ctx->peer.name, &ctx->addr); peer 809 mail/ngx_mail_auth_http_module.c peer->sockaddr = (struct sockaddr *) sin; peer 810 mail/ngx_mail_auth_http_module.c peer->socklen = sizeof(struct sockaddr_in); peer 814 mail/ngx_mail_auth_http_module.c peer->name.len = len; peer 816 mail/ngx_mail_auth_http_module.c peer->name.data = ngx_pnalloc(s->connection->pool, len); peer 817 mail/ngx_mail_auth_http_module.c if (peer->name.data == NULL) { peer 825 mail/ngx_mail_auth_http_module.c ngx_memcpy(peer->name.data, ctx->addr.data, len); peer 827 mail/ngx_mail_auth_http_module.c peer->name.data[len++] = ':'; peer 829 mail/ngx_mail_auth_http_module.c ngx_memcpy(peer->name.data + len, ctx->port.data, ctx->port.len); peer 832 mail/ngx_mail_auth_http_module.c ngx_mail_proxy_init(s, peer); peer 845 mail/ngx_mail_auth_http_module.c ctx->peer.name); peer 846 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 1113 mail/ngx_mail_auth_http_module.c ngx_close_connection(ctx->peer.connection); peer 1327 mail/ngx_mail_auth_http_module.c if (conf->peer == NULL) { peer 1328 mail/ngx_mail_auth_http_module.c conf->peer = prev->peer; peer 1332 mail/ngx_mail_auth_http_module.c if (conf->peer == NULL) { peer 1406 mail/ngx_mail_auth_http_module.c ahcf->peer = u.addrs; peer 111 mail/ngx_mail_proxy_module.c ngx_mail_proxy_init(ngx_mail_session_t *s, ngx_addr_t *peer) peer 143 mail/ngx_mail_proxy_module.c p->upstream.sockaddr = peer->sockaddr; peer 144 mail/ngx_mail_proxy_module.c p->upstream.socklen = peer->socklen; peer 145 mail/ngx_mail_proxy_module.c p->upstream.name = &peer->name;