home *** CD-ROM | disk | FTP | other *** search
/ Source Code 1994 March / Source_Code_CD-ROM_Walnut_Creek_March_1994.iso / netsrcs / sysvloa.dav < prev    next >
Encoding:
Internet Message Format  |  1987-02-10  |  10.8 KB
  1. From allbery@ncoast.UUCP Tue Feb 10 20:53:27 1987
  2. Path: beno!seismo!columbia!rutgers!clyde!cbatt!cwruecmp!hal!ncoast!allbery
  3. From: allbery@ncoast.UUCP (Brandon S. Allbery)
  4. Newsgroups: net.sources
  5. Subject: A load average daemon for System V.2
  6. Message-ID: <2046@ncoast.UUCP>
  7. Date: 11 Feb 87 01:53:27 GMT
  8. Reply-To: allbery@ncoast.UUCP (Brandon S. Allbery)
  9. Distribution: world
  10. Organization: Cleveland Public Access UNIX, Cleveland, OH
  11. Lines: 395
  12.  
  13. +---------------
  14. | Can anyone give me a lead on how one can determine the system load
  15. | on UNIX System V Release 2? (In particular, this is running on a
  16. | 3B2.) It doesn't have to be as elaborate as the 1,5,15 minute averages
  17. | available under Berkeley UNIX, but I need something that could be used
  18. | to get rough estimates of current busy-ness of the system. (This 
  19. | would then by called by processes on other network hosts to find the
  20. | least-used machine to give a job to.)
  21. +---------------    
  22.     
  23. The original form of these routines is From: budd@bu-cs.BU.EDU (Philip Budne).
  24. I include his README below.
  25.  
  26. +---------------
  27. | Here is a program I wrote to generate a load average for USG, we run
  28. | it on our 3b2s and our 3b5.  Of course you might be better off putting
  29. | it into the kernal clock.c routines where the sysinf data is generated.
  30. | 
  31. | This is a real T(w)enex (also BSD) style load average, the sysinf
  32. | structure (shockingly) provides exactly the needed information.
  33. | 
  34. | The data is stored in a BSD style rwhod packet/file.
  35. +---------------
  36.  
  37. I have modified this program:  if RWHOD is defined, it performs its original
  38. function of forging rwhod packets; undef'ed, it creates a shm segment whose
  39. key is ftok("/unix", 'a') and constantly updates three (double)'s stored in
  40. it.  The non-RWHOD stuff doesn't need the network hacks the original needed.
  41.  
  42. It is designed to be run as a ((terminology? daemon: dragon)).  We typically
  43. start it in /etc/rc.  BTW, in case you do telinit s/telinit 2, you should
  44. ipcrm the shm segment before starting avenrun.
  45.  
  46. WARNING:  The file below is NOT a ``shar'' file!!!
  47.  
  48. ++Brandon
  49. -----------------------cut, bend, fold, spindle, mutilate---------------------
  50. /*
  51.  * avenrun.c -- calculate System V load average, post into shm segment
  52.  * Brandon S. Allbery, TDI
  53.  * Based on:
  54.  * ldavg.c -- compute load averages for System V
  55.  * Phil Budne @ Boston U / DSG
  56.  *
  57.  * Forges BSD 4.2 rwhod packets containing system load averages
  58.  *
  59.  * My version (no #define RWHOD) uses a shm segment, ftok("/unix", 'a'),
  60.  * containing three (double)'s, for the 1, 5, and 15 minute load averages.
  61.  */
  62.  
  63. # include <sys/types.h>            /* system types */
  64. # include <sys/sysinfo.h>        /* sysinfo structure */
  65. # include <sys/utsname.h>        /* for uname(2) */
  66. # include <sys/stat.h>            /* for stat(2) */
  67. # include <sys/param.h>            /* for HZ */
  68. # include <stdio.h>
  69. # include <nlist.h>
  70. # include <time.h>
  71. # include <math.h>
  72. # include <utmp.h>
  73. # include <fcntl.h>
  74. #ifdef RWHOD
  75. # include "rwhod.h"            /* (from BSD) */
  76. #else  SHM
  77. # include <sys/ipc.h>
  78. # include <sys/shm.h>
  79. #endif RWHOD
  80.  
  81. /* # define DEBUG /**/
  82. #ifdef RWHOD
  83. # define UDP 1
  84. # define DSK 1
  85. # define PMUL 100
  86.  
  87. # if UDP
  88. # include "netdb.h"
  89. unsigned short port = 513;
  90. unsigned long ipaddr;
  91. # endif
  92. #endif RWHOD
  93.  
  94. extern struct utmp *getutent();
  95.  
  96. # define SYSTEM "/unix"
  97. # define KMEM "/dev/kmem"
  98.  
  99. struct nlist nl[] = {
  100. # define NL_SYSINFO 0
  101.         { "_sysinfo" },            /* 0 */
  102. # define NL_LBOLT 1
  103.     { "_lbolt" },            /* 1 */
  104.         { 0 }
  105. };
  106.  
  107. #ifdef RWHOD
  108. struct whod proto;
  109. struct utsname utsn;
  110. char whopacket[100];
  111. #else  SHM
  112. key_t aven_key;
  113. int aven_shm;
  114. double *aven_seg;
  115. #endif RWHOD
  116. int fd, memfd;
  117.  
  118. char *system = SYSTEM;
  119. char *kmem = KMEM;
  120. char *argv0;
  121.  
  122. main(argc, argv)
  123. int  argc;
  124. char *argv[];
  125. {
  126.     switch (fork()) {
  127.     case -1:
  128.         perror("fork");
  129.         exit(1);
  130.     case 0:
  131.         break;
  132.     default:
  133.         exit(0);
  134.     }
  135.     argv0 = argv[0];
  136. #ifdef RWHOD
  137.     uname(&utsn);            /* get system names */
  138. #endif RWHOD
  139.     setpgrp();            /* create own pgrp */
  140.     init_nlist();            /* get name values, open kmem */
  141.     init_packet();            /* initialize packet prototype */
  142.     doit();                /* never returns */
  143. } /* main */
  144.  
  145. init_nlist() {
  146.     nlist(system, nl);        /* get system values */
  147.  
  148.         if(nl[NL_SYSINFO].n_value == 0) {
  149.                 fprintf(stderr, "%s: can't find sysinf structure\n", argv0);
  150.                 exit(1);
  151.         } /* no value */
  152.  
  153.     if ((memfd = open(kmem, O_RDONLY)) < 0) {
  154.         fprintf(stderr, "%s: no mem\n", argv0);
  155.         exit(1);
  156.     } /* could not open kmem */
  157.  
  158. } /* init_nlist */
  159.  
  160. # define PERIOD 5            /* sample period (in seconds) */
  161. # define INTERVAL1 60            /* average interval 1 (in seconds) */
  162. # define INTERVAL2 (5*60)        /* average interval 2 (in seconds) */
  163. # define INTERVAL3 (15*60)        /* average interval 3 (in seconds) */
  164. # define PACKINTERVAL 30        /* interval for make_packet */
  165.  
  166. doit() {
  167.     struct sysinfo sinf;
  168.     int packt = 0;
  169.     long occ, que, nocc, nque, n, c;
  170.     double avg1, avg2, avg3, new;
  171.     double exp1, exp2, exp3;
  172.  
  173.     exp1 = exp( - ((double) PERIOD) / INTERVAL1 );
  174.     exp2 = exp( - ((double) PERIOD) / INTERVAL2 );
  175.     exp3 = exp( - ((double) PERIOD) / INTERVAL3 );
  176.  
  177.     getsysinf(&sinf);        /* prime the pump */
  178.     occ = sinf.runocc;        /* number of samples */
  179.     que = sinf.runque;        /* run queue summation */
  180.  
  181.     avg1 = avg2 = avg3 = ((double) que) / occ;
  182.  
  183.     for( ; ; ) {
  184.         if( --packt < 0 ) {
  185. #ifdef RWHOD
  186.             make_packet((int) (avg1 * PMUL),
  187.                     (int) (avg2 * PMUL),
  188.                     (int) (avg3 * PMUL));
  189. #else  SHM
  190.             make_packet(avg1, avg2, avg3);
  191. #endif RWHOD
  192.             packt = PACKINTERVAL / PERIOD;
  193.         } /* packet time */
  194.  
  195. /*        printf("runque: %ld  runocc: %ld\n", que, occ ); /**/
  196.  
  197.         sleep(PERIOD);
  198.         getsysinf(&sinf);    /* get new info */
  199.         nocc = sinf.runocc;
  200.         nque = sinf.runque;
  201.  
  202.         n = nocc - occ;        /* get number of times updated */
  203.         if( n <= 0 ) continue;
  204.         c = nque - que - n;    /* get number of runners w/o us */
  205.         if( c < 0 ) c = 0;    /* mumble! */
  206.  
  207.         new = ((double) c ) / n; /* new instantaneous avg */
  208.  
  209.         /************************************************/
  210.         /*   The following formwla is used to achieve   */
  211.         /*   exponential decay of old measurements:    */
  212.         /*    avgN = avgN * expN  +  new * (1 - expN)    */
  213.         /*                        */
  214.         /*   However, the factorized forms below    */
  215.         /*   require fewer floating point operations.    */
  216.         /************************************************/
  217.  
  218.         avg1 = ((avg1 - new) * exp1) + new;
  219.         avg2 = ((avg2 - new) * exp2) + new;
  220.         avg3 = ((avg3 - new) * exp3) + new;
  221.  
  222.         occ = nocc;
  223.         que = nque;
  224.  
  225.     } /* for ever */
  226. } /* doit */
  227.  
  228. getsysinf(s)
  229. struct sysinfo *s;
  230. {
  231.     l_lseek(memfd, (long)nl[NL_SYSINFO].n_value, 0);
  232.     r_read(memfd, (char *)s, sizeof(struct sysinfo));
  233. }
  234.  
  235. /* lseek with error checking */
  236. l_lseek(fd, offset, whence)
  237. int fd, whence;
  238. long    offset;
  239. {
  240.     if (lseek(fd, offset, whence) == -1) {
  241.         fprintf(stderr, "%s: error on lseek\n", argv0);
  242.         exit(1);
  243.     }
  244. }
  245.  
  246. /* read with error checking */
  247. r_read (fd, buf, nbytes)
  248. int    fd, nbytes;
  249. char    *buf;
  250. {
  251.     if (read(fd, buf, nbytes) != nbytes) {
  252.         fprintf(stderr, "%s: error on read\n", argv0);
  253.         exit(1);
  254.     }
  255. }
  256.  
  257. init_packet() {
  258. #ifdef RWHOD
  259.     time_t boothz;
  260. # if UDP
  261.     struct hostent *he;
  262.  
  263.     he = gethostbyname( "localnet" );
  264.     if( he == NULL || he->h_addr == 0 ) {
  265.         fprintf(stderr, "no address: localnet\n");
  266.         exit( 1 );
  267.     }
  268.     ipaddr = he->h_addr;
  269. # endif
  270. # if DSK
  271.     sprintf(whopacket, "/usr/spool/rwho/whod.%s", utsn.nodename);
  272. # endif
  273.     memset(&proto, '\0', sizeof proto);    /* clear proto packet */
  274.  
  275.     strncat(proto.wd_hostname, utsn.nodename, 9); /* at most 9, add null */
  276.     proto.wd_vers = WHODVERSION;
  277.     proto.wd_type = WHODTYPE_STATUS;
  278.  
  279.     l_lseek(memfd, (long)nl[NL_LBOLT].n_value, 0);
  280.     r_read(memfd, (char *)&boothz, sizeof( boothz ) );
  281.     proto.wd_boottime = time(0) - (boothz / HZ);
  282. #else  SHM
  283.     if ((aven_key = ftok(SYSTEM, 'a')) == (key_t) -1) {
  284.         perror(SYSTEM);
  285.         exit(1);
  286.     }
  287.     if ((aven_shm = shmget(aven_key, 3 * sizeof (double), IPC_CREAT|IPC_EXCL|0644)) < 0) {
  288.         perror("shmget");
  289.         exit(1);
  290.     }
  291.     if ((int) (aven_seg = (double *) shmat(aven_shm, (char *) 0, 0)) == -1) {
  292.         perror("shmat");
  293.         if (shmdt((char *) aven_seg) == -1)
  294.             perror("shmdt");
  295.         if (shmctl(aven_shm, IPC_RMID, (struct shmid_ds *) 0) < 0)
  296.             perror("shmctl(IPC_RMID)");
  297.         exit(1);
  298.     }
  299. #endif RWHOD
  300.     
  301. } /* init_packet */
  302.  
  303. make_packet(iavg1, iavg2, iavg3)
  304. #ifdef RWHOD
  305. long iavg1, iavg2, iavg3;
  306. #else  SHM
  307. double iavg1, iavg2, iavg3;
  308. #endif RWHOD
  309. {
  310. #ifdef RWHOD
  311.     static struct whod packet;    /* local packet copy */
  312.     register struct whoent *wep;    /* pointer to packet whoent */
  313.     register struct utmp *utp;    /* return from getutent */
  314.     int whof, cc;            /* output file, char count */
  315.  
  316.     packet = proto;            /* copy proto packet */
  317.     time(&packet.wd_sendtime);
  318.     time(&packet.wd_recvtime);    /* forge this !! */
  319.     packet.wd_loadav[0] = iavg1;
  320.     packet.wd_loadav[1] = iavg2;
  321.     packet.wd_loadav[2] = iavg3;
  322.  
  323.     setutent();            /* open utmp file */
  324.     wep = &packet.wd_we[0];        /* get pointer to first user in pkt */
  325.  
  326.     while( (utp = getutent()) != NULL ) {
  327.         if( (utp->ut_type == USER_PROCESS) && utp->ut_user[0]) {
  328.         strncpy(wep->we_utmp.out_line, utp->ut_id, 4);
  329.         wep->we_utmp.out_line[4] = '\0';
  330.  
  331.         strncpy(wep->we_utmp.out_name, utp->ut_user, 8);
  332.  
  333.         wep->we_utmp.out_time = utp->ut_time;
  334.  
  335.         wep->we_idle = idletime(utp);
  336.         wep++;            /* bump packet pointer */
  337.         } /* user process */
  338.     } /* while */
  339.     endutent();
  340.  
  341. # if DSK
  342.     whof = creat(whopacket, 0644);    /* open packt file */
  343.     if( whof >= 0 ) {
  344.         cc = (char *)wep - (char *)&packet;
  345.         if( write(whof, (char *)&packet, cc) != cc )
  346.             perror("write failed");
  347.         close(whof);
  348.     } /* file opened */
  349.     else perror(whopacket);
  350. # endif
  351. # if UDP
  352.     cc = (char *)wep - (char *)&packet;
  353.     udpsend( (char *)&packet, cc, ipaddr, port, port, 1);
  354. # endif
  355. # ifdef DEBUG
  356.     fprintf(stderr, "wrote packet (%d)\n", cc);
  357.     fflush(stderr);
  358. # endif
  359. #else  SHM
  360.     aven_seg[0] = iavg1;
  361.     aven_seg[1] = iavg2;
  362.     aven_seg[2] = iavg3;
  363. #endif RWHOD
  364. } /* make_packet */
  365.  
  366. #ifdef RWHOD
  367. idletime(up)
  368. struct utmp *up;
  369. {
  370.     register int i;
  371.     register char *cp, *dp;
  372.     char ttyname[10];
  373.     struct stat buf;
  374.     time_t now;
  375.  
  376.     cp = "/dev/";
  377.     dp = ttyname;
  378.     
  379.     while( *cp != '\0' )        /* copy "/dev/" */
  380.         *dp++ = *cp++;
  381.  
  382.     cp = up->ut_line;            /* get line name */
  383.     if( *cp == 's' )            /* starts with an 's'? (sxtnnn) */
  384.         *dp++ = 'v';            /* insert a 'v' */
  385.  
  386.     for( i = 0; i < 8; i++ )        /* copy line name */
  387.         if( (*dp++ = *cp++) == '\0' ) break;    /* or until null */
  388.  
  389.     if( stat(ttyname, &buf) != 0 )    /* get file status */
  390.         return( 0 );
  391.  
  392.     time(&now);                /* get current time */
  393.     i = now - buf.st_atime;        /* get differnce from last acces */
  394.     return( i );            /* return idle time */
  395. } /* idletime */
  396. #endif RWHOD
  397. ------------------------------------------------------------------------------
  398.  
  399.  
  400. -- 
  401. ++Brandon (Resident Elf @ ncoast.UUCP)
  402.  ____   ______________
  403. /    \ / __   __   __ \   Brandon S. Allbery        <backbone>!ncoast!allbery
  404.  ___  | /__> /  \ /  \    aXcess Co., Consulting    ncoast!allbery@Case.CSNET
  405. /   \ | |    `--, `--,    6615 Center St. #A1-105        (...@relay.CS.NET)
  406. |     | \__/ \__/ \__/    Mentor, OH 44060-4101     
  407. \____/ \______________/   +1 216 974 9210
  408.  
  409.  
  410.