openssh/dist/nchan.c

66  * See the debugging output from 'ssh -v' and 'sshd -d' of
67  * ssh-1.2.27 as an example.
78 static void	chan_send_eof2(struct ssh *, Channel *);
79 static void	chan_send_eow2(struct ssh *, Channel *);
82 static void	chan_shutdown_write(struct ssh *, Channel *);
83 static void	chan_shutdown_read(struct ssh *, Channel *);
84 static void	chan_shutdown_extended_read(struct ssh *, Channel *);
114 chan_read_failed(struct ssh *ssh, Channel *c)
119 		chan_shutdown_read(ssh, c);
130 chan_ibuf_empty(struct ssh *ssh, Channel *c)
141 			chan_send_eof2(ssh, c);
152 chan_obuf_empty(struct ssh *ssh, Channel *c)
162 		chan_shutdown_write(ssh, c);
173 chan_rcvd_eow(struct ssh *ssh, Channel *c)
178 		chan_shutdown_read(ssh, c);
185 chan_send_eof2(struct ssh *ssh, Channel *c)
194 		if ((r = sshpkt_start(ssh, SSH2_MSG_CHANNEL_EOF)) != 0 ||
195 		    (r = sshpkt_put_u32(ssh, c->remote_id)) != 0 ||
196 		    (r = sshpkt_send(ssh)) != 0)
208 chan_send_close2(struct ssh *ssh, Channel *c)
222 		if ((r = sshpkt_start(ssh, SSH2_MSG_CHANNEL_CLOSE)) != 0 ||
223 		    (r = sshpkt_put_u32(ssh, c->remote_id)) != 0 ||
224 		    (r = sshpkt_send(ssh)) != 0)
231 chan_send_eow2(struct ssh *ssh, Channel *c)
241 	if (!(ssh->compat & SSH_NEW_OPENSSH))
245 	if ((r = sshpkt_start(ssh, SSH2_MSG_CHANNEL_REQUEST)) != 0 ||
246 	    (r = sshpkt_put_u32(ssh, c->remote_id)) != 0 ||
247 	    (r = sshpkt_put_cstring(ssh, "eow@openssh.com")) != 0 ||
248 	    (r = sshpkt_put_u8(ssh, 0)) != 0 ||
249 	    (r = sshpkt_send(ssh)) != 0)
256 chan_rcvd_ieof(struct ssh *ssh, Channel *c)
265 		chan_obuf_empty(ssh, c);
269 chan_rcvd_oclose(struct ssh *ssh, Channel *c)
295 		chan_shutdown_read(ssh, c);
296 		chan_shutdown_extended_read(ssh, c);
301 			chan_send_eof2(ssh, c);
302 		chan_shutdown_extended_read(ssh, c);
309 chan_write_failed(struct ssh *ssh, Channel *c)
315 		chan_shutdown_write(ssh, c);
317 			chan_send_eow2(ssh, c);
328 chan_mark_dead(struct ssh *ssh, Channel *c)
334 chan_is_dead(struct ssh *ssh, Channel *c, int do_send)
342 	if ((ssh->compat & SSH_BUG_EXTEOF) &&
356 			chan_send_close2(ssh, c);
376 chan_shutdown_write(struct ssh *ssh, Channel *c)
392 		if (channel_close_fd(ssh, c, &c->wfd) < 0) {
401 chan_shutdown_read(struct ssh *ssh, Channel *c)
415 		if (channel_close_fd(ssh, c, &c->rfd) < 0) {
424 chan_shutdown_extended_read(struct ssh *ssh, Channel *c)
434 	if (channel_close_fd(ssh, c, &c->efd) < 0) {