Mercurial > hg > nginx

comparison src/http/ngx_http_request.c @ 239:574bea0142be

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2004-01-26-11:52:49 import
author Igor Sysoev <igor@sysoev.ru>
date Mon, 26 Jan 2004 08:52:49 +0000
parents 4eaafcd57be7
children 187dc0a3197d
comparison
equal deleted inserted replaced
238:674f85a4d00f 239:574bea0142be
1113 static int ngx_http_read_discarded_body(ngx_http_request_t *r) 1113 static int ngx_http_read_discarded_body(ngx_http_request_t *r)
1114 { 1114 {
1115 ssize_t size, n; 1115 ssize_t size, n;
1116 ngx_http_core_loc_conf_t *clcf; 1116 ngx_http_core_loc_conf_t *clcf;
1117 1117
1118 ngx_log_debug(r->connection->log, "http read discarded body"); 1118 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
1119 "http read discarded body");
1119 1120
1120 if (r->headers_in.content_length_n == 0) { 1121 if (r->headers_in.content_length_n == 0) {
1121 return NGX_OK; 1122 return NGX_OK;
1122 } 1123 }
1123 1124
1162 ngx_http_core_loc_conf_t *clcf; 1163 ngx_http_core_loc_conf_t *clcf;
1163 1164
1164 c = r->connection; 1165 c = r->connection;
1165 rev = c->read; 1166 rev = c->read;
1166 1167
1167 ngx_log_debug(c->log, "set http keepalive handler"); 1168 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "set http keepalive handler");
1168 1169
1169 ctx = (ngx_http_log_ctx_t *) c->log->data; 1170 ctx = (ngx_http_log_ctx_t *) c->log->data;
1170 ctx->action = "closing request"; 1171 ctx->action = "closing request";
1171 ngx_http_close_request(r, 0); 1172 ngx_http_close_request(r, 0);
1172 1173
1199 ngx_memcpy(h->start, h->pos, len); 1200 ngx_memcpy(h->start, h->pos, len);
1200 h->pos = h->start; 1201 h->pos = h->start;
1201 h->last = h->start + len; 1202 h->last = h->start + len;
1202 } 1203 }
1203 1204
1204 ngx_log_debug(c->log, "pipelined request"); 1205 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "pipelined request");
1205 1206
1206 c->pipeline = 1; 1207 c->pipeline = 1;
1207 ctx->action = "reading client pipelined request line"; 1208 ctx->action = "reading client pipelined request line";
1208 ngx_http_init_request(rev); 1209 ngx_http_init_request(rev);
1209 return; 1210 return;
1257 ngx_connection_t *c; 1258 ngx_connection_t *c;
1258 ngx_http_log_ctx_t *ctx; 1259 ngx_http_log_ctx_t *ctx;
1259 1260
1260 c = (ngx_connection_t *) rev->data; 1261 c = (ngx_connection_t *) rev->data;
1261 1262
1262 ngx_log_debug(c->log, "http keepalive handler"); 1263 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http keepalive handler");
1263 1264
1264 if (rev->timedout) { 1265 if (rev->timedout) {
1265 ngx_http_close_connection(c); 1266 ngx_http_close_connection(c);
1266 return; 1267 return;
1267 } 1268 }
1368 ngx_http_core_loc_conf_t *clcf; 1369 ngx_http_core_loc_conf_t *clcf;
1369 1370
1370 c = rev->data; 1371 c = rev->data;
1371 r = c->data; 1372 r = c->data;
1372 1373
1373 ngx_log_debug(c->log, "http lingering close handler"); 1374 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0,
1375 "http lingering close handler");
1374 1376
1375 if (rev->timedout) { 1377 if (rev->timedout) {
1376 ngx_http_close_request(r, 0); 1378 ngx_http_close_request(r, 0);
1377 ngx_http_close_connection(c); 1379 ngx_http_close_connection(c);
1378 return; 1380 return;
1409 } 1411 }
1410 1412
1411 do { 1413 do {
1412 n = ngx_recv(c, r->discarded_buffer, clcf->discarded_buffer_size); 1414 n = ngx_recv(c, r->discarded_buffer, clcf->discarded_buffer_size);
1413 1415
1414 ngx_log_debug(c->log, "lingering read: %d" _ n); 1416 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "lingering read: %d", n);
1415 1417
1416 if (n == NGX_ERROR || n == 0) { 1418 if (n == NGX_ERROR || n == 0) {
1417 ngx_http_close_request(r, 0); 1419 ngx_http_close_request(r, 0);
1418 ngx_http_close_connection(c); 1420 ngx_http_close_connection(c);
1419 return; 1421 return;
1432 } 1434 }
1433 1435
1434 1436
1435 void ngx_http_empty_handler(ngx_event_t *wev) 1437 void ngx_http_empty_handler(ngx_event_t *wev)
1436 { 1438 {
1437 ngx_log_debug(wev->log, "http EMPTY handler"); 1439 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, wev->log, 0, "http empty handler");
1438 1440
1439 return; 1441 return;
1440 } 1442 }
1441 1443
1442 1444
1517 } 1519 }
1518 1520
1519 1521
1520 void ngx_http_close_connection(ngx_connection_t *c) 1522 void ngx_http_close_connection(ngx_connection_t *c)
1521 { 1523 {
1522 ngx_log_debug(c->log, "close connection: %d" _ c->fd); 1524 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0,
1525 "close connection: %d", c->fd);
1523 1526
1524 if (c->pool == NULL) { 1527 if (c->pool == NULL) {
1525 ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed"); 1528 ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed");
1526 return; 1529 return;
1527 } 1530 }