| 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, Inc., 59 Temple Place - Suite 330, |
| 23 | Boston, MA 02111-1307, USA. |
| 24 | |
| 25 | * |
| 26 | * Yasunari, Itoh at PFU limited contributed for Fujitsu UTS and SX/A. |
| 27 | * |
| 28 | * Thu Apr 6 13:47:37 JST 1989 |
| 29 | * USG fixes by Sakaeda <saka@mickey.trad.pf.fujitsu.junet> |
| 30 | * |
| 31 | * For Fujitsu UTS compile with: |
| 32 | * cc -O -o tcp tcp.c -DFUJITSU_UTS -lu -lsocket |
| 33 | */ |
| 34 | |
| 35 | #include <stdio.h> |
| 36 | #include <fcntl.h> |
| 37 | #include <ctype.h> |
| 38 | #include <sys/types.h> |
| 39 | |
| 40 | #ifdef FUJITSU_UTS |
| 41 | #define USG |
| 42 | #include <sys/ucbtypes.h> |
| 43 | #include <sys/tisp/socket.h> |
| 44 | #include <netdb.h> |
| 45 | #include <sys/tisp/in.h> |
| 46 | #else |
| 47 | #include <sys/socket.h> |
| 48 | #include <netdb.h> |
| 49 | #include <netinet/in.h> |
| 50 | #endif |
| 51 | |
| 52 | #ifdef USG |
| 53 | #include <sys/stat.h> |
| 54 | #include <signal.h> |
| 55 | #endif |
| 56 | |
| 57 | #ifdef FUJITSU_UTS |
| 58 | #define bcopy(f, t, n) memcpy (t, f, n) |
| 59 | #define bcmp(b1, b2, n) (memcmp (b1, b2, n)!=0) |
| 60 | #define bzero(b, n) memset (b, 0, n) |
| 61 | #endif |
| 62 | |
| 63 | #ifdef USG |
| 64 | int selectable = 1; |
| 65 | |
| 66 | sigout () |
| 67 | { |
| 68 | fcntl (fileno (stdin), F_SETFL, 0); |
| 69 | exit (-1); |
| 70 | } |
| 71 | #endif |
| 72 | |
| 73 | main (argc, argv) |
| 74 | int argc; |
| 75 | char *argv[]; |
| 76 | { |
| 77 | struct hostent *host; |
| 78 | struct sockaddr_in sockin, sockme; |
| 79 | struct servent *serv; |
| 80 | char *hostname = NULL; |
| 81 | char *service = "nntp"; |
| 82 | int port; |
| 83 | int readfds; |
| 84 | int writefds; |
| 85 | int server; /* NNTP Server */ |
| 86 | int emacsIn = fileno (stdin); /* Emacs intput */ |
| 87 | int emacsOut = fileno (stdout); /* Emacs output */ |
| 88 | char buffer[1024]; |
| 89 | int nbuffer; /* Number of bytes in buffer */ |
| 90 | int wret; |
| 91 | char *retry; /* retry bufferp */ |
| 92 | int false = 0; /* FALSE flag for setsockopt () */ |
| 93 | |
| 94 | if (argc < 2) |
| 95 | { |
| 96 | fprintf (stderr, "Usage: %s HOST [SERVICE]\n", argv[0]); |
| 97 | exit (1); |
| 98 | } |
| 99 | if (argc >= 2) |
| 100 | hostname = argv[1]; |
| 101 | if (argc >= 3) |
| 102 | service = argv[2]; |
| 103 | |
| 104 | if ((host = gethostbyname (hostname)) == NULL) |
| 105 | { |
| 106 | perror ("gethostbyname"); |
| 107 | exit (1); |
| 108 | } |
| 109 | if (isdigit (service[0])) |
| 110 | port = atoi (service); |
| 111 | else |
| 112 | { |
| 113 | serv = getservbyname (service, "tcp"); |
| 114 | if (serv == NULL) |
| 115 | { |
| 116 | perror ("getservbyname"); |
| 117 | exit (1); |
| 118 | } |
| 119 | port = serv->s_port; |
| 120 | } |
| 121 | |
| 122 | bzero (&sockin, sizeof (sockin)); |
| 123 | sockin.sin_family = host->h_addrtype; |
| 124 | bcopy (host->h_addr, &sockin.sin_addr, host->h_length); |
| 125 | sockin.sin_port = htons (port); |
| 126 | if ((server = socket (AF_INET, SOCK_STREAM, 0)) < 0) |
| 127 | { |
| 128 | perror ("socket"); |
| 129 | exit (1); |
| 130 | } |
| 131 | if (setsockopt (server, SOL_SOCKET, SO_REUSEADDR, &false, sizeof (false))) |
| 132 | { |
| 133 | perror ("setsockopt"); |
| 134 | exit (1); |
| 135 | } |
| 136 | bzero (&sockme, sizeof (sockme)); |
| 137 | sockme.sin_family = sockin.sin_family; |
| 138 | sockme.sin_addr.s_addr = INADDR_ANY; |
| 139 | if (bind (server, &sockme, sizeof (sockme)) < 0) |
| 140 | { |
| 141 | perror ("bind"); |
| 142 | exit (1); |
| 143 | } |
| 144 | if (connect (server, &sockin, sizeof (sockin)) < 0) |
| 145 | { |
| 146 | perror ("connect"); |
| 147 | close (server); |
| 148 | exit (1); |
| 149 | } |
| 150 | |
| 151 | #ifdef O_NDELAY |
| 152 | fcntl (server, F_SETFL, O_NDELAY); |
| 153 | |
| 154 | #ifdef USG |
| 155 | /* USG pipe cannot not select emacsIn */ |
| 156 | { |
| 157 | struct stat statbuf; |
| 158 | fstat (emacsIn, &statbuf); |
| 159 | if (statbuf.st_mode & 010000) |
| 160 | selectable = 0; |
| 161 | if (!selectable) |
| 162 | { |
| 163 | signal (SIGINT, sigout); |
| 164 | fcntl (emacsIn, F_SETFL, O_NDELAY); |
| 165 | } |
| 166 | } |
| 167 | #endif |
| 168 | #endif |
| 169 | |
| 170 | /* Connection established. */ |
| 171 | while (1) |
| 172 | { |
| 173 | readfds = (1 << server) | (1 << emacsIn); |
| 174 | if (select (32, &readfds, NULL, NULL, (struct timeval *)NULL) == -1) |
| 175 | { |
| 176 | perror ("select"); |
| 177 | exit (1); |
| 178 | } |
| 179 | if (readfds & (1 << emacsIn)) |
| 180 | { |
| 181 | /* From Emacs */ |
| 182 | nbuffer = read (emacsIn, buffer, sizeof buffer -1); |
| 183 | |
| 184 | #ifdef USG |
| 185 | if (selectable && nbuffer == 0) |
| 186 | { |
| 187 | goto finish; |
| 188 | } |
| 189 | else if (!(readfds & (1 << server)) && nbuffer == 0) |
| 190 | { |
| 191 | sleep (1); |
| 192 | } |
| 193 | else |
| 194 | #else |
| 195 | if (nbuffer == 0) |
| 196 | goto finish; |
| 197 | #endif |
| 198 | for (retry = buffer; nbuffer > 0; nbuffer -= wret, retry += wret) |
| 199 | { |
| 200 | writefds = 1 << server; |
| 201 | if (select (server+1, NULL, &writefds, NULL, (struct timeval*)NULL) == -1) |
| 202 | { |
| 203 | perror ("select"); |
| 204 | exit (1); |
| 205 | } |
| 206 | wret = write (server, retry, nbuffer); |
| 207 | if (wret < 0) goto finish; |
| 208 | } |
| 209 | } |
| 210 | if (readfds & (1 << server)) |
| 211 | { |
| 212 | /* From NNTP server */ |
| 213 | nbuffer = read (server, buffer, sizeof buffer -1); |
| 214 | if (nbuffer == 0) |
| 215 | goto finish; |
| 216 | for (retry = buffer; nbuffer > 0; nbuffer -= wret, retry += wret) |
| 217 | { |
| 218 | writefds = 1 << emacsOut; |
| 219 | #ifdef USG |
| 220 | if (selectable) |
| 221 | #endif |
| 222 | if (select (emacsOut+1, NULL, &writefds, NULL, (struct timeval*)NULL) == -1) |
| 223 | { |
| 224 | perror ("select"); |
| 225 | exit (1); |
| 226 | } |
| 227 | wret = write (emacsOut, retry, nbuffer); |
| 228 | if (wret < 0) goto finish; |
| 229 | } |
| 230 | } |
| 231 | } |
| 232 | |
| 233 | /* End of communication. */ |
| 234 | finish: |
| 235 | close (server); |
| 236 | #ifdef USG |
| 237 | if (!selectable) fcntl (emacsIn, F_SETFL, 0); |
| 238 | #endif |
| 239 | close (emacsIn); |
| 240 | close (emacsOut); |
| 241 | exit (0); |
| 242 | } |