Return to scanq.c CVS log

Up to [Research Unix] / researchv10no / cmd / odist / ape

Annotation of researchv10no/cmd/odist/ape/scanq.c, revision 1.1.1.1

1.1       root        1: #include <dirent.h>
                      2: #include <limits.h>
                      3: #include <stdio.h>
                      4: #include <stdlib.h>
                      5: #include <string.h>
                      6: #include <unistd.h>
                      7: #include "dist.h"
                      8: 
                      9: static char *
                     10: copy(char *s)
                     11: {
                     12:        char *r;
                     13: 
                     14:        r = malloc(strlen(s) + 1);
                     15:        if (r)
                     16:                strcpy(r, s);
                     17:        return r;
                     18: }
                     19: 
                     20: static void
                     21: removeq(char *name)
                     22: {
                     23:        DIR *dp;
                     24:        struct dirent *d;
                     25:        char file[2 * MAXNAME + 1];
                     26: 
                     27:        name = copy(name);      /* readdir bug?!? */
                     28:        if (fork() == 0) {
                     29:                setuid(getuid());
                     30:                execl(LDIR "/genmail", "genmail", "-f", name, (char *) 0);
                     31:                exit(0);
                     32:        } else
                     33:                wait(0);
                     34:        if (!(dp = opendir(name)))
                     35:                return;
                     36:        while (d = readdir(dp)) {
                     37:                if (!strcmp(d->d_name, ".") || !strcmp(d->d_name, ".."))
                     38:                        continue;
                     39:                sprintf(file, "%s/%.*s", name, MAXNAME, d->d_name);
                     40:                remove(file);
                     41:        }
                     42:        closedir(dp);
                     43:        rmdir(name);
                     44:        free(name);
                     45: }
                     46: 
                     47: void
                     48: scanq(char *remsys, void (*func)(char *, int, char *))
                     49: {
                     50:        DIR *dp;
                     51:        struct dirent *d;
                     52:        FILE *fp;
                     53:        char sys[MAXLINE], cansys[MAXLINE], file[MAXNAME];
                     54:        int num, zapq;
                     55: 
                     56:        if (remsys)
                     57:                canon(remsys, cansys);
                     58: 
                     59:        if (chdir(SDIR) < 0) {
                     60:                eprintf("can't chdir %s", SDIR);
                     61:                exit(1);
                     62:        }
                     63: 
                     64:        if (!(dp = opendir("."))) {
                     65:                eprintf("can't read spool directory!");
                     66:                exit(1);
                     67:        }
                     68: 
                     69:        while (d = readdir(dp))
                     70:                if (strncmp(d->d_name, QPREFIX, strlen(QPREFIX)) == 0) {
                     71:                        zapq = 1;
                     72:                        if (chdir(d->d_name) < 0) {
                     73:                                eprintf("can't chdir %s/%s", SDIR, d->d_name);
                     74:                                continue;
                     75:                        }
                     76:                        if (fp = fopen(CTL, "r")) {
                     77:                                while (fscanf(fp, "%d%s", &num, sys) == 2) {
                     78:                                        sprintf(file, "%d.%s", num, DONE);
                     79:                                        if (access(file, F_OK) == 0)
                     80:                                                continue;
                     81:                                        if (remsys && strcmp(sys, cansys) != 0) {
                     82:                                                zapq = 0;
                     83:                                                continue;
                     84:                                        }
                     85:                                        if (func)
                     86:                                                (*func)(d->d_name, num, sys);
                     87:                                        if (access(file, F_OK) != 0)
                     88:                                                zapq = 0;
                     89:                                }
                     90:                                fclose(fp);
                     91:                        } else
                     92:                                eprintf("can't read %s/%s", d->d_name, CTL);
                     93:                        chdir("..");
                     94:                        if (zapq)
                     95:                                removeq(d->d_name);
                     96:                }
                     97: 
                     98:        closedir(dp);
                     99: }

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