Return to test.c.mesgring CVS log

Up to [XINU] / xinu / sys / TEST

Annotation of xinu/sys/TEST/test.c.mesgring, revision 1.1

1.1     ! root        1: /* test.c - main */
        !             2: 
        !             3: #include <conf.h>
        !             4: #include <kernel.h>
        !             5: 
        !             6: #define        CIRCUIT 1000
        !             7: 
        !             8: /*------------------------------------------------------------------------
        !             9:  *  main  --  current test routines
        !            10:  *------------------------------------------------------------------------
        !            11:  */
        !            12: main()
        !            13: {
        !            14:        int ctr, succpid;
        !            15:        int ringnode(), startnode();
        !            16: 
        !            17:        succpid = getpid();
        !            18:        for (ctr=0; ctr<NPROC-2; ctr++) {
        !            19:                succpid = create (ringnode, 500, 19, "ringnode", 1, succpid);
        !            20:                if (succpid != SYSERR)
        !            21:                        resume (succpid);
        !            22:                else{
        !            23:                        kprintf("error creating ring node\n");
        !            24:                        break;
        !            25:                        }
        !            26:                }
        !            27:        chprio (getpid(), 19);
        !            28:        startnode(succpid);
        !            29: }
        !            30: 
        !            31: ringnode(succpid)
        !            32: int succpid;
        !            33: {
        !            34:        int ctr, inval, predpid;
        !            35: 
        !            36:        /* send messages around ring CIRCUIT times */
        !            37:        for (ctr = 0; ctr < CIRCUIT; ctr++) {
        !            38:                inval = receive();
        !            39:                while (send(succpid, inval) == SYSERR) {
        !            40:                        kprintf ("error sending\n");
        !            41:                        sleep(1);
        !            42:                        }
        !            43:                }
        !            44:        /* now each node tells its successor its pid */
        !            45:        while (send(succpid, getpid()) == SYSERR)  {
        !            46:                kprintf("error sending\n");
        !            47:                sleep(1);
        !            48:                }
        !            49:        predpid = receive();
        !            50:        /* switch directions and send messages around ring CIRCUIT times */
        !            51:        for (ctr = 0; ctr < CIRCUIT; ctr++) {
        !            52:                inval = receive();
        !            53:                while (send(predpid, inval) == SYSERR)  {
        !            54:                        kprintf("error sending\n");
        !            55:                        sleep(1);
        !            56:                        }
        !            57:                }
        !            58: }
        !            59: 
        !            60: startnode(succpid)
        !            61: int succpid;
        !            62: {
        !            63:        int ctr, inval, predpid;
        !            64: 
        !            65:        /* send messages through ring CIRCUIT times */
        !            66:        kprintf("sending %d messages around ring\n", CIRCUIT);
        !            67:        for (ctr = 0; ctr < CIRCUIT; ctr++) {
        !            68:                while (send(succpid, ctr) == SYSERR) {
        !            69:                        kprintf ("error sending\n");
        !            70:                        sleep(1);
        !            71:                        }
        !            72:                if ((inval = receive()) != ctr)
        !            73:                        kprintf ("bad message\n");
        !            74:                }
        !            75:        kprintf("reversing ring direction\n");
        !            76:        /* now each node tells its successor its pid */
        !            77:        while (send(succpid, getpid()) == SYSERR)  {
        !            78:                kprintf("error sending\n");
        !            79:                sleep(1);
        !            80:                }
        !            81:        predpid = receive(predpid);
        !            82:        /* switch directions and send messages around ring CIRCUIT times */
        !            83:        kprintf("sending %d messages around ring in reversed direction\n", CIRCUIT);
        !            84:        for (ctr = 0; ctr < CIRCUIT; ctr++) {
        !            85:                while (send(predpid, ctr) == SYSERR)  {
        !            86:                        kprintf("error sending\n");
        !            87:                        sleep(1);
        !            88:                        }
        !            89:                if ((inval = receive()) != ctr)
        !            90:                        kprintf("bad message\n");
        !            91:        }
        !            92:        kprintf("done with message passing test\n");
        !            93: }

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