Return to pipeback.c CVS log

Up to [Net/2] / Net2 / tests / benchmarks

Annotation of Net2/tests/benchmarks/pipeback.c, revision 1.1

1.1     ! root        1: /*
        !             2:  * IPC benchmark,
        !             3:  * read and reply using pipes.
        !             4:  *
        !             5:  * Process forks and exchanges messages
        !             6:  * over a pipe in a request-response fashion.
        !             7:  */
        !             8: 
        !             9: main(argc, argv)
        !            10:        char *argv[];
        !            11: {
        !            12:        char buf[512];
        !            13:        int fd[2], fd2[2], msgsize;
        !            14:        register int i, iter;
        !            15: 
        !            16:        if (argc < 3) {
        !            17:                printf("usage: %s iterations message-size\n", argv[0]);
        !            18:                exit(1);
        !            19:        }
        !            20:        argc--, argv++;
        !            21:        iter = atoi(*argv);
        !            22:        argc--, argv++;
        !            23:        msgsize = atoi(*argv);
        !            24:        if (msgsize > sizeof (buf) || msgsize <= 0) {
        !            25:                printf("%s: Bad message size.\n", *argv);
        !            26:                exit(2);
        !            27:        }
        !            28:        if (pipe(fd) < 0) {
        !            29:                perror("pipe");
        !            30:                exit(3);
        !            31:        }
        !            32:        if (pipe(fd2) < 0) {
        !            33:                perror("pipe");
        !            34:                exit(3);
        !            35:        }
        !            36:        if (fork() == 0)
        !            37:                for (i = 0; i < iter; i++) {
        !            38:                        read(fd[0], buf, msgsize);
        !            39:                        write(fd2[1], buf, msgsize);
        !            40:                }
        !            41:        else
        !            42:                for (i = 0; i < iter; i++) {
        !            43:                        write(fd[1], buf, msgsize);
        !            44:                        read(fd2[0], buf, msgsize);
        !            45:                }
        !            46: }

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