Return to receive.c CVS log

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

Annotation of researchv10no/cmd/odist/ape/receive.c, revision 1.1

1.1     ! root        1: #include <stddef.h>
        !             2: #include <stdio.h>
        !             3: #include <sys/types.h>
        !             4: #include <sys/stat.h>
        !             5: #include <fcntl.h>
        !             6: #include <unistd.h>
        !             7: #include "dist.h"
        !             8: 
        !             9: void
        !            10: recvjob(void)
        !            11: {
        !            12:        char data[MAXNAME], errs[MAXNAME], mesg[MAXLINE];
        !            13:        int dfd, efd, attempt, status;
        !            14: 
        !            15:        if (!getline(mesg))
        !            16:                exit(0);
        !            17: 
        !            18:        if (sscanf(mesg, "begin job %s", data) != 1) {
        !            19:                eprintf("job header munged: mesg = %s", mesg);
        !            20:                exit(1);
        !            21:        }
        !            22: 
        !            23:        sprintf(data, "data.%d", getpid());
        !            24:        remove(data);
        !            25:        dfd = creat(data, 0600); /* ape deficiency */
        !            26:        close(dfd);
        !            27:        dfd = open(data, O_RDWR);
        !            28:        if (dfd < 0) {
        !            29:                eprintf("can't create data file %s", data);
        !            30:                exit(1);
        !            31:        }
        !            32: 
        !            33:        if (!recvfile(dfd)) {
        !            34:                remove(data);
        !            35:                eprintf("recvfile failed");
        !            36:                exit(1);
        !            37:        }
        !            38: 
        !            39:        /* see if file system permissions will likely allow inspkg to succeed */
        !            40:        lseek(dfd, 0L, 0);
        !            41:        attempt = tryperm(dfd);
        !            42:        sprintf(mesg, "client attempt=%d\n", attempt);
        !            43:        write(1, mesg, strlen(mesg));
        !            44: 
        !            45:        if (attempt) {
        !            46:                sprintf(errs, "errs.%d", getpid());
        !            47:                efd = creat(errs, 0600);        /* more ape bogosity */
        !            48:                close(efd);
        !            49:                efd = open(errs, O_RDWR);
        !            50:                if (efd < 0) {
        !            51:                        eprintf("can't create errs file %s", errs);
        !            52:                        exit(1);
        !            53:                }
        !            54: 
        !            55:                if (fork()) {
        !            56:                        status = 0xFF; /* evilly catch wait failures */
        !            57:                        wait(&status);
        !            58:                        if (status & 0xFF) {
        !            59:                                sprintf(mesg, "inspkg: exit %d\n", status & 0xFF);
        !            60:                                write(efd, mesg, strlen(mesg));
        !            61:                        }
        !            62:                } else {
        !            63:                        lseek(dfd, 0L, 0);
        !            64:                        dup2(dfd, 0);
        !            65:                        dup2(efd, 1);
        !            66:                        dup2(efd, 2);
        !            67:                        close(dfd);
        !            68:                        close(efd);
        !            69:                        execl(LDIR "/inspkg", "inspkg", 0);
        !            70:                        eprintf("can't exec inspkg");
        !            71:                        exit(1);
        !            72:                }
        !            73: 
        !            74:                lseek(efd, 0L, 0);
        !            75:                if (!sendfile(efd)) {
        !            76:                        remove(data);
        !            77:                        remove(errs);
        !            78:                        eprintf("can't send error log");
        !            79:                        exit(1);
        !            80:                }
        !            81:        }
        !            82: 
        !            83:        close(dfd);
        !            84:        remove(data);
        !            85:        close(efd);
        !            86:        remove(errs);
        !            87: }
        !            88: 
        !            89: int
        !            90: main(int argc, char *argv[])
        !            91: {
        !            92:        prog = argv[0];
        !            93:        for (;;)
        !            94:                recvjob();
        !            95: }

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