lib-src/tcp.c

   1 /*
   2  * TCP/IP stream emulation for GNU Emacs.
   3  * Copyright (C) 1988, 1989, 1992, 1993 Free Software Foundation, Inc.
   4
   5  * Author: Masanobu Umeda
   6  * Maintainer: umerin@mse.kyutech.ac.jp
   7
   8 This file is part of GNU Emacs.
   9
  10 GNU Emacs is free software; you can redistribute it and/or modify
  11 it under the terms of the GNU General Public License as published by
  12 the Free Software Foundation; either version 2, or (at your option)
  13 any later version.
  14
  15 GNU Emacs is distributed in the hope that it will be useful,
  16 but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 GNU General Public License for more details.
  19
  20 You should have received a copy of the GNU General Public License
  21 along with GNU Emacs; see the file COPYING.  If not, write to
  22 the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
  23
  24  *
  25  * Yasunari, Itoh at PFU limited contributed for Fujitsu UTS and SX/A.
  26  *
  27  * Thu Apr  6 13:47:37 JST 1989
  28  * USG fixes by Sakaeda <saka@mickey.trad.pf.fujitsu.junet>
  29  *
  30  * For Fujitsu UTS compile with:
  31  *      cc -O -o tcp tcp.c -DFUJITSU_UTS -lu -lsocket
  32  */
  33
  34 #include <stdio.h>
  35 #include <fcntl.h>
  36 #include <ctype.h>
  37 #include <sys/types.h>
  38
  39 #ifdef FUJITSU_UTS
  40 #define USG
  41 #include <sys/ucbtypes.h>
  42 #include <sys/tisp/socket.h>
  43 #include <netdb.h>
  44 #include <sys/tisp/in.h>
  45 #else
  46 #include <sys/socket.h>
  47 #include <netdb.h>
  48 #include <netinet/in.h>
  49 #endif
  50
  51 #ifdef USG
  52 #include <sys/stat.h>
  53 #include <signal.h>
  54 #endif
  55
  56 #ifdef FUJITSU_UTS
  57 #define bcopy(f, t, n)    memcpy (t, f, n)
  58 #define bcmp(b1, b2, n)   (memcmp (b1, b2, n)!=0)
  59 #define bzero(b, n)      memset (b, 0, n)
  60 #endif
  61
  62 #ifdef USG
  63 int selectable = 1;
  64
  65 sigout ()
  66 {
  67   fcntl (fileno (stdin), F_SETFL, 0);
  68   exit (-1);
  69 }
  70 #endif
  71
  72 main (argc, argv)
  73      int argc;
  74      char *argv[];
  75 {
  76   struct hostent        *host;
  77   struct sockaddr_in    sockin, sockme;
  78   struct servent        *serv;
  79   char  *hostname = NULL;
  80   char  *service = "nntp";
  81   int   port;
  82   int   readfds;
  83   int   writefds;
  84   int   server;                 /* NNTP Server */
  85   int   emacsIn = fileno (stdin); /* Emacs intput */
  86   int   emacsOut = fileno (stdout); /* Emacs output */
  87   char  buffer[1024];
  88   int   nbuffer;                /* Number of bytes in buffer */
  89   int   wret;
  90   char  *retry;                 /* retry bufferp */
  91   int   false = 0;              /* FALSE flag for setsockopt () */
  92
  93   if (argc < 2)
  94     {
  95       fprintf (stderr, "Usage: %s HOST [SERVICE]\n", argv[0]);
  96       exit (1);
  97     }
  98   if (argc >= 2)
  99     hostname = argv[1];
 100   if (argc >= 3)
 101     service = argv[2];
 102
 103   if ((host = gethostbyname (hostname)) == NULL)
 104     {
 105       perror ("gethostbyname");
 106       exit (1);
 107     }
 108   if (isdigit (service[0]))
 109     port = atoi (service);
 110   else
 111     {
 112       serv = getservbyname (service, "tcp");
 113       if (serv == NULL)
 114         {
 115           perror ("getservbyname");
 116           exit (1);
 117         }
 118       port = serv->s_port;
 119     }
 120
 121   bzero (&sockin, sizeof (sockin));
 122   sockin.sin_family = host->h_addrtype;
 123   bcopy (host->h_addr, &sockin.sin_addr, host->h_length);
 124   sockin.sin_port = port;
 125   if ((server = socket (AF_INET, SOCK_STREAM, 0)) < 0)
 126     {
 127       perror ("socket");
 128       exit (1);
 129     }
 130   if (setsockopt (server, SOL_SOCKET, SO_REUSEADDR, &false, sizeof (false)))
 131     {
 132       perror ("setsockopt");
 133       exit (1);
 134     }
 135   bzero (&sockme, sizeof (sockme));
 136   sockme.sin_family = sockin.sin_family;
 137   sockme.sin_addr.s_addr = INADDR_ANY;
 138   if (bind (server, &sockme, sizeof (sockme)) < 0)
 139     {
 140       perror ("bind");
 141       exit (1);
 142     }
 143   if (connect (server, &sockin, sizeof (sockin)) < 0)
 144     {
 145       perror ("connect");
 146       close (server);
 147       exit (1);
 148     }
 149
 150 #ifdef O_NDELAY
 151   fcntl (server, F_SETFL, O_NDELAY);
 152
 153 #ifdef USG
 154   /* USG pipe cannot not select emacsIn */
 155   {
 156     struct stat statbuf;
 157     fstat (emacsIn, &statbuf);
 158     if (statbuf.st_mode & 010000)
 159       selectable = 0;
 160     if (!selectable)
 161       {
 162         signal (SIGINT, sigout);
 163         fcntl (emacsIn, F_SETFL, O_NDELAY);
 164       }
 165   }
 166 #endif
 167 #endif
 168
 169   /* Connection established. */
 170   while (1)
 171     {
 172       readfds = (1 << server) | (1 << emacsIn);
 173       if (select (32, &readfds, NULL, NULL, (struct timeval *)NULL) == -1)
 174         {
 175           perror ("select");
 176           exit (1);
 177         }
 178       if (readfds & (1 << emacsIn))
 179         {
 180           /* From Emacs */
 181           nbuffer = read (emacsIn, buffer, sizeof buffer -1);
 182
 183 #ifdef USG
 184           if (selectable && nbuffer == 0)
 185             {
 186               goto finish;
 187             }
 188           else if (!(readfds & (1 << server)) && nbuffer == 0)
 189             {
 190               sleep (1);
 191             }
 192           else
 193 #else
 194             if (nbuffer == 0)
 195               goto finish;
 196 #endif
 197           for (retry = buffer; nbuffer > 0; nbuffer -= wret, retry += wret)
 198             {
 199               writefds = 1 << server;
 200               if (select (server+1, NULL, &writefds, NULL, (struct timeval*)NULL) == -1)
 201                 {
 202                   perror ("select");
 203                   exit (1);
 204                 }
 205               wret = write (server, retry, nbuffer);
 206               if (wret < 0) goto finish;
 207             }
 208         }
 209       if (readfds & (1 << server))
 210         {
 211           /* From NNTP server */
 212           nbuffer = read (server, buffer, sizeof buffer -1);
 213           if (nbuffer == 0)
 214             goto finish;
 215           for (retry = buffer; nbuffer > 0; nbuffer -= wret, retry += wret)
 216             {
 217               writefds = 1 << emacsOut;
 218 #ifdef USG
 219               if (selectable)
 220 #endif
 221                 if (select (emacsOut+1, NULL, &writefds, NULL, (struct timeval*)NULL) == -1)
 222                   {
 223                     perror ("select");
 224                     exit (1);
 225                   }
 226               wret = write (emacsOut, retry, nbuffer);
 227               if (wret < 0) goto finish;
 228             }
 229         }
 230     }
 231
 232   /* End of communication. */
 233  finish:
 234   close (server);
 235 #ifdef USG
 236   if (!selectable) fcntl (emacsIn, F_SETFL, 0);
 237 #endif
 238   close (emacsIn);
 239   close (emacsOut);
 240   exit (0);
 241 }