rlogin.c revision 1.14 1 1.14 explorer /* $NetBSD: rlogin.c,v 1.14 1996/08/10 19:47:32 explorer Exp $ */
2 1.4 cgd
3 1.1 cgd /*
4 1.4 cgd * Copyright (c) 1983, 1990, 1993
5 1.4 cgd * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.1 cgd * 3. All advertising materials mentioning features or use of this software
16 1.1 cgd * must display the following acknowledgement:
17 1.1 cgd * This product includes software developed by the University of
18 1.1 cgd * California, Berkeley and its contributors.
19 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
20 1.1 cgd * may be used to endorse or promote products derived from this software
21 1.1 cgd * without specific prior written permission.
22 1.1 cgd *
23 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 1.1 cgd * SUCH DAMAGE.
34 1.1 cgd */
35 1.1 cgd
36 1.1 cgd #ifndef lint
37 1.4 cgd static char copyright[] =
38 1.4 cgd "@(#) Copyright (c) 1983, 1990, 1993\n\
39 1.4 cgd The Regents of the University of California. All rights reserved.\n";
40 1.1 cgd #endif /* not lint */
41 1.1 cgd
42 1.1 cgd #ifndef lint
43 1.4 cgd #if 0
44 1.4 cgd static char sccsid[] = "@(#)rlogin.c 8.1 (Berkeley) 6/6/93";
45 1.4 cgd #else
46 1.14 explorer static char rcsid[] = "$NetBSD: rlogin.c,v 1.14 1996/08/10 19:47:32 explorer Exp $";
47 1.4 cgd #endif
48 1.1 cgd #endif /* not lint */
49 1.1 cgd
50 1.1 cgd /*
51 1.1 cgd * rlogin - remote login
52 1.1 cgd */
53 1.1 cgd #include <sys/param.h>
54 1.5 mycroft #include <sys/ioctl.h>
55 1.1 cgd #include <sys/socket.h>
56 1.1 cgd #include <sys/time.h>
57 1.1 cgd #include <sys/resource.h>
58 1.1 cgd #include <sys/wait.h>
59 1.1 cgd
60 1.1 cgd #include <netinet/in.h>
61 1.1 cgd #include <netinet/in_systm.h>
62 1.1 cgd #include <netinet/ip.h>
63 1.1 cgd
64 1.1 cgd #include <errno.h>
65 1.4 cgd #include <fcntl.h>
66 1.4 cgd #include <netdb.h>
67 1.1 cgd #include <pwd.h>
68 1.4 cgd #include <setjmp.h>
69 1.5 mycroft #include <termios.h>
70 1.4 cgd #include <signal.h>
71 1.1 cgd #include <stdio.h>
72 1.4 cgd #include <stdlib.h>
73 1.4 cgd #include <string.h>
74 1.1 cgd #include <unistd.h>
75 1.4 cgd
76 1.4 cgd #ifdef __STDC__
77 1.4 cgd #include <stdarg.h>
78 1.4 cgd #else
79 1.4 cgd #include <varargs.h>
80 1.4 cgd #endif
81 1.1 cgd
82 1.1 cgd #ifdef KERBEROS
83 1.1 cgd #include <kerberosIV/des.h>
84 1.1 cgd #include <kerberosIV/krb.h>
85 1.1 cgd
86 1.4 cgd #include "krb.h"
87 1.4 cgd
88 1.1 cgd CREDENTIALS cred;
89 1.1 cgd Key_schedule schedule;
90 1.1 cgd int use_kerberos = 1, doencrypt;
91 1.1 cgd char dst_realm_buf[REALM_SZ], *dest_realm = NULL;
92 1.1 cgd #endif
93 1.1 cgd
94 1.1 cgd #ifndef TIOCPKT_WINDOW
95 1.1 cgd #define TIOCPKT_WINDOW 0x80
96 1.1 cgd #endif
97 1.1 cgd
98 1.1 cgd /* concession to Sun */
99 1.1 cgd #ifndef SIGUSR1
100 1.1 cgd #define SIGUSR1 30
101 1.1 cgd #endif
102 1.1 cgd
103 1.5 mycroft #ifndef CCEQ
104 1.5 mycroft #define CCEQ(val, c) (c == val ? val != _POSIX_VDISABLE : 0)
105 1.5 mycroft #endif
106 1.5 mycroft
107 1.5 mycroft int eight, rem;
108 1.5 mycroft struct termios deftty;
109 1.1 cgd
110 1.1 cgd int noescape;
111 1.1 cgd u_char escapechar = '~';
112 1.1 cgd
113 1.4 cgd #ifdef OLDSUN
114 1.1 cgd struct winsize {
115 1.1 cgd unsigned short ws_row, ws_col;
116 1.1 cgd unsigned short ws_xpixel, ws_ypixel;
117 1.1 cgd };
118 1.4 cgd #else
119 1.4 cgd #define get_window_size(fd, wp) ioctl(fd, TIOCGWINSZ, wp)
120 1.1 cgd #endif
121 1.1 cgd struct winsize winsize;
122 1.1 cgd
123 1.4 cgd void catch_child __P((int));
124 1.4 cgd void copytochild __P((int));
125 1.4 cgd __dead void doit __P((long));
126 1.4 cgd __dead void done __P((int));
127 1.4 cgd void echo __P((char));
128 1.4 cgd u_int getescape __P((char *));
129 1.4 cgd void lostpeer __P((int));
130 1.4 cgd void mode __P((int));
131 1.4 cgd void msg __P((char *));
132 1.4 cgd void oob __P((int));
133 1.4 cgd int reader __P((int));
134 1.4 cgd void sendwindow __P((void));
135 1.4 cgd void setsignal __P((int));
136 1.4 cgd void sigwinch __P((int));
137 1.6 mycroft void stop __P((int));
138 1.4 cgd __dead void usage __P((void));
139 1.4 cgd void writer __P((void));
140 1.4 cgd void writeroob __P((int));
141 1.4 cgd
142 1.4 cgd #ifdef KERBEROS
143 1.4 cgd void warning __P((const char *, ...));
144 1.4 cgd #endif
145 1.4 cgd #ifdef OLDSUN
146 1.4 cgd int get_window_size __P((int, struct winsize *));
147 1.1 cgd #endif
148 1.1 cgd
149 1.4 cgd int
150 1.1 cgd main(argc, argv)
151 1.1 cgd int argc;
152 1.4 cgd char *argv[];
153 1.1 cgd {
154 1.1 cgd extern char *optarg;
155 1.1 cgd extern int optind;
156 1.1 cgd struct passwd *pw;
157 1.1 cgd struct servent *sp;
158 1.5 mycroft struct termios tty;
159 1.1 cgd long omask;
160 1.1 cgd int argoff, ch, dflag, one, uid;
161 1.12 mrg int i, len, len2;
162 1.12 mrg char *host, *p, *user, term[1024] = "network";
163 1.12 mrg speed_t ospeed;
164 1.1 cgd
165 1.1 cgd argoff = dflag = 0;
166 1.1 cgd one = 1;
167 1.1 cgd host = user = NULL;
168 1.1 cgd
169 1.1 cgd if (p = rindex(argv[0], '/'))
170 1.1 cgd ++p;
171 1.1 cgd else
172 1.1 cgd p = argv[0];
173 1.1 cgd
174 1.1 cgd if (strcmp(p, "rlogin"))
175 1.1 cgd host = p;
176 1.1 cgd
177 1.1 cgd /* handle "rlogin host flags" */
178 1.1 cgd if (!host && argc > 2 && argv[1][0] != '-') {
179 1.1 cgd host = argv[1];
180 1.1 cgd argoff = 1;
181 1.1 cgd }
182 1.1 cgd
183 1.1 cgd #ifdef KERBEROS
184 1.1 cgd #define OPTIONS "8EKLde:k:l:x"
185 1.1 cgd #else
186 1.1 cgd #define OPTIONS "8EKLde:l:"
187 1.1 cgd #endif
188 1.1 cgd while ((ch = getopt(argc - argoff, argv + argoff, OPTIONS)) != EOF)
189 1.1 cgd switch(ch) {
190 1.1 cgd case '8':
191 1.1 cgd eight = 1;
192 1.1 cgd break;
193 1.1 cgd case 'E':
194 1.1 cgd noescape = 1;
195 1.1 cgd break;
196 1.1 cgd case 'K':
197 1.1 cgd #ifdef KERBEROS
198 1.1 cgd use_kerberos = 0;
199 1.1 cgd #endif
200 1.1 cgd break;
201 1.1 cgd case 'd':
202 1.1 cgd dflag = 1;
203 1.1 cgd break;
204 1.1 cgd case 'e':
205 1.4 cgd noescape = 0;
206 1.1 cgd escapechar = getescape(optarg);
207 1.1 cgd break;
208 1.1 cgd #ifdef KERBEROS
209 1.1 cgd case 'k':
210 1.1 cgd dest_realm = dst_realm_buf;
211 1.1 cgd (void)strncpy(dest_realm, optarg, REALM_SZ);
212 1.1 cgd break;
213 1.1 cgd #endif
214 1.1 cgd case 'l':
215 1.1 cgd user = optarg;
216 1.1 cgd break;
217 1.1 cgd #ifdef CRYPT
218 1.1 cgd #ifdef KERBEROS
219 1.1 cgd case 'x':
220 1.1 cgd doencrypt = 1;
221 1.1 cgd des_set_key(cred.session, schedule);
222 1.1 cgd break;
223 1.1 cgd #endif
224 1.1 cgd #endif
225 1.1 cgd case '?':
226 1.1 cgd default:
227 1.1 cgd usage();
228 1.1 cgd }
229 1.1 cgd optind += argoff;
230 1.1 cgd argc -= optind;
231 1.1 cgd argv += optind;
232 1.1 cgd
233 1.1 cgd /* if haven't gotten a host yet, do so */
234 1.1 cgd if (!host && !(host = *argv++))
235 1.1 cgd usage();
236 1.1 cgd
237 1.1 cgd if (*argv)
238 1.1 cgd usage();
239 1.1 cgd
240 1.1 cgd if (!(pw = getpwuid(uid = getuid()))) {
241 1.1 cgd (void)fprintf(stderr, "rlogin: unknown user id.\n");
242 1.1 cgd exit(1);
243 1.1 cgd }
244 1.1 cgd if (!user)
245 1.1 cgd user = pw->pw_name;
246 1.1 cgd
247 1.1 cgd sp = NULL;
248 1.1 cgd #ifdef KERBEROS
249 1.1 cgd if (use_kerberos) {
250 1.1 cgd sp = getservbyname((doencrypt ? "eklogin" : "klogin"), "tcp");
251 1.1 cgd if (sp == NULL) {
252 1.1 cgd use_kerberos = 0;
253 1.1 cgd warning("can't get entry for %s/tcp service",
254 1.1 cgd doencrypt ? "eklogin" : "klogin");
255 1.1 cgd }
256 1.1 cgd }
257 1.1 cgd #endif
258 1.1 cgd if (sp == NULL)
259 1.1 cgd sp = getservbyname("login", "tcp");
260 1.1 cgd if (sp == NULL) {
261 1.1 cgd (void)fprintf(stderr, "rlogin: login/tcp: unknown service.\n");
262 1.1 cgd exit(1);
263 1.1 cgd }
264 1.1 cgd
265 1.12 mrg if (p = getenv("TERM")) {
266 1.12 mrg (void)strncpy(term, p, sizeof(term) - 1);
267 1.12 mrg term[sizeof(term) - 1] = '\0';
268 1.12 mrg }
269 1.12 mrg len = strlen(term);
270 1.12 mrg if (len < (sizeof(term) - 1) && tcgetattr(0, &tty) == 0) {
271 1.12 mrg /* start at 2 to include the / */
272 1.13 thorpej for (ospeed = i = cfgetospeed(&tty), len2 = 2; i > 9; len2++)
273 1.12 mrg i /= 10;
274 1.12 mrg
275 1.14 explorer if (len + len2 < sizeof(term))
276 1.14 explorer (void)snprintf(term + len, len2 + 1, "/%d", ospeed);
277 1.1 cgd }
278 1.1 cgd
279 1.1 cgd (void)get_window_size(0, &winsize);
280 1.1 cgd
281 1.1 cgd (void)signal(SIGPIPE, lostpeer);
282 1.1 cgd /* will use SIGUSR1 for window size hack, so hold it off */
283 1.1 cgd omask = sigblock(sigmask(SIGURG) | sigmask(SIGUSR1));
284 1.4 cgd /*
285 1.4 cgd * We set SIGURG and SIGUSR1 below so that an
286 1.4 cgd * incoming signal will be held pending rather than being
287 1.4 cgd * discarded. Note that these routines will be ready to get
288 1.4 cgd * a signal by the time that they are unblocked below.
289 1.4 cgd */
290 1.4 cgd (void)signal(SIGURG, copytochild);
291 1.4 cgd (void)signal(SIGUSR1, writeroob);
292 1.1 cgd
293 1.1 cgd #ifdef KERBEROS
294 1.1 cgd try_connect:
295 1.1 cgd if (use_kerberos) {
296 1.4 cgd struct hostent *hp;
297 1.4 cgd
298 1.4 cgd /* Fully qualify hostname (needed for krb_realmofhost). */
299 1.4 cgd hp = gethostbyname(host);
300 1.4 cgd if (hp != NULL && !(host = strdup(hp->h_name))) {
301 1.4 cgd (void)fprintf(stderr, "rlogin: %s\n",
302 1.4 cgd strerror(ENOMEM));
303 1.4 cgd exit(1);
304 1.4 cgd }
305 1.4 cgd
306 1.1 cgd rem = KSUCCESS;
307 1.1 cgd errno = 0;
308 1.1 cgd if (dest_realm == NULL)
309 1.1 cgd dest_realm = krb_realmofhost(host);
310 1.1 cgd
311 1.1 cgd #ifdef CRYPT
312 1.1 cgd if (doencrypt)
313 1.1 cgd rem = krcmd_mutual(&host, sp->s_port, user, term, 0,
314 1.1 cgd dest_realm, &cred, schedule);
315 1.1 cgd else
316 1.1 cgd #endif /* CRYPT */
317 1.1 cgd rem = krcmd(&host, sp->s_port, user, term, 0,
318 1.1 cgd dest_realm);
319 1.1 cgd if (rem < 0) {
320 1.1 cgd use_kerberos = 0;
321 1.1 cgd sp = getservbyname("login", "tcp");
322 1.1 cgd if (sp == NULL) {
323 1.1 cgd (void)fprintf(stderr,
324 1.1 cgd "rlogin: unknown service login/tcp.\n");
325 1.1 cgd exit(1);
326 1.1 cgd }
327 1.1 cgd if (errno == ECONNREFUSED)
328 1.1 cgd warning("remote host doesn't support Kerberos");
329 1.1 cgd if (errno == ENOENT)
330 1.1 cgd warning("can't provide Kerberos auth data");
331 1.1 cgd goto try_connect;
332 1.1 cgd }
333 1.1 cgd } else {
334 1.1 cgd #ifdef CRYPT
335 1.1 cgd if (doencrypt) {
336 1.1 cgd (void)fprintf(stderr,
337 1.1 cgd "rlogin: the -x flag requires Kerberos authentication.\n");
338 1.1 cgd exit(1);
339 1.1 cgd }
340 1.1 cgd #endif /* CRYPT */
341 1.1 cgd rem = rcmd(&host, sp->s_port, pw->pw_name, user, term, 0);
342 1.1 cgd }
343 1.1 cgd #else
344 1.1 cgd rem = rcmd(&host, sp->s_port, pw->pw_name, user, term, 0);
345 1.1 cgd #endif /* KERBEROS */
346 1.1 cgd
347 1.1 cgd if (rem < 0)
348 1.1 cgd exit(1);
349 1.1 cgd
350 1.1 cgd if (dflag &&
351 1.1 cgd setsockopt(rem, SOL_SOCKET, SO_DEBUG, &one, sizeof(one)) < 0)
352 1.1 cgd (void)fprintf(stderr, "rlogin: setsockopt: %s.\n",
353 1.1 cgd strerror(errno));
354 1.1 cgd one = IPTOS_LOWDELAY;
355 1.1 cgd if (setsockopt(rem, IPPROTO_IP, IP_TOS, (char *)&one, sizeof(int)) < 0)
356 1.1 cgd perror("rlogin: setsockopt TOS (ignored)");
357 1.1 cgd
358 1.1 cgd (void)setuid(uid);
359 1.1 cgd doit(omask);
360 1.1 cgd /*NOTREACHED*/
361 1.1 cgd }
362 1.1 cgd
363 1.5 mycroft int child;
364 1.1 cgd
365 1.4 cgd void
366 1.1 cgd doit(omask)
367 1.1 cgd long omask;
368 1.1 cgd {
369 1.1 cgd
370 1.1 cgd (void)signal(SIGINT, SIG_IGN);
371 1.4 cgd setsignal(SIGHUP);
372 1.4 cgd setsignal(SIGQUIT);
373 1.5 mycroft mode(1);
374 1.1 cgd child = fork();
375 1.1 cgd if (child == -1) {
376 1.1 cgd (void)fprintf(stderr, "rlogin: fork: %s.\n", strerror(errno));
377 1.1 cgd done(1);
378 1.1 cgd }
379 1.1 cgd if (child == 0) {
380 1.1 cgd if (reader(omask) == 0) {
381 1.1 cgd msg("connection closed.");
382 1.1 cgd exit(0);
383 1.1 cgd }
384 1.1 cgd sleep(1);
385 1.5 mycroft msg("\aconnection closed.");
386 1.1 cgd exit(1);
387 1.1 cgd }
388 1.1 cgd
389 1.1 cgd /*
390 1.1 cgd * We may still own the socket, and may have a pending SIGURG (or might
391 1.4 cgd * receive one soon) that we really want to send to the reader. When
392 1.4 cgd * one of these comes in, the trap copytochild simply copies such
393 1.4 cgd * signals to the child. We can now unblock SIGURG and SIGUSR1
394 1.4 cgd * that were set above.
395 1.1 cgd */
396 1.1 cgd (void)sigsetmask(omask);
397 1.1 cgd (void)signal(SIGCHLD, catch_child);
398 1.1 cgd writer();
399 1.1 cgd msg("closed connection.");
400 1.1 cgd done(0);
401 1.1 cgd }
402 1.1 cgd
403 1.1 cgd /* trap a signal, unless it is being ignored. */
404 1.4 cgd void
405 1.4 cgd setsignal(sig)
406 1.1 cgd int sig;
407 1.1 cgd {
408 1.1 cgd int omask = sigblock(sigmask(sig));
409 1.1 cgd
410 1.4 cgd if (signal(sig, exit) == SIG_IGN)
411 1.1 cgd (void)signal(sig, SIG_IGN);
412 1.1 cgd (void)sigsetmask(omask);
413 1.1 cgd }
414 1.1 cgd
415 1.4 cgd __dead void
416 1.1 cgd done(status)
417 1.1 cgd int status;
418 1.1 cgd {
419 1.1 cgd int w, wstatus;
420 1.1 cgd
421 1.1 cgd mode(0);
422 1.1 cgd if (child > 0) {
423 1.1 cgd /* make sure catch_child does not snap it up */
424 1.1 cgd (void)signal(SIGCHLD, SIG_DFL);
425 1.1 cgd if (kill(child, SIGKILL) >= 0)
426 1.1 cgd while ((w = wait(&wstatus)) > 0 && w != child);
427 1.1 cgd }
428 1.1 cgd exit(status);
429 1.1 cgd }
430 1.1 cgd
431 1.1 cgd int dosigwinch;
432 1.1 cgd
433 1.1 cgd /*
434 1.1 cgd * This is called when the reader process gets the out-of-band (urgent)
435 1.1 cgd * request to turn on the window-changing protocol.
436 1.1 cgd */
437 1.1 cgd void
438 1.4 cgd writeroob(signo)
439 1.4 cgd int signo;
440 1.1 cgd {
441 1.1 cgd if (dosigwinch == 0) {
442 1.1 cgd sendwindow();
443 1.1 cgd (void)signal(SIGWINCH, sigwinch);
444 1.1 cgd }
445 1.1 cgd dosigwinch = 1;
446 1.1 cgd }
447 1.1 cgd
448 1.1 cgd void
449 1.4 cgd catch_child(signo)
450 1.4 cgd int signo;
451 1.1 cgd {
452 1.1 cgd union wait status;
453 1.1 cgd int pid;
454 1.1 cgd
455 1.1 cgd for (;;) {
456 1.4 cgd pid = wait3((int *)&status, WNOHANG|WUNTRACED, NULL);
457 1.1 cgd if (pid == 0)
458 1.1 cgd return;
459 1.1 cgd /* if the child (reader) dies, just quit */
460 1.4 cgd if (pid < 0 || (pid == child && !WIFSTOPPED(status)))
461 1.1 cgd done((int)(status.w_termsig | status.w_retcode));
462 1.1 cgd }
463 1.1 cgd /* NOTREACHED */
464 1.1 cgd }
465 1.1 cgd
466 1.1 cgd /*
467 1.1 cgd * writer: write to remote: 0 -> line.
468 1.1 cgd * ~. terminate
469 1.1 cgd * ~^Z suspend rlogin process.
470 1.1 cgd * ~<delayed-suspend char> suspend rlogin process, but leave reader alone.
471 1.1 cgd */
472 1.4 cgd void
473 1.1 cgd writer()
474 1.1 cgd {
475 1.1 cgd register int bol, local, n;
476 1.1 cgd char c;
477 1.1 cgd
478 1.1 cgd bol = 1; /* beginning of line */
479 1.1 cgd local = 0;
480 1.1 cgd for (;;) {
481 1.1 cgd n = read(STDIN_FILENO, &c, 1);
482 1.1 cgd if (n <= 0) {
483 1.1 cgd if (n < 0 && errno == EINTR)
484 1.1 cgd continue;
485 1.1 cgd break;
486 1.1 cgd }
487 1.1 cgd /*
488 1.1 cgd * If we're at the beginning of the line and recognize a
489 1.1 cgd * command character, then we echo locally. Otherwise,
490 1.1 cgd * characters are echo'd remotely. If the command character
491 1.1 cgd * is doubled, this acts as a force and local echo is
492 1.1 cgd * suppressed.
493 1.1 cgd */
494 1.1 cgd if (bol) {
495 1.1 cgd bol = 0;
496 1.1 cgd if (!noescape && c == escapechar) {
497 1.1 cgd local = 1;
498 1.1 cgd continue;
499 1.1 cgd }
500 1.1 cgd } else if (local) {
501 1.1 cgd local = 0;
502 1.5 mycroft if (c == '.' || CCEQ(deftty.c_cc[VEOF], c)) {
503 1.1 cgd echo(c);
504 1.1 cgd break;
505 1.1 cgd }
506 1.6 mycroft if (CCEQ(deftty.c_cc[VSUSP], c)) {
507 1.1 cgd bol = 1;
508 1.1 cgd echo(c);
509 1.6 mycroft stop(1);
510 1.6 mycroft continue;
511 1.6 mycroft }
512 1.6 mycroft if (CCEQ(deftty.c_cc[VDSUSP], c)) {
513 1.6 mycroft bol = 1;
514 1.6 mycroft echo(c);
515 1.6 mycroft stop(0);
516 1.1 cgd continue;
517 1.1 cgd }
518 1.1 cgd if (c != escapechar)
519 1.1 cgd #ifdef CRYPT
520 1.1 cgd #ifdef KERBEROS
521 1.1 cgd if (doencrypt)
522 1.4 cgd (void)des_write(rem,
523 1.4 cgd (char *)&escapechar, 1);
524 1.1 cgd else
525 1.1 cgd #endif
526 1.1 cgd #endif
527 1.1 cgd (void)write(rem, &escapechar, 1);
528 1.1 cgd }
529 1.1 cgd
530 1.1 cgd #ifdef CRYPT
531 1.1 cgd #ifdef KERBEROS
532 1.1 cgd if (doencrypt) {
533 1.1 cgd if (des_write(rem, &c, 1) == 0) {
534 1.1 cgd msg("line gone");
535 1.1 cgd break;
536 1.1 cgd }
537 1.1 cgd } else
538 1.1 cgd #endif
539 1.1 cgd #endif
540 1.1 cgd if (write(rem, &c, 1) == 0) {
541 1.1 cgd msg("line gone");
542 1.1 cgd break;
543 1.1 cgd }
544 1.5 mycroft bol = CCEQ(deftty.c_cc[VKILL], c) ||
545 1.5 mycroft CCEQ(deftty.c_cc[VEOF], c) ||
546 1.5 mycroft CCEQ(deftty.c_cc[VINTR], c) ||
547 1.5 mycroft CCEQ(deftty.c_cc[VSUSP], c) ||
548 1.1 cgd c == '\r' || c == '\n';
549 1.1 cgd }
550 1.1 cgd }
551 1.1 cgd
552 1.4 cgd void
553 1.4 cgd #if __STDC__
554 1.4 cgd echo(register char c)
555 1.4 cgd #else
556 1.1 cgd echo(c)
557 1.4 cgd register char c;
558 1.4 cgd #endif
559 1.1 cgd {
560 1.1 cgd register char *p;
561 1.1 cgd char buf[8];
562 1.1 cgd
563 1.1 cgd p = buf;
564 1.1 cgd c &= 0177;
565 1.1 cgd *p++ = escapechar;
566 1.1 cgd if (c < ' ') {
567 1.1 cgd *p++ = '^';
568 1.1 cgd *p++ = c + '@';
569 1.1 cgd } else if (c == 0177) {
570 1.1 cgd *p++ = '^';
571 1.1 cgd *p++ = '?';
572 1.1 cgd } else
573 1.1 cgd *p++ = c;
574 1.1 cgd *p++ = '\r';
575 1.1 cgd *p++ = '\n';
576 1.1 cgd (void)write(STDOUT_FILENO, buf, p - buf);
577 1.1 cgd }
578 1.1 cgd
579 1.4 cgd void
580 1.6 mycroft stop(all)
581 1.6 mycroft int all;
582 1.1 cgd {
583 1.1 cgd mode(0);
584 1.1 cgd (void)signal(SIGCHLD, SIG_IGN);
585 1.6 mycroft (void)kill(all ? 0 : getpid(), SIGTSTP);
586 1.1 cgd (void)signal(SIGCHLD, catch_child);
587 1.1 cgd mode(1);
588 1.4 cgd sigwinch(0); /* check for size changes */
589 1.1 cgd }
590 1.1 cgd
591 1.1 cgd void
592 1.4 cgd sigwinch(signo)
593 1.4 cgd int signo;
594 1.1 cgd {
595 1.1 cgd struct winsize ws;
596 1.1 cgd
597 1.1 cgd if (dosigwinch && get_window_size(0, &ws) == 0 &&
598 1.1 cgd bcmp(&ws, &winsize, sizeof(ws))) {
599 1.1 cgd winsize = ws;
600 1.1 cgd sendwindow();
601 1.1 cgd }
602 1.1 cgd }
603 1.1 cgd
604 1.1 cgd /*
605 1.1 cgd * Send the window size to the server via the magic escape
606 1.1 cgd */
607 1.4 cgd void
608 1.1 cgd sendwindow()
609 1.1 cgd {
610 1.1 cgd struct winsize *wp;
611 1.1 cgd char obuf[4 + sizeof (struct winsize)];
612 1.1 cgd
613 1.1 cgd wp = (struct winsize *)(obuf+4);
614 1.1 cgd obuf[0] = 0377;
615 1.1 cgd obuf[1] = 0377;
616 1.1 cgd obuf[2] = 's';
617 1.1 cgd obuf[3] = 's';
618 1.1 cgd wp->ws_row = htons(winsize.ws_row);
619 1.1 cgd wp->ws_col = htons(winsize.ws_col);
620 1.1 cgd wp->ws_xpixel = htons(winsize.ws_xpixel);
621 1.1 cgd wp->ws_ypixel = htons(winsize.ws_ypixel);
622 1.1 cgd
623 1.1 cgd #ifdef CRYPT
624 1.1 cgd #ifdef KERBEROS
625 1.1 cgd if(doencrypt)
626 1.1 cgd (void)des_write(rem, obuf, sizeof(obuf));
627 1.1 cgd else
628 1.1 cgd #endif
629 1.1 cgd #endif
630 1.1 cgd (void)write(rem, obuf, sizeof(obuf));
631 1.1 cgd }
632 1.1 cgd
633 1.1 cgd /*
634 1.1 cgd * reader: read from remote: line -> 1
635 1.1 cgd */
636 1.1 cgd #define READING 1
637 1.1 cgd #define WRITING 2
638 1.1 cgd
639 1.1 cgd jmp_buf rcvtop;
640 1.1 cgd int ppid, rcvcnt, rcvstate;
641 1.1 cgd char rcvbuf[8 * 1024];
642 1.1 cgd
643 1.1 cgd void
644 1.4 cgd oob(signo)
645 1.4 cgd int signo;
646 1.1 cgd {
647 1.5 mycroft struct termios tty;
648 1.8 mycroft int atmark, n, rcvd;
649 1.1 cgd char waste[BUFSIZ], mark;
650 1.1 cgd
651 1.1 cgd rcvd = 0;
652 1.4 cgd while (recv(rem, &mark, 1, MSG_OOB) < 0) {
653 1.1 cgd switch (errno) {
654 1.1 cgd case EWOULDBLOCK:
655 1.1 cgd /*
656 1.1 cgd * Urgent data not here yet. It may not be possible
657 1.1 cgd * to send it yet if we are blocked for output and
658 1.1 cgd * our input buffer is full.
659 1.1 cgd */
660 1.1 cgd if (rcvcnt < sizeof(rcvbuf)) {
661 1.1 cgd n = read(rem, rcvbuf + rcvcnt,
662 1.1 cgd sizeof(rcvbuf) - rcvcnt);
663 1.1 cgd if (n <= 0)
664 1.1 cgd return;
665 1.1 cgd rcvd += n;
666 1.1 cgd } else {
667 1.1 cgd n = read(rem, waste, sizeof(waste));
668 1.1 cgd if (n <= 0)
669 1.1 cgd return;
670 1.1 cgd }
671 1.1 cgd continue;
672 1.1 cgd default:
673 1.1 cgd return;
674 1.4 cgd }
675 1.1 cgd }
676 1.1 cgd if (mark & TIOCPKT_WINDOW) {
677 1.1 cgd /* Let server know about window size changes */
678 1.1 cgd (void)kill(ppid, SIGUSR1);
679 1.1 cgd }
680 1.1 cgd if (!eight && (mark & TIOCPKT_NOSTOP)) {
681 1.5 mycroft (void)tcgetattr(0, &tty);
682 1.5 mycroft tty.c_iflag &= ~IXON;
683 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
684 1.1 cgd }
685 1.1 cgd if (!eight && (mark & TIOCPKT_DOSTOP)) {
686 1.5 mycroft (void)tcgetattr(0, &tty);
687 1.5 mycroft tty.c_iflag |= (deftty.c_iflag & IXON);
688 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
689 1.1 cgd }
690 1.1 cgd if (mark & TIOCPKT_FLUSHWRITE) {
691 1.8 mycroft (void)tcflush(1, TCIOFLUSH);
692 1.1 cgd for (;;) {
693 1.1 cgd if (ioctl(rem, SIOCATMARK, &atmark) < 0) {
694 1.1 cgd (void)fprintf(stderr, "rlogin: ioctl: %s.\n",
695 1.1 cgd strerror(errno));
696 1.1 cgd break;
697 1.1 cgd }
698 1.1 cgd if (atmark)
699 1.1 cgd break;
700 1.1 cgd n = read(rem, waste, sizeof (waste));
701 1.1 cgd if (n <= 0)
702 1.1 cgd break;
703 1.1 cgd }
704 1.1 cgd /*
705 1.1 cgd * Don't want any pending data to be output, so clear the recv
706 1.1 cgd * buffer. If we were hanging on a write when interrupted,
707 1.1 cgd * don't want it to restart. If we were reading, restart
708 1.1 cgd * anyway.
709 1.1 cgd */
710 1.1 cgd rcvcnt = 0;
711 1.1 cgd longjmp(rcvtop, 1);
712 1.1 cgd }
713 1.1 cgd
714 1.1 cgd /* oob does not do FLUSHREAD (alas!) */
715 1.1 cgd
716 1.1 cgd /*
717 1.1 cgd * If we filled the receive buffer while a read was pending, longjmp
718 1.1 cgd * to the top to restart appropriately. Don't abort a pending write,
719 1.1 cgd * however, or we won't know how much was written.
720 1.1 cgd */
721 1.1 cgd if (rcvd && rcvstate == READING)
722 1.1 cgd longjmp(rcvtop, 1);
723 1.1 cgd }
724 1.1 cgd
725 1.1 cgd /* reader: read from remote: line -> 1 */
726 1.4 cgd int
727 1.1 cgd reader(omask)
728 1.1 cgd int omask;
729 1.1 cgd {
730 1.4 cgd int pid, n, remaining;
731 1.4 cgd char *bufp;
732 1.1 cgd
733 1.4 cgd #if BSD >= 43 || defined(SUNOS4)
734 1.4 cgd pid = getpid(); /* modern systems use positives for pid */
735 1.1 cgd #else
736 1.4 cgd pid = -getpid(); /* old broken systems use negatives */
737 1.1 cgd #endif
738 1.1 cgd (void)signal(SIGTTOU, SIG_IGN);
739 1.1 cgd (void)signal(SIGURG, oob);
740 1.1 cgd ppid = getppid();
741 1.1 cgd (void)fcntl(rem, F_SETOWN, pid);
742 1.1 cgd (void)setjmp(rcvtop);
743 1.1 cgd (void)sigsetmask(omask);
744 1.4 cgd bufp = rcvbuf;
745 1.1 cgd for (;;) {
746 1.1 cgd while ((remaining = rcvcnt - (bufp - rcvbuf)) > 0) {
747 1.1 cgd rcvstate = WRITING;
748 1.1 cgd n = write(STDOUT_FILENO, bufp, remaining);
749 1.1 cgd if (n < 0) {
750 1.1 cgd if (errno != EINTR)
751 1.4 cgd return (-1);
752 1.1 cgd continue;
753 1.1 cgd }
754 1.1 cgd bufp += n;
755 1.1 cgd }
756 1.1 cgd bufp = rcvbuf;
757 1.1 cgd rcvcnt = 0;
758 1.1 cgd rcvstate = READING;
759 1.1 cgd
760 1.1 cgd #ifdef CRYPT
761 1.1 cgd #ifdef KERBEROS
762 1.1 cgd if (doencrypt)
763 1.1 cgd rcvcnt = des_read(rem, rcvbuf, sizeof(rcvbuf));
764 1.1 cgd else
765 1.1 cgd #endif
766 1.1 cgd #endif
767 1.1 cgd rcvcnt = read(rem, rcvbuf, sizeof (rcvbuf));
768 1.1 cgd if (rcvcnt == 0)
769 1.1 cgd return (0);
770 1.1 cgd if (rcvcnt < 0) {
771 1.1 cgd if (errno == EINTR)
772 1.1 cgd continue;
773 1.1 cgd (void)fprintf(stderr, "rlogin: read: %s.\n",
774 1.1 cgd strerror(errno));
775 1.4 cgd return (-1);
776 1.1 cgd }
777 1.1 cgd }
778 1.1 cgd }
779 1.1 cgd
780 1.4 cgd void
781 1.1 cgd mode(f)
782 1.4 cgd int f;
783 1.1 cgd {
784 1.5 mycroft struct termios tty;
785 1.5 mycroft
786 1.5 mycroft switch (f) {
787 1.1 cgd case 0:
788 1.5 mycroft (void)tcsetattr(0, TCSANOW, &deftty);
789 1.1 cgd break;
790 1.1 cgd case 1:
791 1.5 mycroft (void)tcgetattr(0, &deftty);
792 1.5 mycroft tty = deftty;
793 1.7 mycroft /* This is loosely derived from sys/compat/tty_compat.c. */
794 1.7 mycroft tty.c_lflag &= ~(ECHO|ICANON|ISIG|IEXTEN);
795 1.5 mycroft tty.c_iflag &= ~ICRNL;
796 1.5 mycroft tty.c_oflag &= ~OPOST;
797 1.9 christos tty.c_cc[VMIN] = 1;
798 1.9 christos tty.c_cc[VTIME] = 0;
799 1.5 mycroft if (eight) {
800 1.5 mycroft tty.c_iflag &= IXOFF;
801 1.5 mycroft tty.c_cflag &= ~(CSIZE|PARENB);
802 1.5 mycroft tty.c_cflag |= CS8;
803 1.5 mycroft }
804 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
805 1.1 cgd break;
806 1.1 cgd default:
807 1.1 cgd return;
808 1.1 cgd }
809 1.1 cgd }
810 1.1 cgd
811 1.1 cgd void
812 1.4 cgd lostpeer(signo)
813 1.4 cgd int signo;
814 1.1 cgd {
815 1.1 cgd (void)signal(SIGPIPE, SIG_IGN);
816 1.5 mycroft msg("\aconnection closed.");
817 1.1 cgd done(1);
818 1.1 cgd }
819 1.1 cgd
820 1.1 cgd /* copy SIGURGs to the child process. */
821 1.1 cgd void
822 1.4 cgd copytochild(signo)
823 1.4 cgd int signo;
824 1.1 cgd {
825 1.1 cgd (void)kill(child, SIGURG);
826 1.1 cgd }
827 1.1 cgd
828 1.4 cgd void
829 1.1 cgd msg(str)
830 1.1 cgd char *str;
831 1.1 cgd {
832 1.1 cgd (void)fprintf(stderr, "rlogin: %s\r\n", str);
833 1.1 cgd }
834 1.1 cgd
835 1.1 cgd #ifdef KERBEROS
836 1.1 cgd /* VARARGS */
837 1.4 cgd void
838 1.4 cgd #if __STDC__
839 1.4 cgd warning(const char *fmt, ...)
840 1.4 cgd #else
841 1.4 cgd warning(fmt, va_alist)
842 1.4 cgd char *fmt;
843 1.4 cgd va_dcl
844 1.4 cgd #endif
845 1.1 cgd {
846 1.1 cgd va_list ap;
847 1.1 cgd
848 1.1 cgd (void)fprintf(stderr, "rlogin: warning, using standard rlogin: ");
849 1.4 cgd #ifdef __STDC__
850 1.4 cgd va_start(ap, fmt);
851 1.4 cgd #else
852 1.1 cgd va_start(ap);
853 1.4 cgd #endif
854 1.1 cgd vfprintf(stderr, fmt, ap);
855 1.1 cgd va_end(ap);
856 1.1 cgd (void)fprintf(stderr, ".\n");
857 1.1 cgd }
858 1.1 cgd #endif
859 1.1 cgd
860 1.4 cgd __dead void
861 1.1 cgd usage()
862 1.1 cgd {
863 1.1 cgd (void)fprintf(stderr,
864 1.1 cgd "usage: rlogin [ -%s]%s[-e char] [ -l username ] host\n",
865 1.1 cgd #ifdef KERBEROS
866 1.1 cgd #ifdef CRYPT
867 1.4 cgd "8EKLx", " [-k realm] ");
868 1.1 cgd #else
869 1.4 cgd "8EKL", " [-k realm] ");
870 1.1 cgd #endif
871 1.1 cgd #else
872 1.1 cgd "8EL", " ");
873 1.1 cgd #endif
874 1.1 cgd exit(1);
875 1.1 cgd }
876 1.1 cgd
877 1.1 cgd /*
878 1.4 cgd * The following routine provides compatibility (such as it is) between older
879 1.1 cgd * Suns and others. Suns have only a `ttysize', so we convert it to a winsize.
880 1.1 cgd */
881 1.4 cgd #ifdef OLDSUN
882 1.4 cgd int
883 1.1 cgd get_window_size(fd, wp)
884 1.1 cgd int fd;
885 1.1 cgd struct winsize *wp;
886 1.1 cgd {
887 1.1 cgd struct ttysize ts;
888 1.1 cgd int error;
889 1.1 cgd
890 1.1 cgd if ((error = ioctl(0, TIOCGSIZE, &ts)) != 0)
891 1.4 cgd return (error);
892 1.1 cgd wp->ws_row = ts.ts_lines;
893 1.1 cgd wp->ws_col = ts.ts_cols;
894 1.1 cgd wp->ws_xpixel = 0;
895 1.1 cgd wp->ws_ypixel = 0;
896 1.4 cgd return (0);
897 1.1 cgd }
898 1.1 cgd #endif
899 1.1 cgd
900 1.4 cgd u_int
901 1.1 cgd getescape(p)
902 1.1 cgd register char *p;
903 1.1 cgd {
904 1.1 cgd long val;
905 1.1 cgd int len;
906 1.1 cgd
907 1.1 cgd if ((len = strlen(p)) == 1) /* use any single char, including '\' */
908 1.4 cgd return ((u_int)*p);
909 1.1 cgd /* otherwise, \nnn */
910 1.1 cgd if (*p == '\\' && len >= 2 && len <= 4) {
911 1.4 cgd val = strtol(++p, NULL, 8);
912 1.1 cgd for (;;) {
913 1.1 cgd if (!*++p)
914 1.4 cgd return ((u_int)val);
915 1.1 cgd if (*p < '0' || *p > '8')
916 1.1 cgd break;
917 1.1 cgd }
918 1.1 cgd }
919 1.1 cgd msg("illegal option value -- e");
920 1.1 cgd usage();
921 1.1 cgd /* NOTREACHED */
922 1.1 cgd }
923