sendfile_max_chunk

This commit is contained in:
Igor Sysoev 2007-05-07 06:33:39 +00:00
parent 544e9f1fd7
commit c9b57dc081
3 changed files with 19 additions and 1 deletions

View File

@ -295,6 +295,13 @@ static ngx_command_t ngx_http_core_commands[] = {
offsetof(ngx_http_core_loc_conf_t, sendfile), offsetof(ngx_http_core_loc_conf_t, sendfile),
NULL }, NULL },
{ ngx_string("sendfile_max_chunk"),
NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
ngx_conf_set_size_slot,
NGX_HTTP_LOC_CONF_OFFSET,
offsetof(ngx_http_core_loc_conf_t, sendfile_max_chunk),
NULL },
{ ngx_string("tcp_nopush"), { ngx_string("tcp_nopush"),
NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG,
ngx_conf_set_flag_slot, ngx_conf_set_flag_slot,
@ -2191,6 +2198,7 @@ ngx_http_core_create_loc_conf(ngx_conf_t *cf)
lcf->internal = NGX_CONF_UNSET; lcf->internal = NGX_CONF_UNSET;
lcf->client_body_in_file_only = NGX_CONF_UNSET; lcf->client_body_in_file_only = NGX_CONF_UNSET;
lcf->sendfile = NGX_CONF_UNSET; lcf->sendfile = NGX_CONF_UNSET;
lcf->sendfile_max_chunk = NGX_CONF_UNSET_SIZE;
lcf->tcp_nopush = NGX_CONF_UNSET; lcf->tcp_nopush = NGX_CONF_UNSET;
lcf->tcp_nodelay = NGX_CONF_UNSET; lcf->tcp_nodelay = NGX_CONF_UNSET;
lcf->send_timeout = NGX_CONF_UNSET_MSEC; lcf->send_timeout = NGX_CONF_UNSET_MSEC;
@ -2359,6 +2367,8 @@ ngx_http_core_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child)
ngx_conf_merge_value(conf->client_body_in_file_only, ngx_conf_merge_value(conf->client_body_in_file_only,
prev->client_body_in_file_only, 0); prev->client_body_in_file_only, 0);
ngx_conf_merge_value(conf->sendfile, prev->sendfile, 0); ngx_conf_merge_value(conf->sendfile, prev->sendfile, 0);
ngx_conf_merge_size_value(conf->sendfile_max_chunk,
prev->sendfile_max_chunk, 0);
ngx_conf_merge_value(conf->tcp_nopush, prev->tcp_nopush, 0); ngx_conf_merge_value(conf->tcp_nopush, prev->tcp_nopush, 0);
ngx_conf_merge_value(conf->tcp_nodelay, prev->tcp_nodelay, 1); ngx_conf_merge_value(conf->tcp_nodelay, prev->tcp_nodelay, 1);

View File

@ -245,6 +245,7 @@ struct ngx_http_core_loc_conf_s {
size_t send_lowat; /* send_lowat */ size_t send_lowat; /* send_lowat */
size_t postpone_output; /* postpone_output */ size_t postpone_output; /* postpone_output */
size_t limit_rate; /* limit_rate */ size_t limit_rate; /* limit_rate */
size_t sendfile_max_chunk; /* sendfile_max_chunk */
ngx_msec_t client_body_timeout; /* client_body_timeout */ ngx_msec_t client_body_timeout; /* client_body_timeout */
ngx_msec_t send_timeout; /* send_timeout */ ngx_msec_t send_timeout; /* send_timeout */

View File

@ -222,6 +222,9 @@ ngx_http_write_filter(ngx_http_request_t *r, ngx_chain_t *in)
return NGX_AGAIN; return NGX_AGAIN;
} }
} else if (clcf->sendfile_max_chunk) {
limit = clcf->sendfile_max_chunk;
} else { } else {
limit = 0; limit = 0;
} }
@ -241,10 +244,14 @@ ngx_http_write_filter(ngx_http_request_t *r, ngx_chain_t *in)
return NGX_ERROR; return NGX_ERROR;
} }
if (limit) { if (r->limit_rate) {
sent = c->sent - sent; sent = c->sent - sent;
c->write->delayed = 1; c->write->delayed = 1;
ngx_add_timer(c->write, (ngx_msec_t) (sent * 1000 / r->limit_rate + 1)); ngx_add_timer(c->write, (ngx_msec_t) (sent * 1000 / r->limit_rate + 1));
} else if (c->write->ready && clcf->sendfile_max_chunk) {
c->write->delayed = 1;
ngx_add_timer(c->write, 1);
} }
for (cl = r->out; cl && cl != chain; /* void */) { for (cl = r->out; cl && cl != chain; /* void */) {