Attachment #1885 for bug #1750

Lines 834-841 channel_pre_open(Channel c, fd_set rea Link Here

(-)channels.c (-4 / +11 lines)
834	if (c->extended_usage == CHAN_EXTENDED_WRITE &&	834	if (c->extended_usage == CHAN_EXTENDED_WRITE &&
835	buffer_len(&c->extended) > 0)	835	buffer_len(&c->extended) > 0)
836	FD_SET(c->efd, writeset);	836	FD_SET(c->efd, writeset);
837	else if (!(c->flags & CHAN_EOF_SENT) &&	837	else if (c->efd != -1 && !(c->flags & CHAN_EOF_SENT) &&
838	c->extended_usage == CHAN_EXTENDED_READ &&	838	(c->extended_usage == CHAN_EXTENDED_READ \|\|
		839	c->extended_usage == CHAN_EXTENDED_IGNORE) &&
839	buffer_len(&c->extended) < c->remote_window)	840	buffer_len(&c->extended) < c->remote_window)
840	FD_SET(c->efd, readset);	841	FD_SET(c->efd, readset);
841	}	842	}
Lines 1734-1740 channel_handle_efd(Channel c, fd_set r Link Here
1734	buffer_consume(&c->extended, len);	1735	buffer_consume(&c->extended, len);
1735	c->local_consumed += len;	1736	c->local_consumed += len;
1736	}	1737	}
1737	} else if (c->extended_usage == CHAN_EXTENDED_READ &&	1738	} else if (c->efd != -1 &&
		1739	(c->extended_usage == CHAN_EXTENDED_READ \|\|
		1740	c->extended_usage == CHAN_EXTENDED_IGNORE) &&
1738	FD_ISSET(c->efd, readset)) {	1741	FD_ISSET(c->efd, readset)) {
1739	len = read(c->efd, buf, sizeof(buf));	1742	len = read(c->efd, buf, sizeof(buf));
1740	debug2("channel %d: read %d from efd %d",	1743	debug2("channel %d: read %d from efd %d",
Lines 1746-1752 channel_handle_efd(Channel c, fd_set r Link Here
1746	c->self, c->efd);	1749	c->self, c->efd);
1747	channel_close_fd(&c->efd);	1750	channel_close_fd(&c->efd);
1748	} else {	1751	} else {
1749	buffer_append(&c->extended, buf, len);	1752	if (c->extended_usage == CHAN_EXTENDED_IGNORE) {
		1753	debug3("channel %d: discard efd",
		1754	c->self);
		1755	} else
		1756	buffer_append(&c->extended, buf, len);
1750	}	1757	}
1751	}	1758	}
1752	}	1759	}




/* func */

Session *session_new(void);
void	session_set_fds(Session *, int, int, int, int, int);
void	session_pty_cleanup(Session *);
void	session_proctitle(Session *);
int	session_setup_x11fwd(Session *);

		close(pin[1]);
		return -1;
	}
	if (pipe(perr) < 0) {
		error("%s: pipe err: %.100s", __func__,
		    strerror(errno));
		close(pin[0]);
		close(pin[1]);
		close(pout[0]);
		close(pout[1]);
		return -1;
			return -1;
		}
		perr[0] = -1;
	} else {
		if (pipe(perr) < 0) {
			error("%s: pipe err: %.100s", __func__,
			    strerror(errno));
			close(pin[0]);
			close(pin[1]);
			close(pout[0]);
			close(pout[1]);
			return -1;
		}
	}
#else
	int inout[2], err[2];

		error("%s: socketpair #1: %.100s", __func__, strerror(errno));
		return -1;
	}
	if (socketpair(AF_UNIX, SOCK_STREAM, 0, err) < 0) {
		error("%s: socketpair #2: %.100s", __func__,
		    strerror(errno));
		close(inout[0]);
		close(inout[1]);
		return -1;
			return -1;
		}
		err[1] = -1;
	} else {
		if (socketpair(AF_UNIX, SOCK_STREAM, 0, err) < 0) {
			error("%s: socketpair #2: %.100s", __func__,
			    strerror(errno));
			close(inout[0]);
			close(inout[1]);
			return -1;
		}
	}
#endif


		close(pin[1]);
		close(pout[0]);
		close(pout[1]);
		close(perr[0]);
			close(perr[0]);
		close(perr[1]);
#else
		close(inout[0]);
		close(inout[1]);
		close(err[0]);
		close(err[1]);
			close(err[1]);
#endif
		return -1;
	case 0:

		close(pout[1]);

		/* Redirect stderr. */
		close(perr[0]);
			close(perr[0]);
		if (dup2(perr[1], 2) < 0)
			perror("dup2 stderr");
		close(perr[1]);

		 * seem to depend on it.
		 */
		close(inout[1]);
		close(err[1]);
			close(err[1]);
		if (dup2(inout[0], 0) < 0)	/* stdin */
			perror("dup2 stdin");
		if (dup2(inout[0], 1) < 0)	/* stdout (same as stdin) */

	close(perr[1]);

	if (compat20) {
		session_set_fds(s, pin[1], pout[0], perr[0],
		    s->is_subsystem, 0);
	} else {
		/* Enter the interactive session. */
		server_loop(pid, pin[1], pout[0], perr[0]);

	 * handle the case that fdin and fdout are the same.
	 */
	if (compat20) {
		session_set_fds(s, inout[1], inout[1], err[1],
		    s->is_subsystem, 0);
	} else {
		server_loop(pid, inout[1], inout[1], err[1]);
		/* server_loop has closed inout[1] and err[1]. */

	s->ptymaster = ptymaster;
	packet_set_interactive(1);
	if (compat20) {
		session_set_fds(s, ptyfd, fdout, -1, 1, 1);
	} else {
		server_loop(pid, ptyfd, fdout, -1);
		/* server_loop _has_ closed ptyfd and fdout. */

}

void
session_set_fds(Session *s, int fdin, int fdout, int fderr, int ignore_fderr,
    int is_tty)
{
	if (!compat20)
		fatal("session_set_fds: called for proto != 2.0");

		fatal("no channel for session %d", s->self);
	channel_set_fds(s->chanid,
	    fdout, fdin, fderr,
	    ignore_fderr ? CHAN_EXTENDED_IGNORE : CHAN_EXTENDED_READ,
	    1, is_tty, CHAN_SES_WINDOW_DEFAULT);
}


Return to bug 1750

Lines 97-103 Link Here

(-)session.c (-52 / +27 lines)
97	/* func */	97	/* func */
98		98
99	Session *session_new(void);	99	Session *session_new(void);
100	void session_set_fds(Session *, int, int, int, int);	100	void session_set_fds(Session *, int, int, int, int, int);
101	void session_pty_cleanup(Session *);	101	void session_pty_cleanup(Session *);
102	void session_proctitle(Session *);	102	void session_proctitle(Session *);
103	int session_setup_x11fwd(Session *);	103	int session_setup_x11fwd(Session *);
Lines 448-474 do_exec_no_pty(Session s, const char c Link Here
448	close(pin[1]);	448	close(pin[1]);
449	return -1;	449	return -1;
450	}	450	}
451	if (s->is_subsystem) {	451	if (pipe(perr) < 0) {
452	if ((perr[1] = open(_PATH_DEVNULL, O_WRONLY)) == -1) {	452	error("%s: pipe err: %.100s", __func__,
453	error("%s: open(%s): %s", __func__, _PATH_DEVNULL,	453	strerror(errno));
454	strerror(errno));	454	close(pin[0]);
455	close(pin[0]);	455	close(pin[1]);
456	close(pin[1]);	456	close(pout[0]);
457	close(pout[0]);	457	close(pout[1]);
458	close(pout[1]);	458	return -1;
459	return -1;
460	}
461	perr[0] = -1;
462	} else {
463	if (pipe(perr) < 0) {
464	error("%s: pipe err: %.100s", __func__,
465	strerror(errno));
466	close(pin[0]);
467	close(pin[1]);
468	close(pout[0]);
469	close(pout[1]);
470	return -1;
471	}
472	}	459	}
473	#else	460	#else
474	int inout[2], err[2];	461	int inout[2], err[2];
Lines 481-503 do_exec_no_pty(Session s, const char c Link Here
481	error("%s: socketpair #1: %.100s", __func__, strerror(errno));	468	error("%s: socketpair #1: %.100s", __func__, strerror(errno));
482	return -1;	469	return -1;
483	}	470	}
484	if (s->is_subsystem) {	471	if (socketpair(AF_UNIX, SOCK_STREAM, 0, err) < 0) {
485	if ((err[0] = open(_PATH_DEVNULL, O_WRONLY)) == -1) {	472	error("%s: socketpair #2: %.100s", __func__,
486	error("%s: open(%s): %s", __func__, _PATH_DEVNULL,	473	strerror(errno));
487	strerror(errno));	474	close(inout[0]);
488	close(inout[0]);	475	close(inout[1]);
489	close(inout[1]);	476	return -1;
490	return -1;
491	}
492	err[1] = -1;
493	} else {
494	if (socketpair(AF_UNIX, SOCK_STREAM, 0, err) < 0) {
495	error("%s: socketpair #2: %.100s", __func__,
496	strerror(errno));
497	close(inout[0]);
498	close(inout[1]);
499	return -1;
500	}
501	}	477	}
502	#endif	478	#endif
503		479
Lines 512-526 do_exec_no_pty(Session s, const char c Link Here
512	close(pin[1]);	488	close(pin[1]);
513	close(pout[0]);	489	close(pout[0]);
514	close(pout[1]);	490	close(pout[1]);
515	if (perr[0] != -1)	491	close(perr[0]);
516	close(perr[0]);
517	close(perr[1]);	492	close(perr[1]);
518	#else	493	#else
519	close(inout[0]);	494	close(inout[0]);
520	close(inout[1]);	495	close(inout[1]);
521	close(err[0]);	496	close(err[0]);
522	if (err[1] != -1)	497	close(err[1]);
523	close(err[1]);
524	#endif	498	#endif
525	return -1;	499	return -1;
526	case 0:	500	case 0:
Lines 554-561 do_exec_no_pty(Session s, const char c Link Here
554	close(pout[1]);	528	close(pout[1]);
555		529
556	/* Redirect stderr. */	530	/* Redirect stderr. */
557	if (perr[0] != -1)	531	close(perr[0]);
558	close(perr[0]);
559	if (dup2(perr[1], 2) < 0)	532	if (dup2(perr[1], 2) < 0)
560	perror("dup2 stderr");	533	perror("dup2 stderr");
561	close(perr[1]);	534	close(perr[1]);
Lines 566-573 do_exec_no_pty(Session s, const char c Link Here
566	* seem to depend on it.	539	* seem to depend on it.
567	*/	540	*/
568	close(inout[1]);	541	close(inout[1]);
569	if (err[1] != -1)	542	close(err[1]);
570	close(err[1]);
571	if (dup2(inout[0], 0) < 0) /* stdin */	543	if (dup2(inout[0], 0) < 0) /* stdin */
572	perror("dup2 stdin");	544	perror("dup2 stdin");
573	if (dup2(inout[0], 1) < 0) /* stdout (same as stdin) */	545	if (dup2(inout[0], 1) < 0) /* stdout (same as stdin) */
Lines 596-602 do_exec_no_pty(Session s, const char c Link Here
596	close(perr[1]);	568	close(perr[1]);
597		569
598	if (compat20) {	570	if (compat20) {
599	session_set_fds(s, pin[1], pout[0], perr[0], 0);	571	session_set_fds(s, pin[1], pout[0], perr[0],
		572	s->is_subsystem, 0);
600	} else {	573	} else {
601	/* Enter the interactive session. */	574	/* Enter the interactive session. */
602	server_loop(pid, pin[1], pout[0], perr[0]);	575	server_loop(pid, pin[1], pout[0], perr[0]);
Lines 612-618 do_exec_no_pty(Session s, const char c Link Here
612	* handle the case that fdin and fdout are the same.	585	* handle the case that fdin and fdout are the same.
613	*/	586	*/
614	if (compat20) {	587	if (compat20) {
615	session_set_fds(s, inout[1], inout[1], err[1], 0);	588	session_set_fds(s, inout[1], inout[1], err[1],
		589	s->is_subsystem, 0);
616	} else {	590	} else {
617	server_loop(pid, inout[1], inout[1], err[1]);	591	server_loop(pid, inout[1], inout[1], err[1]);
618	/* server_loop has closed inout[1] and err[1]. */	592	/* server_loop has closed inout[1] and err[1]. */
Lines 717-723 do_exec_pty(Session s, const char comm Link Here
717	s->ptymaster = ptymaster;	691	s->ptymaster = ptymaster;
718	packet_set_interactive(1);	692	packet_set_interactive(1);
719	if (compat20) {	693	if (compat20) {
720	session_set_fds(s, ptyfd, fdout, -1, 1);	694	session_set_fds(s, ptyfd, fdout, -1, 1, 1);
721	} else {	695	} else {
722	server_loop(pid, ptyfd, fdout, -1);	696	server_loop(pid, ptyfd, fdout, -1);
723	/* server_loop _has_ closed ptyfd and fdout. */	697	/* server_loop _has_ closed ptyfd and fdout. */
Lines 1936-1942 session_input_channel_req(Channel *c, co Link Here
1936	}	1910	}
1937		1911
1938	void	1912	void
1939	session_set_fds(Session *s, int fdin, int fdout, int fderr, int is_tty)	1913	session_set_fds(Session *s, int fdin, int fdout, int fderr, int ignore_fderr,
		1914	int is_tty)
1940	{	1915	{
1941	if (!compat20)	1916	if (!compat20)
1942	fatal("session_set_fds: called for proto != 2.0");	1917	fatal("session_set_fds: called for proto != 2.0");
Lines 1948-1954 session_set_fds(Session *s, int fdin, in Link Here
1948	fatal("no channel for session %d", s->self);	1923	fatal("no channel for session %d", s->self);
1949	channel_set_fds(s->chanid,	1924	channel_set_fds(s->chanid,
1950	fdout, fdin, fderr,	1925	fdout, fdin, fderr,
1951	fderr == -1 ? CHAN_EXTENDED_IGNORE : CHAN_EXTENDED_READ,	1926	ignore_fderr ? CHAN_EXTENDED_IGNORE : CHAN_EXTENDED_READ,
1952	1, is_tty, CHAN_SES_WINDOW_DEFAULT);	1927	1, is_tty, CHAN_SES_WINDOW_DEFAULT);
1953	}	1928	}
1954		1929