Displaying 1 result from an estimated 1 matches for "chan_wont_read_12".
2002 Feb 05
0
New forkoff() and chan_wont_read/write() API
...om channel for socket (ostate) */
chan_event_fn *chan_rcvd_ieof = NULL;
chan_event_fn *chan_write_failed = NULL;
+chan_event_fn *chan_wont_write = NULL;
chan_event_fn *chan_obuf_empty = NULL;
/*
* ACTIONS: should never update the channel states
@@ -137,6 +139,28 @@
}
}
static void
+chan_wont_read_12(Channel *c)
+{
+ debug("channel %d: wont read", c->self);
+ switch (c->istate) {
+ case CHAN_INPUT_OPEN:
+ debug("channel %d: input open -> drain", c->self);
+ chan_shutdown_read(c);
+ c->istate = CHAN_INPUT_WAIT_DRAIN;
+#if 0
+ if (buffer_len(&c->input...