102 static void ngx_stream_proxy_ssl_handshake(ngx_connection_t *pc);
694     ngx_connection_t             *c, *pc;  in ngx_stream_proxy_connect()  local
751     pc = u->peer.connection;  in ngx_stream_proxy_connect()
753     pc->data = s;  in ngx_stream_proxy_connect()
754     pc->log = c->log;  in ngx_stream_proxy_connect()
755     pc->pool = c->pool;  in ngx_stream_proxy_connect()
756     pc->read->log = c->log;  in ngx_stream_proxy_connect()
757     pc->write->log = c->log;  in ngx_stream_proxy_connect()
764     pc->read->handler = ngx_stream_proxy_connect_handler;  in ngx_stream_proxy_connect()
765     pc->write->handler = ngx_stream_proxy_connect_handler;  in ngx_stream_proxy_connect()
767     ngx_add_timer(pc->write, pscf->connect_timeout);  in ngx_stream_proxy_connect()
776     ngx_connection_t             *c, *pc;  in ngx_stream_proxy_init_upstream()  local
783     pc = u->peer.connection;  in ngx_stream_proxy_init_upstream()
787     if (pc->type == SOCK_STREAM  in ngx_stream_proxy_init_upstream()
789         && ngx_tcp_nodelay(pc) != NGX_OK)  in ngx_stream_proxy_init_upstream()
799     if (pc->type == SOCK_STREAM && pscf->ssl) {  in ngx_stream_proxy_init_upstream()
809         if (pc->ssl == NULL) {  in ngx_stream_proxy_init_upstream()
826         if (ngx_connection_local_sockaddr(pc, &str, 1) == NGX_OK) {  in ngx_stream_proxy_init_upstream()
832                           pc->type == SOCK_DGRAM ? "udp " : "",  in ngx_stream_proxy_init_upstream()
917     pc->read->handler = ngx_stream_proxy_upstream_handler;  in ngx_stream_proxy_init_upstream()
918     pc->write->handler = ngx_stream_proxy_upstream_handler;  in ngx_stream_proxy_init_upstream()
920     if (pc->read->ready) {  in ngx_stream_proxy_init_upstream()
921         ngx_post_event(pc->read, &ngx_posted_events);  in ngx_stream_proxy_init_upstream()
935     ngx_connection_t             *c, *pc;  in ngx_stream_proxy_send_proxy_protocol()  local
953     pc = u->peer.connection;  in ngx_stream_proxy_send_proxy_protocol()
957     n = pc->send(pc, buf, size);  in ngx_stream_proxy_send_proxy_protocol()
960         if (ngx_handle_write_event(pc->write, 0) != NGX_OK) {  in ngx_stream_proxy_send_proxy_protocol()
967         ngx_add_timer(pc->write, pscf->timeout);  in ngx_stream_proxy_send_proxy_protocol()
969         pc->write->handler = ngx_stream_proxy_connect_handler;  in ngx_stream_proxy_send_proxy_protocol()
1028     ngx_connection_t             *pc;  in ngx_stream_proxy_ssl_init_connection()  local
1034     pc = u->peer.connection;  in ngx_stream_proxy_ssl_init_connection()
1038     if (ngx_ssl_create_connection(pscf->ssl, pc, NGX_SSL_BUFFER|NGX_SSL_CLIENT)  in ngx_stream_proxy_ssl_init_connection()
1053         pc->ssl->save_session = ngx_stream_proxy_ssl_save_session;  in ngx_stream_proxy_ssl_init_connection()
1063     rc = ngx_ssl_handshake(pc);  in ngx_stream_proxy_ssl_init_connection()
1067         if (!pc->write->timer_set) {  in ngx_stream_proxy_ssl_init_connection()
1068             ngx_add_timer(pc->write, pscf->connect_timeout);  in ngx_stream_proxy_ssl_init_connection()
1071         pc->ssl->handler = ngx_stream_proxy_ssl_handshake;  in ngx_stream_proxy_ssl_init_connection()
1075     ngx_stream_proxy_ssl_handshake(pc);  in ngx_stream_proxy_ssl_init_connection()
1080 ngx_stream_proxy_ssl_handshake(ngx_connection_t *pc)  in ngx_stream_proxy_ssl_handshake()  argument
1087     s = pc->data;  in ngx_stream_proxy_ssl_handshake()
1091     if (pc->ssl->handshaked) {  in ngx_stream_proxy_ssl_handshake()
1094             rc = SSL_get_verify_result(pc->ssl->connection);  in ngx_stream_proxy_ssl_handshake()
1097                 ngx_log_error(NGX_LOG_ERR, pc->log, 0,  in ngx_stream_proxy_ssl_handshake()
1105             if (ngx_ssl_check_host(pc, &u->ssl_name) != NGX_OK) {  in ngx_stream_proxy_ssl_handshake()
1106                 ngx_log_error(NGX_LOG_ERR, pc->log, 0,  in ngx_stream_proxy_ssl_handshake()
1113         if (pc->write->timer_set) {  in ngx_stream_proxy_ssl_handshake()
1114             ngx_del_timer(pc->write);  in ngx_stream_proxy_ssl_handshake()
1328     ngx_connection_t             *c, *pc;  in ngx_stream_proxy_process_connection()  local
1345     pc = u->peer.connection;  in ngx_stream_proxy_process_connection()
1362                 if (u->connected && !c->read->delayed && !pc->read->delayed) {  in ngx_stream_proxy_process_connection()
1391                                   pc ? pc->sent : 0);  in ngx_stream_proxy_process_connection()
1399                 ngx_connection_error(pc, NGX_ETIMEDOUT, "upstream timed out");  in ngx_stream_proxy_process_connection()
1401                 pc->read->error = 1;  in ngx_stream_proxy_process_connection()
1521     ngx_connection_t             *c, *pc, *src, *dst;  in ngx_stream_proxy_process()  local
1529     pc = u->connected ? u->peer.connection : NULL;  in ngx_stream_proxy_process()
1549         src = pc;  in ngx_stream_proxy_process()
1562         dst = pc;  in ngx_stream_proxy_process()
1698         if (!c->read->delayed && !pc->read->delayed) {  in ngx_stream_proxy_process()
1712     ngx_connection_t             *c, *pc;  in ngx_stream_proxy_test_finalize()  local
1721     pc = u->connected ? u->peer.connection : NULL;  in ngx_stream_proxy_test_finalize()
1739         if (pc == NULL || c->buffered || pc->buffered) {  in ngx_stream_proxy_test_finalize()
1752                       s->received, c->sent, u->received, pc ? pc->sent : 0);  in ngx_stream_proxy_test_finalize()
1763     if (pc == NULL  in ngx_stream_proxy_test_finalize()
1764         || (!c->read->eof && !pc->read->eof)  in ngx_stream_proxy_test_finalize()
1766         || (!pc->read->eof && pc->buffered))  in ngx_stream_proxy_test_finalize()
1779                   s->received, c->sent, u->received, pc ? pc->sent : 0);  in ngx_stream_proxy_test_finalize()
1793     ngx_connection_t             *pc;  in ngx_stream_proxy_next_upstream()  local
1801     pc = u->peer.connection;  in ngx_stream_proxy_next_upstream()
1803     if (pc && pc->buffered) {  in ngx_stream_proxy_next_upstream()
1831     if (pc) {  in ngx_stream_proxy_next_upstream()
1833                        "close proxy upstream connection: %d", pc->fd);  in ngx_stream_proxy_next_upstream()
1836         if (pc->ssl) {  in ngx_stream_proxy_next_upstream()
1837             pc->ssl->no_wait_shutdown = 1;  in ngx_stream_proxy_next_upstream()
1838             pc->ssl->no_send_shutdown = 1;  in ngx_stream_proxy_next_upstream()
1840             (void) ngx_ssl_shutdown(pc);  in ngx_stream_proxy_next_upstream()
1845         u->state->bytes_sent = pc->sent;  in ngx_stream_proxy_next_upstream()
1847         ngx_close_connection(pc);  in ngx_stream_proxy_next_upstream()
1859     ngx_connection_t       *pc;  in ngx_stream_proxy_finalize()  local
1876     pc = u->peer.connection;  in ngx_stream_proxy_finalize()
1883         if (pc) {  in ngx_stream_proxy_finalize()
1885             u->state->bytes_sent = pc->sent;  in ngx_stream_proxy_finalize()
1892         if (pc && pc->type == SOCK_DGRAM  in ngx_stream_proxy_finalize()
1893             && (pc->read->error || pc->write->error))  in ngx_stream_proxy_finalize()
1902     if (pc) {  in ngx_stream_proxy_finalize()
1904                        "close stream proxy upstream connection: %d", pc->fd);  in ngx_stream_proxy_finalize()
1907         if (pc->ssl) {  in ngx_stream_proxy_finalize()
1908             pc->ssl->no_wait_shutdown = 1;  in ngx_stream_proxy_finalize()
1909             (void) ngx_ssl_shutdown(pc);  in ngx_stream_proxy_finalize()
1913         ngx_close_connection(pc);  in ngx_stream_proxy_finalize()
1927     ngx_connection_t       *pc;  in ngx_stream_proxy_log_error()  local
1942     pc = u->peer.connection;  in ngx_stream_proxy_log_error()
1948                      u->received, pc ? pc->sent : 0);  in ngx_stream_proxy_log_error()