mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-06-07 17:52:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

nginx-0.0.7-2004-07-23-21:05:37 import

Browse Source
This commit is contained in:
Igor Sysoev 2004-07-23 17:05:37 +00:00
parent 6cd88bb7ab
commit a2b360d0b9
1 changed files with 31 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/event/ngx_event_openssl.c
View File

@ -106,27 +106,39 @@ ngx_int_t ngx_ssl_recv(ngx_connection_t *c, u_char *buf, size_t size)
} }
/*
* OpenSSL has no SSL_writev() so we copy several bufs into our 16K buffer
* before SSL_write() call to decrease a SSL overhead.
*
* Besides for protocols such as HTTP it is possible to always buffer
* the output to decrease a SSL overhead some more.
*/
ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in, ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in,
off_t limit) off_t limit)
{ {
int n; int n;
ngx_uint_t flush; ngx_uint_t flush, last;
ssize_t send, size; ssize_t send, size;
ngx_buf_t *buf; ngx_buf_t *buf;
buf = c->ssl->buf; buf = c->ssl->buf;
if (in && in->next == NULL && !c->ssl->buffer && buf->pos == buf->last) { if (in && in->next == NULL && buf->pos == buf->last && !c->ssl->buffer) {
/* /*
* the optimized path without a copy if there is the single incoming * we avoid a buffer copy if the incoming buf is a single,
* buf, we do not need to buffer output and our buffer is empty * our buffer is empty, and we do not need to buffer the output
*/ */
n = ngx_ssl_write(c, in->buf->pos, in->buf->last - in->buf->pos); n = ngx_ssl_write(c, in->buf->pos, in->buf->last - in->buf->pos);
if (n == NGX_ERROR) {
return NGX_CHAIN_ERROR;
}
if (n < 0) { if (n < 0) {
return (ngx_chain_t *) n; n = 0;
} }
in->buf->pos += n; in->buf->pos += n;
@ -136,15 +148,18 @@ ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in,
send = 0; send = 0;
flush = (in == NULL) ? 1 : 0; flush = (in == NULL) ? 1 : 0;
last = (in == NULL) ? 1 : 0;
for ( ;; ) { for ( ;; ) {
while (in && buf->last < buf->end) { while (in && buf->last < buf->end) {
if (in->buf->last_buf) { if (in->buf->last_buf) {
flush = 1; flush = 1;
last = 1;
} }
if (ngx_buf_special(in->buf)) { if (ngx_buf_special(in->buf)) {
in = in->next;
continue; continue;
} }
@ -156,7 +171,7 @@ ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in,
/* /*
* TODO: the taking in->buf->flush into account can be * TODO: the taking in->buf->flush into account can be
* implemented using the limit * implemented using the limit on the higher level
*/ */
if (send + size > limit) { if (send + size > limit) {
@ -179,15 +194,18 @@ ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in,
size = buf->last - buf->pos; size = buf->last - buf->pos;
if (flush || buf->last == buf->end || !c->ssl->buffer) { if (!flush && buf->last < buf->end && c->ssl->buffer) {
n = ngx_ssl_write(c, buf->pos, size); break;
}
} else { n = ngx_ssl_write(c, buf->pos, size);
return NGX_CHAIN_AGAIN;
if (n == NGX_ERROR) {
return NGX_CHAIN_ERROR;
} }
if (n < 0) { if (n < 0) {
return (ngx_chain_t *) n; n = 0;
} }
buf->pos += n; buf->pos += n;
@ -212,11 +230,11 @@ ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in,
return in; return in;
} }
if (buf->pos == buf->last) { if (buf->pos == buf->last || !last) {
return NULL; return NULL;
} }
return NGX_CHAIN_AGAIN; return NGX_CHAIN_AGAIN;
} }