Return to faces.c CVS log

Up to [Research Unix] / researchv10no / cmd / face

Annotation of researchv10no/cmd/face/faces.c, revision 1.1.1.1

1.1       root        1: #include <sys/types.h>
                      2: #include <signal.h>
                      3: #include <ipc.h>
                      4: #include <stdio.h>
                      5: #include "faces.h"
                      6: 
                      7: static fd_set cfds;
                      8: static int maxfd;
                      9: static char *pfile = "/usr/net/face/people.tab";
                     10: static char *mfile = "/usr/net/face/machine.tab";
                     11: 
                     12: main(argc, argv)
                     13: int argc;
                     14: char **argv;
                     15: {
                     16: 
                     17:        if (argc < 2) {
                     18:                fprintf(stderr, "usage: faces server-name ...\n");
                     19:                exit(1);
                     20:        }
                     21:        maketree(pfile, mfile);
                     22:        for (;;) {
                     23:                listen(argc-1, argv+1);
                     24:                log("network restart\n");
                     25:        }
                     26: }
                     27: 
                     28: catchalarm()
                     29: {
                     30:        signal(SIGALRM, catchalarm);
                     31: }
                     32: 
                     33: /*
                     34:  * the main loop, listening for calls and requests
                     35:  */
                     36: 
                     37: listen(nname, namelist)
                     38: int nname;
                     39: char **namelist;
                     40: {
                     41:        static int *namefd;
                     42:        fd_set rfds;
                     43:        register int i;
                     44:        ipcinfo *ip;
                     45: 
                     46:        if (namefd == NULL)
                     47:                namefd = (int *)emalloc(sizeof(int)*nname);
                     48:        for (i = 0; i < nname; i++)
                     49:                namefd[i] = -1;
                     50:        FD_ZERO(cfds);
                     51:        for (;;) {
                     52:                for (i = 0; i < nname; i++) {
                     53:                        if (namefd[i] < 0) {
                     54:                                namefd[i] = ipccreat(ipcpath("", "", namelist[i]), "");
                     55:                                if (namefd[i] < 0)
                     56:                                        log("can't announce %s: %s\n", namelist[i], errstr);
                     57:                                else {
                     58:                                        log("fd %d: announced %s\n", namefd[i], namelist[i]);
                     59:                                        FD_SET(namefd[i], cfds);
                     60:                                }
                     61:                        }
                     62:                        if (namefd[i] >= 0 && namefd[i] > maxfd)
                     63:                                maxfd = namefd[i];
                     64:                }
                     65:                rfds = cfds;
                     66:                if (select(maxfd+1, &rfds, (fd_set *)0, 60*1000) < 0) {
                     67:                        log("select failed\n");
                     68:                        for (i = 0; i < maxfd; i++)
                     69:                                if (FD_ISSET(i, cfds))
                     70:                                        close(i);
                     71:                        return;
                     72:                }
                     73:                for (i = 0; i < nname; i++) {
                     74:                        if (namefd[i] < 0)
                     75:                                continue;
                     76:                        if (FD_ISSET(namefd[i], rfds)) {
                     77:                                FD_CLR(namefd[i], rfds);
                     78:                                if ((ip = ipclisten(namefd[i])) == NULL) {
                     79:                                        log("fd %d: %s: listen failed\n", namefd[i], errstr);
                     80:                                        FD_CLR(namefd[i], cfds);
                     81:                                        close(namefd[i]);
                     82:                                        namefd[i] = -1;
                     83:                                        continue;
                     84:                                }
                     85:                                newclient(ip);
                     86:                        }
                     87:                }
                     88:                for (i = 0; i <= maxfd; i++)
                     89:                        if (FD_ISSET(i, rfds) && FD_ISSET(i, cfds)) {
                     90:                                signal(SIGALRM, catchalarm);
                     91:                                alarm(60);
                     92:                                if (dorequest(i) == 0)
                     93:                                        dropclient(i);
                     94:                                alarm(0);
                     95:                        }
                     96:                checknew();
                     97:        }
                     98: }
                     99: 
                    100: /* add client to the list */
                    101: newclient(ip)
                    102: register ipcinfo *ip;
                    103: {
                    104:        int fd;
                    105: 
                    106:        if ((fd = ipcaccept(ip)) < 0) {
                    107:                log("ipcaccept failed\n");
                    108:                return;
                    109:        }
                    110:        FD_SET(fd, cfds);
                    111:        if (fd > maxfd)
                    112:                maxfd = fd;
                    113:        log("fd %d: client %s\n", fd, ip->machine);
                    114: }
                    115: 
                    116: dropclient (fd)
                    117: int fd;
                    118: {
                    119:        FD_CLR(fd, cfds);
                    120:        close (fd);
                    121:        log("fd %d: off\n", fd);
                    122: }
                    123: 
                    124: /*
                    125:  * check for new data, rebuild tree if necessary
                    126:  */
                    127: 
                    128: #define        MINCHK  120     /* at most once in this many seconds */
                    129: 
                    130: checknew()
                    131: {
                    132:        static time_t lastcheck;
                    133:        time_t now;
                    134: 
                    135:        now = time((time_t *)0);
                    136:        if (now + MINCHK < lastcheck)
                    137:                return;
                    138:        if (newdata(pfile, mfile)) {
                    139:                log("new data, reinitializing\n");
                    140:                maketree(pfile, mfile);
                    141:                now = time((time_t *)0);
                    142:        }
                    143:        lastcheck = now;
                    144: }

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