|  | 
 | /* | 
 |  * Copyright (C) Igor Sysoev | 
 |  * Copyright (C) Nginx, Inc. | 
 |  */ | 
 |  | 
 |  | 
 | #include <ngx_config.h> | 
 | #include <ngx_core.h> | 
 | #include <ngx_stream.h> | 
 |  | 
 |  | 
 | typedef ngx_int_t (*ngx_ssl_variable_handler_pt)(ngx_connection_t *c, | 
 |     ngx_pool_t *pool, ngx_str_t *s); | 
 |  | 
 |  | 
 | #define NGX_DEFAULT_CIPHERS     "HIGH:!aNULL:!MD5" | 
 | #define NGX_DEFAULT_ECDH_CURVE  "auto" | 
 |  | 
 |  | 
 | static ngx_int_t ngx_stream_ssl_handler(ngx_stream_session_t *s); | 
 | static ngx_int_t ngx_stream_ssl_init_connection(ngx_ssl_t *ssl, | 
 |     ngx_connection_t *c); | 
 | static void ngx_stream_ssl_handshake_handler(ngx_connection_t *c); | 
 | static ngx_int_t ngx_stream_ssl_static_variable(ngx_stream_session_t *s, | 
 |     ngx_stream_variable_value_t *v, uintptr_t data); | 
 | static ngx_int_t ngx_stream_ssl_variable(ngx_stream_session_t *s, | 
 |     ngx_stream_variable_value_t *v, uintptr_t data); | 
 |  | 
 | static ngx_int_t ngx_stream_ssl_add_variables(ngx_conf_t *cf); | 
 | static void *ngx_stream_ssl_create_conf(ngx_conf_t *cf); | 
 | static char *ngx_stream_ssl_merge_conf(ngx_conf_t *cf, void *parent, | 
 |     void *child); | 
 |  | 
 | static char *ngx_stream_ssl_password_file(ngx_conf_t *cf, ngx_command_t *cmd, | 
 |     void *conf); | 
 | static char *ngx_stream_ssl_session_cache(ngx_conf_t *cf, ngx_command_t *cmd, | 
 |     void *conf); | 
 | static ngx_int_t ngx_stream_ssl_init(ngx_conf_t *cf); | 
 |  | 
 |  | 
 | static ngx_conf_bitmask_t  ngx_stream_ssl_protocols[] = { | 
 |     { ngx_string("SSLv2"), NGX_SSL_SSLv2 }, | 
 |     { ngx_string("SSLv3"), NGX_SSL_SSLv3 }, | 
 |     { ngx_string("TLSv1"), NGX_SSL_TLSv1 }, | 
 |     { ngx_string("TLSv1.1"), NGX_SSL_TLSv1_1 }, | 
 |     { ngx_string("TLSv1.2"), NGX_SSL_TLSv1_2 }, | 
 |     { ngx_string("TLSv1.3"), NGX_SSL_TLSv1_3 }, | 
 |     { ngx_null_string, 0 } | 
 | }; | 
 |  | 
 |  | 
 | static ngx_conf_enum_t  ngx_stream_ssl_verify[] = { | 
 |     { ngx_string("off"), 0 }, | 
 |     { ngx_string("on"), 1 }, | 
 |     { ngx_string("optional"), 2 }, | 
 |     { ngx_string("optional_no_ca"), 3 }, | 
 |     { ngx_null_string, 0 } | 
 | }; | 
 |  | 
 |  | 
 | static ngx_command_t  ngx_stream_ssl_commands[] = { | 
 |  | 
 |     { ngx_string("ssl_handshake_timeout"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_msec_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, handshake_timeout), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_certificate"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_array_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, certificates), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_certificate_key"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_array_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, certificate_keys), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_password_file"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_stream_ssl_password_file, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       0, | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_dhparam"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, dhparam), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_ecdh_curve"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, ecdh_curve), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_protocols"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_1MORE, | 
 |       ngx_conf_set_bitmask_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, protocols), | 
 |       &ngx_stream_ssl_protocols }, | 
 |  | 
 |     { ngx_string("ssl_ciphers"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, ciphers), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_verify_client"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_enum_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, verify), | 
 |       &ngx_stream_ssl_verify }, | 
 |  | 
 |     { ngx_string("ssl_verify_depth"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_num_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, verify_depth), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_client_certificate"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, client_certificate), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_trusted_certificate"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, trusted_certificate), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_prefer_server_ciphers"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_FLAG, | 
 |       ngx_conf_set_flag_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, prefer_server_ciphers), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_session_cache"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE12, | 
 |       ngx_stream_ssl_session_cache, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       0, | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_session_tickets"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_FLAG, | 
 |       ngx_conf_set_flag_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, session_tickets), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_session_ticket_key"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_array_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, session_ticket_keys), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_session_timeout"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_sec_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, session_timeout), | 
 |       NULL }, | 
 |  | 
 |     { ngx_string("ssl_crl"), | 
 |       NGX_STREAM_MAIN_CONF|NGX_STREAM_SRV_CONF|NGX_CONF_TAKE1, | 
 |       ngx_conf_set_str_slot, | 
 |       NGX_STREAM_SRV_CONF_OFFSET, | 
 |       offsetof(ngx_stream_ssl_conf_t, crl), | 
 |       NULL }, | 
 |  | 
 |       ngx_null_command | 
 | }; | 
 |  | 
 |  | 
 | static ngx_stream_module_t  ngx_stream_ssl_module_ctx = { | 
 |     ngx_stream_ssl_add_variables,          /* preconfiguration */ | 
 |     ngx_stream_ssl_init,                   /* postconfiguration */ | 
 |  | 
 |     NULL,                                  /* create main configuration */ | 
 |     NULL,                                  /* init main configuration */ | 
 |  | 
 |     ngx_stream_ssl_create_conf,            /* create server configuration */ | 
 |     ngx_stream_ssl_merge_conf              /* merge server configuration */ | 
 | }; | 
 |  | 
 |  | 
 | ngx_module_t  ngx_stream_ssl_module = { | 
 |     NGX_MODULE_V1, | 
 |     &ngx_stream_ssl_module_ctx,            /* module context */ | 
 |     ngx_stream_ssl_commands,               /* module directives */ | 
 |     NGX_STREAM_MODULE,                     /* module type */ | 
 |     NULL,                                  /* init master */ | 
 |     NULL,                                  /* init module */ | 
 |     NULL,                                  /* init process */ | 
 |     NULL,                                  /* init thread */ | 
 |     NULL,                                  /* exit thread */ | 
 |     NULL,                                  /* exit process */ | 
 |     NULL,                                  /* exit master */ | 
 |     NGX_MODULE_V1_PADDING | 
 | }; | 
 |  | 
 |  | 
 | static ngx_stream_variable_t  ngx_stream_ssl_vars[] = { | 
 |  | 
 |     { ngx_string("ssl_protocol"), NULL, ngx_stream_ssl_static_variable, | 
 |       (uintptr_t) ngx_ssl_get_protocol, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_cipher"), NULL, ngx_stream_ssl_static_variable, | 
 |       (uintptr_t) ngx_ssl_get_cipher_name, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_ciphers"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_ciphers, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_curves"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_curves, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_session_id"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_session_id, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_session_reused"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_session_reused, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_server_name"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_server_name, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_cert"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_certificate, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_raw_cert"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_raw_certificate, | 
 |       NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_escaped_cert"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_escaped_certificate, | 
 |       NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_s_dn"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_subject_dn, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_i_dn"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_issuer_dn, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_serial"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_serial_number, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_fingerprint"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_fingerprint, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_verify"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_client_verify, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_v_start"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_client_v_start, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_v_end"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_client_v_end, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |     { ngx_string("ssl_client_v_remain"), NULL, ngx_stream_ssl_variable, | 
 |       (uintptr_t) ngx_ssl_get_client_v_remain, NGX_STREAM_VAR_CHANGEABLE, 0 }, | 
 |  | 
 |       ngx_stream_null_variable | 
 | }; | 
 |  | 
 |  | 
 | static ngx_str_t ngx_stream_ssl_sess_id_ctx = ngx_string("STREAM"); | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_handler(ngx_stream_session_t *s) | 
 | { | 
 |     long                    rc; | 
 |     X509                   *cert; | 
 |     ngx_int_t               rv; | 
 |     ngx_connection_t       *c; | 
 |     ngx_stream_ssl_conf_t  *sslcf; | 
 |  | 
 |     if (!s->ssl) { | 
 |         return NGX_OK; | 
 |     } | 
 |  | 
 |     c = s->connection; | 
 |  | 
 |     sslcf = ngx_stream_get_module_srv_conf(s, ngx_stream_ssl_module); | 
 |  | 
 |     if (c->ssl == NULL) { | 
 |         c->log->action = "SSL handshaking"; | 
 |  | 
 |         rv = ngx_stream_ssl_init_connection(&sslcf->ssl, c); | 
 |  | 
 |         if (rv != NGX_OK) { | 
 |             return rv; | 
 |         } | 
 |     } | 
 |  | 
 |     if (sslcf->verify) { | 
 |         rc = SSL_get_verify_result(c->ssl->connection); | 
 |  | 
 |         if (rc != X509_V_OK | 
 |             && (sslcf->verify != 3 || !ngx_ssl_verify_error_optional(rc))) | 
 |         { | 
 |             ngx_log_error(NGX_LOG_INFO, c->log, 0, | 
 |                           "client SSL certificate verify error: (%l:%s)", | 
 |                           rc, X509_verify_cert_error_string(rc)); | 
 |  | 
 |             ngx_ssl_remove_cached_session(c->ssl->session_ctx, | 
 |                                        (SSL_get0_session(c->ssl->connection))); | 
 |             return NGX_ERROR; | 
 |         } | 
 |  | 
 |         if (sslcf->verify == 1) { | 
 |             cert = SSL_get_peer_certificate(c->ssl->connection); | 
 |  | 
 |             if (cert == NULL) { | 
 |                 ngx_log_error(NGX_LOG_INFO, c->log, 0, | 
 |                               "client sent no required SSL certificate"); | 
 |  | 
 |                 ngx_ssl_remove_cached_session(c->ssl->session_ctx, | 
 |                                        (SSL_get0_session(c->ssl->connection))); | 
 |                 return NGX_ERROR; | 
 |             } | 
 |  | 
 |             X509_free(cert); | 
 |         } | 
 |     } | 
 |  | 
 |     return NGX_OK; | 
 | } | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_init_connection(ngx_ssl_t *ssl, ngx_connection_t *c) | 
 | { | 
 |     ngx_int_t                    rc; | 
 |     ngx_stream_session_t        *s; | 
 |     ngx_stream_ssl_conf_t       *sslcf; | 
 |     ngx_stream_core_srv_conf_t  *cscf; | 
 |  | 
 |     s = c->data; | 
 |  | 
 |     cscf = ngx_stream_get_module_srv_conf(s, ngx_stream_core_module); | 
 |  | 
 |     if (cscf->tcp_nodelay && ngx_tcp_nodelay(c) != NGX_OK) { | 
 |         return NGX_ERROR; | 
 |     } | 
 |  | 
 |     if (ngx_ssl_create_connection(ssl, c, 0) != NGX_OK) { | 
 |         return NGX_ERROR; | 
 |     } | 
 |  | 
 |     rc = ngx_ssl_handshake(c); | 
 |  | 
 |     if (rc == NGX_ERROR) { | 
 |         return NGX_ERROR; | 
 |     } | 
 |  | 
 |     if (rc == NGX_AGAIN) { | 
 |         sslcf = ngx_stream_get_module_srv_conf(s, ngx_stream_ssl_module); | 
 |  | 
 |         ngx_add_timer(c->read, sslcf->handshake_timeout); | 
 |  | 
 |         c->ssl->handler = ngx_stream_ssl_handshake_handler; | 
 |  | 
 |         return NGX_AGAIN; | 
 |     } | 
 |  | 
 |     /* rc == NGX_OK */ | 
 |  | 
 |     return NGX_OK; | 
 | } | 
 |  | 
 |  | 
 | static void | 
 | ngx_stream_ssl_handshake_handler(ngx_connection_t *c) | 
 | { | 
 |     ngx_stream_session_t  *s; | 
 |  | 
 |     s = c->data; | 
 |  | 
 |     if (!c->ssl->handshaked) { | 
 |         ngx_stream_finalize_session(s, NGX_STREAM_INTERNAL_SERVER_ERROR); | 
 |         return; | 
 |     } | 
 |  | 
 |     if (c->read->timer_set) { | 
 |         ngx_del_timer(c->read); | 
 |     } | 
 |  | 
 |     ngx_stream_core_run_phases(s); | 
 | } | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_static_variable(ngx_stream_session_t *s, | 
 |     ngx_stream_variable_value_t *v, uintptr_t data) | 
 | { | 
 |     ngx_ssl_variable_handler_pt  handler = (ngx_ssl_variable_handler_pt) data; | 
 |  | 
 |     size_t     len; | 
 |     ngx_str_t  str; | 
 |  | 
 |     if (s->connection->ssl) { | 
 |  | 
 |         (void) handler(s->connection, NULL, &str); | 
 |  | 
 |         v->data = str.data; | 
 |  | 
 |         for (len = 0; v->data[len]; len++) { /* void */ } | 
 |  | 
 |         v->len = len; | 
 |         v->valid = 1; | 
 |         v->no_cacheable = 0; | 
 |         v->not_found = 0; | 
 |  | 
 |         return NGX_OK; | 
 |     } | 
 |  | 
 |     v->not_found = 1; | 
 |  | 
 |     return NGX_OK; | 
 | } | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_variable(ngx_stream_session_t *s, | 
 |     ngx_stream_variable_value_t *v, uintptr_t data) | 
 | { | 
 |     ngx_ssl_variable_handler_pt  handler = (ngx_ssl_variable_handler_pt) data; | 
 |  | 
 |     ngx_str_t  str; | 
 |  | 
 |     if (s->connection->ssl) { | 
 |  | 
 |         if (handler(s->connection, s->connection->pool, &str) != NGX_OK) { | 
 |             return NGX_ERROR; | 
 |         } | 
 |  | 
 |         v->len = str.len; | 
 |         v->data = str.data; | 
 |  | 
 |         if (v->len) { | 
 |             v->valid = 1; | 
 |             v->no_cacheable = 0; | 
 |             v->not_found = 0; | 
 |  | 
 |             return NGX_OK; | 
 |         } | 
 |     } | 
 |  | 
 |     v->not_found = 1; | 
 |  | 
 |     return NGX_OK; | 
 | } | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_add_variables(ngx_conf_t *cf) | 
 | { | 
 |     ngx_stream_variable_t  *var, *v; | 
 |  | 
 |     for (v = ngx_stream_ssl_vars; v->name.len; v++) { | 
 |         var = ngx_stream_add_variable(cf, &v->name, v->flags); | 
 |         if (var == NULL) { | 
 |             return NGX_ERROR; | 
 |         } | 
 |  | 
 |         var->get_handler = v->get_handler; | 
 |         var->data = v->data; | 
 |     } | 
 |  | 
 |     return NGX_OK; | 
 | } | 
 |  | 
 |  | 
 | static void * | 
 | ngx_stream_ssl_create_conf(ngx_conf_t *cf) | 
 | { | 
 |     ngx_stream_ssl_conf_t  *scf; | 
 |  | 
 |     scf = ngx_pcalloc(cf->pool, sizeof(ngx_stream_ssl_conf_t)); | 
 |     if (scf == NULL) { | 
 |         return NULL; | 
 |     } | 
 |  | 
 |     /* | 
 |      * set by ngx_pcalloc(): | 
 |      * | 
 |      *     scf->listen = 0; | 
 |      *     scf->protocols = 0; | 
 |      *     scf->dhparam = { 0, NULL }; | 
 |      *     scf->ecdh_curve = { 0, NULL }; | 
 |      *     scf->client_certificate = { 0, NULL }; | 
 |      *     scf->trusted_certificate = { 0, NULL }; | 
 |      *     scf->crl = { 0, NULL }; | 
 |      *     scf->ciphers = { 0, NULL }; | 
 |      *     scf->shm_zone = NULL; | 
 |      */ | 
 |  | 
 |     scf->handshake_timeout = NGX_CONF_UNSET_MSEC; | 
 |     scf->certificates = NGX_CONF_UNSET_PTR; | 
 |     scf->certificate_keys = NGX_CONF_UNSET_PTR; | 
 |     scf->passwords = NGX_CONF_UNSET_PTR; | 
 |     scf->prefer_server_ciphers = NGX_CONF_UNSET; | 
 |     scf->verify = NGX_CONF_UNSET_UINT; | 
 |     scf->verify_depth = NGX_CONF_UNSET_UINT; | 
 |     scf->builtin_session_cache = NGX_CONF_UNSET; | 
 |     scf->session_timeout = NGX_CONF_UNSET; | 
 |     scf->session_tickets = NGX_CONF_UNSET; | 
 |     scf->session_ticket_keys = NGX_CONF_UNSET_PTR; | 
 |  | 
 |     return scf; | 
 | } | 
 |  | 
 |  | 
 | static char * | 
 | ngx_stream_ssl_merge_conf(ngx_conf_t *cf, void *parent, void *child) | 
 | { | 
 |     ngx_stream_ssl_conf_t *prev = parent; | 
 |     ngx_stream_ssl_conf_t *conf = child; | 
 |  | 
 |     ngx_pool_cleanup_t  *cln; | 
 |  | 
 |     ngx_conf_merge_msec_value(conf->handshake_timeout, | 
 |                          prev->handshake_timeout, 60000); | 
 |  | 
 |     ngx_conf_merge_value(conf->session_timeout, | 
 |                          prev->session_timeout, 300); | 
 |  | 
 |     ngx_conf_merge_value(conf->prefer_server_ciphers, | 
 |                          prev->prefer_server_ciphers, 0); | 
 |  | 
 |     ngx_conf_merge_bitmask_value(conf->protocols, prev->protocols, | 
 |                          (NGX_CONF_BITMASK_SET|NGX_SSL_TLSv1 | 
 |                           |NGX_SSL_TLSv1_1|NGX_SSL_TLSv1_2)); | 
 |  | 
 |     ngx_conf_merge_uint_value(conf->verify, prev->verify, 0); | 
 |     ngx_conf_merge_uint_value(conf->verify_depth, prev->verify_depth, 1); | 
 |  | 
 |     ngx_conf_merge_ptr_value(conf->certificates, prev->certificates, NULL); | 
 |     ngx_conf_merge_ptr_value(conf->certificate_keys, prev->certificate_keys, | 
 |                          NULL); | 
 |  | 
 |     ngx_conf_merge_ptr_value(conf->passwords, prev->passwords, NULL); | 
 |  | 
 |     ngx_conf_merge_str_value(conf->dhparam, prev->dhparam, ""); | 
 |  | 
 |     ngx_conf_merge_str_value(conf->client_certificate, prev->client_certificate, | 
 |                          ""); | 
 |     ngx_conf_merge_str_value(conf->trusted_certificate, | 
 |                          prev->trusted_certificate, ""); | 
 |     ngx_conf_merge_str_value(conf->crl, prev->crl, ""); | 
 |  | 
 |     ngx_conf_merge_str_value(conf->ecdh_curve, prev->ecdh_curve, | 
 |                          NGX_DEFAULT_ECDH_CURVE); | 
 |  | 
 |     ngx_conf_merge_str_value(conf->ciphers, prev->ciphers, NGX_DEFAULT_CIPHERS); | 
 |  | 
 |  | 
 |     conf->ssl.log = cf->log; | 
 |  | 
 |     if (!conf->listen) { | 
 |         return NGX_CONF_OK; | 
 |     } | 
 |  | 
 |     if (conf->certificates == NULL) { | 
 |         ngx_log_error(NGX_LOG_EMERG, cf->log, 0, | 
 |                       "no \"ssl_certificate\" is defined for " | 
 |                       "the \"listen ... ssl\" directive in %s:%ui", | 
 |                       conf->file, conf->line); | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (conf->certificate_keys == NULL) { | 
 |         ngx_log_error(NGX_LOG_EMERG, cf->log, 0, | 
 |                       "no \"ssl_certificate_key\" is defined for " | 
 |                       "the \"listen ... ssl\" directive in %s:%ui", | 
 |                       conf->file, conf->line); | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (conf->certificate_keys->nelts < conf->certificates->nelts) { | 
 |         ngx_log_error(NGX_LOG_EMERG, cf->log, 0, | 
 |                       "no \"ssl_certificate_key\" is defined " | 
 |                       "for certificate \"%V\" and " | 
 |                       "the \"listen ... ssl\" directive in %s:%ui", | 
 |                       ((ngx_str_t *) conf->certificates->elts) | 
 |                       + conf->certificates->nelts - 1, | 
 |                       conf->file, conf->line); | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (ngx_ssl_create(&conf->ssl, conf->protocols, NULL) != NGX_OK) { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     cln = ngx_pool_cleanup_add(cf->pool, 0); | 
 |     if (cln == NULL) { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     cln->handler = ngx_ssl_cleanup_ctx; | 
 |     cln->data = &conf->ssl; | 
 |  | 
 |     if (ngx_ssl_certificates(cf, &conf->ssl, conf->certificates, | 
 |                              conf->certificate_keys, conf->passwords) | 
 |         != NGX_OK) | 
 |     { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (ngx_ssl_ciphers(cf, &conf->ssl, &conf->ciphers, | 
 |                         conf->prefer_server_ciphers) | 
 |         != NGX_OK) | 
 |     { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (conf->verify) { | 
 |  | 
 |         if (conf->client_certificate.len == 0 && conf->verify != 3) { | 
 |             ngx_log_error(NGX_LOG_EMERG, cf->log, 0, | 
 |                           "no ssl_client_certificate for ssl_client_verify"); | 
 |             return NGX_CONF_ERROR; | 
 |         } | 
 |  | 
 |         if (ngx_ssl_client_certificate(cf, &conf->ssl, | 
 |                                        &conf->client_certificate, | 
 |                                        conf->verify_depth) | 
 |             != NGX_OK) | 
 |         { | 
 |             return NGX_CONF_ERROR; | 
 |         } | 
 |  | 
 |         if (ngx_ssl_trusted_certificate(cf, &conf->ssl, | 
 |                                         &conf->trusted_certificate, | 
 |                                         conf->verify_depth) | 
 |             != NGX_OK) | 
 |         { | 
 |             return NGX_CONF_ERROR; | 
 |         } | 
 |  | 
 |         if (ngx_ssl_crl(cf, &conf->ssl, &conf->crl) != NGX_OK) { | 
 |             return NGX_CONF_ERROR; | 
 |         } | 
 |     } | 
 |  | 
 |     if (ngx_ssl_dhparam(cf, &conf->ssl, &conf->dhparam) != NGX_OK) { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     if (ngx_ssl_ecdh_curve(cf, &conf->ssl, &conf->ecdh_curve) != NGX_OK) { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     ngx_conf_merge_value(conf->builtin_session_cache, | 
 |                          prev->builtin_session_cache, NGX_SSL_NONE_SCACHE); | 
 |  | 
 |     if (conf->shm_zone == NULL) { | 
 |         conf->shm_zone = prev->shm_zone; | 
 |     } | 
 |  | 
 |     if (ngx_ssl_session_cache(&conf->ssl, &ngx_stream_ssl_sess_id_ctx, | 
 |                               conf->builtin_session_cache, | 
 |                               conf->shm_zone, conf->session_timeout) | 
 |         != NGX_OK) | 
 |     { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     ngx_conf_merge_value(conf->session_tickets, | 
 |                          prev->session_tickets, 1); | 
 |  | 
 | #ifdef SSL_OP_NO_TICKET | 
 |     if (!conf->session_tickets) { | 
 |         SSL_CTX_set_options(conf->ssl.ctx, SSL_OP_NO_TICKET); | 
 |     } | 
 | #endif | 
 |  | 
 |     ngx_conf_merge_ptr_value(conf->session_ticket_keys, | 
 |                          prev->session_ticket_keys, NULL); | 
 |  | 
 |     if (ngx_ssl_session_ticket_keys(cf, &conf->ssl, conf->session_ticket_keys) | 
 |         != NGX_OK) | 
 |     { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     return NGX_CONF_OK; | 
 | } | 
 |  | 
 |  | 
 | static char * | 
 | ngx_stream_ssl_password_file(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | 
 | { | 
 |     ngx_stream_ssl_conf_t  *scf = conf; | 
 |  | 
 |     ngx_str_t  *value; | 
 |  | 
 |     if (scf->passwords != NGX_CONF_UNSET_PTR) { | 
 |         return "is duplicate"; | 
 |     } | 
 |  | 
 |     value = cf->args->elts; | 
 |  | 
 |     scf->passwords = ngx_ssl_read_password_file(cf, &value[1]); | 
 |  | 
 |     if (scf->passwords == NULL) { | 
 |         return NGX_CONF_ERROR; | 
 |     } | 
 |  | 
 |     return NGX_CONF_OK; | 
 | } | 
 |  | 
 |  | 
 | static char * | 
 | ngx_stream_ssl_session_cache(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | 
 | { | 
 |     ngx_stream_ssl_conf_t  *scf = conf; | 
 |  | 
 |     size_t       len; | 
 |     ngx_str_t   *value, name, size; | 
 |     ngx_int_t    n; | 
 |     ngx_uint_t   i, j; | 
 |  | 
 |     value = cf->args->elts; | 
 |  | 
 |     for (i = 1; i < cf->args->nelts; i++) { | 
 |  | 
 |         if (ngx_strcmp(value[i].data, "off") == 0) { | 
 |             scf->builtin_session_cache = NGX_SSL_NO_SCACHE; | 
 |             continue; | 
 |         } | 
 |  | 
 |         if (ngx_strcmp(value[i].data, "none") == 0) { | 
 |             scf->builtin_session_cache = NGX_SSL_NONE_SCACHE; | 
 |             continue; | 
 |         } | 
 |  | 
 |         if (ngx_strcmp(value[i].data, "builtin") == 0) { | 
 |             scf->builtin_session_cache = NGX_SSL_DFLT_BUILTIN_SCACHE; | 
 |             continue; | 
 |         } | 
 |  | 
 |         if (value[i].len > sizeof("builtin:") - 1 | 
 |             && ngx_strncmp(value[i].data, "builtin:", sizeof("builtin:") - 1) | 
 |                == 0) | 
 |         { | 
 |             n = ngx_atoi(value[i].data + sizeof("builtin:") - 1, | 
 |                          value[i].len - (sizeof("builtin:") - 1)); | 
 |  | 
 |             if (n == NGX_ERROR) { | 
 |                 goto invalid; | 
 |             } | 
 |  | 
 |             scf->builtin_session_cache = n; | 
 |  | 
 |             continue; | 
 |         } | 
 |  | 
 |         if (value[i].len > sizeof("shared:") - 1 | 
 |             && ngx_strncmp(value[i].data, "shared:", sizeof("shared:") - 1) | 
 |                == 0) | 
 |         { | 
 |             len = 0; | 
 |  | 
 |             for (j = sizeof("shared:") - 1; j < value[i].len; j++) { | 
 |                 if (value[i].data[j] == ':') { | 
 |                     break; | 
 |                 } | 
 |  | 
 |                 len++; | 
 |             } | 
 |  | 
 |             if (len == 0) { | 
 |                 goto invalid; | 
 |             } | 
 |  | 
 |             name.len = len; | 
 |             name.data = value[i].data + sizeof("shared:") - 1; | 
 |  | 
 |             size.len = value[i].len - j - 1; | 
 |             size.data = name.data + len + 1; | 
 |  | 
 |             n = ngx_parse_size(&size); | 
 |  | 
 |             if (n == NGX_ERROR) { | 
 |                 goto invalid; | 
 |             } | 
 |  | 
 |             if (n < (ngx_int_t) (8 * ngx_pagesize)) { | 
 |                 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | 
 |                                    "session cache \"%V\" is too small", | 
 |                                    &value[i]); | 
 |  | 
 |                 return NGX_CONF_ERROR; | 
 |             } | 
 |  | 
 |             scf->shm_zone = ngx_shared_memory_add(cf, &name, n, | 
 |                                                    &ngx_stream_ssl_module); | 
 |             if (scf->shm_zone == NULL) { | 
 |                 return NGX_CONF_ERROR; | 
 |             } | 
 |  | 
 |             scf->shm_zone->init = ngx_ssl_session_cache_init; | 
 |  | 
 |             continue; | 
 |         } | 
 |  | 
 |         goto invalid; | 
 |     } | 
 |  | 
 |     if (scf->shm_zone && scf->builtin_session_cache == NGX_CONF_UNSET) { | 
 |         scf->builtin_session_cache = NGX_SSL_NO_BUILTIN_SCACHE; | 
 |     } | 
 |  | 
 |     return NGX_CONF_OK; | 
 |  | 
 | invalid: | 
 |  | 
 |     ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | 
 |                        "invalid session cache \"%V\"", &value[i]); | 
 |  | 
 |     return NGX_CONF_ERROR; | 
 | } | 
 |  | 
 |  | 
 | static ngx_int_t | 
 | ngx_stream_ssl_init(ngx_conf_t *cf) | 
 | { | 
 |     ngx_stream_handler_pt        *h; | 
 |     ngx_stream_core_main_conf_t  *cmcf; | 
 |  | 
 |     cmcf = ngx_stream_conf_get_module_main_conf(cf, ngx_stream_core_module); | 
 |  | 
 |     h = ngx_array_push(&cmcf->phases[NGX_STREAM_SSL_PHASE].handlers); | 
 |     if (h == NULL) { | 
 |         return NGX_ERROR; | 
 |     } | 
 |  | 
 |     *h = ngx_stream_ssl_handler; | 
 |  | 
 |     return NGX_OK; | 
 | } |