version 1.32, 2001/10/10 22:18:47 |
version 1.33, 2001/12/19 07:18:56 |
|
|
break; |
break; |
default: |
default: |
error("channel %d: cannot send oclose for ostate %d", |
error("channel %d: cannot send oclose for ostate %d", |
c->self, c->ostate); |
c->self, c->ostate); |
break; |
break; |
} |
} |
} |
} |
|
|
debug("channel %d: ibuf empty", c->self); |
debug("channel %d: ibuf empty", c->self); |
if (buffer_len(&c->input)) { |
if (buffer_len(&c->input)) { |
error("channel %d: chan_ibuf_empty for non empty buffer", |
error("channel %d: chan_ibuf_empty for non empty buffer", |
c->self); |
c->self); |
return; |
return; |
} |
} |
switch (c->istate) { |
switch (c->istate) { |
|
|
break; |
break; |
default: |
default: |
error("channel %d: chan_ibuf_empty for istate %d", |
error("channel %d: chan_ibuf_empty for istate %d", |
c->self, c->istate); |
c->self, c->istate); |
break; |
break; |
} |
} |
} |
} |
|
|
debug2("channel %d: active efd: %d len %d type %s", |
debug2("channel %d: active efd: %d len %d type %s", |
c->self, c->efd, buffer_len(&c->extended), |
c->self, c->efd, buffer_len(&c->extended), |
c->extended_usage==CHAN_EXTENDED_READ ? |
c->extended_usage==CHAN_EXTENDED_READ ? |
"read": "write"); |
"read": "write"); |
} else { |
} else { |
if (!(c->flags & CHAN_CLOSE_SENT)) { |
if (!(c->flags & CHAN_CLOSE_SENT)) { |
if (send) { |
if (send) { |