From 7f4c79484bd46d3b3699694d9ef6931c9fcbd0a5 Mon Sep 17 00:00:00 2001 From: "Ugen J.S. Antsilevich" Date: Fri, 17 Feb 1995 14:36:03 +0000 Subject: [PATCH] This is watch - programm to work with /dev/snp, it still lacks manpage-i will commit it today later. For now to test try: watch [ttyname] :) --- usr.bin/watch/Makefile | 6 + usr.bin/watch/watch.c | 404 ++++++++++++++++++++++++++++++++++++++++ usr.sbin/watch/Makefile | 6 + usr.sbin/watch/watch.c | 404 ++++++++++++++++++++++++++++++++++++++++ 4 files changed, 820 insertions(+) create mode 100644 usr.bin/watch/Makefile create mode 100644 usr.bin/watch/watch.c create mode 100644 usr.sbin/watch/Makefile create mode 100644 usr.sbin/watch/watch.c diff --git a/usr.bin/watch/Makefile b/usr.bin/watch/Makefile new file mode 100644 index 000000000000..3d541639ef6a --- /dev/null +++ b/usr.bin/watch/Makefile @@ -0,0 +1,6 @@ +PROG= watch +NOMAN= +BINMODE=500 +LDADD= -ltermcap + +.include diff --git a/usr.bin/watch/watch.c b/usr.bin/watch/watch.c new file mode 100644 index 000000000000..f5e4007c2a41 --- /dev/null +++ b/usr.bin/watch/watch.c @@ -0,0 +1,404 @@ +/* + * Copyright (c) 1995 Ugen J.S.Antsilevich + * + * Redistribution and use in source forms, with and without modification, + * are permitted provided that this entire comment appears intact. + * + * Redistribution in binary form may occur without any restrictions. + * Obviously, it would be nice if you gave credit where credit is due + * but requiring it would be too onerous. + * + * This software is provided ``AS IS'' without any warranties of any kind. + * + * Snoop stuff. + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + + +#define MSG_INIT "Snoop started." +#define MSG_OFLOW "Snoop stopped due to overflow.Reconnecting." +#define MSG_CLOSED "Snoop stopped due to tty close.Reconnecting." +#define MSG_CHANGE "Snoop device change by user request." + + +#define DEV_NAME_LEN 12 /* for /dev/ttyXX++ */ +#define MIN_SIZE 256 + +#define CHR_SWITCH 24 /* Ctrl+X */ +#define CHR_CLEAR 23 /* Ctrl+V */ + + +int opt_reconn_close = 0; +int opt_reconn_oflow = 0; +int opt_interactive = 1; +int opt_timestamp = 0; + +char dev_name[DEV_NAME_LEN]; +int snp_io; +struct snptty snp_tty; +int std_in = 0, std_out = 1; + + +int clear_ok = 0; +struct sgttyb sgo; +char tbuf[1024], buf[1024]; + + +void +clear() +{ + if (clear_ok) + tputs(buf, 1, putchar); + fflush(stdout); +} + +void +timestamp(buf) + char *buf; +{ + time_t t; + char btmp[1024]; + clear(); + printf("\n---------------------------------------------\n"); + t = time(NULL); + strftime(btmp, 1024, "Time: %d %b %H:%M", localtime(&t)); + printf("%s\n", btmp); + printf("%s\n", buf); + printf("---------------------------------------------\n"); + fflush(stdout); +} + +void +set_tty() +{ + struct sgttyb sgn; + ioctl(std_in, TIOCGETP, &sgo); + /* bcopy(&sgn, &sgo, sizeof(struct sgttyb)); */ + sgn = sgo; + sgn.sg_flags |= CBREAK; + sgn.sg_flags &= ~ECHO; + ioctl(std_in, TIOCSETP, &sgn); +} + +void +unset_tty() +{ + ioctl(std_in, TIOCSETP, &sgo); +} + + +void +fatal(buf) + char *buf; +{ + unset_tty(); + if (buf) + fprintf(stderr, "Fatal: %s\n", buf); + exit(1); +} + +int +open_snp() +{ + char snp[DEV_NAME_LEN] = "/dev/snpX"; + char c; + int f; + for (c = '0'; c <= '9'; c++) { + snp[8] = c; + if ((f = open(snp, O_RDONLY)) < 0) + continue; + return f; + } + fatal("Cannot open snoop device."); +} + + +void +cleanup() +{ + if (opt_timestamp) + timestamp("Logging Exited."); + close(snp_io); + unset_tty(); + exit(0); +} + + +void +show_usage() +{ + printf("watch -[ciot] [tty name]\n"); + exit(1); +} + +void +setup_scr() +{ + char *cbuf = buf, *term; + if (!opt_interactive) + return; + if ((term = getenv("TERM"))) + if (tgetent(tbuf, term) == 1) + if (tgetstr("cl", &cbuf)) + clear_ok = 1; + clear(); + set_tty(); +} + + +int +ctoh(c) + char c; +{ + if (c >= '0' && c <= '9') + return (int) (c - '0'); + + if (c >= 'a' && c <= 'f') + return (int) (c - 'a' + 10); + + fatal("Bad tty number."); +} + + +void +detach_snp() +{ + struct snptty st; + st.st_type = -1; + st.st_unit = -1; + ioctl(snp_io, SNPSTTY, &st); +} + +void +attach_snp() +{ + if (ioctl(snp_io, SNPSTTY, &snp_tty) != 0) + fatal("Cannot attach to tty."); + if (opt_timestamp) + timestamp("Logging Started."); +} + + +void +set_dev(name) + char *name; +{ + char buf[DEV_NAME_LEN], num[DEV_NAME_LEN]; + int unitbase = 0; + + if (strlen(name) > 5 && !strncmp(name, "/dev/", 5)) + strcpy(buf, &(name[5])); + else + strcpy(buf, name); + + if (strlen(buf) < 4) + fatal("Bad tty name."); + + if (!strncmp(buf, "tty", 3)) + switch (buf[3]) { + case 'v': + snp_tty.st_unit = ctoh(buf[4]); + snp_tty.st_type = ST_VTY; + goto got_num; + case 'r': + unitbase += 16; + case 'q': + unitbase += 16; + case 'p': + snp_tty.st_unit = ctoh(buf[4]) + unitbase; + snp_tty.st_type = ST_PTY; + goto got_num; + case '0': + case 'd': + snp_tty.st_unit = ctoh(buf[4]); + snp_tty.st_type = ST_SIO; + goto got_num; + default: + fatal("Bad tty name."); + + } + + + if (!strncmp(buf, "vty", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_VTY; + goto got_num; + } + if (!strncmp(buf, "pty", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_PTY; + goto got_num; + } + if (!strncmp(buf, "sio", 3) || !strncmp(buf, "cua", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_SIO; + goto got_num; + } + fatal("Bad tty name."); +got_num: + attach_snp(); +} + +void +ask_dev(dev_name, msg) + char *dev_name, *msg; +{ + char buf[DEV_NAME_LEN]; + int len; + + clear(); + unset_tty(); + + if (msg) + printf("%s\n", msg); + if (dev_name) + printf("Enter device name [%s]:", dev_name); + else + printf("Enter device name:"); + + if (fgets(buf, DEV_NAME_LEN - 1, stdin)) { + len = strlen(buf); + if (buf[len - 1] == '\n') + buf[len - 1] = '\0'; + if (buf[0] != '\0' && buf[0] != ' ') + strcpy(dev_name, buf); + } + set_tty(); +} + + +void +main(ac, av) + int ac; + char **av; +{ + int res, nread, b_size = MIN_SIZE; + extern int optind; + char ch, *buf; + fd_set fd_s; + + if (getuid() != 0) + fatal(NULL); + + if (isatty(std_out)) + opt_interactive = 1; + else + opt_interactive = 0; + + + while ((ch = getopt(ac, av, "ciot")) != EOF) + switch (ch) { + case 'c': + opt_reconn_close = 1; + break; + case 'i': + opt_interactive = 1; + break; + case 'o': + opt_reconn_oflow = 1; + break; + case 't': + opt_timestamp = 1; + break; + case '?': + default: + show_usage(); + exit(1); + } + + signal(SIGINT, cleanup); + + setup_scr(); + snp_io = open_snp(); + + if (*(av += optind) == NULL) { + if (opt_interactive) + ask_dev(dev_name, MSG_INIT); + else + fatal("No device name given."); + } else + strncpy(dev_name, *av, DEV_NAME_LEN); + + set_dev(dev_name); + + if (!(buf = (char *) malloc(b_size))) + fatal("Cannot malloc()."); + + FD_ZERO(&fd_s); + + while (1) { + if (opt_interactive) + FD_SET(std_in, &fd_s); + FD_SET(snp_io, &fd_s); + res = select(snp_io + 1, &fd_s, NULL, NULL, NULL); + if (opt_interactive && FD_ISSET(std_in, &fd_s)) { + switch (ch = getchar()) { + case CHR_CLEAR: + clear(); + break; + case CHR_SWITCH: + /* detach_snp(); */ + ask_dev(dev_name, MSG_CHANGE); + set_dev(dev_name); + break; + default: + } + } + if (!FD_ISSET(snp_io, &fd_s)) + continue; + + if ((res = ioctl(snp_io, FIONREAD, &nread)) != 0) + fatal("ioctl() failed."); + + switch (nread) { + case SNP_OFLOW: + if (opt_reconn_oflow) + attach_snp(); + else if (opt_interactive) { + ask_dev(dev_name, MSG_OFLOW); + set_dev(dev_name); + } else + cleanup(); + case SNP_DETACH: + case SNP_TTYCLOSE: + if (opt_reconn_close) + attach_snp(); + else if (opt_interactive) { + ask_dev(dev_name, MSG_CLOSED); + set_dev(dev_name); + } else + cleanup(); + default: + if (nread < (b_size / 2) && (b_size / 2) > MIN_SIZE) { + free(buf); + if (!(buf = (char *) malloc(b_size / 2))) + fatal("Cannot malloc()"); + b_size = b_size / 2; + } + if (nread > b_size) { + b_size = (nread % 2) ? (nread + 1) : (nread); + free(buf); + if (!(buf = (char *) malloc(b_size))) + fatal("Cannot malloc()"); + } + if (read(snp_io, buf, nread) < nread) + fatal("read failed."); + if (write(std_out, buf, nread) < nread) + fatal("write failed."); + } + } /* While */ +} diff --git a/usr.sbin/watch/Makefile b/usr.sbin/watch/Makefile new file mode 100644 index 000000000000..3d541639ef6a --- /dev/null +++ b/usr.sbin/watch/Makefile @@ -0,0 +1,6 @@ +PROG= watch +NOMAN= +BINMODE=500 +LDADD= -ltermcap + +.include diff --git a/usr.sbin/watch/watch.c b/usr.sbin/watch/watch.c new file mode 100644 index 000000000000..f5e4007c2a41 --- /dev/null +++ b/usr.sbin/watch/watch.c @@ -0,0 +1,404 @@ +/* + * Copyright (c) 1995 Ugen J.S.Antsilevich + * + * Redistribution and use in source forms, with and without modification, + * are permitted provided that this entire comment appears intact. + * + * Redistribution in binary form may occur without any restrictions. + * Obviously, it would be nice if you gave credit where credit is due + * but requiring it would be too onerous. + * + * This software is provided ``AS IS'' without any warranties of any kind. + * + * Snoop stuff. + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + + +#define MSG_INIT "Snoop started." +#define MSG_OFLOW "Snoop stopped due to overflow.Reconnecting." +#define MSG_CLOSED "Snoop stopped due to tty close.Reconnecting." +#define MSG_CHANGE "Snoop device change by user request." + + +#define DEV_NAME_LEN 12 /* for /dev/ttyXX++ */ +#define MIN_SIZE 256 + +#define CHR_SWITCH 24 /* Ctrl+X */ +#define CHR_CLEAR 23 /* Ctrl+V */ + + +int opt_reconn_close = 0; +int opt_reconn_oflow = 0; +int opt_interactive = 1; +int opt_timestamp = 0; + +char dev_name[DEV_NAME_LEN]; +int snp_io; +struct snptty snp_tty; +int std_in = 0, std_out = 1; + + +int clear_ok = 0; +struct sgttyb sgo; +char tbuf[1024], buf[1024]; + + +void +clear() +{ + if (clear_ok) + tputs(buf, 1, putchar); + fflush(stdout); +} + +void +timestamp(buf) + char *buf; +{ + time_t t; + char btmp[1024]; + clear(); + printf("\n---------------------------------------------\n"); + t = time(NULL); + strftime(btmp, 1024, "Time: %d %b %H:%M", localtime(&t)); + printf("%s\n", btmp); + printf("%s\n", buf); + printf("---------------------------------------------\n"); + fflush(stdout); +} + +void +set_tty() +{ + struct sgttyb sgn; + ioctl(std_in, TIOCGETP, &sgo); + /* bcopy(&sgn, &sgo, sizeof(struct sgttyb)); */ + sgn = sgo; + sgn.sg_flags |= CBREAK; + sgn.sg_flags &= ~ECHO; + ioctl(std_in, TIOCSETP, &sgn); +} + +void +unset_tty() +{ + ioctl(std_in, TIOCSETP, &sgo); +} + + +void +fatal(buf) + char *buf; +{ + unset_tty(); + if (buf) + fprintf(stderr, "Fatal: %s\n", buf); + exit(1); +} + +int +open_snp() +{ + char snp[DEV_NAME_LEN] = "/dev/snpX"; + char c; + int f; + for (c = '0'; c <= '9'; c++) { + snp[8] = c; + if ((f = open(snp, O_RDONLY)) < 0) + continue; + return f; + } + fatal("Cannot open snoop device."); +} + + +void +cleanup() +{ + if (opt_timestamp) + timestamp("Logging Exited."); + close(snp_io); + unset_tty(); + exit(0); +} + + +void +show_usage() +{ + printf("watch -[ciot] [tty name]\n"); + exit(1); +} + +void +setup_scr() +{ + char *cbuf = buf, *term; + if (!opt_interactive) + return; + if ((term = getenv("TERM"))) + if (tgetent(tbuf, term) == 1) + if (tgetstr("cl", &cbuf)) + clear_ok = 1; + clear(); + set_tty(); +} + + +int +ctoh(c) + char c; +{ + if (c >= '0' && c <= '9') + return (int) (c - '0'); + + if (c >= 'a' && c <= 'f') + return (int) (c - 'a' + 10); + + fatal("Bad tty number."); +} + + +void +detach_snp() +{ + struct snptty st; + st.st_type = -1; + st.st_unit = -1; + ioctl(snp_io, SNPSTTY, &st); +} + +void +attach_snp() +{ + if (ioctl(snp_io, SNPSTTY, &snp_tty) != 0) + fatal("Cannot attach to tty."); + if (opt_timestamp) + timestamp("Logging Started."); +} + + +void +set_dev(name) + char *name; +{ + char buf[DEV_NAME_LEN], num[DEV_NAME_LEN]; + int unitbase = 0; + + if (strlen(name) > 5 && !strncmp(name, "/dev/", 5)) + strcpy(buf, &(name[5])); + else + strcpy(buf, name); + + if (strlen(buf) < 4) + fatal("Bad tty name."); + + if (!strncmp(buf, "tty", 3)) + switch (buf[3]) { + case 'v': + snp_tty.st_unit = ctoh(buf[4]); + snp_tty.st_type = ST_VTY; + goto got_num; + case 'r': + unitbase += 16; + case 'q': + unitbase += 16; + case 'p': + snp_tty.st_unit = ctoh(buf[4]) + unitbase; + snp_tty.st_type = ST_PTY; + goto got_num; + case '0': + case 'd': + snp_tty.st_unit = ctoh(buf[4]); + snp_tty.st_type = ST_SIO; + goto got_num; + default: + fatal("Bad tty name."); + + } + + + if (!strncmp(buf, "vty", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_VTY; + goto got_num; + } + if (!strncmp(buf, "pty", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_PTY; + goto got_num; + } + if (!strncmp(buf, "sio", 3) || !strncmp(buf, "cua", 3)) { + strcpy(num, &(buf[3])); + snp_tty.st_unit = atoi(num); + snp_tty.st_type = ST_SIO; + goto got_num; + } + fatal("Bad tty name."); +got_num: + attach_snp(); +} + +void +ask_dev(dev_name, msg) + char *dev_name, *msg; +{ + char buf[DEV_NAME_LEN]; + int len; + + clear(); + unset_tty(); + + if (msg) + printf("%s\n", msg); + if (dev_name) + printf("Enter device name [%s]:", dev_name); + else + printf("Enter device name:"); + + if (fgets(buf, DEV_NAME_LEN - 1, stdin)) { + len = strlen(buf); + if (buf[len - 1] == '\n') + buf[len - 1] = '\0'; + if (buf[0] != '\0' && buf[0] != ' ') + strcpy(dev_name, buf); + } + set_tty(); +} + + +void +main(ac, av) + int ac; + char **av; +{ + int res, nread, b_size = MIN_SIZE; + extern int optind; + char ch, *buf; + fd_set fd_s; + + if (getuid() != 0) + fatal(NULL); + + if (isatty(std_out)) + opt_interactive = 1; + else + opt_interactive = 0; + + + while ((ch = getopt(ac, av, "ciot")) != EOF) + switch (ch) { + case 'c': + opt_reconn_close = 1; + break; + case 'i': + opt_interactive = 1; + break; + case 'o': + opt_reconn_oflow = 1; + break; + case 't': + opt_timestamp = 1; + break; + case '?': + default: + show_usage(); + exit(1); + } + + signal(SIGINT, cleanup); + + setup_scr(); + snp_io = open_snp(); + + if (*(av += optind) == NULL) { + if (opt_interactive) + ask_dev(dev_name, MSG_INIT); + else + fatal("No device name given."); + } else + strncpy(dev_name, *av, DEV_NAME_LEN); + + set_dev(dev_name); + + if (!(buf = (char *) malloc(b_size))) + fatal("Cannot malloc()."); + + FD_ZERO(&fd_s); + + while (1) { + if (opt_interactive) + FD_SET(std_in, &fd_s); + FD_SET(snp_io, &fd_s); + res = select(snp_io + 1, &fd_s, NULL, NULL, NULL); + if (opt_interactive && FD_ISSET(std_in, &fd_s)) { + switch (ch = getchar()) { + case CHR_CLEAR: + clear(); + break; + case CHR_SWITCH: + /* detach_snp(); */ + ask_dev(dev_name, MSG_CHANGE); + set_dev(dev_name); + break; + default: + } + } + if (!FD_ISSET(snp_io, &fd_s)) + continue; + + if ((res = ioctl(snp_io, FIONREAD, &nread)) != 0) + fatal("ioctl() failed."); + + switch (nread) { + case SNP_OFLOW: + if (opt_reconn_oflow) + attach_snp(); + else if (opt_interactive) { + ask_dev(dev_name, MSG_OFLOW); + set_dev(dev_name); + } else + cleanup(); + case SNP_DETACH: + case SNP_TTYCLOSE: + if (opt_reconn_close) + attach_snp(); + else if (opt_interactive) { + ask_dev(dev_name, MSG_CLOSED); + set_dev(dev_name); + } else + cleanup(); + default: + if (nread < (b_size / 2) && (b_size / 2) > MIN_SIZE) { + free(buf); + if (!(buf = (char *) malloc(b_size / 2))) + fatal("Cannot malloc()"); + b_size = b_size / 2; + } + if (nread > b_size) { + b_size = (nread % 2) ? (nread + 1) : (nread); + free(buf); + if (!(buf = (char *) malloc(b_size))) + fatal("Cannot malloc()"); + } + if (read(snp_io, buf, nread) < nread) + fatal("read failed."); + if (write(std_out, buf, nread) < nread) + fatal("write failed."); + } + } /* While */ +}