Changes in benchmark/io/http/main.cfa [d9c2284:e95a117]

File:

• benchmark/io/http/main.cfa (modified) (2 diffs)

benchmark/io/http/main.cfa

@@ -93 +93 @@
                 &wait_connect = &chan;
 
-                int pipe_cnt = options.clopts.nworkers * 2;
-                int pipe_off;
-                int * fds;
-                [fds, pipe_off] = filefds( pipe_cnt );
-                for(i; 0 ~ pipe_cnt ~ 2) {
-                        int ret = pipe(&fds[pipe_off + i]);
-                        if( ret < 0 ) { abort( "pipe error: (%d) %s\n", (int)errno, strerror(errno) ); }
-                }
-
                 {
                         ServerProc procs[options.clopts.nprocs];
                         {
                                 Worker workers[options.clopts.nworkers];
-                                for(i; options.clopts.nworkers) {
-                                        if( options.file_cache.fixed_fds ) {
-                                                workers[i].pipe[0] = pipe_off + (i * 2) + 0;
-                                                workers[i].pipe[1] = pipe_off + (i * 2) + 1;
-                                        }
-                                        else {
-                                                workers[i].pipe[0] = fds[pipe_off + (i * 2) + 0];
-                                                workers[i].pipe[1] = fds[pipe_off + (i * 2) + 1];
-                                        }
-                                        unpark( workers[i] __cfaabi_dbg_ctx2 );
-                                }
                                 printf("%d workers started on %d processors\n", options.clopts.nworkers, options.clopts.nprocs);
                                 {
@@ -137 +117 @@
                         printf("Workers Closed\n");
                 }
-
-                for(i; pipe_cnt) {
-                        ret = close( fds[pipe_off + i] );
-                        if(ret < 0) {
-                                abort( "close pipe error: (%d) %s\n", (int)errno, strerror(errno) );
-                        }
-                }
-                free(fds);
         }