Lines Matching refs:Channel
45 * SSH Protocol 1.5 aka New Channel Protocol
61 * i.e. both sides have to close the channel
70 /* functions manipulating channel states */
72 * EVENTS update channel input/output states execute ACTIONS
75 * ACTIONS: should never update the channel states
77 static void chan_send_ieof1(Channel *);
78 static void chan_send_oclose1(Channel *);
79 static void chan_send_close2(Channel *);
80 static void chan_send_eof2(Channel *);
81 static void chan_send_eow2(Channel *);
84 static void chan_shutdown_write(Channel *);
85 static void chan_shutdown_read(Channel *);
91 chan_set_istate(Channel *c, u_int next)
95 debug2("channel %d: input %s -> %s", c->self, istates[c->istate],
100 chan_set_ostate(Channel *c, u_int next)
104 debug2("channel %d: output %s -> %s", c->self, ostates[c->ostate],
114 chan_rcvd_oclose1(Channel *c)
116 debug2("channel %d: rcvd oclose", c->self);
132 error("channel %d: protocol error: rcvd_oclose for istate %d",
138 chan_read_failed(Channel *c)
140 debug2("channel %d: read failed", c->self);
147 error("channel %d: chan_read_failed for istate %d",
153 chan_ibuf_empty(Channel *c)
155 debug2("channel %d: ibuf empty", c->self);
157 error("channel %d: chan_ibuf_empty for non empty buffer",
173 error("channel %d: chan_ibuf_empty for istate %d",
179 chan_rcvd_ieof1(Channel *c)
181 debug2("channel %d: rcvd ieof", c->self);
190 error("channel %d: protocol error: rcvd_ieof for ostate %d",
196 chan_write_failed1(Channel *c)
198 debug2("channel %d: write failed", c->self);
211 error("channel %d: chan_write_failed for ostate %d",
217 chan_obuf_empty(Channel *c)
219 debug2("channel %d: obuf empty", c->self);
221 error("channel %d: chan_obuf_empty for non empty buffer",
233 error("channel %d: internal error: obuf_empty for ostate %d",
239 chan_send_ieof1(Channel *c)
241 debug2("channel %d: send ieof", c->self);
250 error("channel %d: cannot send ieof for istate %d",
256 chan_send_oclose1(Channel *c)
258 debug2("channel %d: send oclose", c->self);
268 error("channel %d: cannot send oclose for ostate %d",
278 chan_rcvd_close2(Channel *c)
280 debug2("channel %d: rcvd close", c->self);
283 error("channel %d: protocol error: close rcvd twice",
296 * wait until a data from the channel is consumed if a CLOSE
316 chan_rcvd_eow(Channel *c)
318 debug2("channel %d: rcvd eow", c->self);
327 chan_rcvd_eof2(Channel *c)
329 debug2("channel %d: rcvd eof", c->self);
335 chan_write_failed2(Channel *c)
337 debug2("channel %d: write failed", c->self);
347 error("channel %d: chan_write_failed for ostate %d",
353 chan_send_eof2(Channel *c)
355 debug2("channel %d: send eof", c->self);
364 error("channel %d: cannot send eof for istate %d",
370 chan_send_close2(Channel *c)
372 debug2("channel %d: send close", c->self);
375 error("channel %d: cannot send close for istate/ostate %d/%d",
378 error("channel %d: already sent close", c->self);
387 chan_send_eow2(Channel *c)
389 debug2("channel %d: send eow", c->self);
391 error("channel %d: must not sent eow on closed output",
407 chan_rcvd_ieof(Channel *c)
419 chan_rcvd_oclose(Channel *c)
427 chan_write_failed(Channel *c)
436 chan_mark_dead(Channel *c)
442 chan_is_dead(Channel *c, int do_send)
445 debug2("channel %d: zombie", c->self);
451 debug2("channel %d: is dead", c->self);
458 debug2("channel %d: active efd: %d len %d",
463 debug2("channel %d: is dead (local)", c->self);
470 /* channel would be dead if we sent a close */
472 debug2("channel %d: almost dead",
480 debug2("channel %d: is dead", c->self);
488 chan_shutdown_write(Channel *c)
494 debug2("channel %d: close_write", c->self);
497 debug2("channel %d: chan_shutdown_write: "
502 logit("channel %d: chan_shutdown_write: "
508 chan_shutdown_read(Channel *c)
512 debug2("channel %d: close_read", c->self);
521 error("channel %d: chan_shutdown_read: "
527 logit("channel %d: chan_shutdown_read: "
