Skip to content

Commit dab6e3b

Browse files
committed
1.23 stream
1 parent 35f5c69 commit dab6e3b

File tree

2 files changed

+9
-6
lines changed

2 files changed

+9
-6
lines changed

nginx/src/stream/ngx_stream_proxy_module.c

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1069,8 +1069,10 @@ ngx_stream_proxy_ssl_init_connection(ngx_stream_session_t *s)
10691069
}
10701070
}
10711071

1072-
if (pscf->ssl_certificate && (pscf->ssl_certificate->lengths
1073-
|| pscf->ssl_certificate_key->lengths))
1072+
if (pscf->ssl_certificate
1073+
&& pscf->ssl_certificate->value.len
1074+
&& (pscf->ssl_certificate->lengths
1075+
|| pscf->ssl_certificate_key->lengths))
10741076
{
10751077
if (ngx_stream_proxy_ssl_certificate(s) != NGX_OK) {
10761078
ngx_stream_proxy_finalize(s, NGX_STREAM_INTERNAL_SERVER_ERROR);
@@ -1735,7 +1737,7 @@ ngx_stream_proxy_process(ngx_stream_session_t *s, ngx_uint_t from_upstream,
17351737

17361738
cl->buf->temporary = (n ? 1 : 0);
17371739
cl->buf->last_buf = src->read->eof;
1738-
cl->buf->flush = 1;
1740+
cl->buf->flush = !src->read->eof;
17391741

17401742
(*packets)++;
17411743
*received += n;
@@ -2225,8 +2227,9 @@ ngx_stream_proxy_set_ssl(ngx_conf_t *cf, ngx_stream_proxy_srv_conf_t *pscf)
22252227
return NGX_ERROR;
22262228
}
22272229

2228-
if (pscf->ssl_certificate) {
2229-
2230+
if (pscf->ssl_certificate
2231+
&& pscf->ssl_certificate->value.len)
2232+
{
22302233
if (pscf->ssl_certificate_key == NULL) {
22312234
ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
22322235
"no \"proxy_ssl_certificate_key\" is defined "

nginx/src/stream/ngx_stream_write_filter_module.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ ngx_stream_write_filter(ngx_stream_session_t *s, ngx_chain_t *in,
235235
if (size == 0
236236
&& !(c->buffered & NGX_LOWLEVEL_BUFFERED)
237237
&& !(last && c->need_last_buf)
238-
&& !(c->type == SOCK_DGRAM && flush))
238+
&& !(flush && c->need_flush_buf))
239239
{
240240
if (last || flush || sync) {
241241
for (cl = *out; cl; /* void */) {

0 commit comments

Comments
 (0)