rlogin.c revision 1.10 1 1.10 mrg /* $NetBSD: rlogin.c,v 1.10 1996/06/19 06:02:24 mrg 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.10 mrg static char rcsid[] = "$NetBSD: rlogin.c,v 1.10 1996/06/19 06:02:24 mrg 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.1 cgd char *host, *p, *user, term[1024];
162 1.1 cgd
163 1.1 cgd argoff = dflag = 0;
164 1.1 cgd one = 1;
165 1.1 cgd host = user = NULL;
166 1.1 cgd
167 1.1 cgd if (p = rindex(argv[0], '/'))
168 1.1 cgd ++p;
169 1.1 cgd else
170 1.1 cgd p = argv[0];
171 1.1 cgd
172 1.1 cgd if (strcmp(p, "rlogin"))
173 1.1 cgd host = p;
174 1.1 cgd
175 1.1 cgd /* handle "rlogin host flags" */
176 1.1 cgd if (!host && argc > 2 && argv[1][0] != '-') {
177 1.1 cgd host = argv[1];
178 1.1 cgd argoff = 1;
179 1.1 cgd }
180 1.1 cgd
181 1.1 cgd #ifdef KERBEROS
182 1.1 cgd #define OPTIONS "8EKLde:k:l:x"
183 1.1 cgd #else
184 1.1 cgd #define OPTIONS "8EKLde:l:"
185 1.1 cgd #endif
186 1.1 cgd while ((ch = getopt(argc - argoff, argv + argoff, OPTIONS)) != EOF)
187 1.1 cgd switch(ch) {
188 1.1 cgd case '8':
189 1.1 cgd eight = 1;
190 1.1 cgd break;
191 1.1 cgd case 'E':
192 1.1 cgd noescape = 1;
193 1.1 cgd break;
194 1.1 cgd case 'K':
195 1.1 cgd #ifdef KERBEROS
196 1.1 cgd use_kerberos = 0;
197 1.1 cgd #endif
198 1.1 cgd break;
199 1.1 cgd case 'd':
200 1.1 cgd dflag = 1;
201 1.1 cgd break;
202 1.1 cgd case 'e':
203 1.4 cgd noescape = 0;
204 1.1 cgd escapechar = getescape(optarg);
205 1.1 cgd break;
206 1.1 cgd #ifdef KERBEROS
207 1.1 cgd case 'k':
208 1.1 cgd dest_realm = dst_realm_buf;
209 1.1 cgd (void)strncpy(dest_realm, optarg, REALM_SZ);
210 1.1 cgd break;
211 1.1 cgd #endif
212 1.1 cgd case 'l':
213 1.1 cgd user = optarg;
214 1.1 cgd break;
215 1.1 cgd #ifdef CRYPT
216 1.1 cgd #ifdef KERBEROS
217 1.1 cgd case 'x':
218 1.1 cgd doencrypt = 1;
219 1.1 cgd des_set_key(cred.session, schedule);
220 1.1 cgd break;
221 1.1 cgd #endif
222 1.1 cgd #endif
223 1.1 cgd case '?':
224 1.1 cgd default:
225 1.1 cgd usage();
226 1.1 cgd }
227 1.1 cgd optind += argoff;
228 1.1 cgd argc -= optind;
229 1.1 cgd argv += optind;
230 1.1 cgd
231 1.1 cgd /* if haven't gotten a host yet, do so */
232 1.1 cgd if (!host && !(host = *argv++))
233 1.1 cgd usage();
234 1.1 cgd
235 1.1 cgd if (*argv)
236 1.1 cgd usage();
237 1.1 cgd
238 1.1 cgd if (!(pw = getpwuid(uid = getuid()))) {
239 1.1 cgd (void)fprintf(stderr, "rlogin: unknown user id.\n");
240 1.1 cgd exit(1);
241 1.1 cgd }
242 1.1 cgd if (!user)
243 1.1 cgd user = pw->pw_name;
244 1.1 cgd
245 1.1 cgd sp = NULL;
246 1.1 cgd #ifdef KERBEROS
247 1.1 cgd if (use_kerberos) {
248 1.1 cgd sp = getservbyname((doencrypt ? "eklogin" : "klogin"), "tcp");
249 1.1 cgd if (sp == NULL) {
250 1.1 cgd use_kerberos = 0;
251 1.1 cgd warning("can't get entry for %s/tcp service",
252 1.1 cgd doencrypt ? "eklogin" : "klogin");
253 1.1 cgd }
254 1.1 cgd }
255 1.1 cgd #endif
256 1.1 cgd if (sp == NULL)
257 1.1 cgd sp = getservbyname("login", "tcp");
258 1.1 cgd if (sp == NULL) {
259 1.1 cgd (void)fprintf(stderr, "rlogin: login/tcp: unknown service.\n");
260 1.1 cgd exit(1);
261 1.1 cgd }
262 1.1 cgd
263 1.10 mrg (void)strncpy(term, (p = getenv("TERM")) ? p : "network",
264 1.10 mrg sizeof(term) - 1);
265 1.10 mrg term[sizeof(term) - 1] = '\0';
266 1.5 mycroft if (tcgetattr(0, &tty) == 0) {
267 1.10 mrg (void)strncat(term, "/", sizeof(term) - strlen(term));
268 1.10 mrg (void)snprintf(term + strlen(term),
269 1.10 mrg sizeof(term) - strlen(term) - 1, "%d", cfgetospeed(&tty));
270 1.10 mrg term[sizeof(term) - 1] = '\0';
271 1.1 cgd }
272 1.1 cgd
273 1.1 cgd (void)get_window_size(0, &winsize);
274 1.1 cgd
275 1.1 cgd (void)signal(SIGPIPE, lostpeer);
276 1.1 cgd /* will use SIGUSR1 for window size hack, so hold it off */
277 1.1 cgd omask = sigblock(sigmask(SIGURG) | sigmask(SIGUSR1));
278 1.4 cgd /*
279 1.4 cgd * We set SIGURG and SIGUSR1 below so that an
280 1.4 cgd * incoming signal will be held pending rather than being
281 1.4 cgd * discarded. Note that these routines will be ready to get
282 1.4 cgd * a signal by the time that they are unblocked below.
283 1.4 cgd */
284 1.4 cgd (void)signal(SIGURG, copytochild);
285 1.4 cgd (void)signal(SIGUSR1, writeroob);
286 1.1 cgd
287 1.1 cgd #ifdef KERBEROS
288 1.1 cgd try_connect:
289 1.1 cgd if (use_kerberos) {
290 1.4 cgd struct hostent *hp;
291 1.4 cgd
292 1.4 cgd /* Fully qualify hostname (needed for krb_realmofhost). */
293 1.4 cgd hp = gethostbyname(host);
294 1.4 cgd if (hp != NULL && !(host = strdup(hp->h_name))) {
295 1.4 cgd (void)fprintf(stderr, "rlogin: %s\n",
296 1.4 cgd strerror(ENOMEM));
297 1.4 cgd exit(1);
298 1.4 cgd }
299 1.4 cgd
300 1.1 cgd rem = KSUCCESS;
301 1.1 cgd errno = 0;
302 1.1 cgd if (dest_realm == NULL)
303 1.1 cgd dest_realm = krb_realmofhost(host);
304 1.1 cgd
305 1.1 cgd #ifdef CRYPT
306 1.1 cgd if (doencrypt)
307 1.1 cgd rem = krcmd_mutual(&host, sp->s_port, user, term, 0,
308 1.1 cgd dest_realm, &cred, schedule);
309 1.1 cgd else
310 1.1 cgd #endif /* CRYPT */
311 1.1 cgd rem = krcmd(&host, sp->s_port, user, term, 0,
312 1.1 cgd dest_realm);
313 1.1 cgd if (rem < 0) {
314 1.1 cgd use_kerberos = 0;
315 1.1 cgd sp = getservbyname("login", "tcp");
316 1.1 cgd if (sp == NULL) {
317 1.1 cgd (void)fprintf(stderr,
318 1.1 cgd "rlogin: unknown service login/tcp.\n");
319 1.1 cgd exit(1);
320 1.1 cgd }
321 1.1 cgd if (errno == ECONNREFUSED)
322 1.1 cgd warning("remote host doesn't support Kerberos");
323 1.1 cgd if (errno == ENOENT)
324 1.1 cgd warning("can't provide Kerberos auth data");
325 1.1 cgd goto try_connect;
326 1.1 cgd }
327 1.1 cgd } else {
328 1.1 cgd #ifdef CRYPT
329 1.1 cgd if (doencrypt) {
330 1.1 cgd (void)fprintf(stderr,
331 1.1 cgd "rlogin: the -x flag requires Kerberos authentication.\n");
332 1.1 cgd exit(1);
333 1.1 cgd }
334 1.1 cgd #endif /* CRYPT */
335 1.1 cgd rem = rcmd(&host, sp->s_port, pw->pw_name, user, term, 0);
336 1.1 cgd }
337 1.1 cgd #else
338 1.1 cgd rem = rcmd(&host, sp->s_port, pw->pw_name, user, term, 0);
339 1.1 cgd #endif /* KERBEROS */
340 1.1 cgd
341 1.1 cgd if (rem < 0)
342 1.1 cgd exit(1);
343 1.1 cgd
344 1.1 cgd if (dflag &&
345 1.1 cgd setsockopt(rem, SOL_SOCKET, SO_DEBUG, &one, sizeof(one)) < 0)
346 1.1 cgd (void)fprintf(stderr, "rlogin: setsockopt: %s.\n",
347 1.1 cgd strerror(errno));
348 1.1 cgd one = IPTOS_LOWDELAY;
349 1.1 cgd if (setsockopt(rem, IPPROTO_IP, IP_TOS, (char *)&one, sizeof(int)) < 0)
350 1.1 cgd perror("rlogin: setsockopt TOS (ignored)");
351 1.1 cgd
352 1.1 cgd (void)setuid(uid);
353 1.1 cgd doit(omask);
354 1.1 cgd /*NOTREACHED*/
355 1.1 cgd }
356 1.1 cgd
357 1.5 mycroft int child;
358 1.1 cgd
359 1.4 cgd void
360 1.1 cgd doit(omask)
361 1.1 cgd long omask;
362 1.1 cgd {
363 1.1 cgd
364 1.1 cgd (void)signal(SIGINT, SIG_IGN);
365 1.4 cgd setsignal(SIGHUP);
366 1.4 cgd setsignal(SIGQUIT);
367 1.5 mycroft mode(1);
368 1.1 cgd child = fork();
369 1.1 cgd if (child == -1) {
370 1.1 cgd (void)fprintf(stderr, "rlogin: fork: %s.\n", strerror(errno));
371 1.1 cgd done(1);
372 1.1 cgd }
373 1.1 cgd if (child == 0) {
374 1.1 cgd if (reader(omask) == 0) {
375 1.1 cgd msg("connection closed.");
376 1.1 cgd exit(0);
377 1.1 cgd }
378 1.1 cgd sleep(1);
379 1.5 mycroft msg("\aconnection closed.");
380 1.1 cgd exit(1);
381 1.1 cgd }
382 1.1 cgd
383 1.1 cgd /*
384 1.1 cgd * We may still own the socket, and may have a pending SIGURG (or might
385 1.4 cgd * receive one soon) that we really want to send to the reader. When
386 1.4 cgd * one of these comes in, the trap copytochild simply copies such
387 1.4 cgd * signals to the child. We can now unblock SIGURG and SIGUSR1
388 1.4 cgd * that were set above.
389 1.1 cgd */
390 1.1 cgd (void)sigsetmask(omask);
391 1.1 cgd (void)signal(SIGCHLD, catch_child);
392 1.1 cgd writer();
393 1.1 cgd msg("closed connection.");
394 1.1 cgd done(0);
395 1.1 cgd }
396 1.1 cgd
397 1.1 cgd /* trap a signal, unless it is being ignored. */
398 1.4 cgd void
399 1.4 cgd setsignal(sig)
400 1.1 cgd int sig;
401 1.1 cgd {
402 1.1 cgd int omask = sigblock(sigmask(sig));
403 1.1 cgd
404 1.4 cgd if (signal(sig, exit) == SIG_IGN)
405 1.1 cgd (void)signal(sig, SIG_IGN);
406 1.1 cgd (void)sigsetmask(omask);
407 1.1 cgd }
408 1.1 cgd
409 1.4 cgd __dead void
410 1.1 cgd done(status)
411 1.1 cgd int status;
412 1.1 cgd {
413 1.1 cgd int w, wstatus;
414 1.1 cgd
415 1.1 cgd mode(0);
416 1.1 cgd if (child > 0) {
417 1.1 cgd /* make sure catch_child does not snap it up */
418 1.1 cgd (void)signal(SIGCHLD, SIG_DFL);
419 1.1 cgd if (kill(child, SIGKILL) >= 0)
420 1.1 cgd while ((w = wait(&wstatus)) > 0 && w != child);
421 1.1 cgd }
422 1.1 cgd exit(status);
423 1.1 cgd }
424 1.1 cgd
425 1.1 cgd int dosigwinch;
426 1.1 cgd
427 1.1 cgd /*
428 1.1 cgd * This is called when the reader process gets the out-of-band (urgent)
429 1.1 cgd * request to turn on the window-changing protocol.
430 1.1 cgd */
431 1.1 cgd void
432 1.4 cgd writeroob(signo)
433 1.4 cgd int signo;
434 1.1 cgd {
435 1.1 cgd if (dosigwinch == 0) {
436 1.1 cgd sendwindow();
437 1.1 cgd (void)signal(SIGWINCH, sigwinch);
438 1.1 cgd }
439 1.1 cgd dosigwinch = 1;
440 1.1 cgd }
441 1.1 cgd
442 1.1 cgd void
443 1.4 cgd catch_child(signo)
444 1.4 cgd int signo;
445 1.1 cgd {
446 1.1 cgd union wait status;
447 1.1 cgd int pid;
448 1.1 cgd
449 1.1 cgd for (;;) {
450 1.4 cgd pid = wait3((int *)&status, WNOHANG|WUNTRACED, NULL);
451 1.1 cgd if (pid == 0)
452 1.1 cgd return;
453 1.1 cgd /* if the child (reader) dies, just quit */
454 1.4 cgd if (pid < 0 || (pid == child && !WIFSTOPPED(status)))
455 1.1 cgd done((int)(status.w_termsig | status.w_retcode));
456 1.1 cgd }
457 1.1 cgd /* NOTREACHED */
458 1.1 cgd }
459 1.1 cgd
460 1.1 cgd /*
461 1.1 cgd * writer: write to remote: 0 -> line.
462 1.1 cgd * ~. terminate
463 1.1 cgd * ~^Z suspend rlogin process.
464 1.1 cgd * ~<delayed-suspend char> suspend rlogin process, but leave reader alone.
465 1.1 cgd */
466 1.4 cgd void
467 1.1 cgd writer()
468 1.1 cgd {
469 1.1 cgd register int bol, local, n;
470 1.1 cgd char c;
471 1.1 cgd
472 1.1 cgd bol = 1; /* beginning of line */
473 1.1 cgd local = 0;
474 1.1 cgd for (;;) {
475 1.1 cgd n = read(STDIN_FILENO, &c, 1);
476 1.1 cgd if (n <= 0) {
477 1.1 cgd if (n < 0 && errno == EINTR)
478 1.1 cgd continue;
479 1.1 cgd break;
480 1.1 cgd }
481 1.1 cgd /*
482 1.1 cgd * If we're at the beginning of the line and recognize a
483 1.1 cgd * command character, then we echo locally. Otherwise,
484 1.1 cgd * characters are echo'd remotely. If the command character
485 1.1 cgd * is doubled, this acts as a force and local echo is
486 1.1 cgd * suppressed.
487 1.1 cgd */
488 1.1 cgd if (bol) {
489 1.1 cgd bol = 0;
490 1.1 cgd if (!noescape && c == escapechar) {
491 1.1 cgd local = 1;
492 1.1 cgd continue;
493 1.1 cgd }
494 1.1 cgd } else if (local) {
495 1.1 cgd local = 0;
496 1.5 mycroft if (c == '.' || CCEQ(deftty.c_cc[VEOF], c)) {
497 1.1 cgd echo(c);
498 1.1 cgd break;
499 1.1 cgd }
500 1.6 mycroft if (CCEQ(deftty.c_cc[VSUSP], c)) {
501 1.1 cgd bol = 1;
502 1.1 cgd echo(c);
503 1.6 mycroft stop(1);
504 1.6 mycroft continue;
505 1.6 mycroft }
506 1.6 mycroft if (CCEQ(deftty.c_cc[VDSUSP], c)) {
507 1.6 mycroft bol = 1;
508 1.6 mycroft echo(c);
509 1.6 mycroft stop(0);
510 1.1 cgd continue;
511 1.1 cgd }
512 1.1 cgd if (c != escapechar)
513 1.1 cgd #ifdef CRYPT
514 1.1 cgd #ifdef KERBEROS
515 1.1 cgd if (doencrypt)
516 1.4 cgd (void)des_write(rem,
517 1.4 cgd (char *)&escapechar, 1);
518 1.1 cgd else
519 1.1 cgd #endif
520 1.1 cgd #endif
521 1.1 cgd (void)write(rem, &escapechar, 1);
522 1.1 cgd }
523 1.1 cgd
524 1.1 cgd #ifdef CRYPT
525 1.1 cgd #ifdef KERBEROS
526 1.1 cgd if (doencrypt) {
527 1.1 cgd if (des_write(rem, &c, 1) == 0) {
528 1.1 cgd msg("line gone");
529 1.1 cgd break;
530 1.1 cgd }
531 1.1 cgd } else
532 1.1 cgd #endif
533 1.1 cgd #endif
534 1.1 cgd if (write(rem, &c, 1) == 0) {
535 1.1 cgd msg("line gone");
536 1.1 cgd break;
537 1.1 cgd }
538 1.5 mycroft bol = CCEQ(deftty.c_cc[VKILL], c) ||
539 1.5 mycroft CCEQ(deftty.c_cc[VEOF], c) ||
540 1.5 mycroft CCEQ(deftty.c_cc[VINTR], c) ||
541 1.5 mycroft CCEQ(deftty.c_cc[VSUSP], c) ||
542 1.1 cgd c == '\r' || c == '\n';
543 1.1 cgd }
544 1.1 cgd }
545 1.1 cgd
546 1.4 cgd void
547 1.4 cgd #if __STDC__
548 1.4 cgd echo(register char c)
549 1.4 cgd #else
550 1.1 cgd echo(c)
551 1.4 cgd register char c;
552 1.4 cgd #endif
553 1.1 cgd {
554 1.1 cgd register char *p;
555 1.1 cgd char buf[8];
556 1.1 cgd
557 1.1 cgd p = buf;
558 1.1 cgd c &= 0177;
559 1.1 cgd *p++ = escapechar;
560 1.1 cgd if (c < ' ') {
561 1.1 cgd *p++ = '^';
562 1.1 cgd *p++ = c + '@';
563 1.1 cgd } else if (c == 0177) {
564 1.1 cgd *p++ = '^';
565 1.1 cgd *p++ = '?';
566 1.1 cgd } else
567 1.1 cgd *p++ = c;
568 1.1 cgd *p++ = '\r';
569 1.1 cgd *p++ = '\n';
570 1.1 cgd (void)write(STDOUT_FILENO, buf, p - buf);
571 1.1 cgd }
572 1.1 cgd
573 1.4 cgd void
574 1.6 mycroft stop(all)
575 1.6 mycroft int all;
576 1.1 cgd {
577 1.1 cgd mode(0);
578 1.1 cgd (void)signal(SIGCHLD, SIG_IGN);
579 1.6 mycroft (void)kill(all ? 0 : getpid(), SIGTSTP);
580 1.1 cgd (void)signal(SIGCHLD, catch_child);
581 1.1 cgd mode(1);
582 1.4 cgd sigwinch(0); /* check for size changes */
583 1.1 cgd }
584 1.1 cgd
585 1.1 cgd void
586 1.4 cgd sigwinch(signo)
587 1.4 cgd int signo;
588 1.1 cgd {
589 1.1 cgd struct winsize ws;
590 1.1 cgd
591 1.1 cgd if (dosigwinch && get_window_size(0, &ws) == 0 &&
592 1.1 cgd bcmp(&ws, &winsize, sizeof(ws))) {
593 1.1 cgd winsize = ws;
594 1.1 cgd sendwindow();
595 1.1 cgd }
596 1.1 cgd }
597 1.1 cgd
598 1.1 cgd /*
599 1.1 cgd * Send the window size to the server via the magic escape
600 1.1 cgd */
601 1.4 cgd void
602 1.1 cgd sendwindow()
603 1.1 cgd {
604 1.1 cgd struct winsize *wp;
605 1.1 cgd char obuf[4 + sizeof (struct winsize)];
606 1.1 cgd
607 1.1 cgd wp = (struct winsize *)(obuf+4);
608 1.1 cgd obuf[0] = 0377;
609 1.1 cgd obuf[1] = 0377;
610 1.1 cgd obuf[2] = 's';
611 1.1 cgd obuf[3] = 's';
612 1.1 cgd wp->ws_row = htons(winsize.ws_row);
613 1.1 cgd wp->ws_col = htons(winsize.ws_col);
614 1.1 cgd wp->ws_xpixel = htons(winsize.ws_xpixel);
615 1.1 cgd wp->ws_ypixel = htons(winsize.ws_ypixel);
616 1.1 cgd
617 1.1 cgd #ifdef CRYPT
618 1.1 cgd #ifdef KERBEROS
619 1.1 cgd if(doencrypt)
620 1.1 cgd (void)des_write(rem, obuf, sizeof(obuf));
621 1.1 cgd else
622 1.1 cgd #endif
623 1.1 cgd #endif
624 1.1 cgd (void)write(rem, obuf, sizeof(obuf));
625 1.1 cgd }
626 1.1 cgd
627 1.1 cgd /*
628 1.1 cgd * reader: read from remote: line -> 1
629 1.1 cgd */
630 1.1 cgd #define READING 1
631 1.1 cgd #define WRITING 2
632 1.1 cgd
633 1.1 cgd jmp_buf rcvtop;
634 1.1 cgd int ppid, rcvcnt, rcvstate;
635 1.1 cgd char rcvbuf[8 * 1024];
636 1.1 cgd
637 1.1 cgd void
638 1.4 cgd oob(signo)
639 1.4 cgd int signo;
640 1.1 cgd {
641 1.5 mycroft struct termios tty;
642 1.8 mycroft int atmark, n, rcvd;
643 1.1 cgd char waste[BUFSIZ], mark;
644 1.1 cgd
645 1.1 cgd rcvd = 0;
646 1.4 cgd while (recv(rem, &mark, 1, MSG_OOB) < 0) {
647 1.1 cgd switch (errno) {
648 1.1 cgd case EWOULDBLOCK:
649 1.1 cgd /*
650 1.1 cgd * Urgent data not here yet. It may not be possible
651 1.1 cgd * to send it yet if we are blocked for output and
652 1.1 cgd * our input buffer is full.
653 1.1 cgd */
654 1.1 cgd if (rcvcnt < sizeof(rcvbuf)) {
655 1.1 cgd n = read(rem, rcvbuf + rcvcnt,
656 1.1 cgd sizeof(rcvbuf) - rcvcnt);
657 1.1 cgd if (n <= 0)
658 1.1 cgd return;
659 1.1 cgd rcvd += n;
660 1.1 cgd } else {
661 1.1 cgd n = read(rem, waste, sizeof(waste));
662 1.1 cgd if (n <= 0)
663 1.1 cgd return;
664 1.1 cgd }
665 1.1 cgd continue;
666 1.1 cgd default:
667 1.1 cgd return;
668 1.4 cgd }
669 1.1 cgd }
670 1.1 cgd if (mark & TIOCPKT_WINDOW) {
671 1.1 cgd /* Let server know about window size changes */
672 1.1 cgd (void)kill(ppid, SIGUSR1);
673 1.1 cgd }
674 1.1 cgd if (!eight && (mark & TIOCPKT_NOSTOP)) {
675 1.5 mycroft (void)tcgetattr(0, &tty);
676 1.5 mycroft tty.c_iflag &= ~IXON;
677 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
678 1.1 cgd }
679 1.1 cgd if (!eight && (mark & TIOCPKT_DOSTOP)) {
680 1.5 mycroft (void)tcgetattr(0, &tty);
681 1.5 mycroft tty.c_iflag |= (deftty.c_iflag & IXON);
682 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
683 1.1 cgd }
684 1.1 cgd if (mark & TIOCPKT_FLUSHWRITE) {
685 1.8 mycroft (void)tcflush(1, TCIOFLUSH);
686 1.1 cgd for (;;) {
687 1.1 cgd if (ioctl(rem, SIOCATMARK, &atmark) < 0) {
688 1.1 cgd (void)fprintf(stderr, "rlogin: ioctl: %s.\n",
689 1.1 cgd strerror(errno));
690 1.1 cgd break;
691 1.1 cgd }
692 1.1 cgd if (atmark)
693 1.1 cgd break;
694 1.1 cgd n = read(rem, waste, sizeof (waste));
695 1.1 cgd if (n <= 0)
696 1.1 cgd break;
697 1.1 cgd }
698 1.1 cgd /*
699 1.1 cgd * Don't want any pending data to be output, so clear the recv
700 1.1 cgd * buffer. If we were hanging on a write when interrupted,
701 1.1 cgd * don't want it to restart. If we were reading, restart
702 1.1 cgd * anyway.
703 1.1 cgd */
704 1.1 cgd rcvcnt = 0;
705 1.1 cgd longjmp(rcvtop, 1);
706 1.1 cgd }
707 1.1 cgd
708 1.1 cgd /* oob does not do FLUSHREAD (alas!) */
709 1.1 cgd
710 1.1 cgd /*
711 1.1 cgd * If we filled the receive buffer while a read was pending, longjmp
712 1.1 cgd * to the top to restart appropriately. Don't abort a pending write,
713 1.1 cgd * however, or we won't know how much was written.
714 1.1 cgd */
715 1.1 cgd if (rcvd && rcvstate == READING)
716 1.1 cgd longjmp(rcvtop, 1);
717 1.1 cgd }
718 1.1 cgd
719 1.1 cgd /* reader: read from remote: line -> 1 */
720 1.4 cgd int
721 1.1 cgd reader(omask)
722 1.1 cgd int omask;
723 1.1 cgd {
724 1.4 cgd int pid, n, remaining;
725 1.4 cgd char *bufp;
726 1.1 cgd
727 1.4 cgd #if BSD >= 43 || defined(SUNOS4)
728 1.4 cgd pid = getpid(); /* modern systems use positives for pid */
729 1.1 cgd #else
730 1.4 cgd pid = -getpid(); /* old broken systems use negatives */
731 1.1 cgd #endif
732 1.1 cgd (void)signal(SIGTTOU, SIG_IGN);
733 1.1 cgd (void)signal(SIGURG, oob);
734 1.1 cgd ppid = getppid();
735 1.1 cgd (void)fcntl(rem, F_SETOWN, pid);
736 1.1 cgd (void)setjmp(rcvtop);
737 1.1 cgd (void)sigsetmask(omask);
738 1.4 cgd bufp = rcvbuf;
739 1.1 cgd for (;;) {
740 1.1 cgd while ((remaining = rcvcnt - (bufp - rcvbuf)) > 0) {
741 1.1 cgd rcvstate = WRITING;
742 1.1 cgd n = write(STDOUT_FILENO, bufp, remaining);
743 1.1 cgd if (n < 0) {
744 1.1 cgd if (errno != EINTR)
745 1.4 cgd return (-1);
746 1.1 cgd continue;
747 1.1 cgd }
748 1.1 cgd bufp += n;
749 1.1 cgd }
750 1.1 cgd bufp = rcvbuf;
751 1.1 cgd rcvcnt = 0;
752 1.1 cgd rcvstate = READING;
753 1.1 cgd
754 1.1 cgd #ifdef CRYPT
755 1.1 cgd #ifdef KERBEROS
756 1.1 cgd if (doencrypt)
757 1.1 cgd rcvcnt = des_read(rem, rcvbuf, sizeof(rcvbuf));
758 1.1 cgd else
759 1.1 cgd #endif
760 1.1 cgd #endif
761 1.1 cgd rcvcnt = read(rem, rcvbuf, sizeof (rcvbuf));
762 1.1 cgd if (rcvcnt == 0)
763 1.1 cgd return (0);
764 1.1 cgd if (rcvcnt < 0) {
765 1.1 cgd if (errno == EINTR)
766 1.1 cgd continue;
767 1.1 cgd (void)fprintf(stderr, "rlogin: read: %s.\n",
768 1.1 cgd strerror(errno));
769 1.4 cgd return (-1);
770 1.1 cgd }
771 1.1 cgd }
772 1.1 cgd }
773 1.1 cgd
774 1.4 cgd void
775 1.1 cgd mode(f)
776 1.4 cgd int f;
777 1.1 cgd {
778 1.5 mycroft struct termios tty;
779 1.5 mycroft
780 1.5 mycroft switch (f) {
781 1.1 cgd case 0:
782 1.5 mycroft (void)tcsetattr(0, TCSANOW, &deftty);
783 1.1 cgd break;
784 1.1 cgd case 1:
785 1.5 mycroft (void)tcgetattr(0, &deftty);
786 1.5 mycroft tty = deftty;
787 1.7 mycroft /* This is loosely derived from sys/compat/tty_compat.c. */
788 1.7 mycroft tty.c_lflag &= ~(ECHO|ICANON|ISIG|IEXTEN);
789 1.5 mycroft tty.c_iflag &= ~ICRNL;
790 1.5 mycroft tty.c_oflag &= ~OPOST;
791 1.9 christos tty.c_cc[VMIN] = 1;
792 1.9 christos tty.c_cc[VTIME] = 0;
793 1.5 mycroft if (eight) {
794 1.5 mycroft tty.c_iflag &= IXOFF;
795 1.5 mycroft tty.c_cflag &= ~(CSIZE|PARENB);
796 1.5 mycroft tty.c_cflag |= CS8;
797 1.5 mycroft }
798 1.5 mycroft (void)tcsetattr(0, TCSANOW, &tty);
799 1.1 cgd break;
800 1.1 cgd default:
801 1.1 cgd return;
802 1.1 cgd }
803 1.1 cgd }
804 1.1 cgd
805 1.1 cgd void
806 1.4 cgd lostpeer(signo)
807 1.4 cgd int signo;
808 1.1 cgd {
809 1.1 cgd (void)signal(SIGPIPE, SIG_IGN);
810 1.5 mycroft msg("\aconnection closed.");
811 1.1 cgd done(1);
812 1.1 cgd }
813 1.1 cgd
814 1.1 cgd /* copy SIGURGs to the child process. */
815 1.1 cgd void
816 1.4 cgd copytochild(signo)
817 1.4 cgd int signo;
818 1.1 cgd {
819 1.1 cgd (void)kill(child, SIGURG);
820 1.1 cgd }
821 1.1 cgd
822 1.4 cgd void
823 1.1 cgd msg(str)
824 1.1 cgd char *str;
825 1.1 cgd {
826 1.1 cgd (void)fprintf(stderr, "rlogin: %s\r\n", str);
827 1.1 cgd }
828 1.1 cgd
829 1.1 cgd #ifdef KERBEROS
830 1.1 cgd /* VARARGS */
831 1.4 cgd void
832 1.4 cgd #if __STDC__
833 1.4 cgd warning(const char *fmt, ...)
834 1.4 cgd #else
835 1.4 cgd warning(fmt, va_alist)
836 1.4 cgd char *fmt;
837 1.4 cgd va_dcl
838 1.4 cgd #endif
839 1.1 cgd {
840 1.1 cgd va_list ap;
841 1.1 cgd
842 1.1 cgd (void)fprintf(stderr, "rlogin: warning, using standard rlogin: ");
843 1.4 cgd #ifdef __STDC__
844 1.4 cgd va_start(ap, fmt);
845 1.4 cgd #else
846 1.1 cgd va_start(ap);
847 1.4 cgd #endif
848 1.1 cgd vfprintf(stderr, fmt, ap);
849 1.1 cgd va_end(ap);
850 1.1 cgd (void)fprintf(stderr, ".\n");
851 1.1 cgd }
852 1.1 cgd #endif
853 1.1 cgd
854 1.4 cgd __dead void
855 1.1 cgd usage()
856 1.1 cgd {
857 1.1 cgd (void)fprintf(stderr,
858 1.1 cgd "usage: rlogin [ -%s]%s[-e char] [ -l username ] host\n",
859 1.1 cgd #ifdef KERBEROS
860 1.1 cgd #ifdef CRYPT
861 1.4 cgd "8EKLx", " [-k realm] ");
862 1.1 cgd #else
863 1.4 cgd "8EKL", " [-k realm] ");
864 1.1 cgd #endif
865 1.1 cgd #else
866 1.1 cgd "8EL", " ");
867 1.1 cgd #endif
868 1.1 cgd exit(1);
869 1.1 cgd }
870 1.1 cgd
871 1.1 cgd /*
872 1.4 cgd * The following routine provides compatibility (such as it is) between older
873 1.1 cgd * Suns and others. Suns have only a `ttysize', so we convert it to a winsize.
874 1.1 cgd */
875 1.4 cgd #ifdef OLDSUN
876 1.4 cgd int
877 1.1 cgd get_window_size(fd, wp)
878 1.1 cgd int fd;
879 1.1 cgd struct winsize *wp;
880 1.1 cgd {
881 1.1 cgd struct ttysize ts;
882 1.1 cgd int error;
883 1.1 cgd
884 1.1 cgd if ((error = ioctl(0, TIOCGSIZE, &ts)) != 0)
885 1.4 cgd return (error);
886 1.1 cgd wp->ws_row = ts.ts_lines;
887 1.1 cgd wp->ws_col = ts.ts_cols;
888 1.1 cgd wp->ws_xpixel = 0;
889 1.1 cgd wp->ws_ypixel = 0;
890 1.4 cgd return (0);
891 1.1 cgd }
892 1.1 cgd #endif
893 1.1 cgd
894 1.4 cgd u_int
895 1.1 cgd getescape(p)
896 1.1 cgd register char *p;
897 1.1 cgd {
898 1.1 cgd long val;
899 1.1 cgd int len;
900 1.1 cgd
901 1.1 cgd if ((len = strlen(p)) == 1) /* use any single char, including '\' */
902 1.4 cgd return ((u_int)*p);
903 1.1 cgd /* otherwise, \nnn */
904 1.1 cgd if (*p == '\\' && len >= 2 && len <= 4) {
905 1.4 cgd val = strtol(++p, NULL, 8);
906 1.1 cgd for (;;) {
907 1.1 cgd if (!*++p)
908 1.4 cgd return ((u_int)val);
909 1.1 cgd if (*p < '0' || *p > '8')
910 1.1 cgd break;
911 1.1 cgd }
912 1.1 cgd }
913 1.1 cgd msg("illegal option value -- e");
914 1.1 cgd usage();
915 1.1 cgd /* NOTREACHED */
916 1.1 cgd }
917