|
|
@ -842,7 +842,7 @@ static int ssh1_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
if (ssh->cipher && detect_attack(ssh->crcda_ctx, ssh->pktin.data,
|
|
|
|
if (ssh->cipher && detect_attack(ssh->crcda_ctx, ssh->pktin.data,
|
|
|
|
st->biglen, NULL)) {
|
|
|
|
st->biglen, NULL)) {
|
|
|
|
bombout(("Network attack (CRC compensation) detected!"));
|
|
|
|
bombout(("Network attack (CRC compensation) detected!"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (ssh->cipher)
|
|
|
|
if (ssh->cipher)
|
|
|
@ -852,7 +852,7 @@ static int ssh1_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
st->gotcrc = GET_32BIT(ssh->pktin.data + st->biglen - 4);
|
|
|
|
st->gotcrc = GET_32BIT(ssh->pktin.data + st->biglen - 4);
|
|
|
|
if (st->gotcrc != st->realcrc) {
|
|
|
|
if (st->gotcrc != st->realcrc) {
|
|
|
|
bombout(("Incorrect CRC received on packet"));
|
|
|
|
bombout(("Incorrect CRC received on packet"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ssh->pktin.body = ssh->pktin.data + st->pad + 1;
|
|
|
|
ssh->pktin.body = ssh->pktin.data + st->pad + 1;
|
|
|
@ -893,7 +893,7 @@ static int ssh1_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
long stringlen = GET_32BIT(ssh->pktin.body);
|
|
|
|
long stringlen = GET_32BIT(ssh->pktin.body);
|
|
|
|
if (stringlen + 4 != ssh->pktin.length) {
|
|
|
|
if (stringlen + 4 != ssh->pktin.length) {
|
|
|
|
bombout(("Received data packet with bogus string length"));
|
|
|
|
bombout(("Received data packet with bogus string length"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -926,7 +926,7 @@ static int ssh1_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
buf[nowlen + msglen] = '\0';
|
|
|
|
buf[nowlen + msglen] = '\0';
|
|
|
|
/* logevent(buf); (this is now done within the bombout macro) */
|
|
|
|
/* logevent(buf); (this is now done within the bombout macro) */
|
|
|
|
bombout(("Server sent disconnect message:\n\"%s\"", buf+nowlen));
|
|
|
|
bombout(("Server sent disconnect message:\n\"%s\"", buf+nowlen));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
crFinish(0);
|
|
|
|
crFinish(0);
|
|
|
@ -981,7 +981,7 @@ static int ssh2_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
if (st->len < 0 || st->pad < 0 || st->len + st->pad < 0) {
|
|
|
|
if (st->len < 0 || st->pad < 0 || st->len + st->pad < 0) {
|
|
|
|
bombout(("Incoming packet was garbled on decryption"));
|
|
|
|
bombout(("Incoming packet was garbled on decryption"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
@ -1030,7 +1030,7 @@ static int ssh2_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
&& !ssh->scmac->verify(ssh->sc_mac_ctx, ssh->pktin.data, st->len + 4,
|
|
|
|
&& !ssh->scmac->verify(ssh->sc_mac_ctx, ssh->pktin.data, st->len + 4,
|
|
|
|
st->incoming_sequence)) {
|
|
|
|
st->incoming_sequence)) {
|
|
|
|
bombout(("Incorrect MAC received on packet"));
|
|
|
|
bombout(("Incorrect MAC received on packet"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
st->incoming_sequence++; /* whether or not we MACed */
|
|
|
|
st->incoming_sequence++; /* whether or not we MACed */
|
|
|
|
|
|
|
|
|
|
|
@ -1094,7 +1094,7 @@ static int ssh2_rdpkt(Ssh ssh, unsigned char **data, int *datalen)
|
|
|
|
ssh2_disconnect_reasons[reason] : "unknown",
|
|
|
|
ssh2_disconnect_reasons[reason] : "unknown",
|
|
|
|
buf+nowlen));
|
|
|
|
buf+nowlen));
|
|
|
|
sfree(buf);
|
|
|
|
sfree(buf);
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|
case SSH2_MSG_IGNORE:
|
|
|
|
case SSH2_MSG_IGNORE:
|
|
|
@ -1938,11 +1938,11 @@ static int do_ssh_init(Ssh ssh, unsigned char c)
|
|
|
|
|
|
|
|
|
|
|
|
if (ssh->cfg.sshprot == 0 && !s->proto1) {
|
|
|
|
if (ssh->cfg.sshprot == 0 && !s->proto1) {
|
|
|
|
bombout(("SSH protocol version 1 required by user but not provided by server"));
|
|
|
|
bombout(("SSH protocol version 1 required by user but not provided by server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (ssh->cfg.sshprot == 3 && !s->proto2) {
|
|
|
|
if (ssh->cfg.sshprot == 3 && !s->proto2) {
|
|
|
|
bombout(("SSH protocol version 2 required by user but not provided by server"));
|
|
|
|
bombout(("SSH protocol version 2 required by user but not provided by server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (s->proto2 && (ssh->cfg.sshprot >= 2 || !s->proto1)) {
|
|
|
|
if (s->proto2 && (ssh->cfg.sshprot >= 2 || !s->proto1)) {
|
|
|
@ -2301,7 +2301,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
|
|
|
|
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_PUBLIC_KEY) {
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_PUBLIC_KEY) {
|
|
|
|
bombout(("Public key packet not received"));
|
|
|
|
bombout(("Public key packet not received"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
logevent("Received public keys");
|
|
|
|
logevent("Received public keys");
|
|
|
@ -2415,7 +2415,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
else
|
|
|
|
else
|
|
|
|
/* shouldn't happen */
|
|
|
|
/* shouldn't happen */
|
|
|
|
bombout(("No supported ciphers found"));
|
|
|
|
bombout(("No supported ciphers found"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* Warn about chosen cipher if necessary. */
|
|
|
|
/* Warn about chosen cipher if necessary. */
|
|
|
@ -2460,7 +2460,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
|
|
|
|
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
bombout(("Encryption not successfully enabled"));
|
|
|
|
bombout(("Encryption not successfully enabled"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
logevent("Successfully started encryption");
|
|
|
|
logevent("Successfully started encryption");
|
|
|
@ -2477,7 +2477,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
logevent("No username provided. Abandoning session.");
|
|
|
|
logevent("No username provided. Abandoning session.");
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturn(1);
|
|
|
|
crStop(1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
int ret; /* need not be kept over crReturn */
|
|
|
|
int ret; /* need not be kept over crReturn */
|
|
|
@ -2755,7 +2755,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
logevent("Unable to authenticate");
|
|
|
|
logevent("Unable to authenticate");
|
|
|
|
connection_fatal(ssh->frontend, "Unable to authenticate");
|
|
|
|
connection_fatal(ssh->frontend, "Unable to authenticate");
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturn(1);
|
|
|
|
crStop(1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
/* Prompt may have come from server. We've munged it a bit, so
|
|
|
|
/* Prompt may have come from server. We've munged it a bit, so
|
|
|
@ -2810,7 +2810,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_AUTH_RSA_CHALLENGE) {
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_AUTH_RSA_CHALLENGE) {
|
|
|
|
bombout(("Bizarre response to offer of public key"));
|
|
|
|
bombout(("Bizarre response to offer of public key"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
{
|
|
|
|
{
|
|
|
@ -2846,7 +2846,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
continue; /* go and try password */
|
|
|
|
continue; /* go and try password */
|
|
|
|
} else if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
} else if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
bombout(("Bizarre response to RSA authentication response"));
|
|
|
|
bombout(("Bizarre response to RSA authentication response"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
break; /* we're through! */
|
|
|
|
break; /* we're through! */
|
|
|
@ -2979,7 +2979,7 @@ static int do_ssh1_login(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
logevent("Authentication refused");
|
|
|
|
logevent("Authentication refused");
|
|
|
|
} else if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
} else if (ssh->pktin.type != SSH1_SMSG_SUCCESS) {
|
|
|
|
bombout(("Strange packet received, type %d", ssh->pktin.type));
|
|
|
|
bombout(("Strange packet received, type %d", ssh->pktin.type));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -3079,7 +3079,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
logevent("Agent forwarding refused");
|
|
|
|
logevent("Agent forwarding refused");
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -3109,7 +3109,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
logevent("X11 forwarding refused");
|
|
|
|
logevent("X11 forwarding refused");
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -3177,7 +3177,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
while (*ssh->portfwd_strptr) ssh->portfwd_strptr++;
|
|
|
|
while (*ssh->portfwd_strptr) ssh->portfwd_strptr++;
|
|
|
|
dport = -1;
|
|
|
|
dport = dserv = -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sport = atoi(sports);
|
|
|
|
sport = atoi(sports);
|
|
|
|
sserv = 0;
|
|
|
|
sserv = 0;
|
|
|
@ -3245,7 +3245,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
c_write_str(ssh, "Server refused port"
|
|
|
|
c_write_str(ssh, "Server refused port"
|
|
|
|
" forwarding\r\n");
|
|
|
|
" forwarding\r\n");
|
|
|
@ -3270,7 +3270,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
c_write_str(ssh, "Server refused to allocate pty\r\n");
|
|
|
|
c_write_str(ssh, "Server refused to allocate pty\r\n");
|
|
|
|
ssh->editing = ssh->echoing = 1;
|
|
|
|
ssh->editing = ssh->echoing = 1;
|
|
|
@ -3288,7 +3288,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
if (ssh->pktin.type != SSH1_SMSG_SUCCESS
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
&& ssh->pktin.type != SSH1_SMSG_FAILURE) {
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
bombout(("Protocol confusion"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_FAILURE) {
|
|
|
|
c_write_str(ssh, "Server refused to compress\r\n");
|
|
|
|
c_write_str(ssh, "Server refused to compress\r\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -3348,7 +3348,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
} else if (ssh->pktin.type == SSH1_MSG_DISCONNECT) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_MSG_DISCONNECT) {
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
logevent("Received disconnect request");
|
|
|
|
logevent("Received disconnect request");
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_X11_OPEN) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_SMSG_X11_OPEN) {
|
|
|
|
/* Remote side is trying to open a channel to talk to our
|
|
|
|
/* Remote side is trying to open a channel to talk to our
|
|
|
|
* X-Server. Give them back a local channel number. */
|
|
|
|
* X-Server. Give them back a local channel number. */
|
|
|
@ -3542,6 +3542,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
ssh->pktin.type == SSH1_MSG_CHANNEL_CLOSE ? "" :
|
|
|
|
ssh->pktin.type == SSH1_MSG_CHANNEL_CLOSE ? "" :
|
|
|
|
"_CONFIRMATION", c ? "half-open" : "nonexistent",
|
|
|
|
"_CONFIRMATION", c ? "half-open" : "nonexistent",
|
|
|
|
i));
|
|
|
|
i));
|
|
|
|
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else if (ssh->pktin.type == SSH1_MSG_CHANNEL_DATA) {
|
|
|
|
} else if (ssh->pktin.type == SSH1_MSG_CHANNEL_DATA) {
|
|
|
|
/* Data sent down one of our channels. */
|
|
|
|
/* Data sent down one of our channels. */
|
|
|
@ -3551,7 +3552,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
struct ssh_channel *c;
|
|
|
|
struct ssh_channel *c;
|
|
|
|
c = find234(ssh->channels, &i, ssh_channelfind);
|
|
|
|
c = find234(ssh->channels, &i, ssh_channelfind);
|
|
|
|
if (c) {
|
|
|
|
if (c) {
|
|
|
|
int bufsize;
|
|
|
|
int bufsize = 0;
|
|
|
|
switch (c->type) {
|
|
|
|
switch (c->type) {
|
|
|
|
case CHAN_X11:
|
|
|
|
case CHAN_X11:
|
|
|
|
bufsize = x11_send(c->u.x11.s, (char *)p, len);
|
|
|
|
bufsize = x11_send(c->u.x11.s, (char *)p, len);
|
|
|
@ -3639,10 +3640,10 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
* we've sent EXIT_CONFIRMATION.
|
|
|
|
* we've sent EXIT_CONFIRMATION.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
bombout(("Strange packet received: type %d", ssh->pktin.type));
|
|
|
|
bombout(("Strange packet received: type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
while (inlen > 0) {
|
|
|
|
while (inlen > 0) {
|
|
|
@ -3915,7 +3916,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
|
|
|
|
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_KEXINIT) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_KEXINIT) {
|
|
|
|
bombout(("expected key exchange packet from server"));
|
|
|
|
bombout(("expected key exchange packet from server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ssh->kex = NULL;
|
|
|
|
ssh->kex = NULL;
|
|
|
|
ssh->hostkey = NULL;
|
|
|
|
ssh->hostkey = NULL;
|
|
|
@ -3966,7 +3967,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (!s->cscipher_tobe) {
|
|
|
|
if (!s->cscipher_tobe) {
|
|
|
|
bombout(("Couldn't agree a client-to-server cipher (available: %s)",
|
|
|
|
bombout(("Couldn't agree a client-to-server cipher (available: %s)",
|
|
|
|
str ? str : "(null)"));
|
|
|
|
str ? str : "(null)"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ssh2_pkt_getstring(ssh, &str, &len); /* server->client cipher */
|
|
|
|
ssh2_pkt_getstring(ssh, &str, &len); /* server->client cipher */
|
|
|
@ -3992,7 +3993,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (!s->sccipher_tobe) {
|
|
|
|
if (!s->sccipher_tobe) {
|
|
|
|
bombout(("Couldn't agree a server-to-client cipher (available: %s)",
|
|
|
|
bombout(("Couldn't agree a server-to-client cipher (available: %s)",
|
|
|
|
str ? str : "(null)"));
|
|
|
|
str ? str : "(null)"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ssh2_pkt_getstring(ssh, &str, &len); /* client->server mac */
|
|
|
|
ssh2_pkt_getstring(ssh, &str, &len); /* client->server mac */
|
|
|
@ -4065,7 +4066,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_KEX_DH_GEX_GROUP) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_KEX_DH_GEX_GROUP) {
|
|
|
|
bombout(("expected key exchange group packet from server"));
|
|
|
|
bombout(("expected key exchange group packet from server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
s->p = ssh2_pkt_getmp(ssh);
|
|
|
|
s->p = ssh2_pkt_getmp(ssh);
|
|
|
|
s->g = ssh2_pkt_getmp(ssh);
|
|
|
|
s->g = ssh2_pkt_getmp(ssh);
|
|
|
@ -4091,7 +4092,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
if (ssh->pktin.type != s->kex_reply_value) {
|
|
|
|
if (ssh->pktin.type != s->kex_reply_value) {
|
|
|
|
bombout(("expected key exchange reply packet from server"));
|
|
|
|
bombout(("expected key exchange reply packet from server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ssh2_pkt_getstring(ssh, &s->hostkeydata, &s->hostkeylen);
|
|
|
|
ssh2_pkt_getstring(ssh, &s->hostkeydata, &s->hostkeylen);
|
|
|
|
s->f = ssh2_pkt_getmp(ssh);
|
|
|
|
s->f = ssh2_pkt_getmp(ssh);
|
|
|
@ -4123,7 +4124,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
!ssh->hostkey->verifysig(s->hkey, s->sigdata, s->siglen,
|
|
|
|
!ssh->hostkey->verifysig(s->hkey, s->sigdata, s->siglen,
|
|
|
|
(char *)s->exchange_hash, 20)) {
|
|
|
|
(char *)s->exchange_hash, 20)) {
|
|
|
|
bombout(("Server's host key did not match the signature supplied"));
|
|
|
|
bombout(("Server's host key did not match the signature supplied"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
@ -4155,7 +4156,7 @@ static int do_ssh2_transport(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
crWaitUntil(ispkt);
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_NEWKEYS) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_NEWKEYS) {
|
|
|
|
bombout(("expected new-keys packet from server"));
|
|
|
|
bombout(("expected new-keys packet from server"));
|
|
|
|
crReturn(0);
|
|
|
|
crStop(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
@ -4370,7 +4371,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
crWaitUntilV(ispkt);
|
|
|
|
crWaitUntilV(ispkt);
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_SERVICE_ACCEPT) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_SERVICE_ACCEPT) {
|
|
|
|
bombout(("Server refused user authentication protocol"));
|
|
|
|
bombout(("Server refused user authentication protocol"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
@ -4419,7 +4420,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
logevent("No username provided. Abandoning session.");
|
|
|
|
logevent("No username provided. Abandoning session.");
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
int ret; /* need not be saved across crReturn */
|
|
|
|
int ret; /* need not be saved across crReturn */
|
|
|
@ -4536,7 +4537,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
} else if (ssh->pktin.type != SSH2_MSG_USERAUTH_FAILURE) {
|
|
|
|
} else if (ssh->pktin.type != SSH2_MSG_USERAUTH_FAILURE) {
|
|
|
|
bombout(("Strange packet received during authentication: type %d",
|
|
|
|
bombout(("Strange packet received during authentication: type %d",
|
|
|
|
ssh->pktin.type));
|
|
|
|
ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
s->gotit = FALSE;
|
|
|
|
s->gotit = FALSE;
|
|
|
@ -4933,7 +4934,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
connection_fatal(ssh->frontend,
|
|
|
|
connection_fatal(ssh->frontend,
|
|
|
|
"Unable to authenticate");
|
|
|
|
"Unable to authenticate");
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
int ret; /* need not be saved across crReturn */
|
|
|
|
int ret; /* need not be saved across crReturn */
|
|
|
@ -5122,7 +5123,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
ssh2_pkt_addstring(ssh, "en"); /* language tag */
|
|
|
|
ssh2_pkt_addstring(ssh, "en"); /* language tag */
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} while (!s->we_are_in);
|
|
|
|
} while (!s->we_are_in);
|
|
|
@ -5150,12 +5151,12 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
crWaitUntilV(ispkt);
|
|
|
|
crWaitUntilV(ispkt);
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_OPEN_CONFIRMATION) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_OPEN_CONFIRMATION) {
|
|
|
|
bombout(("Server refused to open a session"));
|
|
|
|
bombout(("Server refused to open a session"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
/* FIXME: error data comes back in FAILURE packet */
|
|
|
|
/* FIXME: error data comes back in FAILURE packet */
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (ssh2_pkt_getuint32(ssh) != ssh->mainchan->localid) {
|
|
|
|
if (ssh2_pkt_getuint32(ssh) != ssh->mainchan->localid) {
|
|
|
|
bombout(("Server's channel confirmation cited wrong channel"));
|
|
|
|
bombout(("Server's channel confirmation cited wrong channel"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ssh->mainchan->remoteid = ssh2_pkt_getuint32(ssh);
|
|
|
|
ssh->mainchan->remoteid = ssh2_pkt_getuint32(ssh);
|
|
|
|
ssh->mainchan->type = CHAN_MAINSESSION;
|
|
|
|
ssh->mainchan->type = CHAN_MAINSESSION;
|
|
|
@ -5201,7 +5202,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
bombout(("Unexpected response to X11 forwarding request:"
|
|
|
|
bombout(("Unexpected response to X11 forwarding request:"
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
logevent("X11 forwarding refused");
|
|
|
|
logevent("X11 forwarding refused");
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -5272,7 +5273,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
while (*ssh->portfwd_strptr) ssh->portfwd_strptr++;
|
|
|
|
while (*ssh->portfwd_strptr) ssh->portfwd_strptr++;
|
|
|
|
dport = -1;
|
|
|
|
dport = dserv = -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sport = atoi(sports);
|
|
|
|
sport = atoi(sports);
|
|
|
|
sserv = 0;
|
|
|
|
sserv = 0;
|
|
|
@ -5357,7 +5358,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
bombout(("Unexpected response to port "
|
|
|
|
bombout(("Unexpected response to port "
|
|
|
|
"forwarding request: packet type %d",
|
|
|
|
"forwarding request: packet type %d",
|
|
|
|
ssh->pktin.type));
|
|
|
|
ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
logevent("Server refused this port forwarding");
|
|
|
|
logevent("Server refused this port forwarding");
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -5396,7 +5397,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
bombout(("Unexpected response to agent forwarding request:"
|
|
|
|
bombout(("Unexpected response to agent forwarding request:"
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
logevent("Agent forwarding refused");
|
|
|
|
logevent("Agent forwarding refused");
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -5439,7 +5440,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
bombout(("Unexpected response to pty request:"
|
|
|
|
bombout(("Unexpected response to pty request:"
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
c_write_str(ssh, "Server refused to allocate pty\r\n");
|
|
|
|
c_write_str(ssh, "Server refused to allocate pty\r\n");
|
|
|
|
ssh->editing = ssh->echoing = 1;
|
|
|
|
ssh->editing = ssh->echoing = 1;
|
|
|
@ -5497,7 +5498,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
if (ssh->pktin.type != SSH2_MSG_CHANNEL_FAILURE) {
|
|
|
|
bombout(("Unexpected response to shell/command request:"
|
|
|
|
bombout(("Unexpected response to shell/command request:"
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
" packet type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* We failed to start the command. If this is the
|
|
|
|
* We failed to start the command. If this is the
|
|
|
@ -5511,7 +5512,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
bombout(("Server refused to start a shell/command"));
|
|
|
|
bombout(("Server refused to start a shell/command"));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
logevent("Started a shell/command");
|
|
|
|
logevent("Started a shell/command");
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -5548,7 +5549,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
continue; /* extended but not stderr */
|
|
|
|
continue; /* extended but not stderr */
|
|
|
|
ssh2_pkt_getstring(ssh, &data, &length);
|
|
|
|
ssh2_pkt_getstring(ssh, &data, &length);
|
|
|
|
if (data) {
|
|
|
|
if (data) {
|
|
|
|
int bufsize;
|
|
|
|
int bufsize = 0;
|
|
|
|
c->v.v2.locwindow -= length;
|
|
|
|
c->v.v2.locwindow -= length;
|
|
|
|
switch (c->type) {
|
|
|
|
switch (c->type) {
|
|
|
|
case CHAN_MAINSESSION:
|
|
|
|
case CHAN_MAINSESSION:
|
|
|
@ -5650,6 +5651,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
if (!c || ((int)c->remoteid) == -1) {
|
|
|
|
if (!c || ((int)c->remoteid) == -1) {
|
|
|
|
bombout(("Received CHANNEL_CLOSE for %s channel %d\n",
|
|
|
|
bombout(("Received CHANNEL_CLOSE for %s channel %d\n",
|
|
|
|
c ? "half-open" : "nonexistent", i));
|
|
|
|
c ? "half-open" : "nonexistent", i));
|
|
|
|
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/* Do pre-close processing on the channel. */
|
|
|
|
/* Do pre-close processing on the channel. */
|
|
|
|
switch (c->type) {
|
|
|
|
switch (c->type) {
|
|
|
@ -5702,7 +5704,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
#endif
|
|
|
|
#endif
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
continue; /* remote sends close; ignore (FIXME) */
|
|
|
|
continue; /* remote sends close; ignore (FIXME) */
|
|
|
|
} else if (ssh->pktin.type == SSH2_MSG_CHANNEL_WINDOW_ADJUST) {
|
|
|
|
} else if (ssh->pktin.type == SSH2_MSG_CHANNEL_WINDOW_ADJUST) {
|
|
|
@ -5780,7 +5782,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
ssh2_pkt_send(ssh);
|
|
|
|
connection_fatal(ssh->frontend, "%s", buf);
|
|
|
|
connection_fatal(ssh->frontend, "%s", buf);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
ssh_closing((Plug)ssh, NULL, 0, 0);
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
@ -5931,7 +5933,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
bombout(("Strange packet received: type %d", ssh->pktin.type));
|
|
|
|
bombout(("Strange packet received: type %d", ssh->pktin.type));
|
|
|
|
crReturnV;
|
|
|
|
crStopV;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|