pc 14 event/ngx_event_connect.c ngx_event_connect_peer(ngx_peer_connection_t *pc) pc 24 event/ngx_event_connect.c rc = pc->get(pc, pc->data); pc 29 event/ngx_event_connect.c s = ngx_socket(pc->sockaddr->sa_family, SOCK_STREAM, 0); pc 31 event/ngx_event_connect.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0, "socket %d", s); pc 34 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 40 event/ngx_event_connect.c c = ngx_get_connection(s, pc->log); pc 44 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 51 event/ngx_event_connect.c if (pc->rcvbuf) { pc 53 event/ngx_event_connect.c (const void *) &pc->rcvbuf, sizeof(int)) == -1) pc 55 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 62 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 68 event/ngx_event_connect.c if (pc->local) { pc 69 event/ngx_event_connect.c if (bind(s, pc->local->sockaddr, pc->local->socklen) == -1) { pc 70 event/ngx_event_connect.c ngx_log_error(NGX_LOG_CRIT, pc->log, ngx_socket_errno, pc 71 event/ngx_event_connect.c "bind(%V) failed", &pc->local->name); pc 84 event/ngx_event_connect.c c->log_error = pc->log_error; pc 86 event/ngx_event_connect.c if (pc->sockaddr->sa_family != AF_INET) { pc 99 event/ngx_event_connect.c rev->log = pc->log; pc 100 event/ngx_event_connect.c wev->log = pc->log; pc 102 event/ngx_event_connect.c pc->connection = c; pc 110 event/ngx_event_connect.c rev->lock = pc->lock; pc 111 event/ngx_event_connect.c wev->lock = pc->lock; pc 123 event/ngx_event_connect.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0, pc 124 event/ngx_event_connect.c "connect to %V, fd:%d #%d", pc->name, s, c->number); pc 126 event/ngx_event_connect.c rc = connect(s, pc->sockaddr, pc->socklen); pc 160 event/ngx_event_connect.c pc->name); pc 174 event/ngx_event_connect.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected"); pc 183 event/ngx_event_connect.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, ngx_socket_errno, pc 189 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 235 event/ngx_event_connect.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected"); pc 246 event/ngx_event_connect.c ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, pc 255 event/ngx_event_connect.c ngx_event_get_peer(ngx_peer_connection_t *pc, void *data) pc 23 event/ngx_event_connect.h typedef ngx_int_t (*ngx_event_get_peer_pt)(ngx_peer_connection_t *pc, pc 25 event/ngx_event_connect.h typedef void (*ngx_event_free_peer_pt)(ngx_peer_connection_t *pc, void *data, pc 29 event/ngx_event_connect.h typedef ngx_int_t (*ngx_event_set_peer_session_pt)(ngx_peer_connection_t *pc, pc 31 event/ngx_event_connect.h typedef void (*ngx_event_save_peer_session_pt)(ngx_peer_connection_t *pc, pc 71 event/ngx_event_connect.h ngx_int_t ngx_event_connect_peer(ngx_peer_connection_t *pc); pc 72 event/ngx_event_connect.h ngx_int_t ngx_event_get_peer(ngx_peer_connection_t *pc, void *data); pc 28 http/modules/ngx_http_upstream_ip_hash_module.c static ngx_int_t ngx_http_upstream_get_ip_hash_peer(ngx_peer_connection_t *pc, pc 137 http/modules/ngx_http_upstream_ip_hash_module.c ngx_http_upstream_get_ip_hash_peer(ngx_peer_connection_t *pc, void *data) pc 146 http/modules/ngx_http_upstream_ip_hash_module.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 147 http/modules/ngx_http_upstream_ip_hash_module.c "get ip hash peer, try: %ui", pc->tries); pc 152 http/modules/ngx_http_upstream_ip_hash_module.c return iphp->get_rr_peer(pc, &iphp->rrp); pc 157 http/modules/ngx_http_upstream_ip_hash_module.c pc->cached = 0; pc 158 http/modules/ngx_http_upstream_ip_hash_module.c pc->connection = NULL; pc 175 http/modules/ngx_http_upstream_ip_hash_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 198 http/modules/ngx_http_upstream_ip_hash_module.c pc->tries--; pc 202 http/modules/ngx_http_upstream_ip_hash_module.c return iphp->get_rr_peer(pc, &iphp->rrp); pc 208 http/modules/ngx_http_upstream_ip_hash_module.c pc->sockaddr = peer->sockaddr; pc 209 http/modules/ngx_http_upstream_ip_hash_module.c pc->socklen = peer->socklen; pc 210 http/modules/ngx_http_upstream_ip_hash_module.c pc->name = &peer->name; pc 357 http/ngx_http_upstream_round_robin.c ngx_http_upstream_get_round_robin_peer(ngx_peer_connection_t *pc, void *data) pc 369 http/ngx_http_upstream_round_robin.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 370 http/ngx_http_upstream_round_robin.c "get rr peer, try: %ui", pc->tries); pc 390 http/ngx_http_upstream_round_robin.c pc->connection = c; pc 391 http/ngx_http_upstream_round_robin.c pc->cached = 1; pc 396 http/ngx_http_upstream_round_robin.c pc->cached = 0; pc 397 http/ngx_http_upstream_round_robin.c pc->connection = NULL; pc 406 http/ngx_http_upstream_round_robin.c if (pc->tries == rrp->peers->number) { pc 410 http/ngx_http_upstream_round_robin.c i = pc->tries; pc 415 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 445 http/ngx_http_upstream_round_robin.c pc->tries--; pc 448 http/ngx_http_upstream_round_robin.c if (pc->tries == 0) { pc 453 http/ngx_http_upstream_round_robin.c ngx_log_error(NGX_LOG_ALERT, pc->log, 0, pc 455 http/ngx_http_upstream_round_robin.c pc->tries); pc 464 http/ngx_http_upstream_round_robin.c i = pc->tries; pc 493 http/ngx_http_upstream_round_robin.c pc->tries--; pc 502 http/ngx_http_upstream_round_robin.c if (pc->tries == 0) { pc 507 http/ngx_http_upstream_round_robin.c ngx_log_error(NGX_LOG_ALERT, pc->log, 0, pc 509 http/ngx_http_upstream_round_robin.c pc->tries); pc 520 http/ngx_http_upstream_round_robin.c pc->sockaddr = peer->sockaddr; pc 521 http/ngx_http_upstream_round_robin.c pc->socklen = peer->socklen; pc 522 http/ngx_http_upstream_round_robin.c pc->name = &peer->name; pc 526 http/ngx_http_upstream_round_robin.c if (pc->tries == 1 && rrp->peers->next) { pc 527 http/ngx_http_upstream_round_robin.c pc->tries += rrp->peers->next->number; pc 545 http/ngx_http_upstream_round_robin.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, pc->log, 0, "backup servers"); pc 548 http/ngx_http_upstream_round_robin.c pc->tries = rrp->peers->number; pc 555 http/ngx_http_upstream_round_robin.c rc = ngx_http_upstream_get_round_robin_peer(pc, rrp); pc 572 http/ngx_http_upstream_round_robin.c pc->name = peers->name; pc 628 http/ngx_http_upstream_round_robin.c ngx_http_upstream_free_round_robin_peer(ngx_peer_connection_t *pc, void *data, pc 636 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 637 http/ngx_http_upstream_round_robin.c "free rr peer %ui %ui", pc->tries, state); pc 639 http/ngx_http_upstream_round_robin.c if (state == 0 && pc->tries == 0) { pc 646 http/ngx_http_upstream_round_robin.c pc->tries = 0; pc 664 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 681 http/ngx_http_upstream_round_robin.c if (pc->tries) { pc 682 http/ngx_http_upstream_round_robin.c pc->tries--; pc 692 http/ngx_http_upstream_round_robin.c ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc, pc 708 http/ngx_http_upstream_round_robin.c rc = ngx_ssl_set_session(pc->connection, ssl_session); pc 710 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 721 http/ngx_http_upstream_round_robin.c ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc, pc 729 http/ngx_http_upstream_round_robin.c ssl_session = ngx_ssl_get_session(pc->connection); pc 735 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 750 http/ngx_http_upstream_round_robin.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0, pc 70 http/ngx_http_upstream_round_robin.h ngx_int_t ngx_http_upstream_get_round_robin_peer(ngx_peer_connection_t *pc, pc 72 http/ngx_http_upstream_round_robin.h void ngx_http_upstream_free_round_robin_peer(ngx_peer_connection_t *pc, pc 77 http/ngx_http_upstream_round_robin.h ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc, pc 79 http/ngx_http_upstream_round_robin.h void ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc,