home *** CD-ROM | disk | FTP | other *** search
/ Language/OS - Multiplatform Resource Library / LANGUAGE OS.iso / oper_sys / emerald / emrldsys.lha / Kernel / KmdOps / wstats.c < prev   
Encoding:
C/C++ Source or Header  |  1990-08-30  |  8.1 KB  |  321 lines
  1. /*  C O P Y R I G H T   N O T I C E :
  2.  * Copyright 1986 Eric Jul.  May not be used for any
  3.  * purpose without written permission from the author
  4.  */
  5.  
  6. /* File:        wstats.c     Eric Jul, 1986-06-03     */
  7.  
  8. /*
  9.  * $Header$
  10.  * INTERFACE:    See usage printout.
  11.  *
  12.  * FUNCTION:    Print Kernel statistics repeatedly using windows,
  13.  *              see curses(3X).
  14.  *
  15.  * IMPORTS:    loads, see #include
  16.  *
  17.  * EXPORTS:    Nothing.
  18.  *
  19.  * DESIGN:    Send start snapshot message to Emerald process and then
  20.  *              repeatedly receive and print data until stop snapshot
  21.  *              message arrives.
  22.  *              Then repeat after waiting t seconds.
  23.  *
  24.  * $Log$
  25.  * 1986-06-03   Modified to work with 4.2bsd sockets.
  26.  * 1985-01-06   Initial implementation, Eric Jul.
  27.  */
  28.  
  29. #include <sys/types.h>
  30. #include <sys/socket.h>
  31. #include <netinet/in.h>
  32. #include <stdio.h>
  33. #include <curses.h>
  34. #include <signal.h>
  35.  
  36.  
  37. #define mSUCCESS(X) (((X) & 7) == 1)
  38.  
  39.  
  40. #undef FALSE
  41. #undef TRUE
  42. #undef integer
  43.  
  44. typedef int KKStatus;
  45.  
  46. #define MAXMESSAGESIZE        1000
  47. #include "Kernel/h/emPorts.h"
  48. #include "Kernel/h/kmdDefs.h"
  49.  
  50. #include <netdb.h>
  51. #include <signal.h>
  52.  
  53. #define endcase break
  54.  
  55. char *snapshotname, *snapshotstring;
  56. int   talkSock, pid = 0, prodTime = 1, MType, MInt;
  57. char  MString[500];
  58.  
  59. struct sockaddr_in destSockDescr = {AF_INET};
  60.  
  61. /* Define signal handlers */
  62.  
  63. void PipeHandler(sig)
  64. int sig;
  65. {
  66.   printf("SIGPIPE>>> The connection to the process broke.\nTerminating.\n");
  67.   exit(1);
  68. }
  69.  
  70. void TerminationHandler(sig)
  71. int sig;
  72. { 
  73.   fprintf(stderr, "Terminating wstats.\n");
  74.   /* Important to tell kernel that we are bye, bye ... */
  75.   KMDSend(talkSock, KMDCLASTMSG, 0, "Done");
  76.   if (shutdown(talkSock, 1) < 0) perror("shutdown1");
  77.   while(mSUCCESS(KMDReceive(talkSock, &MType, &MInt, MString)));
  78.   close(talkSock);
  79.   printw("Terminating.\n");
  80.   endwin();
  81.   exit(sig);
  82. }
  83.  
  84.  
  85.  
  86. main(argc, argv)
  87. int   argc;
  88. char *argv[];
  89. {
  90.   int  OKtoGoOn;
  91.   int  MType, MInt;
  92.   char MString[500];
  93.   char snapbuf[500];
  94.  
  95.   static int        i, EPLNN, SValue;
  96.   static int        pidGiven = 0, machineNameGiven = 0;
  97.   KKStatus          kstat;
  98.   char              myHostName[100];
  99.   struct hostent   *myHost;
  100.   struct servent   *myService;
  101.   int               WaitTime;
  102.   long              theTime;
  103.  
  104.     snapshotname = "MMStats";        /* default */
  105.     snapshotstring = (char *) 0;
  106.  
  107.     SValue = 0;                      /* default */
  108.     EPLNN = 8;                       /* default */
  109.     WaitTime = 5;                    /* default */
  110.  
  111.         if (argc == 2) 
  112.             if (!strcmp(argv[1], "usage")) {
  113.             fprintf(stderr,
  114.             "Usage: wstats [-N <LNN>] [-M <Machine Name>] [-t <WaitInterval>] [-n <Snapshot>\n");
  115.                 TerminationHandler(0);
  116.             };
  117.  
  118.     /*
  119.      * Parse command line options
  120.      */
  121.     while (argc > 1 && argv[1][0] == '-') {
  122.         switch (argv[1][1]) {
  123.         case 'N':        /* Set logical node number */
  124.             if (argv[1][2] == '\0') {
  125.                 EPLNN = atoi(argv[2]);
  126.                 argc--;
  127.                 argv++;
  128.             } else
  129.                 EPLNN = atoi(&argv[1][2]);
  130.                         
  131.             printf("warning: -N ignored.\n");
  132.             break;
  133.         case 'X':        /* Set logical node number (hex) */
  134.                         if (argv[1][2] == '\0') {
  135.                                 sscanf(argv[2], "%x", &EPLNN);
  136.                                 argc--;
  137.                                 argv++;
  138.                         } else
  139.                                 sscanf(&argv[1][2], "%x", &EPLNN);
  140.             printf("warning: -X ignored.\n");
  141.             break;
  142.         case 'd':
  143.             if (argv[1][2] == '\0') {
  144.                 SValue = atoi(argv[2]);
  145.                 argc--;
  146.                 argv++;
  147.             } else
  148.                 SValue = atoi(&argv[1][2]);
  149.             break;
  150.         case 'P':       /* Set pid, cancel LNN usage. */
  151.             if (argv[1][2] == '\0') {
  152.                 pid = atoi(argv[2]);
  153.                 argc--;
  154.                 argv++;
  155.             } else
  156.                 pid = atoi(&argv[1][2]);
  157.                         pidGiven = 1;
  158.             printf("warning: -P ignored.\n");
  159.             break;
  160.                 case 'h':
  161.                         if (argv[1][2] == '\0') {
  162.                                 sscanf(argv[2], "%x", &SValue);
  163.                                 argc--;
  164.                                 argv++;
  165.                         } else
  166.                                 sscanf(&argv[1][2], "%x", &SValue);
  167.                         break;
  168.         case 't':
  169.             if (argv[1][2] == '\0') {
  170.                 WaitTime = atoi(argv[2]);
  171.                 argc--;
  172.                 argv++;
  173.             } else
  174.                 WaitTime = atoi(&argv[1][2]);
  175.             break;
  176.                 case 'n':
  177.                         snapshotname = argv[2];
  178.                         argc--;
  179.                         argv++;
  180.                         break;
  181.                 case 'S':
  182.                         snapshotstring = argv[2];
  183.                         argc--;
  184.                         argv++;
  185.                         break;
  186.                 case 'M':
  187.                 case 'm':
  188.                         strcpy(myHostName, argv[2]);
  189.                         argc--;
  190.                         argv++;
  191.             machineNameGiven ++;
  192.                         break;
  193.                 default:
  194.                         fprintf(stderr,
  195.                 "wstats: (warning) Unknown option: %c",
  196.                 argv[1][2]);
  197.                         break;
  198.  
  199.         }
  200.         argc--;
  201.         argv++;
  202.     }
  203.  
  204.     
  205.     /* Set termination handler. */
  206.     signal(SIGHUP, TerminationHandler);
  207.     signal(SIGQUIT, TerminationHandler);
  208.     signal(SIGINT, TerminationHandler);
  209.     signal(SIGBUS, TerminationHandler);
  210.     signal(SIGSEGV, TerminationHandler);
  211.     signal(SIGTERM, TerminationHandler);
  212.     signal(SIGPIPE, PipeHandler);
  213.     
  214.     talkSock = socket(AF_INET, SOCK_STREAM, 0, 0);
  215.     if (talkSock < 0) {
  216.                 perror("snapshot: socket");
  217.     }
  218.  
  219.     if (! machineNameGiven) {
  220.     if (gethostname(myHostName, 100) < 0) {
  221.         perror("snapshot: gethostname");
  222.                 TerminationHandler(0);
  223.     }
  224.     }
  225.     myHost = gethostbyname(myHostName);
  226.     if (myHost == NULL) {
  227.             perror("snapshot: gethostbyname");
  228.                 TerminationHandler(0);
  229.     }
  230.  
  231.     bcopy(myHost->h_addr, &destSockDescr.sin_addr, myHost->h_length);
  232.  
  233.     {
  234.       char *emplanename;
  235.       int emPlane = 0;
  236.       int emPort = EMKERNELDEFAULTPORTNUMBER;
  237.       struct servent   *myService;
  238.       emplanename = (char *) getenv("EMPLANE");
  239.       if (emplanename != NULL) emPlane = atoi(emplanename);
  240. #ifdef DIKU
  241.       myService = getservbyname(EMKERNELSERVICEPORT, "tcp");
  242.       if(myService)
  243.     emPort = ntohs(myService->s_port);
  244. #endif
  245.       destSockDescr.sin_port = htons(emPort + emPlane*4 + 1);
  246.     }
  247.  
  248.     if (connect(talkSock, &destSockDescr, sizeof(destSockDescr)) == -1) {
  249.                 perror("snapshot: connect");
  250.                 TerminationHandler(0);
  251.     }
  252.     if ( KMDTest )
  253.         printf("Connected to %d\n", ntohs(destSockDescr.sin_port));
  254.  
  255.     KMDReceive(talkSock, &MType, &MInt, MString);
  256.     printf("%s", MString);
  257.  
  258.     /* Initialize window. */
  259.     initscr();
  260.  
  261. Restartit:
  262.     /* Reset window. */
  263.     move(0, 0);
  264.     erase();
  265.     theTime = time(0);
  266.     standout();
  267.     printw("%s at %s\n", snapshotname, ctime(&theTime));
  268.     standend();
  269.     /* Start snapshot.*/
  270.     sprintf(snapbuf, "%s %s", snapshotname, snapshotstring);
  271.     kstat = KMDSend(talkSock, KMDCSNAPSHOT, SValue, snapbuf);
  272.  
  273.     if (! mSUCCESS( kstat ) ) {
  274.     endwin();
  275.         fprintf(stderr,
  276.         "wstats: Send snapshot msg failed, kstat = 0x%08x\n", kstat);
  277.                 TerminationHandler(0);
  278.     };
  279.  
  280.     OKtoGoOn = 1;
  281.     while (OKtoGoOn==1) {
  282.         if(!mSUCCESS(KMDReceive(talkSock, &MType, &MInt, MString))){
  283.         fprintf(stderr, "Premature snapshot termination\n");
  284.         perror("recv");
  285.         TerminationHandler(0);
  286.     };
  287.     
  288.         if ( KMDTest ) {
  289.             printf("Msg from: %d, (%d, %d, %s)\n", talkSock,
  290.                 MType, MInt, MString),
  291.             fflush(stdout);
  292.     }
  293.         
  294.         switch ( MType ) {
  295.         
  296.         case KMDCDATA:
  297.             printw("%s", MString);
  298.             fflush(stdout);
  299.         endcase;
  300.         
  301.         case KMDCERRMSG:
  302.         endwin();
  303.             fprintf(stderr, "wstats: %s\n", MString);
  304.             OKtoGoOn = 0;         /* quit */
  305.             TerminationHandler(0);
  306.         endcase;
  307.  
  308.         case KMDCLASTMSG:
  309.         refresh();
  310.             sleep(WaitTime);
  311.         goto Restartit;
  312.         endcase;
  313.  
  314.         default:
  315.             fprintf(stderr,
  316.             "**** KMD error: Warning, bad msgtype: %d \n", MType);
  317.         }
  318.     }
  319.     TerminationHandler(0);        
  320. }
  321.