/*
     * Now we're authenticated for the connection protocol. The
     * connection protocol will automatically have started at this
     * point; there's no need to send SERVICE_REQUEST.
     */

    ssh->channels = newtree234(ssh_channelcmp);

    /*
     * So now create a channel with a session in it.
     * Create the main session channel.
     */
    ssh->channels = newtree234(ssh_channelcmp);
    ssh->mainchan = snew(struct ssh_channel);
    ssh->mainchan->ssh = ssh;
    ssh->mainchan->localid = alloc_channel_id(ssh);
    ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_OPEN);
    ssh2_pkt_addstring(ssh, "session");
    ssh2_pkt_adduint32(ssh, ssh->mainchan->localid);
    ssh->mainchan->v.v2.locwindow = OUR_V2_WINSIZE;
    ssh2_pkt_adduint32(ssh, ssh->mainchan->v.v2.locwindow);/* our window size */
    ssh2_pkt_adduint32(ssh, 0x4000UL);      /* our max pkt size */
    ssh2_pkt_send(ssh);
    crWaitUntilV(ispkt);
    if (ssh->pktin.type != SSH2_MSG_CHANNEL_OPEN_CONFIRMATION) {
	bombout(("Server refused to open a session"));
	crStopV;
	/* FIXME: error data comes back in FAILURE packet */
    }
    if (ssh_pkt_getuint32(ssh) != ssh->mainchan->localid) {
	bombout(("Server's channel confirmation cited wrong channel"));
	crStopV;
    }
    ssh->mainchan->remoteid = ssh_pkt_getuint32(ssh);
    ssh->mainchan->type = CHAN_MAINSESSION;
    ssh->mainchan->closes = 0;
    ssh->mainchan->v.v2.remwindow = ssh_pkt_getuint32(ssh);
    ssh->mainchan->v.v2.remmaxpkt = ssh_pkt_getuint32(ssh);
    bufchain_init(&ssh->mainchan->v.v2.outbuffer);
    add234(ssh->channels, ssh->mainchan);
    logevent("Opened channel for session");
    if (!ssh->cfg.ssh_no_shell) {
	ssh->mainchan = snew(struct ssh_channel);
	ssh->mainchan->ssh = ssh;
	ssh->mainchan->localid = alloc_channel_id(ssh);
	ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_OPEN);
	ssh2_pkt_addstring(ssh, "session");
	ssh2_pkt_adduint32(ssh, ssh->mainchan->localid);
	ssh->mainchan->v.v2.locwindow = OUR_V2_WINSIZE;
	ssh2_pkt_adduint32(ssh, ssh->mainchan->v.v2.locwindow);/* our window size */
	ssh2_pkt_adduint32(ssh, 0x4000UL);      /* our max pkt size */
	ssh2_pkt_send(ssh);
	crWaitUntilV(ispkt);
	if (ssh->pktin.type != SSH2_MSG_CHANNEL_OPEN_CONFIRMATION) {
	    bombout(("Server refused to open a session"));
	    crStopV;
	    /* FIXME: error data comes back in FAILURE packet */
	}
	if (ssh_pkt_getuint32(ssh) != ssh->mainchan->localid) {
	    bombout(("Server's channel confirmation cited wrong channel"));
	    crStopV;
	}
	ssh->mainchan->remoteid = ssh_pkt_getuint32(ssh);
	ssh->mainchan->type = CHAN_MAINSESSION;
	ssh->mainchan->closes = 0;
	ssh->mainchan->v.v2.remwindow = ssh_pkt_getuint32(ssh);
	ssh->mainchan->v.v2.remmaxpkt = ssh_pkt_getuint32(ssh);
	bufchain_init(&ssh->mainchan->v.v2.outbuffer);
	add234(ssh->channels, ssh->mainchan);
	logevent("Opened channel for session");
    } else
	ssh->mainchan = NULL;

    /*
     * Potentially enable X11 forwarding.
     */
    if (ssh->cfg.x11_forward) {
    if (ssh->mainchan && ssh->cfg.x11_forward) {
	char proto[20], data[64];
	logevent("Requesting X11 forwarding");
	ssh->x11auth = x11_invent_auth(proto, sizeof(proto),
				       data, sizeof(data), ssh->cfg.x11_auth);
        x11_get_real_auth(ssh->x11auth, ssh->cfg.x11_display);
	ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_REQUEST);
	ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);

	    }
	}
    }

    /*
     * Potentially enable agent forwarding.
     */
    if (ssh->cfg.agentfwd && agent_exists()) {
    if (ssh->mainchan && ssh->cfg.agentfwd && agent_exists()) {
	logevent("Requesting OpenSSH-style agent forwarding");
	ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_REQUEST);
	ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);
	ssh2_pkt_addstring(ssh, "auth-agent-req@openssh.com");
	ssh2_pkt_addbool(ssh, 1);	       /* want reply */
	ssh2_pkt_send(ssh);

	    ssh->agentfwd_enabled = TRUE;
	}
    }

    /*
     * Now allocate a pty for the session.
     */
    if (!ssh->cfg.nopty) {
    if (ssh->mainchan && !ssh->cfg.nopty) {
	/* Unpick the terminal-speed string. */
	/* XXX perhaps we should allow no speeds to be sent. */
        ssh->ospeed = 38400; ssh->ispeed = 38400; /* last-resort defaults */
	sscanf(ssh->cfg.termspeed, "%d,%d", &ssh->ospeed, &ssh->ispeed);
	/* Build the pty request. */
	ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_REQUEST);
	ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);	/* recipient channel */

    }

    /*
     * Start a shell or a remote command. We may have to attempt
     * this twice if the config data has provided a second choice
     * of command.
     */
    while (1) {
    if (ssh->mainchan) while (1) {
	int subsys;
	char *cmd;

	if (ssh->fallback_cmd) {
	    subsys = ssh->cfg.ssh_subsys2;
	    cmd = ssh->cfg.remote_cmd_ptr2;
	} else {

	ssh_special(ssh, TS_EOF);

    /*
     * Transfer data!
     */
    if (ssh->ldisc)
	ldisc_send(ssh->ldisc, NULL, 0, 0);/* cause ldisc to notice changes */
    if (ssh->mainchan)
    ssh->send_ok = 1;
	ssh->send_ok = 1;
    while (1) {
	crReturnV;
	s->try_send = FALSE;
	if (ispkt) {
	    if (ssh->pktin.type == SSH2_MSG_CHANNEL_DATA ||
		ssh->pktin.type == SSH2_MSG_CHANNEL_EXTENDED_DATA) {
		char *data;

		}
		del234(ssh->channels, c);
		bufchain_clear(&c->v.v2.outbuffer);
		sfree(c);

		/*
		 * See if that was the last channel left open.
		 * (This is only our termination condition if we're
		 * not running in -N mode.)
		 */
		if (count234(ssh->channels) == 0) {
		if (!ssh->cfg.ssh_no_shell && count234(ssh->channels) == 0) {
		    logevent("All channels closed. Disconnecting");
#if 0
                    /*
                     * We used to send SSH_MSG_DISCONNECT here,
                     * because I'd believed that _every_ conforming
                     * SSH2 connection had to end with a disconnect
                     * being sent by at least one side; apparently

		    ssh2_pkt_adduint32(ssh, 0x4000UL);	/* our max pkt size */
		    ssh2_pkt_send(ssh);
		}
	    } else {
		bombout(("Strange packet received: type %d", ssh->pktin.type));
		crStopV;
	    }
	} else {
	} else if (ssh->mainchan) {
	    /*
	     * We have spare data. Add it to the channel buffer.
	     */
	    ssh2_add_channel_data(ssh->mainchan, (char *)in, inlen);
	    s->try_send = TRUE;
	}
	if (s->try_send) {

      case SSH_STATE_SESSION:
	if (!ssh->cfg.nopty) {
	    if (ssh->version == 1) {
		send_packet(ssh, SSH1_CMSG_WINDOW_SIZE,
			    PKT_INT, ssh->term_height,
			    PKT_INT, ssh->term_width,
			    PKT_INT, 0, PKT_INT, 0, PKT_END);
	    } else {
	    } else if (ssh->mainchan) {
		ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_REQUEST);
		ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);
		ssh2_pkt_addstring(ssh, "window-change");
		ssh2_pkt_addbool(ssh, 0);
		ssh2_pkt_adduint32(ssh, ssh->term_width);
		ssh2_pkt_adduint32(ssh, ssh->term_height);
		ssh2_pkt_adduint32(ssh, 0);

	     */
	    if (code == TS_EOF)
		ssh->eof_needed = TRUE;
	    return;
	}
	if (ssh->version == 1) {
	    send_packet(ssh, SSH1_CMSG_EOF, PKT_END);
	} else {
	} else if (ssh->mainchan) {
	    ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_EOF);
	    ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);
	    ssh2_pkt_send(ssh);
	}
	logevent("Sent EOF message");
    } else if (code == TS_PING || code == TS_NOP) {
	if (ssh->state == SSH_STATE_CLOSED

	    ssh2_pkt_send(ssh);
	}
    } else if (code == TS_BRK) {
	if (ssh->state == SSH_STATE_CLOSED
	    || ssh->state == SSH_STATE_PREPACKET) return;
	if (ssh->version == 1) {
	    logevent("Unable to send BREAK signal in SSH1");
	} else {
	} else if (ssh->mainchan) {
	    ssh2_pkt_init(ssh, SSH2_MSG_CHANNEL_REQUEST);
	    ssh2_pkt_adduint32(ssh, ssh->mainchan->remoteid);
	    ssh2_pkt_addstring(ssh, "break");
	    ssh2_pkt_addbool(ssh, 0);
	    ssh2_pkt_adduint32(ssh, 0);   /* default break length */
	    ssh2_pkt_send(ssh);
	}