Return to scanq.c CVS log

Up to [Research Unix] / researchv10no / cmd / dist / lib

Annotation of researchv10no/cmd/dist/lib/scanq.c, revision 1.1

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

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