diff options
Diffstat (limited to 'imap/src/osdep/tops-20/tcp_t20.c')
| -rw-r--r-- | imap/src/osdep/tops-20/tcp_t20.c | 365 |
1 files changed, 365 insertions, 0 deletions
diff --git a/imap/src/osdep/tops-20/tcp_t20.c b/imap/src/osdep/tops-20/tcp_t20.c new file mode 100644 index 00000000..7b2a2580 --- /dev/null +++ b/imap/src/osdep/tops-20/tcp_t20.c @@ -0,0 +1,365 @@ +/* ======================================================================== + * Copyright 1988-2008 University of Washington + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * + * ======================================================================== + */ + +/* + * Program: TOPS-20 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: 1 August 1988 + * Last Edited: 13 January 2008 + */ + + +/* Dedication: + * This file is dedicated with affection to the TOPS-20 operating system, which + * set standards for user and programmer friendliness that have still not been + * equaled by more `modern' operating systems. + * Wasureru mon ka!!!! + */ + +static char *tcp_getline_work (TCPSTREAM *stream,unsigned long *size, + long *contd); + +/* TCP/IP manipulate parameters + * Accepts: function code + * function-dependent value + * Returns: function-dependent return value + */ + +void *tcp_parameters (long function,void *value) +{ + return NIL; +} + +/* 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) +{ + char *s,tmp[MAILTMPLEN]; + TCPSTREAM *stream = NIL; + int argblk[5],jfn; + unsigned long i,j,k,l; + char file[MAILTMPLEN]; + port &= 0xffff; /* erase flags */ + /* 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) { + argblk[3] = (i << 24) + (j << 16) + (k << 8) + l; + sprintf (tmp,"[%lu.%lu.%lu.%lu]",i,j,k,l); + } + else { + sprintf (tmp,"Bad format domain-literal: %.80s",host); + mm_log (tmp,ERROR); + return NIL; + } + } + else { /* host name */ + argblk[1] = _GTHPN; /* get IP address and primary name */ + argblk[2] = (int) (host-1); /* pointer to host */ + argblk[4] = (int) (tmp-1); + if (!jsys (GTHST,argblk)) { /* first try DEC's domain way */ + argblk[1] = _GTHPN; /* get IP address and primary name */ + argblk[2] = (int) (host-1); + argblk[4] = (int) (tmp-1); + if (!jsys (GTDOM,argblk)){/* try the CHIVES domain way */ + argblk[1] = _GTHSN; /* failed, do the host table then */ + if (!jsys (GTHST,argblk)) { + sprintf (tmp,"No such host as %s",host); + mm_log (tmp,ERROR); + return NIL; + } + argblk[1] = _GTHNS; /* convert number to string */ + argblk[2] = (int) (tmp-1); + /* get the official name */ + if (!jsys (GTHST,argblk)) strcpy (tmp,host); + } + } + } + + sprintf (file,"TCP:.%o-%d;PERSIST:30;CONNECTION:ACTIVE",argblk[3],port); + argblk[1] = GJ_SHT; /* short form GTJFN% */ + argblk[2] = (int) (file-1); /* pointer to file name */ + /* get JFN for TCP: file */ + if (!jsys (GTJFN,argblk)) fatal ("Unable to create TCP JFN"); + jfn = argblk[1]; /* note JFN for later */ + /* want 8-bit bidirectional I/O */ + argblk[2] = OF_RD|OF_WR|(FLD (8,monsym("OF%BSZ"))); + if (!jsys (OPENF,argblk)) { + sprintf (file,"Can't connect to %s,%d server",tmp,port); + mm_log (file,ERROR); + return NIL; + } + /* create TCP/IP stream */ + stream = (TCPSTREAM *) fs_get (sizeof (TCPSTREAM)); + stream->host = cpystr (tmp); /* copy official host name */ + argblk[1] = _GTHNS; /* convert number to string */ + argblk[2] = (int) (tmp-1); + argblk[3] = -1; /* want local host */ + if (!jsys (GTHST,argblk)) strcpy (tmp,"LOCAL"); + stream->localhost = cpystr (tmp); + stream->port = port; /* save port number */ + stream->jfn = jfn; /* init JFN */ + return stream; +} + +/* 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; +} + +/* TCP receive line + * Accepts: TCP stream + * Returns: text line string or NIL if failure + */ + +char *tcp_getline (TCPSTREAM *stream) +{ + unsigned long n,contd; + char *ret = tcp_getline_work (stream,&n,&contd); + if (ret && contd) { /* got a line needing continuation? */ + STRINGLIST *stl = mail_newstringlist (); + STRINGLIST *stc = stl; + do { /* collect additional lines */ + stc->text.data = (unsigned char *) ret; + stc->text.size = n; + stc = stc->next = mail_newstringlist (); + ret = tcp_getline_work (stream,&n,&contd); + } while (ret && contd); + if (ret) { /* stash final part of line on list */ + stc->text.data = (unsigned char *) ret; + stc->text.size = n; + /* determine how large a buffer we need */ + for (n = 0, stc = stl; stc; stc = stc->next) n += stc->text.size; + ret = fs_get (n + 1); /* copy parts into buffer */ + for (n = 0, stc = stl; stc; n += stc->text.size, stc = stc->next) + memcpy (ret + n,stc->text.data,stc->text.size); + ret[n] = '\0'; + } + mail_free_stringlist (&stl);/* either way, done with list */ + } + return ret; +} + +/* TCP receive line or partial line + * Accepts: TCP stream + * pointer to return size + * pointer to return continuation flag + * Returns: text line string, size and continuation flag, or NIL if failure + */ + +static char *tcp_getline_work (TCPSTREAM *stream,unsigned long *size, + long *contd) +{ + int argblk[5]; + unsigned long n,m; + char *ret,*stp,*st; + *contd = NIL; /* assume no continuation */ + argblk[1] = stream->jfn; /* read from TCP */ + /* pointer to buffer */ + argblk[2] = (int) (stream->ibuf - 1); + argblk[3] = BUFLEN; /* max number of bytes to read */ + argblk[4] = '\012'; /* terminate on LF */ + if (!jsys (SIN,argblk)) return NIL; + n = BUFLEN - argblk[3]; /* number of bytes read */ + /* got a complete line? */ + if ((stream->ibuf[n - 2] == '\015') && (stream->ibuf[n - 1] == '\012')) { + memcpy ((ret = (char *) fs_get (n)),stream->ibuf,*size = n - 2); + ret[n - 2] = '\0'; /* tie off string with null */ + return ret; + } + /* copy partial string */ + memcpy ((ret = (char *) fs_get (n)),stream->ibuf,*size = n); + /* special case of newline broken by buffer */ + if ((stream->ibuf[n - 1] == '\015') && jsys (BIN,argblk) && + (argblk[2] == '\012')) { /* was it? */ + ret[n - 1] = '\0'; /* tie off string with null */ + } + /* otherwise back up */ + else if (!jsys (BKJFN,argblk)) fs_give ((void **) &ret); + else *contd = LONGT; /* continuation needed */ + return ret; +} + +/* TCP/IP receive buffer + * Accepts: TCP/IP stream + * size in bytes + * buffer to read into + * Returns: T if success, NIL otherwise + */ + +long tcp_getbuffer (TCPSTREAM *stream,unsigned long size,char *buffer) +{ + int argblk[5]; + argblk[1] = stream->jfn; /* read from TCP */ + argblk[2] = (int) (buffer-1); /* pointer to buffer */ + argblk[3] = -size; /* number of bytes to read */ + if (!jsys (SIN,argblk)) return NIL; + buffer[size] = '\0'; /* tie off text */ + return T; +} + + +/* TCP/IP send string as record + * Accepts: TCP/IP stream + * string pointer + * Returns: T if success else NIL + */ + +long tcp_soutr (TCPSTREAM *stream,char *string) +{ + int argblk[5]; + argblk[1] = stream->jfn; /* write to TCP */ + argblk[2] = (int) (string-1); /* pointer to buffer */ + argblk[3] = 0; /* write until NUL */ + if (!jsys (SOUTR,argblk)) return NIL; + return T; +} + + +/* TCP/IP send string + * Accepts: TCP/IP stream + * string pointer + * byte count + * Returns: T if success else NIL + */ + +long tcp_sout (TCPSTREAM *stream,char *string,unsigned long size) +{ + int argblk[5]; + argblk[1] = stream->jfn; /* write to TCP */ + argblk[2] = (int) (string-1); /* pointer to buffer */ + argblk[3] = -size; /* write this many bytes */ + if (!jsys (SOUTR,argblk)) return NIL; + return T; +} + +/* TCP/IP close + * Accepts: TCP/IP stream + */ + +void tcp_close (TCPSTREAM *stream) +{ + int argblk[5]; + argblk[1] = stream->jfn; /* close TCP */ + jsys (CLOSF,argblk); + /* flush host names */ + fs_give ((void **) &stream->host); + fs_give ((void **) &stream->localhost); + fs_give ((void **) &stream); /* flush the stream */ +} + + +/* TCP/IP return host for this stream + * Accepts: TCP/IP stream + * Returns: host name for this stream + */ + +char *tcp_host (TCPSTREAM *stream) +{ + return stream->host; /* return host name */ +} + + +/* TCP/IP return remote host for this stream + * Accepts: TCP/IP stream + * Returns: host name for this stream + */ + +char *tcp_remotehost (TCPSTREAM *stream) +{ + return stream->host; /* return host name */ +} + + +/* TCP/IP return port for this stream + * Accepts: TCP/IP stream + * Returns: port number for this stream + */ + +unsigned long tcp_port (TCPSTREAM *stream) +{ + return stream->port; /* return port number */ +} + + +/* TCP/IP return local host for this stream + * Accepts: TCP/IP stream + * Returns: local host name for this stream + */ + +char *tcp_localhost (TCPSTREAM *stream) +{ + return stream->localhost; /* return local host name */ +} + +/* TCP/IP return canonical form of host name + * Accepts: host name + * Returns: canonical form of host name + */ + +char *tcp_canonical (char *name) +{ + int argblk[5]; + static char tmp[MAILTMPLEN]; + /* look like domain literal? */ + if (name[0] == '[' && name[strlen (name) - 1] == ']') return name; + argblk[1] = _GTHPN; /* get IP address and primary name */ + argblk[2] = (int) (name-1); /* pointer to host */ + argblk[4] = (int) (tmp-1); /* pointer to return destination */ + if (!jsys (GTHST,argblk)) { /* first try DEC's domain way */ + argblk[1] = _GTHPN; /* get IP address and primary name */ + argblk[2] = (int) (name-1); + argblk[4] = (int) (tmp-1); + if (!jsys (GTDOM,argblk)) { /* try the CHIVES domain way */ + argblk[1] = _GTHSN; /* failed, do the host table then */ + if (!jsys (GTHST,argblk)) return name; + argblk[1] = _GTHNS; /* convert number to string */ + argblk[2] = (int) (tmp-1); + /* get the official name */ + if (!jsys (GTHST,argblk)) return name; + } + } + return tmp; +} + + +/* TCP/IP get client host name (server calls only) + * Returns: client host name + */ + +char *tcp_clienthost () +{ + return "UNKNOWN"; +} |