diff options
Diffstat (limited to 'usr.sbin/i4b/isdnmonitor/main.c')
| -rw-r--r-- | usr.sbin/i4b/isdnmonitor/main.c | 675 |
1 files changed, 0 insertions, 675 deletions
diff --git a/usr.sbin/i4b/isdnmonitor/main.c b/usr.sbin/i4b/isdnmonitor/main.c deleted file mode 100644 index 73ae8fe01f86a..0000000000000 --- a/usr.sbin/i4b/isdnmonitor/main.c +++ /dev/null @@ -1,675 +0,0 @@ -/* - * Copyright (c) 1998 Martin Husemann. All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * 3. Neither the name of the author nor the names of any co-contributors - * may be used to endorse or promote products derived from this software - * without specific prior written permission. - * 4. Altered versions must be plainly marked as such, and must not be - * misrepresented as being the original software and/or documentation. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND - * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE - * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE - * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE - * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL - * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS - * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) - * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT - * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY - * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF - * SUCH DAMAGE. - * - *--------------------------------------------------------------------------- - * - * i4b daemon - network monitor client - * ----------------------------------- - * - * $Id: main.c,v 1.9 1998/10/27 10:54:23 hm Exp $ - * - * last edit-date: [Tue Oct 27 11:53:12 1998] - * - * -mh created - * -hm checking in - * -hm porting to HPUX - * -mh all events the fullscreen mode displays now as monitor event - * - *---------------------------------------------------------------------------*/ - - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <signal.h> -#include <time.h> -#include <errno.h> -#include <unistd.h> -#include <netdb.h> -#include <sys/types.h> -#include <sys/socket.h> -#include <sys/ioctl.h> -#include <sys/un.h> -#include <netinet/in.h> -#include <arpa/inet.h> - -#include <machine/i4b_ioctl.h> - -#ifdef __hpux -#define AF_LOCAL AF_UNIX -#endif - -#ifdef DEBUG -#include <ctype.h> -#endif - -#include "monitor.h" - -/* - * Local function prototypes - */ -static int connect_local(const char *sockpath); -static int connect_remote(const char *host, int portno); -static void usage(); -static void mloop(); -static void handle_input(); -static void print_menu(); -static void print_logevent(time_t tstamp, int prio, const char * what, const char * msg); -static void print_charge(time_t tstamp, int channel, int units, int estimated); -static void print_connect(time_t tstamp, int dir, int channel, const char * cfgname, const char * devname, const char * remphone, const char * locphone); -static void print_disconnect(time_t tstamp, int channel); -static void print_updown(time_t tstamp, int channel, int isup); -static void handle_event(BYTE *msg, int len); -#ifdef DEBUG -static void dump_event(BYTE *msg, int len); -#endif - -/* - * Global variables - */ -static int dumpall = 0; -static int monsock = -1; -static int state = 0; -static int sub_state = 0; -static int sub_state_count = 0; - -static int major = 0; -static int minor = 0; -static int nctrl = 0; -static u_int32_t rights = 0; - -/* - * Parse command line, startup monitor client - */ -int main(int argc, char **argv) -{ - char * sockpath = NULL; - char * hostname = NULL; - int portno = DEF_MONPORT; - int i; - - while ((i = getopt(argc, argv, "dh:p:l:")) != EOF) - { - switch (i) - { - case 'd': - dumpall = 1; - break; - case 'h': - hostname = optarg; - break; - case 'l': - sockpath = optarg; - break; - case 'p': - if ((sscanf(optarg, "%i", &portno)) != 1) - usage(); - break; - default: - usage(); - break; - } - } - - if (hostname && sockpath) - { - fprintf(stderr, "Error: can not use local socket path on remote machine\n" - "conflicting options -h and -l!\n"); - return 1; - } - - if (sockpath) - { - monsock = connect_local(sockpath); - } - else if (hostname) - { - monsock = connect_remote(hostname, portno); - } - else - { - usage(); - } - - if (monsock == -1) - { - fprintf(stderr, "Could not connect to i4b isdn daemon.\n"); - return 1; - } - - signal(SIGPIPE, SIG_IGN); - mloop(); - - close(monsock); - - return 0; -} - -/* - * Display usage and exit - */ -static void usage() -{ - fprintf(stderr, "usage:\n" - " isdnmonitor [-d] -h (host) -p (port)\n" - "or\n" - " isdnmonitor [-d] -l (path)\n" - "where (host) is the hostname and (port) the port number of\n" - "the isdnd to be monitored and (path) is the pathname of the\n" - "local domain socket used to communicate with a daemon on the\n" - "local machine.\n" - "Options are:\n" - " -d dump all incoming packets as hexdump\n" - ); - exit(0); -} - -/* - * Connect via tcp/ip. - * Return socket if successfull, -1 on error. - */ -static int connect_remote(const char *host, int portno) -{ - struct sockaddr_in sa; - struct hostent *h; - int remotesockfd; - - h = gethostbyname(host); - - if (!h) - { - fprintf(stderr, "could not resolve hostname '%s'\n", host); - exit(1); - } - - remotesockfd = socket(AF_INET, SOCK_STREAM, 0); - - if (remotesockfd == -1) - { - fprintf(stderr, "could not create remote monitor socket: %s\n", strerror(errno)); - exit(1); - } - - memset(&sa, 0, sizeof sa); - -#ifdef BSD4_4 - sa.sin_len = sizeof sa; -#endif - sa.sin_family = AF_INET; - sa.sin_port = htons(portno); - - memcpy(&sa.sin_addr.s_addr, h->h_addr_list[0], sizeof sa.sin_addr.s_addr); - - if (connect(remotesockfd, (struct sockaddr *)&sa, sizeof sa) == -1) - { - fprintf(stderr, "could not connect remote monitor: %s\n", strerror(errno)); - exit(1); - } - - return remotesockfd; -} - -/* - * Connect local. - * Return socket on success, -1 on failure. - */ -static int connect_local(const char *sockpath) -{ - int s; - struct sockaddr_un sa; - - /* check path length */ - if (strlen(sockpath) >= sizeof sa.sun_path) - { - fprintf(stderr, "pathname to long for local socket: %s\n", - sockpath); - exit(1); - } - - /* create and setup socket */ - s = socket(AF_LOCAL, SOCK_STREAM, 0); - - if (s == -1) - { - fprintf(stderr, "could not create local monitor socket:%s\n", strerror(errno)); - exit(1); - } - - memset(&sa, 0, sizeof sa); - -#ifndef __hpux - sa.sun_len = sizeof sa; -#endif - - sa.sun_family = AF_LOCAL; - strcpy(sa.sun_path, sockpath); - - if (connect(s, (struct sockaddr *)&sa, sizeof sa)) - { - fprintf(stderr, "could not connect local monitor socket [%s]: %s\n", sockpath, strerror(errno)); - } - - return s; -} - -/* - * main event loop - */ -static void mloop() -{ - for (;;) - { - fd_set rd, wr, ex; - - FD_ZERO(&rd); - FD_ZERO(&wr); - FD_ZERO(&ex); - FD_SET(fileno(stdin), &rd); - FD_SET(monsock, &rd); - - select(monsock+1, &rd, &wr, &ex, NULL); - - if (FD_ISSET(fileno(stdin), &rd)) - { - handle_input(); - } - - if (FD_ISSET(monsock, &rd)) - { - BYTE buf[1024]; - u_long u; - int bytes, ret; - - /* Network transfer may deliver two or more packets concatenated. - * Peek at the header and read only one event at a time... */ - - ioctl(monsock, FIONREAD, &u); - - if (u < I4B_MON_EVNT_HDR) - continue; /* not enough data there yet */ - - bytes = recv(monsock, buf, I4B_MON_EVNT_HDR, MSG_PEEK); - - if (bytes < I4B_MON_EVNT_HDR) - continue; /* errh? something must be wrong... */ - - bytes = I4B_GET_2B(buf, I4B_MON_EVNT_LEN); - - if (bytes >= sizeof buf) - break; - - /* now we know the size, it fits, so lets read it! */ - - ret = read(monsock, buf, bytes); - - if (ret == 0) - { - printf("remote isdnd has closed our connection\n"); - break; - } - else if (ret < 0) - { - printf("error reading from isdnd: %s", strerror(errno)); - break; - } -#ifdef DEBUG - if (dumpall) - dump_event(buf, ret); -#endif - handle_event(buf, ret); - } - } -} - -#ifdef DEBUG -/* - * Dump a complete event packet. - */ -static void dump_event(BYTE *msg, int len) -{ - int i; - - printf("event dump:"); - - for (i = 0; i < len; i++) - { - if (i % 8 == 0) - printf("\n%02x: ", i); - printf("%02x %c ", msg[i], isprint(msg[i]) ? msg[i] : '.'); - } - printf("\n"); -} -#endif - -static void print_logevent(time_t tstamp, int prio, const char * what, const char * msg) -{ - char buf[256]; - strftime(buf, sizeof buf, I4B_TIME_FORMAT, localtime(&tstamp)); - printf("log: %s prio %d what=%s msg=%s\n", - buf, prio, what, msg); -} - -static void print_charge(time_t tstamp, int channel, int units, int estimated) -{ - char buf[256]; - strftime(buf, sizeof buf, I4B_TIME_FORMAT, localtime(&tstamp)); - printf("%s: channel %d, charge = %d%s\n", - buf, channel, units, estimated ? " (estimated)" : ""); -} - -/* - * Print a connect event. - * A real monitor would allocate state info for "channel" on this - * event. - */ -static void print_connect( - time_t tstamp, /* server time of event */ - int outgoing, /* 0 = incoming, 1 = outgoing */ - int channel, /* channel no, used to identify this connection until disconnect */ - const char * cfgname, /* name of config entry/connection */ - const char * devname, /* device used (e.g. isp0) */ - const char * remphone, /* phone no of remote side */ - const char * locphone) /* local phone no */ -{ - char buf[256]; - strftime(buf, sizeof buf, I4B_TIME_FORMAT, localtime(&tstamp)); - - if (outgoing) - printf("%s: calling out to '%s' [from msn: '%s']", - buf, remphone, locphone); - else - printf("%s: incoming call from '%s' [to msn: '%s']", - buf, remphone, locphone); - printf(", channel %d, config '%s' on device '%s'\n", - channel, cfgname, devname); -} - -/* - * Print a disconnect event. - * A real monitor could free the "per connection" state - * for this channel now - */ -static void print_disconnect(time_t tstamp, int channel) -{ - char buf[256]; - strftime(buf, sizeof buf, I4B_TIME_FORMAT, localtime(&tstamp)); - printf("%s: channel %d disconnected\n", - buf, channel); -} - -/* - * Print an up- or down event - */ -static void print_updown(time_t tstamp, int channel, int isup) -{ - char buf[256]; - strftime(buf, sizeof buf, I4B_TIME_FORMAT, localtime(&tstamp)); - printf("%s: channel %d is %s\n", - buf, channel, isup ? "up" : "down"); -} - -/* - * Dispatch one message received from the daemon. - */ -static void handle_event(BYTE *msg, int len) -{ - BYTE cmd[I4B_MON_ICLIENT_SIZE]; - int local; - u_int32_t net; - u_int32_t mask; - u_int32_t who; - - switch (state) - { - case 0: /* initial data */ - - major = I4B_GET_2B(msg, I4B_MON_IDATA_VERSMAJOR); - minor = I4B_GET_2B(msg, I4B_MON_IDATA_VERSMINOR); - nctrl = I4B_GET_2B(msg, I4B_MON_IDATA_NUMCTRL); - rights = I4B_GET_4B(msg, I4B_MON_IDATA_CLACCESS); - - printf("remote protocol version is %02d.%02d, %d controller(s) found, our rights = %x\n", - major, minor, nctrl, rights); - - if (nctrl > 0) - { - state = 1; - sub_state = 0; - } - else - { - state = 2; - - /* show menu for the first time */ - print_menu(); - } - - /* set maximum event mask */ - I4B_PREP_CMD(cmd, I4B_MON_CCMD_SETMASK); - I4B_PUT_2B(cmd, I4B_MON_ICLIENT_VERMAJOR, MPROT_VERSION); - I4B_PUT_2B(cmd, I4B_MON_ICLIENT_VERMINOR, MPROT_REL); - I4B_PUT_4B(cmd, I4B_MON_ICLIENT_EVENTS, ~0U); - - write(monsock, cmd, sizeof cmd); - - break; - - case 1: /* initial controller list */ - printf("controller %d: %s\n", sub_state++, msg+I4B_MON_ICTRL_NAME); - - if (sub_state >= nctrl) - { - state = 2; /* end of list reached */ - sub_state = 0; - - /* show menu for the first time */ - print_menu(); - } - break; - - case 2: /* any event */ - - switch (I4B_GET_2B(msg, I4B_MON_EVNT)) - { - case I4B_MON_DRINI_CODE: - state = 3; /* list of rights entries will follow */ - sub_state = 0; - sub_state_count = I4B_GET_2B(msg, I4B_MON_DRINI_COUNT); - printf("monitor rights:\n"); - break; - - case I4B_MON_DCINI_CODE: - state = 4; - sub_state = 0; - sub_state_count = I4B_GET_2B(msg, I4B_MON_DCINI_COUNT); - printf("monitor connections:\n"); - break; - - case I4B_MON_LOGEVNT_CODE: - print_logevent(I4B_GET_4B(msg, I4B_MON_LOGEVNT_TSTAMP), - I4B_GET_4B(msg, I4B_MON_LOGEVNT_PRIO), - msg+I4B_MON_LOGEVNT_WHAT, - msg+I4B_MON_LOGEVNT_MSG); - break; - - case I4B_MON_CHRG_CODE: - print_charge(I4B_GET_4B(msg, I4B_MON_CHRG_TSTAMP), - I4B_GET_4B(msg, I4B_MON_CHRG_CHANNEL), - I4B_GET_4B(msg, I4B_MON_CHRG_UNITS), - I4B_GET_4B(msg, I4B_MON_CHRG_ESTIMATED)); - break; - - case I4B_MON_CONNECT_CODE: - print_connect( - I4B_GET_4B(msg, I4B_MON_CONNECT_TSTAMP), - I4B_GET_4B(msg, I4B_MON_CONNECT_DIR), - I4B_GET_4B(msg, I4B_MON_CONNECT_CHANNEL), - msg+I4B_MON_CONNECT_CFGNAME, - msg+I4B_MON_CONNECT_DEVNAME, - msg+I4B_MON_CONNECT_REMPHONE, - msg+I4B_MON_CONNECT_LOCPHONE); - break; - - case I4B_MON_DISCONNECT_CODE: - print_disconnect( - I4B_GET_4B(msg, I4B_MON_DISCONNECT_TSTAMP), - I4B_GET_4B(msg, I4B_MON_DISCONNECT_CHANNEL)); - break; - - case I4B_MON_UPDOWN_CODE: - print_updown( - I4B_GET_4B(msg, I4B_MON_UPDOWN_TSTAMP), - I4B_GET_4B(msg, I4B_MON_UPDOWN_CHANNEL), - I4B_GET_4B(msg, I4B_MON_UPDOWN_ISUP)); - break; - - default: - printf("unknown event code: %d\n", I4B_GET_2B(msg, I4B_MON_EVNT)); - } - break; - - case 3: /* one record in a list of monitor rights */ - rights = I4B_GET_4B(msg, I4B_MON_DR_RIGHTS); - net = I4B_GET_4B(msg, I4B_MON_DR_NET); - mask = I4B_GET_4B(msg, I4B_MON_DR_MASK); - local = I4B_GET_1B(msg, I4B_MON_DR_LOCAL); - - if (local) - { - printf("\tlocal: rights = %x\n", rights); - } - else - { - printf("\tfrom: %d.%d.%d.%d, mask %d.%d.%d.%d, rights = %x\n", - (net >> 24) & 0x00ff, (net >> 16) & 0x00ff, (net >> 8) & 0x00ff, net & 0x00ff, - (mask >> 24) & 0x00ff, (mask >> 16) & 0x00ff, (mask >> 8) & 0x00ff, mask & 0x00ff, - rights); - } - - sub_state++; - - if (sub_state >= sub_state_count) - { - state = 2; - print_menu(); - } - break; - - case 4: - who = I4B_GET_4B(msg, I4B_MON_DC_WHO); - rights = I4B_GET_4B(msg, I4B_MON_DC_RIGHTS); - - printf("\tfrom: %d.%d.%d.%d, rights = %x\n", - (who >> 24) & 0x00ff, (who >> 16) & 0x00ff, (who >> 8) & 0x00ff, who & 0x00ff, - rights); - - sub_state++; - - if (sub_state >= sub_state_count) - { - state = 2; - print_menu(); - } - break; - - default: - printf("unknown event from remote: local state = %d, evnt = %x, len = %d\n", - state, I4B_GET_2B(msg, I4B_MON_EVNT), len); - } -} - -/* - * Process input from user - */ -static void handle_input() -{ - char buf[1024]; - int channel; - - fgets(buf, sizeof buf, stdin); - - switch (atoi(buf)) - { - case 1: - { - BYTE cmd[I4B_MON_DUMPRIGHTS_SIZE]; - I4B_PREP_CMD(cmd, I4B_MON_DUMPRIGHTS_CODE); - write(monsock, cmd, I4B_MON_DUMPRIGHTS_SIZE); - } - break; - - case 2: - { - BYTE cmd[I4B_MON_DUMPMCONS_SIZE]; - I4B_PREP_CMD(cmd, I4B_MON_DUMPMCONS_CODE); - write(monsock, cmd, I4B_MON_DUMPMCONS_SIZE); - } - break; - - case 3: - { - BYTE cmd[I4B_MON_CFGREREAD_SIZE]; - I4B_PREP_CMD(cmd, I4B_MON_CFGREREAD_CODE); - write(monsock, cmd, I4B_MON_CFGREREAD_SIZE); - } - break; - - case 4: - { - BYTE cmd[I4B_MON_HANGUP_SIZE]; - I4B_PREP_CMD(cmd, I4B_MON_HANGUP_CODE); - printf("Which channel do you wish to hangup? "); - fgets(buf, sizeof buf, stdin); - channel = atoi(buf); - I4B_PUT_4B(cmd, I4B_MON_HANGUP_CHANNEL, channel); - write(monsock, cmd, I4B_MON_HANGUP_SIZE); - } - break; - - case 9: - close(monsock); - exit(0); - break; - - default: - print_menu(); - break; - } -} - -/* - * Display menu - */ -static void print_menu() -{ - printf("Menu: <1> display rights, <2> display monitor connections,\n"); - printf(" <3> reread config file, <4> hangup \n"); - printf(" <9> quit isdnmonitor\n"); -} |