Return to system10.c CVS log

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

Annotation of researchv10no/cmd/vsw/system10.c, revision 1.1

1.1     ! root        1: #include       <libc.h>
        !             2: #include       <fio.h>
        !             3: #include       <ctype.h>
        !             4: #include       <sysent.h>
        !             5: #include       <string.h>
        !             6: #include       "crossbar.h"
        !             7: 
        !             8: int rread(int fd, char *buf, int n);
        !             9: 
        !            10: System10::System10(char *dkname, int n, int depth) : (dkname, n, depth)
        !            11: {
        !            12: }
        !            13: 
        !            14: void
        !            15: System10::startup()
        !            16: {
        !            17:        int i, n;
        !            18:        char buf[256];
        !            19:        extern int opendk(char *);
        !            20: 
        !            21:        fd = opendk(dial);
        !            22:        for(i = 0; i < 3; i++){
        !            23:                write(fd, "@\r", 2);
        !            24:                read(fd, buf, 3);
        !            25:                if((n = read(fd, buf, sizeof buf)) != 3){
        !            26:                        fprint(2, "read %d, wanted %d: %s: ", n, 3, buf);
        !            27:                        perror("read");
        !            28:                        exit(1);
        !            29:                }
        !            30:                if(strncmp(buf, "@\r", 2) == 0)
        !            31:                        break;
        !            32:        }
        !            33: }
        !            34: 
        !            35: int
        !            36: System10::connect(int input, Crossbar *c, int output, int nw)
        !            37: {
        !            38:        char buf[256];
        !            39:        int n;
        !            40: 
        !            41:        if(fd < 0)
        !            42:                startup();
        !            43:        if(c != this){
        !            44:                if(nextc->connect(nextl, c, output, nw) == 0)
        !            45:                        return(0);
        !            46:                output = froml;
        !            47:        }
        !            48:        nw /= nwires;
        !            49:        while(nw-- > 0){
        !            50:                fprint(fd, "%d%d\r", output, input);
        !            51:                n = read(fd, buf, 7);
        !            52:                if(n != 7){
        !            53:                        fprint(2, "%s.con %d->%d failed; %d!=7\n", name(), input, output, n);
        !            54:                        return(0);
        !            55:                }
        !            56:                input++, output++;
        !            57:        }
        !            58:        return(1);
        !            59: }
        !            60: 
        !            61: void
        !            62: System10::config()
        !            63: {
        !            64:        int i, n;
        !            65:        char buf[256], *s;
        !            66: 
        !            67:        imap = new int[nouts];
        !            68:        write(fd, "?\r", 2);
        !            69:        read(fd, buf, 3);
        !            70:        if((n = rread(fd, buf, 31)) < 0){
        !            71:                perror("read2");
        !            72:                exit(1);
        !            73:        }
        !            74:        if(n != 31){
        !            75:                fprint(2, "erk! read expected 31, got %d '%s'\n", n, buf);
        !            76:                exit(1);
        !            77:        }
        !            78:        for(i = 0, s = buf; i < 10; i++){
        !            79:                if(!isdigit(*s)){
        !            80:                        fprint(2, "erk: output must be digit '%s'\n", s);
        !            81:                        exit(1);
        !            82:                }
        !            83:                if(!isdigit(s[1])){
        !            84:                        fprint(2, "erk: input must be digit '%s'\n", s+1);
        !            85:                        exit(1);
        !            86:                }
        !            87:                imap[*s-'0'] = s[1]-'0';
        !            88: if(0)Fprint(1, "%c<-%c ", s[0], s[1]);
        !            89:                s += 3;
        !            90:        }
        !            91: if(0)Fprint(1, "\n"), Fflush(1);
        !            92: }
        !            93: 
        !            94: int
        !            95: rread(int fd, char *buf, int n)
        !            96: {
        !            97:        int k, m = 0;
        !            98: 
        !            99:        while(m != n){
        !           100: buf[m]=0;fprint(2, "read %d of %d '%s'\n", m, n, buf);
        !           101:                k = read(fd, &buf[m], n-m);
        !           102:                if(k < 0)
        !           103:                        return(k);
        !           104:                if(k == 0)
        !           105:                        break;
        !           106:                m += k;
        !           107:        }
        !           108:        return(m);
        !           109: }

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