Return to rwhoind.c CVS log

Up to [XINU] / xinu / sys

Annotation of xinu/sys/rwhoind.c, revision 1.1.1.1

1.1       root        1: /* rwhoind.c - rwhoind */
                      2: 
                      3: #include <conf.h>
                      4: #include <kernel.h>
                      5: #include <network.h>
                      6: #include <rwho.h>
                      7: 
                      8: /*------------------------------------------------------------------------
                      9:  *  rwhoind  -  rwho daemon to record info from incoming rwho packets
                     10:  *------------------------------------------------------------------------
                     11:  */
                     12: PROCESS        rwhoind()
                     13: {
                     14:        int     dev;
                     15:        int     len;
                     16:        int     i;
                     17:        long    now;
                     18:        PStype  ps;
                     19:        struct  rwhopac *rpacptr;
                     20:        struct  rwent   *rwptr;
                     21: 
                     22:        if ( (dev=open(INTERNET, ANYFPORT, URWHO)) == SYSERR ||
                     23:              control(dev, DG_SETMODE, DG_DMODE) == SYSERR)
                     24:                panic("rwho_in: cannot open rwho port");
                     25:        while (TRUE) {
                     26:                if ( (len = read(dev,Rwho.rbuf,RWMAXP)) == SYSERR )
                     27:                        continue;
                     28:                rpacptr = (struct rwhopac *) Rwho.rbuf;
                     29:                for (i=0 ; i<Rwho.rwnent ; i++) {
                     30:                        rwptr = &Rwho.rwcache[i];
                     31:                        if (strncmp(rpacptr->rw_host, rwptr->rwmach,
                     32:                            RMACLEN) == 0)
                     33:                                break;
                     34:                }
                     35:                if (i >= Rwho.rwnent) {
                     36:                        disable(ps);
                     37:                        if (Rwho.rwnent >= RWCSIZ) {
                     38:                                restore(ps);
                     39:                                continue;
                     40:                        }
                     41:                        rwptr = &Rwho.rwcache[Rwho.rwnent++];
                     42:                        strncpy(rwptr->rwmach, rpacptr->rw_host, RMACLEN);
                     43:                        restore(ps);
                     44:                }
                     45:                rwptr->rwboot = net2hl(rpacptr->rw_btim);
                     46:                gettime(&now);
                     47:                rwptr->rwlast = now;
                     48:                rwptr->rwslast = net2hl(rpacptr->rw_sndtim);
                     49:                for (i=0 ; i<RWNLOAD ; i++)
                     50:                        rwptr->rwload[i] = net2hl(rpacptr->rw_load[i]);
                     51:                rwptr->rwusers = (len-RWMINP)/sizeof(struct rw_who);
                     52:        }
                     53: }

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.