Archipelago » qemu

		 * the mbuf point to ti

		 */

		m->m_data = (caddr_t)ti;

		m->m_len = sizeof (struct tcpiphdr);

		tlen = 0;

#define xchg(a,b,type) { type t; t=a; a=b; b=t; }

     struct socket *so;

{

  int ret=0;

  DEBUG_CALL("tcp_fconnect");

  DEBUG_ARG("so = %lx", (long )so);

    setsockopt(s,SOL_SOCKET,SO_REUSEADDR,(char *)&opt,sizeof(opt ));

    opt = 1;

    setsockopt(s,SOL_SOCKET,SO_OOBINLINE,(char *)&opt,sizeof(opt ));

    addr.sin_family = AF_INET;

    if ((so->so_faddr.s_addr & htonl(0xffffff00)) == special_addr.s_addr) {

      /* It's an alias */

    } else

      addr.sin_addr = so->so_faddr;

    addr.sin_port = so->so_fport;

    DEBUG_MISC((dfd, " connect()ing, addr.sin_port=%d, "

		"addr.sin_addr.s_addr=%.16s\n",

		ntohs(addr.sin_port), inet_ntoa(addr.sin_addr)));

    /* We don't care what port we get */

    ret = connect(s,(struct sockaddr *)&addr,sizeof (addr));

    /*

     * If it's not in progress, it failed, so we just return 0,

     * without clearing SS_NOFDREF

};

struct emu_t *tcpemu = 0;

/*

 * Return TOS according to the above table

 */

 * more checks are needed here

 *

 * XXX Assumes the whole command came in one packet

 * XXX Some ftp clients will have their TOS set to

 * LOWDELAY and so Nagel will kick in.  Because of this,

 * we'll get the first letter, followed by the rest, so

	switch(so->so_emu) {

		int x, i;

	 case EMU_IDENT:

		/*

		 * Identification protocol as per rfc-1413

		 */

		{

			struct socket *tmpso;

			struct sockaddr_in addr;

			int addrlen = sizeof(struct sockaddr_in);

			struct sbuf *so_rcv = &so->so_rcv;

			memcpy(so_rcv->sb_wptr, m->m_data, m->m_len);

			so_rcv->sb_wptr += m->m_len;

			so_rcv->sb_rptr += m->m_len;

			m_free(m);

			return 0;

		}

#if 0

	 case EMU_RLOGIN:

		/*

			char term[100];

			struct sbuf *so_snd = &so->so_snd;

			struct sbuf *so_rcv = &so->so_rcv;

			/* First check if they have a priveladged port, or too much data has arrived */

			if (ntohs(so->so_lport) > 1023 || ntohs(so->so_lport) < 512 ||

			    (m->m_len + so_rcv->sb_wptr) > (so_rcv->sb_data + so_rcv->sb_datalen)) {

				m_free(m);

				return 0;

			}

			/* Append the current data */

			memcpy(so_rcv->sb_wptr, m->m_data, m->m_len);

			so_rcv->sb_wptr += m->m_len;

			so_rcv->sb_rptr += m->m_len;

			m_free(m);

			/*

			 * Check if we have all the initial options,

			 * and build argument list to rlogin while we're here

					}

				}

			}

			if (n != 4)

			   return 0;

			/* We have it, set our term variable and fork_exec() */

#ifdef HAVE_SETENV

			setenv("TERM", term, 1);

			fork_exec(so, args, 2);

			term[0] = 0;

			so->so_emu = 0;

			/* And finally, send the client a 0 character */

			so_snd->sb_wptr[0] = 0;

			so_snd->sb_wptr++;

			so_snd->sb_cc++;

			return 0;

		}

	 case EMU_RSH:

		/*

		 * rsh emulation

			char *args;

			struct sbuf *so_snd = &so->so_snd;

			struct sbuf *so_rcv = &so->so_rcv;

			/* First check if they have a priveladged port, or too much data has arrived */

			if (ntohs(so->so_lport) > 1023 || ntohs(so->so_lport) < 512 ||

			    (m->m_len + so_rcv->sb_wptr) > (so_rcv->sb_data + so_rcv->sb_datalen)) {

				m_free(m);

				return 0;

			}

			/* Append the current data */

			memcpy(so_rcv->sb_wptr, m->m_data, m->m_len);

			so_rcv->sb_wptr += m->m_len;

			so_rcv->sb_rptr += m->m_len;

			m_free(m);

			/*

			 * Check if we have all the initial options,

			 * and build argument list to rlogin while we're here

				ns->so_iptos = tcp_tos(ns);

				tp = sototcpcb(ns);

				tcp_template(tp);

				/* Compute window scaling to request.  */

				/*	while (tp->request_r_scale < TCP_MAX_WINSHIFT &&

				 *		(TCP_MAXWIN << tp->request_r_scale) < so->so_rcv.sb_hiwat)

                /*soisfconnecting(ns);*/

				tcpstat.tcps_connattempt++;

				tp->t_state = TCPS_SYN_SENT;

				tp->t_timer[TCPT_KEEP] = TCPTV_KEEP_INIT;

				tp->iss = tcp_iss;

                }

              }

			}

			if (n != 4)

              return 0;

			rsh_exec(so,so->extra, user, inet_ntoa(so->so_faddr), args);

			so->so_emu = 0;

			so->extra=NULL;

			/* And finally, send the client a 0 character */

			so_snd->sb_wptr[0] = 0;

			so_snd->sb_wptr++;

			so_snd->sb_cc++;

			return 0;

		}

			int num;

			struct sbuf *so_snd = &so->so_snd;

			struct sbuf *so_rcv = &so->so_rcv;

			/*

			 * If there is binary data here, we save it in so->so_m

			 */

			    }

			  }

			} /* if(so->so_m==NULL) */

			/*

			 * Append the line

			 */

			sbappendsb(so_rcv, m);

			/* To avoid going over the edge of the buffer, we reset it */

			if (so_snd->sb_cc == 0)

			   so_snd->sb_wptr = so_snd->sb_rptr = so_snd->sb_data;

			/*

			 * A bit of a hack:

			 * If the first packet we get here is 1 byte long, then it

			  tcp_output(sototcpcb(so)); /* XXX */

			} else

			  m_free(m);

			num = 0;

			while (num < so->so_rcv.sb_cc) {

				if (*(so->so_rcv.sb_rptr + num) == '\n' ||

				    *(so->so_rcv.sb_rptr + num) == '\r') {

					int n;

					*(so_rcv->sb_rptr + num) = 0;

					if (ctl_password && !ctl_password_ok) {

						/* Need a password */

			}

			return 0;

		}

        case EMU_FTP: /* ftp */

		*(m->m_data+m->m_len) = 0; /* NULL terminate for strstr */

		if ((bptr = (char *)strstr(m->m_data, "ORT")) != NULL) {

			/*

			 * Need to emulate the PORT command

			x = sscanf(bptr, "ORT %d,%d,%d,%d,%d,%d\r\n%256[^\177]",

				   &n1, &n2, &n3, &n4, &n5, &n6, buff);

			if (x < 6)

			   return 1;

			laddr = htonl((n1 << 24) | (n2 << 16) | (n3 << 8) | (n4));

			lport = htons((n5 << 8) | (n6));

			if ((so = solisten(0, laddr, lport, SS_FACCEPTONCE)) == NULL)

			   return 1;

			n6 = ntohs(so->so_fport);

			n5 = (n6 >> 8) & 0xff;

			n6 &= 0xff;

			laddr = ntohl(so->so_faddr.s_addr);

			n1 = ((laddr >> 24) & 0xff);

			n2 = ((laddr >> 16) & 0xff);

			n3 = ((laddr >> 8)  & 0xff);

			n4 =  (laddr & 0xff);

			m->m_len = bptr - m->m_data; /* Adjust length */

			m->m_len += sprintf(bptr,"ORT %d,%d,%d,%d,%d,%d\r\n%s",

					    n1, n2, n3, n4, n5, n6, x==7?buff:"");

				   &n1, &n2, &n3, &n4, &n5, &n6, buff);

			if (x < 6)

			   return 1;

			laddr = htonl((n1 << 24) | (n2 << 16) | (n3 << 8) | (n4));

			lport = htons((n5 << 8) | (n6));

			if ((so = solisten(0, laddr, lport, SS_FACCEPTONCE)) == NULL)

			   return 1;

			n6 = ntohs(so->so_fport);

			n5 = (n6 >> 8) & 0xff;

			n6 &= 0xff;

			laddr = ntohl(so->so_faddr.s_addr);

			n1 = ((laddr >> 24) & 0xff);

			n2 = ((laddr >> 16) & 0xff);

			n3 = ((laddr >> 8)  & 0xff);

			n4 =  (laddr & 0xff);

			m->m_len = bptr - m->m_data; /* Adjust length */

			m->m_len += sprintf(bptr,"27 Entering Passive Mode (%d,%d,%d,%d,%d,%d)\r\n%s",

					    n1, n2, n3, n4, n5, n6, x==7?buff:"");

			return 1;

		}

		return 1;

	 case EMU_KSH:

		/*

		 * The kshell (Kerberos rsh) and shell services both pass

		    (so = solisten(0, so->so_laddr.s_addr, htons(lport), SS_FACCEPTONCE)) != NULL)

			m->m_len = sprintf(m->m_data, "%d", ntohs(so->so_fport))+1;

		return 1;

	 case EMU_IRC:

		/*

		 * Need to emulate DCC CHAT, DCC SEND and DCC MOVE

		*(m->m_data+m->m_len) = 0; /* NULL terminate the string for strstr */

		if ((bptr = (char *)strstr(m->m_data, "DCC")) == NULL)

			 return 1;

		/* The %256s is for the broken mIRC */

		if (sscanf(bptr, "DCC CHAT %256s %u %u", buff, &laddr, &lport) == 3) {

			if ((so = solisten(0, htonl(laddr), htons(lport), SS_FACCEPTONCE)) == NULL)

				return 1;

			m->m_len = bptr - m->m_data; /* Adjust length */

			m->m_len += sprintf(bptr, "DCC CHAT chat %lu %u%c\n",

			     (unsigned long)ntohl(so->so_faddr.s_addr),

		} else if (sscanf(bptr, "DCC SEND %256s %u %u %u", buff, &laddr, &lport, &n1) == 4) {

			if ((so = solisten(0, htonl(laddr), htons(lport), SS_FACCEPTONCE)) == NULL)

				return 1;

			m->m_len = bptr - m->m_data; /* Adjust length */

			m->m_len += sprintf(bptr, "DCC SEND %s %lu %u %u%c\n",

			      buff, (unsigned long)ntohl(so->so_faddr.s_addr),

		} else if (sscanf(bptr, "DCC MOVE %256s %u %u %u", buff, &laddr, &lport, &n1) == 4) {

			if ((so = solisten(0, htonl(laddr), htons(lport), SS_FACCEPTONCE)) == NULL)

				return 1;

			m->m_len = bptr - m->m_data; /* Adjust length */

			m->m_len += sprintf(bptr, "DCC MOVE %s %lu %u %u%c\n",

			      buff, (unsigned long)ntohl(so->so_faddr.s_addr),

		 * any more.

		 *

		 * A typical packet for player version 1.0 (release version):

		 * 0000:50 4E 41 00 05

		 * 0000:00 01 00 02 1B D7 00 00 67 E6 6C DC 63 00 12 50 .....?..g?l?c..P

		 * 0010:4E 43 4C 49 45 4E 54 20 31 30 31 20 41 4C 50 48 NCLIENT 101 ALPH

		 * 0020:41 6C 00 00 52 00 17 72 61 66 69 6C 65 73 2F 76 Al..R..rafiles/v

		 * 0030:6F 61 2F 65 6E 67 6C 69 73 68 5F 2E 72 61 79 42 oa/english_.rayB

		 * Now the port number 0x1BD7 is found at offset 0x04 of the

		 * Now the port number 0x1BD7 is found at offset 0x04 of the

		 * second packet. This time we received five bytes first and

		 * then the rest. You never know how many bytes you get.

		 *

		 * A typical packet for player version 2.0 (beta):

		 * 0000:50 4E 41 00 06 00 02 00 00 00 01 00 02 1B C1 00 PNA...........?.

		 * 0010:00 67 75 78 F5 63 00 0A 57 69 6E 32 2E 30 2E 30 .gux?c..Win2.0.0

		 * 0020:2E 35 6C 00 00 52 00 1C 72 61 66 69 6C 65 73 2F .5l..R..rafiles/

		 * 0030:77 65 62 73 69 74 65 2F 32 30 72 65 6C 65 61 73 website/20releas

		 * 0040:65 2E 72 61 79 53 00 00 06 36 42                e.rayS...6B

		 * Port number 0x1BC1 is found at offset 0x0d.

		 * This is just a horrible switch statement. Variable ra tells

		 * us where we're going.

		 */

		bptr = m->m_data;

		while (bptr < m->m_data + m->m_len) {

			u_short p;

			static int ra = 0;

			char ra_tbl[4];

			ra_tbl[0] = 0x50;

			ra_tbl[1] = 0x4e;

			ra_tbl[2] = 0x41;

			ra_tbl[3] = 0;

			switch (ra) {

			 case 0:

			 case 2:

					continue;

				}

				break;

			 case 1:

				/*

				 * We may get 0x50 several times, ignore them

					continue;

				}

				break;

			 case 4:

				/*

				 * skip version number

				 */

				bptr++;

				break;

			 case 5:

				/*

				 * The difference between versions 1.0 and

				   bptr += 8;

				else

				   bptr += 4;

			 case 6:

				/* This is the field containing the port

				 * number that RA-player is listening to.

				 */

				lport = (((u_char*)bptr)[0] << 8)

				+ ((u_char *)bptr)[1];

				   lport += 256;   /* don't know why */

				if (lport < 6970 || lport > 7170)

				   return 1;       /* failed */

				/* try to get udp port between 6970 - 7170 */

				for (p = 6970; p < 7071; p++) {

					if (udp_listen( htons(p),

				*(u_char *)bptr++ = p & 0xff;

				ra = 0;

				return 1;   /* port redirected, we're done */

			 default:

			}

			ra++;

		}

	 default:

		/* Ooops, not emulated, won't call tcp_emu again */

		so->so_emu = 0;

	switch(command) {

	default: /* Check for exec's */

		/*

		 * Check if it's pty_exec

		 */

				goto do_exec;

			}

		}

		/*

		 * Nothing bound..

		 */

		/* tcp_fconnect(so); */

		/* FALLTHROUGH */

	case CTL_ALIAS:

	  sb->sb_cc = sprintf(sb->sb_wptr,

	do_exec:

		DEBUG_MISC((dfd, " executing %s \n",ex_ptr->ex_exec));

		return(fork_exec(so, ex_ptr->ex_exec, do_pty));

#if 0

	case CTL_CMD:

	   for (tmpso = tcb.so_next; tmpso != &tcb; tmpso = tmpso->so_next) {