/* * Program:	Macintosh TCP/IP routines * * Author:	Mark Crispin *		Networks and Distributed Computing *		Computing & Communications *		University of Washington *		Administration Building, AG-44 *		Seattle, WA  98195 *		Internet: MRC@CAC.Washington.EDU * * Date:	26 January 1992 * Last Edited:	24 October 2000 *  * The IMAP toolkit provided in this Distribution is * Copyright 2000 University of Washington. * The full text of our legal notices is contained in the file called * CPYRIGHT, included with this Distribution. *//*  This is a totally new operating-system dependent module for the Macintosh, * written using THINK C on my Mac PowerBook-100 in my free time. * Unlike earlier efforts, this version requires no external TCP library.  It * also takes advantage of the Map panel in System 7 for the timezone. */static tcptimeout_t tmoh = NIL;	/* TCP timeout handler routine */static long ttmo_open = 75;	/* TCP timeouts, in seconds */static long ttmo_read = 0;static long ttmo_write = 0;static long ttmo_close = 0;/* TCP/IP manipulate parameters * Accepts: function code *	    function-dependent value * Returns: function-dependent return value */void *tcp_parameters (long function,void *value){  void *ret = NIL;  switch ((int) function) {  case SET_TIMEOUT:    tmoh = (tcptimeout_t) value;  case GET_TIMEOUT:    ret = (void *) tmoh;    break;  case SET_OPENTIMEOUT:    ttmo_open = (long) value;  case GET_OPENTIMEOUT:    ret = (void *) ttmo_open;    break;  case SET_READTIMEOUT:    ttmo_read = (long) value;  case GET_READTIMEOUT:    ret = (void *) ttmo_read;    break;  case SET_WRITETIMEOUT:    ttmo_write = (long) value;  case GET_WRITETIMEOUT:    ret = (void *) ttmo_write;    break;  case SET_CLOSETIMEOUT:    ttmo_close = (long) value;  case GET_CLOSETIMEOUT:    ret = (void *) ttmo_close;    break;  }  return ret;}/* TCP/IP open * Accepts: host name *	    contact service name *	    contact port number * Returns: TCP stream if success else NIL */TCPSTREAM *tcp_open (char *host,char *service,unsigned long port){  TCPSTREAM *stream;  struct hostInfo hst;  struct TCPCreatePB *createpb;  struct TCPOpenPB *openpb;  char *s;  unsigned long i,j,k,l;  char tmp[MAILTMPLEN];  port &= 0xffff;		/* erase flags */				/* init MacTCP */  if (!TCPdriver && OpenDriver (TCPDRIVER,&TCPdriver)) {    mm_log ("Can't init MacTCP",ERROR);    return NIL;  }  if (!resolveropen && OpenResolver (NIL)) {    mm_log ("Can't init domain resolver",ERROR);    return NIL;  }  resolveropen = T;		/* note resolver open now */				/* domain literal? */  if (host[0] == '[' && host[strlen (host)-1] == ']') {    if (((i = strtoul (s = host+1,&s,10)) <= 255) && *s++ == '.' &&	((j = strtoul (s,&s,10)) <= 255) && *s++ == '.' &&	((k = strtoul (s,&s,10)) <= 255) && *s++ == '.' &&	((l = strtoul (s,&s,10)) <= 255) && *s++ == ']' && !*s) {      hst.addr[0] = (i << 24) + (j << 16) + (k << 8) + l;      hst.addr[1] = 0;		/* only one address to try! */      sprintf (hst.cname,"[%ld.%ld.%ld.%ld]",i,j,k,l);    }    else {      sprintf (tmp,"Bad format domain-literal: %.80s",host);      mm_log (tmp,ERROR);      return NIL;    }  }  else {			/* look up host name */    if (!tcp_dns_upp) tcp_dns_upp = NewResultProc (tcp_dns_result);    if (StrToAddr (host,&hst,tcp_dns_upp,NIL)) {      while (hst.rtnCode == cacheFault && wait ());				/* kludge around MacTCP bug */      if (hst.rtnCode == outOfMemory) {	mm_log ("Re-initializing domain resolver",WARN);	CloseResolver ();	/* bop it on the head and try again */	OpenResolver (NIL);	/* note this will leak 12K */	StrToAddr (host,&hst,tcp_dns_upp,NIL);	while (hst.rtnCode == cacheFault && wait ());      }      if (hst.rtnCode) {	/* still have error status? */	switch (hst.rtnCode) {	/* analyze return */	case nameSyntaxErr:	  s = "Syntax error in name";	  break;	case noResultProc:	  s = "No result procedure";	  break;	case noNameServer:	  s = "No name server found";	  break;	case authNameErr:	  s = "Host does not exist";	  break;	case noAnsErr:	  s = "No name servers responding";	  break;	case dnrErr:	  s = "Name server returned an error";	  break;	case outOfMemory:	  s = "Not enough memory to resolve name";	  break;	case notOpenErr:	  s = "Driver not open";	  break;	default:	  s = NIL;	  break;	}	if (s) sprintf (tmp,"%s: %.80s",s,host);	else sprintf (tmp,"Unknown resolver error (%ld): %.80s",		      hst.rtnCode,host);	mm_log (tmp,ERROR);	return NIL;      }    }  }				/* create local TCP/IP stream */  stream = (TCPSTREAM *) fs_get (sizeof (TCPSTREAM));  stream->ictr = 0;		/* initialize input */  stream->pb.ioCRefNum = TCPdriver;  createpb = &stream->pb.csParam.create;  openpb = &stream->pb.csParam.open;  stream->pb.csCode = TCPCreate;/* create a TCP stream */				/* set up buffer for TCP */  createpb->rcvBuffLen = 4*BUFLEN;  createpb->rcvBuff = fs_get (createpb->rcvBuffLen);  createpb->notifyProc = NIL;	/* no special notify procedure */  createpb->userDataPtr = NIL;  if (PBControlSync ((ParmBlkPtr) &stream->pb))    fatal ("Can't create TCP stream");  				/* open TCP connection */  stream->pb.csCode = TCPActiveOpen;  openpb->ulpTimeoutValue = (int) ttmo_open;  openpb->ulpTimeoutAction = T;  openpb->validityFlags = timeoutValue|timeoutAction;				/* remote host (should try all) */  openpb->remoteHost = hst.addr[0];  openpb->remotePort = port;	/* caller specified remote port */  openpb->localPort = 0;	/* generate a local port */  openpb->tosFlags = 0;		/* no special TOS */  openpb->precedence = 0;	/* no special precedence */  openpb->dontFrag = 0;		/* allow fragmentation */  openpb->timeToLive = 255;	/* standards say 60, UNIX uses 255 */  openpb->security = 0;		/* no special security */  openpb->optionCnt = 0;	/* no IP options */  openpb->options[0] = 0;  openpb->userDataPtr = NIL;	/* no special data pointer */  PBControlAsync ((ParmBlkPtr) &stream->pb);  while (stream->pb.ioResult == inProgress && wait ());  if (stream->pb.ioResult) {	/* got back error status? */    sprintf (tmp,"Can't connect to %.80s,%ld",hst.cname,port);    mm_log (tmp,ERROR);				/* nuke the buffer */    stream->pb.csCode = TCPRelease;    createpb->userDataPtr = NIL;    if (PBControlSync ((ParmBlkPtr) &stream->pb)) fatal ("TCPRelease lossage");				/* free its buffer */    fs_give ((void **) &createpb->rcvBuff);    fs_give ((void **) &stream);/* and the local stream */    return NIL;  }				/* copy host names for later use */  stream->host = cpystr (hst.cname);				/* tie off trailing dot */  stream->host[strlen (stream->host) - 1] = '\0';				/* the open gave us our address */  i = (openpb->localHost >> 24) & 0xff;  j = (openpb->localHost >> 16) & 0xff;  k = (openpb->localHost >> 8) & 0xff;  l = openpb->localHost & 0xff;  sprintf (tmp,"[%ld.%ld.%ld.%ld]",i,j,k,l);  stream->localhost = cpystr (tmp);  if (!myLocalHost) myLocalHost = cpystr (tmp);  stream->port = port;		/* copy port number */  return stream;}/* Called when have return from DNS * Accepts: host info pointer *	    user data pointer */ResultUPP tcp_dns_upp = NIL;pascal void tcp_dns_result (struct hostInfo *hostInfoPtr,char *userDataPtr){  /* dummy routine */}/* TCP/IP authenticated open * Accepts: NETMBX specifier *	    service name *	    returned user name buffer * Returns: TCP/IP stream if success else NIL */TCPSTREAM *tcp_aopen (NETMBX *mb,char *service,char *usrbuf){  return NIL;			/* no authenticated opens on Mac */}/* TCP/IP receive line * Accepts: TCP/IP stream * Returns: text line string or NIL if failure */char *tcp_getline (TCPSTREAM *stream){  int n,m;