Annotation of src/usr.bin/cu/cu.c, Revision 1.19
1.19 ! nicm 1: /* $OpenBSD: cu.c,v 1.18 2014/03/31 09:16:26 nicm Exp $ */
1.1 nicm 2:
3: /*
4: * Copyright (c) 2012 Nicholas Marriott <nicm@openbsd.org>
5: *
6: * Permission to use, copy, modify, and distribute this software for any
7: * purpose with or without fee is hereby granted, provided that the above
8: * copyright notice and this permission notice appear in all copies.
9: *
10: * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11: * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12: * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13: * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14: * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
15: * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
16: * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17: */
18:
19: #include <sys/param.h>
20: #include <sys/ioctl.h>
21:
1.11 halex 22: #include <ctype.h>
1.1 nicm 23: #include <err.h>
24: #include <event.h>
25: #include <fcntl.h>
26: #include <getopt.h>
27: #include <paths.h>
28: #include <pwd.h>
29: #include <signal.h>
30: #include <stdio.h>
31: #include <stdlib.h>
32: #include <string.h>
33: #include <termios.h>
34: #include <unistd.h>
35:
36: #include "cu.h"
37:
38: extern char *__progname;
39:
1.6 nicm 40: FILE *record_file;
1.1 nicm 41: struct termios saved_tio;
42: struct bufferevent *input_ev;
43: struct bufferevent *output_ev;
1.16 nicm 44: const char *line_path = NULL;
45: int line_speed = -1;
1.1 nicm 46: int line_fd;
1.12 nicm 47: struct termios line_tio;
1.1 nicm 48: struct bufferevent *line_ev;
49: struct event sigterm_ev;
1.8 nicm 50: struct event sighup_ev;
1.1 nicm 51: enum {
52: STATE_NONE,
53: STATE_NEWLINE,
54: STATE_TILDE
55: } last_state = STATE_NEWLINE;
56:
57: __dead void usage(void);
58: void signal_event(int, short, void *);
59: void stream_read(struct bufferevent *, void *);
60: void stream_error(struct bufferevent *, short, void *);
61: void line_read(struct bufferevent *, void *);
62: void line_error(struct bufferevent *, short, void *);
1.17 nicm 63: void try_remote(const char *, const char *, const char *);
1.1 nicm 64:
65: __dead void
66: usage(void)
67: {
1.16 nicm 68: fprintf(stderr, "usage: %s [-l line] [-s speed | -speed] [host]\n",
1.7 nicm 69: __progname);
1.1 nicm 70: exit(1);
71: }
72:
73: int
74: main(int argc, char **argv)
75: {
1.16 nicm 76: const char *errstr;
1.17 nicm 77: char *tmp, *s, *host;
1.16 nicm 78: int opt, i;
1.1 nicm 79:
1.16 nicm 80: if (isatty(STDIN_FILENO) && tcgetattr(STDIN_FILENO, &saved_tio) != 0)
81: err(1, "tcgetattr");
1.1 nicm 82:
83: /*
84: * Convert obsolescent -### speed to modern -s### syntax which getopt()
85: * can handle.
86: */
87: for (i = 1; i < argc; i++) {
1.10 dlg 88: if (strcmp("--", argv[i]) == 0)
89: break;
1.15 deraadt 90: if (argv[i][0] != '-' || !isdigit((unsigned char)argv[i][1]))
1.10 dlg 91: continue;
92:
93: if (asprintf(&argv[i], "-s%s", &argv[i][1]) == -1)
94: errx(1, "speed asprintf");
1.1 nicm 95: }
96:
97: while ((opt = getopt(argc, argv, "l:s:")) != -1) {
98: switch (opt) {
99: case 'l':
1.16 nicm 100: line_path = optarg;
1.1 nicm 101: break;
102: case 's':
1.16 nicm 103: line_speed = strtonum(optarg, 0, INT_MAX, &errstr);
1.1 nicm 104: if (errstr != NULL)
105: errx(1, "speed is %s: %s", errstr, optarg);
106: break;
107: default:
108: usage();
109: }
110: }
111: argc -= optind;
112: argv += optind;
1.16 nicm 113: if (argc != 0 && argc != 1)
1.1 nicm 114: usage();
115:
1.17 nicm 116: if (argc == 1)
117: host = argv[0];
118: else
119: host = getenv("HOST");
120: if (host != NULL && *host != '\0') {
1.19 ! nicm 121: if (*host == '/') {
! 122: if (line_path == NULL)
! 123: line_path = host;
! 124: } else {
1.18 nicm 125: s = getenv("REMOTE");
126: if (s != NULL && *s == '/')
127: try_remote(host, s, NULL);
128: else
129: try_remote(host, NULL, s);
130: }
1.17 nicm 131: }
1.16 nicm 132:
133: if (line_path == NULL)
134: line_path = "/dev/cua00";
135: if (line_speed == -1)
136: line_speed = 9600;
137:
138: if (strchr(line_path, '/') == NULL) {
139: if (asprintf(&tmp, "%s%s", _PATH_DEV, line_path) == -1)
1.1 nicm 140: err(1, "asprintf");
1.16 nicm 141: line_path = tmp;
1.1 nicm 142: }
143:
1.16 nicm 144: line_fd = open(line_path, O_RDWR);
1.1 nicm 145: if (line_fd < 0)
1.16 nicm 146: err(1, "open(\"%s\")", line_path);
1.1 nicm 147: if (ioctl(line_fd, TIOCEXCL) != 0)
148: err(1, "ioctl(TIOCEXCL)");
1.12 nicm 149: if (tcgetattr(line_fd, &line_tio) != 0)
150: err(1, "tcgetattr");
1.16 nicm 151: if (set_line(line_speed) != 0)
1.4 nicm 152: err(1, "tcsetattr");
1.1 nicm 153:
154: event_init();
1.3 nicm 155:
1.1 nicm 156: signal_set(&sigterm_ev, SIGTERM, signal_event, NULL);
157: signal_add(&sigterm_ev, NULL);
1.8 nicm 158: signal_set(&sighup_ev, SIGHUP, signal_event, NULL);
159: signal_add(&sighup_ev, NULL);
1.3 nicm 160: if (signal(SIGINT, SIG_IGN) == SIG_ERR)
161: err(1, "signal");
162: if (signal(SIGQUIT, SIG_IGN) == SIG_ERR)
163: err(1, "signal");
1.1 nicm 164:
1.4 nicm 165: set_termios(); /* after this use cu_err and friends */
1.1 nicm 166:
167: /* stdin and stdout get separate events */
168: input_ev = bufferevent_new(STDIN_FILENO, stream_read, NULL,
169: stream_error, NULL);
170: bufferevent_enable(input_ev, EV_READ);
171: output_ev = bufferevent_new(STDOUT_FILENO, NULL, NULL, stream_error,
172: NULL);
173: bufferevent_enable(output_ev, EV_WRITE);
174:
175: line_ev = bufferevent_new(line_fd, line_read, NULL, line_error,
176: NULL);
177: bufferevent_enable(line_ev, EV_READ|EV_WRITE);
178:
1.16 nicm 179: printf("Connected to %s (speed %d)\r\n", line_path, line_speed);
1.1 nicm 180: event_dispatch();
181:
1.5 nicm 182: restore_termios();
1.1 nicm 183: printf("\r\n[EOT]\n");
184:
185: exit(0);
186: }
187:
188: void
189: signal_event(int fd, short events, void *data)
190: {
1.5 nicm 191: restore_termios();
1.1 nicm 192: printf("\r\n[SIG%s]\n", sys_signame[fd]);
193:
194: exit(0);
195: }
196:
197: void
198: set_termios(void)
199: {
200: struct termios tio;
201:
202: if (!isatty(STDIN_FILENO))
203: return;
204:
205: memcpy(&tio, &saved_tio, sizeof(tio));
206: tio.c_lflag &= ~(ICANON|IEXTEN|ECHO);
207: tio.c_iflag &= ~(INPCK|ICRNL);
208: tio.c_oflag &= ~OPOST;
209: tio.c_cc[VMIN] = 1;
210: tio.c_cc[VTIME] = 0;
211: tio.c_cc[VDISCARD] = _POSIX_VDISABLE;
212: tio.c_cc[VDSUSP] = _POSIX_VDISABLE;
213: tio.c_cc[VINTR] = _POSIX_VDISABLE;
214: tio.c_cc[VLNEXT] = _POSIX_VDISABLE;
215: tio.c_cc[VQUIT] = _POSIX_VDISABLE;
216: tio.c_cc[VSUSP] = _POSIX_VDISABLE;
217: if (tcsetattr(STDIN_FILENO, TCSAFLUSH, &tio) != 0)
1.4 nicm 218: cu_err(1, "tcsetattr");
1.1 nicm 219: }
220:
221: void
222: restore_termios(void)
223: {
1.4 nicm 224: if (isatty(STDIN_FILENO))
225: tcsetattr(STDIN_FILENO, TCSAFLUSH, &saved_tio);
1.2 nicm 226: }
227:
228: int
229: set_line(int speed)
230: {
231: struct termios tio;
232:
1.12 nicm 233: memcpy(&tio, &line_tio, sizeof(tio));
234: tio.c_iflag &= ~(ISTRIP|ICRNL);
235: tio.c_oflag &= ~OPOST;
236: tio.c_lflag &= ~(ICANON|ISIG|IEXTEN|ECHO);
237: tio.c_cflag &= ~(CSIZE|PARENB);
238: tio.c_cflag |= CREAD|CS8|CLOCAL;
1.2 nicm 239: tio.c_cc[VMIN] = 1;
240: tio.c_cc[VTIME] = 0;
241: cfsetspeed(&tio, speed);
1.4 nicm 242: if (tcsetattr(line_fd, TCSAFLUSH, &tio) != 0)
1.2 nicm 243: return (-1);
244: return (0);
1.1 nicm 245: }
246:
247: void
248: stream_read(struct bufferevent *bufev, void *data)
249: {
250: char *new_data, *ptr;
251: size_t new_size;
252: int state_change;
253:
254: new_data = EVBUFFER_DATA(input_ev->input);
255: new_size = EVBUFFER_LENGTH(input_ev->input);
256: if (new_size == 0)
257: return;
258:
259: state_change = isatty(STDIN_FILENO);
260: for (ptr = new_data; ptr < new_data + new_size; ptr++) {
261: switch (last_state) {
262: case STATE_NONE:
263: if (state_change && *ptr == '\r')
264: last_state = STATE_NEWLINE;
265: break;
266: case STATE_NEWLINE:
267: if (state_change && *ptr == '~') {
268: last_state = STATE_TILDE;
269: continue;
270: }
271: if (*ptr != '\r')
272: last_state = STATE_NONE;
273: break;
274: case STATE_TILDE:
275: do_command(*ptr);
276: last_state = STATE_NEWLINE;
277: continue;
278: }
279:
280: bufferevent_write(line_ev, ptr, 1);
281: }
282:
283: evbuffer_drain(input_ev->input, new_size);
284: }
285:
286: void
287: stream_error(struct bufferevent *bufev, short what, void *data)
288: {
289: event_loopexit(NULL);
290: }
291:
292: void
293: line_read(struct bufferevent *bufev, void *data)
294: {
295: char *new_data;
296: size_t new_size;
297:
298: new_data = EVBUFFER_DATA(line_ev->input);
299: new_size = EVBUFFER_LENGTH(line_ev->input);
300: if (new_size == 0)
301: return;
302:
1.6 nicm 303: if (record_file != NULL)
304: fwrite(new_data, 1, new_size, record_file);
1.1 nicm 305: bufferevent_write(output_ev, new_data, new_size);
306:
307: evbuffer_drain(line_ev->input, new_size);
308: }
309:
310: void
311: line_error(struct bufferevent *bufev, short what, void *data)
312: {
313: event_loopexit(NULL);
1.16 nicm 314: }
315:
316: void
1.17 nicm 317: try_remote(const char *host, const char *path, const char *entry)
1.16 nicm 318: {
319: const char *paths[] = { "/etc/remote", NULL, NULL };
320: char *cp, *s;
321: long l;
322: int error;
323:
324: if (path != NULL) {
325: paths[0] = path;
326: paths[1] = "/etc/remote";
327: }
328:
1.17 nicm 329: if (entry != NULL && cgetset(entry) != 0)
330: cu_errx(1, "cgetset failed");
1.16 nicm 331: error = cgetent(&cp, (char**)paths, (char*)host);
332: if (error < 0) {
333: switch (error) {
334: case -1:
335: cu_errx(1, "unknown host %s", host);
336: case -2:
337: cu_errx(1, "can't open remote file");
338: case -3:
339: cu_errx(1, "loop in remote file");
340: default:
341: cu_errx(1, "unknown error in remote file");
342: }
343: }
344:
345: if (line_path == NULL && cgetstr(cp, "dv", &s) >= 0)
346: line_path = s;
347:
348: if (line_speed == -1 && cgetnum(cp, "br", &l) >= 0) {
349: if (l < 0 || l > INT_MAX)
350: cu_errx(1, "speed out of range");
351: line_speed = l;
352: }
1.1 nicm 353: }
354:
355: /* Expands tildes in the file name. Based on code from ssh/misc.c. */
356: char *
357: tilde_expand(const char *filename1)
358: {
1.14 tedu 359: const char *filename, *path, *sep;
360: char user[128], *out;
1.1 nicm 361: struct passwd *pw;
362: u_int len, slash;
1.14 tedu 363: int rv;
1.1 nicm 364:
365: if (*filename1 != '~')
366: goto no_change;
367: filename = filename1 + 1;
368:
369: path = strchr(filename, '/');
370: if (path != NULL && path > filename) { /* ~user/path */
371: slash = path - filename;
372: if (slash > sizeof(user) - 1)
373: goto no_change;
374: memcpy(user, filename, slash);
375: user[slash] = '\0';
376: if ((pw = getpwnam(user)) == NULL)
377: goto no_change;
378: } else if ((pw = getpwuid(getuid())) == NULL) /* ~/path */
379: goto no_change;
380:
381: /* Make sure directory has a trailing '/' */
382: len = strlen(pw->pw_dir);
1.14 tedu 383: if (len == 0 || pw->pw_dir[len - 1] != '/')
384: sep = "/";
385: else
386: sep = "";
1.1 nicm 387:
388: /* Skip leading '/' from specified path */
389: if (path != NULL)
390: filename = path + 1;
1.14 tedu 391:
392: if ((rv = asprintf(&out, "%s%s%s", pw->pw_dir, sep, filename)) == -1)
393: cu_err(1, "asprintf");
394: if (rv >= MAXPATHLEN) {
395: free(out);
1.1 nicm 396: goto no_change;
1.14 tedu 397: }
1.1 nicm 398:
399: return (out);
400:
401: no_change:
402: out = strdup(filename1);
403: if (out == NULL)
1.4 nicm 404: cu_err(1, "strdup");
1.1 nicm 405: return (out);
406: }
![[BACK]](/icons/back.gif){kind=icon}
Return to cu.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / cu