version 1.52, 2000/05/01 18:31:27 |
version 1.53, 2000/05/01 19:11:35 |
|
|
if (c->rfd != -1 && |
if (c->rfd != -1 && |
FD_ISSET(c->rfd, readset)) { |
FD_ISSET(c->rfd, readset)) { |
len = read(c->rfd, buf, sizeof(buf)); |
len = read(c->rfd, buf, sizeof(buf)); |
|
if (len < 0 && (errno == EINTR || errno == EAGAIN)) |
|
return 1; |
if (len <= 0) { |
if (len <= 0) { |
debug("channel %d: read<=0 rfd %d len %d", |
debug("channel %d: read<=0 rfd %d len %d", |
c->self, c->rfd, len); |
c->self, c->rfd, len); |
|
|
FD_ISSET(c->wfd, writeset) && |
FD_ISSET(c->wfd, writeset) && |
buffer_len(&c->output) > 0) { |
buffer_len(&c->output) > 0) { |
len = write(c->wfd, buffer_ptr(&c->output), |
len = write(c->wfd, buffer_ptr(&c->output), |
buffer_len(&c->output)); |
buffer_len(&c->output)); |
|
if (len < 0 && (errno == EINTR || errno == EAGAIN)) |
|
return 1; |
if (len <= 0) { |
if (len <= 0) { |
if (compat13) { |
if (compat13) { |
buffer_consume(&c->output, buffer_len(&c->output)); |
buffer_consume(&c->output, buffer_len(&c->output)); |