Mercurial > hg > nginx

comparison src/http/modules/proxy/ngx_http_proxy_handler.c @ 317:1308b98496a2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.3-2004-04-15-19:34:36 import
author Igor Sysoev <igor@sysoev.ru>
date Thu, 15 Apr 2004 15:34:36 +0000
parents 39b6f2df45c0
children 159dd60d257a
comparison
equal deleted inserted replaced
316:a0beefedaf94 317:1308b98496a2
426 426
427 n = recv(c->fd, buf, 1, MSG_PEEK); 427 n = recv(c->fd, buf, 1, MSG_PEEK);
428 428
429 err = ngx_socket_errno; 429 err = ngx_socket_errno;
430 430
431 /*
432 * we do not need to disable the write event because
433 * that event has NGX_USE_CLEAR_EVENT type
434 */
435
431 if (ev->write && (n >= 0 || err == NGX_EAGAIN)) { 436 if (ev->write && (n >= 0 || err == NGX_EAGAIN)) {
432 return; 437 return;
433 } 438 }
434 439
440 if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && ev->active) {
441 if (ngx_del_event(ev, NGX_READ_EVENT, 0) == NGX_ERROR) {
442 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
443 }
444 }
445
435 if (n > 0) { 446 if (n > 0) {
436 if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && ev->active) {
437 if (ngx_del_event(ev, NGX_READ_EVENT, 0) == NGX_ERROR) {
438 ngx_http_proxy_finalize_request(p,
439 NGX_HTTP_INTERNAL_SERVER_ERROR);
440 }
441 }
442
443 return; 447 return;
444 } 448 }
445 449
446 ev->eof = 1; 450 ev->eof = 1;
447 451