Return to finput.c CVS log

Up to [XINU] / xinu / sys

Annotation of xinu/sys/finput.c, revision 1.1

1.1     ! root        1: /* finput.c - finput, sendack, sendnack, sendsack */
        !             2: 
        !             3: #include <conf.h>
        !             4: #include <kernel.h>
        !             5: #include <frame.h>
        !             6: 
        !             7: /*------------------------------------------------------------------------
        !             8:  *  finput  -- read frames and enqueue for local machine or forwarding
        !             9:  *------------------------------------------------------------------------
        !            10:  */
        !            11: PROCESS        finput(netid)
        !            12:        int     netid;
        !            13: {
        !            14:        int     len;                    /* length of actual data        */
        !            15:        int     to, from;               /* "to" and "from" addresses    */
        !            16:        struct  fglob   *fgptr;
        !            17:        struct  frame   *fptr, *fptr2;
        !            18:        char    *t, *f;                 /* used to copy broadcast frames*/
        !            19: 
        !            20:        fgptr = &fdata[netid];
        !            21:        fptr = getbuf(frbpool);
        !            22:        for (fgptr->fiseq = fgptr->fifails = 0 ; TRUE ; ) {
        !            23:                len = read(fgptr->findev, fptr, FRMAXLEN);
        !            24:                if (len < FRMINLEN || len != getflen(fptr))
        !            25:                        sendnack(fgptr);
        !            26:                else if ( (int)fptr->frseq != fgptr->fiseq)
        !            27:                        sendsack(fgptr);
        !            28:                else {
        !            29:                        to = getfto(fptr->fraddr);
        !            30:                        from = getfrom(fptr->fraddr);
        !            31:                        if (to == FRBCAST) {    /* broadcast */
        !            32:                                if (from == fgptr->fmachid) {
        !            33:                                        psend(fgptr->fiport, fptr);
        !            34:                                        fptr = getbuf(frbpool);
        !            35:                                } else {
        !            36:                                        fptr2 = getbuf(frbpool);
        !            37:                                        for (f=fptr,t=fptr2; len-->0; )
        !            38:                                                *t++ = *f++;
        !            39:                                        psend(fgptr->fiport, fptr);
        !            40:                                        psend(fgptr->ffport, fptr2);
        !            41:                                        signal(fgptr->fosem);
        !            42:                                        fptr = getbuf(frbpool);
        !            43:                                }
        !            44:                        } else if (to == fgptr->fmachid) {
        !            45:                                psend(fgptr->fiport, fptr);
        !            46:                                fptr = getbuf(frbpool);
        !            47:                        } else if (from == fgptr->fmachid) {
        !            48:                                printf("Can't deliver to %d\n", to);
        !            49:                        } else {
        !            50:                                psend(fgptr->ffport, fptr);
        !            51:                                signal(fgptr->fosem); /* bug fix to text */
        !            52:                                fptr = getbuf(frbpool);
        !            53:                        }
        !            54:                        sendack(fgptr);
        !            55:                }
        !            56:        }
        !            57: }
        !            58: 
        !            59: /*------------------------------------------------------------------------
        !            60:  *  sendack  --  send a positive acknowledgement with sequence number
        !            61:  *------------------------------------------------------------------------
        !            62:  */
        !            63: LOCAL  sendack(fgptr)
        !            64:        struct  fglob   *fgptr;
        !            65: {
        !            66:        fgptr->fifails = 0;
        !            67:        if (++fgptr->fiseq > FRMAXSEQ)
        !            68:                fgptr->fiseq = 0;
        !            69:        putc(fgptr->findev, FRACK | fgptr->fiseq);
        !            70: }
        !            71: 
        !            72: /*------------------------------------------------------------------------
        !            73:  *  sendnack --  send a negative acknowledgement with sequence number
        !            74:  *------------------------------------------------------------------------
        !            75:  */
        !            76: LOCAL  sendnack(fgptr)
        !            77:        struct  fglob   *fgptr;
        !            78: {
        !            79:        putc(fgptr->findev, FRNACK | fgptr->fiseq);
        !            80: }
        !            81: 
        !            82: /*------------------------------------------------------------------------
        !            83:  *  sendsack --  send a negative acknowledgement and restart sequence
        !            84:  *------------------------------------------------------------------------
        !            85:  */
        !            86: LOCAL  sendsack(fgptr)
        !            87:        struct  fglob   *fgptr;
        !            88: {
        !            89:        if (++fgptr->fifails >= FRFAIL) {
        !            90:                fgptr->fiseq = 0;
        !            91:                fgptr->fifails = 0;
        !            92:                putc(fgptr->findev, FRSACK);
        !            93:        } else
        !            94:                putc(fgptr->findev, FRNACK);
        !            95: }

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